Documentation ¶
Index ¶
Constants ¶
View Source
const ( CMD_RUN = 1 CMD_PAUSE = 2 CMD_STOP = 3 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AgentInfo ¶
type AgentInfo struct {
LastUpdatedTime int64
}
the detail of service
func NewAgentInfo ¶
func NewAgentInfo() *AgentInfo
func (*AgentInfo) SetLastUpdatedTime ¶
type EtcdRegisterWorker ¶
type EtcdRegisterWorker struct {
// contains filtered or unexported fields
}
func NewEtcdRegisterWorker ¶
func NewEtcdRegisterWorker(nodeId string, cli *clientv3.Client, roles []string) *EtcdRegisterWorker
func (*EtcdRegisterWorker) Start ¶
func (s *EtcdRegisterWorker) Start() error
func (*EtcdRegisterWorker) Stop ¶
func (s *EtcdRegisterWorker) Stop()
type EtcdWatcherWorker ¶
type EtcdWatcherWorker struct {
// contains filtered or unexported fields
}
func NewEtcdWatcherWorker ¶
func NewEtcdWatcherWorker(nodeId string, cli *clientv3.Client) *EtcdWatcherWorker
func (*EtcdWatcherWorker) GetRuntimeNodeIds ¶
func (myself *EtcdWatcherWorker) GetRuntimeNodeIds() []string
GetRuntimeNodeIds
func (*EtcdWatcherWorker) Start ¶
func (myself *EtcdWatcherWorker) Start() error
func (*EtcdWatcherWorker) Stop ¶
func (myself *EtcdWatcherWorker) Stop() error
func (*EtcdWatcherWorker) WatcherQueueResp ¶
func (myself *EtcdWatcherWorker) WatcherQueueResp(key string, newCbs ...api.Callback)
type NatsMQWorker ¶
type NatsMQWorker struct {
// contains filtered or unexported fields
}
workerManager monitor all running services, if facade mode
func NewNatsMQWorker ¶
func NewNatsMQWorker(natsConn stan.Conn) *NatsMQWorker
func (*NatsMQWorker) RequestHandler ¶
func (myself *NatsMQWorker) RequestHandler(fn func(req *schema.ReqQ))
func (*NatsMQWorker) Run ¶
func (myself *NatsMQWorker) Run()
type QueueWatcher ¶
type QueueWatcher struct {
// contains filtered or unexported fields
}
func NewQueueWatcher ¶
func NewQueueWatcher(client *clientv3.Client) *QueueWatcher
func (*QueueWatcher) SetCallbacks ¶
func (myself *QueueWatcher) SetCallbacks(newCbs ...api.Callback)
func (*QueueWatcher) SetEventKey ¶
func (myself *QueueWatcher) SetEventKey(eventKey string)
Click to show internal directories.
Click to hide internal directories.