server

Documentation

Index

• type NodeServer
  • func NewNodeServer(key string) (*NodeServer, error)
  • func (server *NodeServer) OnCacheAllocWatchHandlerFunc(path string, data []byte, err error)
  • func (server *NodeServer) OnDriverExecuteHandlerFunc(state int, context *driver.DriverContext)
  • func (server *NodeServer) OnDriverSelectHandlerFunc(context *driver.DriverContext)
  • func (server *NodeServer) OnDriverStopedHandlerFunc(state int, context *driver.DriverContext)
  • func (server *NodeServer) OnJobCacheChangedHandlerFunc(event cache.CacheEvent, jobbase *models.JobBase)
  • func (server *NodeServer) OnJobCacheExceptionHandlerFunc(event cache.CacheEvent, workdir string, jobget *cache.JobGet, ...)
  • func (server *NodeServer) OnSeverConfigsWatchHandlerFunc(path string, data []byte, err error)
  • func (server *NodeServer) OnZkWrapperNodeHandlerFunc(nodestore *gzkwrapper.NodeStore)
  • func (server *NodeServer) OnZkWrapperPulseHandlerFunc(key string, nodedata *gzkwrapper.NodeData, err error)
  • func (server *NodeServer) RefreshCacheAlloc() (int, error)
  • func (server *NodeServer) RefreshServerConfig(data []byte) error
  • func (server *NodeServer) Startup() error
  • func (server *NodeServer) Stop() error

Types

type NodeServer

type NodeServer struct {
	Key        string
	Runtime    string
	ConfigPath string
	AllocPath  string
	Data       *gzkwrapper.NodeData
	Worker     *gzkwrapper.Worker
	Cache      *cache.Cache
	Driver     *driver.Driver
	Notify     *notify.NotifySender

	gzkwrapper.INodeNotifyHandler
	cache.ICacheHandler
	driver.IDriverHandler
	// contains filtered or unexported fields
}

NodeServer is exported

func NewNodeServer

func NewNodeServer(key string) (*NodeServer, error)

NewNodeServer is exported

func (*NodeServer) OnCacheAllocWatchHandlerFunc

func (server *NodeServer) OnCacheAllocWatchHandlerFunc(path string, data []byte, err error)

func (*NodeServer) OnDriverExecuteHandlerFunc

func (server *NodeServer) OnDriverExecuteHandlerFunc(state int, context *driver.DriverContext)

func (*NodeServer) OnDriverSelectHandlerFunc

func (server *NodeServer) OnDriverSelectHandlerFunc(context *driver.DriverContext)

func (*NodeServer) OnDriverStopedHandlerFunc

func (server *NodeServer) OnDriverStopedHandlerFunc(state int, context *driver.DriverContext)

func (*NodeServer) OnJobCacheChangedHandlerFunc

func (server *NodeServer) OnJobCacheChangedHandlerFunc(event cache.CacheEvent, jobbase *models.JobBase)

func (*NodeServer) OnJobCacheExceptionHandlerFunc

func (server *NodeServer) OnJobCacheExceptionHandlerFunc(event cache.CacheEvent, workdir string, jobget *cache.JobGet, jobgeterror *cache.JobGetError)

func (*NodeServer) OnSeverConfigsWatchHandlerFunc

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

func (*NodeServer) OnZkWrapperNodeHandlerFunc

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

func (*NodeServer) OnZkWrapperPulseHandlerFunc

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

func (*NodeServer) RefreshCacheAlloc

func (server *NodeServer) RefreshCacheAlloc() (int, error)

RefreshCacheAlloc is exported

func (*NodeServer) RefreshServerConfig

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

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

func (*NodeServer) Startup

func (server *NodeServer) Startup() error

Startup is exported

func (*NodeServer) Stop

func (server *NodeServer) Stop() error

Stop is exported