worker

Documentation

Index

• Constants
• type AgentInfo
  • func NewAgentInfo() *AgentInfo
  • func (myself *AgentInfo) SetLastUpdatedTime(t int64)
• type EtcdRegisterWorker
  • func NewEtcdRegisterWorker(nodeId string, cli *clientv3.Client, roles []string) *EtcdRegisterWorker
  • func (s *EtcdRegisterWorker) Start() error
  • func (s *EtcdRegisterWorker) Stop()
• type EtcdWatcherWorker
  • func NewEtcdWatcherWorker(nodeId string, cli *clientv3.Client) *EtcdWatcherWorker
  • func (myself *EtcdWatcherWorker) GetRuntimeNodeIds() []string
  • func (myself *EtcdWatcherWorker) Start() error
  • func (myself *EtcdWatcherWorker) Stop() error
  • func (myself *EtcdWatcherWorker) WatcherQueueResp(key string, newCbs ...api.Callback)
• type NatsMQWorker
  • func NewNatsMQWorker(natsConn stan.Conn) *NatsMQWorker
  • func (myself *NatsMQWorker) RequestHandler(fn func(req *schema.ReqQ))
  • func (myself *NatsMQWorker) Run()
  • func (myself *NatsMQWorker) Stop()
• type QueueWatcher
  • func NewQueueWatcher(client *clientv3.Client) *QueueWatcher
  • func (myself *QueueWatcher) SetCallbacks(newCbs ...api.Callback)
  • func (myself *QueueWatcher) SetEventKey(eventKey string)

Constants

const (
	CMD_RUN   = 1
	CMD_PAUSE = 2
	CMD_STOP  = 3
)

Types

type AgentInfo

type AgentInfo struct {
	LastUpdatedTime int64
}

the detail of service

func NewAgentInfo

func NewAgentInfo() *AgentInfo

func (*AgentInfo) SetLastUpdatedTime

func (myself *AgentInfo) SetLastUpdatedTime(t int64)

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()

func (*NatsMQWorker) Stop

func (myself *NatsMQWorker) Stop()

Stop send commond stop

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)