server

Documentation

Index

• type CenterServer
  • func NewCenterServer(key string) (*CenterServer, error)
  • func (server *CenterServer) OnAllocCacheHandlerFunc(event cache.AllocEvent, location string, data []byte, err error)
  • func (server *CenterServer) OnNodeCacheHandlerFunc(event cache.NodeEvent, location string, worker *cache.Worker)
  • func (server *CenterServer) OnSeverConfigsWatchHandlerFunc(path string, data []byte, err error)
  • func (server *CenterServer) OnZkWrapperNodeHandlerFunc(nodestore *gzkwrapper.NodeStore)
  • func (server *CenterServer) OnZkWrapperPulseHandlerFunc(key string, nodedata *gzkwrapper.NodeData, err error)
  • func (server *CenterServer) RefreshServerConfig(data []byte) error
  • func (server *CenterServer) Startup(startCh chan<- bool) error
  • func (server *CenterServer) Stop() error

Types

type CenterServer

type CenterServer struct {
	Key             string
	ConfigPath      string
	Data            *gzkwrapper.NodeData
	Master          *gzkwrapper.Server
	NotifySender    *notify.NotifySender
	CacheRepository *cache.CacheRepository
	Scheduler       *scheduler.Scheduler
	MessageCache    *models.MessageCache

	gzkwrapper.INodeNotifyHandler
	// contains filtered or unexported fields
}

CenterServer is exported

func NewCenterServer

func NewCenterServer(key string) (*CenterServer, error)

NewCenterServer is exported

func (*CenterServer) OnAllocCacheHandlerFunc

func (server *CenterServer) OnAllocCacheHandlerFunc(event cache.AllocEvent, location string, data []byte, err error)

func (*CenterServer) OnNodeCacheHandlerFunc

func (server *CenterServer) OnNodeCacheHandlerFunc(event cache.NodeEvent, location string, worker *cache.Worker)

func (*CenterServer) OnSeverConfigsWatchHandlerFunc

func (server *CenterServer) OnSeverConfigsWatchHandlerFunc(path string, data []byte, err error)

func (*CenterServer) OnZkWrapperNodeHandlerFunc

func (server *CenterServer) OnZkWrapperNodeHandlerFunc(nodestore *gzkwrapper.NodeStore)

func (*CenterServer) OnZkWrapperPulseHandlerFunc

func (server *CenterServer) OnZkWrapperPulseHandlerFunc(key string, nodedata *gzkwrapper.NodeData, err error)

func (*CenterServer) RefreshServerConfig

func (server *CenterServer) RefreshServerConfig(data []byte) error

RefreshServerConfig is exported save serverConfig, re-set to references objects.

func (*CenterServer) Startup

func (server *CenterServer) Startup(startCh chan<- bool) error

Startup is exported

func (*CenterServer) Stop

func (server *CenterServer) Stop() error

Stop is exported