server

package

v0.0.0-...-4a99f62 Latest Latest Go to latest Published: Jun 7, 2014 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func Join()

func Leave()

func Run(bindAddr string, initialView *view.View)

type AdminService int

func (r *AdminService) Leave(anything bool, reply *bool) error

func (r *AdminService) Ping(anything bool, reply *bool) error

func (r *AdminService) Terminate(anything bool, reply *bool) error

type ContactQService struct{}

func (nq *ContactQService) Read(arg struct{}, reply *Value) error

func (nq *ContactQService) Write(value Value, reply *struct{}) error

type NotifyMsg struct {
	View   *view.View
	Sender view.Process
}

type NotifyQService struct{}

func (nq *NotifyQService) Notify(notifyMsg NotifyMsg, reply *struct{}) error

type RegisterService int

---------- RPC Requests -------------

func (r *RegisterService) GetCurrentView(value int, reply *view.View) error

func (r *RegisterService) Read(arg struct{}, reply *Value) error

func (r *RegisterService) Reconfig(updates []view.Update, reply *struct{}) error

func (r *RegisterService) Write(value Value, reply *struct{}) error

type Value struct {
	Value     interface{}
	Timestamp int

	Err error
	// contains filtered or unexported fields
}

--------- Types ---------

type ViewSeq []*view.View

func (viewSeq ViewSeq) Delete(toBeDeletedView *view.View) ViewSeq

func (viewSeq ViewSeq) Equal(otherViewSeq ViewSeq) bool

func (viewSeq ViewSeq) GetLeastUpdatedView() *view.View

func (viewSeq ViewSeq) GetMostUpdatedView() *view.View

func (viewSeq ViewSeq) HasView(view *view.View) bool