plane

func (*PlaneLite) GetAppStatus ¶

func (p *PlaneLite) GetAppStatus() (*xplane.AppStatus, error)

func (*PlaneLite) GetIdService ¶

func (p *PlaneLite) GetIdService() xplane.IDService

func (*PlaneLite) GetLocker ¶

func (p *PlaneLite) GetLocker() xplane.Locker

locker

func (*PlaneLite) GetMsgBus ¶

func (p *PlaneLite) GetMsgBus() xplane.MsgBus

func (*PlaneLite) GetNodeId ¶

func (p *PlaneLite) GetNodeId() int64

func (*PlaneLite) GetRouter ¶

func (p *PlaneLite) GetRouter() xplane.Router

func (*PlaneLite) GetSockdRouter ¶

func (p *PlaneLite) GetSockdRouter() xplane.SockdRouter

sockdrouter

func (*PlaneLite) Inject ¶

func (p *PlaneLite) Inject(iapp interface{}, config *config.Config) error

func (*PlaneLite) NotifyStat ¶

func (p *PlaneLite) NotifyStat(stats xplane.NodeStat) error

func (*PlaneLite) SetJobChan ¶

func (p *PlaneLite) SetJobChan(ic chan *job.Job)

router stuff

func (*PlaneLite) Start ¶

func (p *PlaneLite) Start() error

func (Router) Route ¶

func (r Router) Route(j *job.Job) bool

func (*Sequencer) DeviceId ¶

func (s *Sequencer) DeviceId() int64

func (*Sequencer) DisplayErrId ¶

func (s *Sequencer) DisplayErrId() string

func (*Sequencer) EventId ¶

func (s *Sequencer) EventId() string

func (*Sequencer) NewGlobalId ¶

func (s *Sequencer) NewGlobalId() int64

func (*Sequencer) NewNode ¶

func (s *Sequencer) NewNode() *snowflake.Node

func (*Sequencer) RequestId ¶

func (s *Sequencer) RequestId() string

func (*Sequencer) SessionId ¶

func (s *Sequencer) SessionId() int64

func (*SockdRouter) Broadcast ¶

func (sr *SockdRouter) Broadcast(tenantId, room string, rawData []byte) error

func (*SockdRouter) Publish ¶

func (sr *SockdRouter) Publish(tenantId, room string, tags map[string]string, rawData []byte) error

func (*SockdRouter) SendSession ¶

func (sr *SockdRouter) SendSession(tenantId, session string, rawData []byte) error