Documentation ¶
Index ¶
- type Server
- func (s *Server) AddServer(server notify.Interface)
- func (s *Server) Close()
- func (s *Server) Commit(args *coordinator.CommitArgs, reply *coordinator.CommitReply) error
- func (s *Server) GetCommonConfig(args *interface{}, reply *common.Config) error
- func (s *Server) GetInfo(args *interface{}, reply *coordinator.GetInfoReply) error
- func (s *Server) GetIntVec(args *coordinator.GetIntVecArgs, reply *coordinator.GetIntVecReply) error
- func (s *Server) GetLayout(args *coordinator.GetLayoutArgs, reply *coordinator.GetLayoutReply) error
- func (s *Server) NotifySnapshot(force bool) bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Server ¶
Server is the main logic for the central coordinator
func NewServer ¶
func NewServer(name string, addr string, config common.Config, servers []notify.Interface, snapshotThreshold uint64, snapshotInterval time.Duration) (*Server, error)
NewServer creates a new Talek centralized coordinator server
func (*Server) Commit ¶
func (s *Server) Commit(args *coordinator.CommitArgs, reply *coordinator.CommitReply) error
Commit accepts a single Write to commit without data. Used to maintain the cuckoo table
func (*Server) GetCommonConfig ¶
GetCommonConfig returns the common global config
func (*Server) GetInfo ¶
func (s *Server) GetInfo(args *interface{}, reply *coordinator.GetInfoReply) error
GetInfo returns information about this server
func (*Server) GetIntVec ¶
func (s *Server) GetIntVec(args *coordinator.GetIntVecArgs, reply *coordinator.GetIntVecReply) error
GetIntVec returns the global interest vector
func (*Server) GetLayout ¶
func (s *Server) GetLayout(args *coordinator.GetLayoutArgs, reply *coordinator.GetLayoutReply) error
GetLayout returns the layout for a shard
func (*Server) NotifySnapshot ¶
NotifySnapshot notifies the current cuckoo layout out If `force` is false, ignore when under a threshold Returns: true if snapshot was built, false if ignored
Click to show internal directories.
Click to hide internal directories.