monitor

Documentation

Index

• Variables
• type DevRPC
  • func (cs *DevRPC) AuthFun() hbtp.AuthFun
  • func (cs *DevRPC) CpuInfos(c *hbtp.Context)
  • func (cs *DevRPC) Process(c *hbtp.Context)
• type Manager
  • func NewManager(name string) *Manager
  • func (c *Manager) OnBroadcast(e *ywtree.Engine, msg *messages.MessageBox) *messages.ReplyInfo
  • func (c *Manager) OnConnect(e *ywtree.Engine)
  • func (c *Manager) OnDisconnect(e *ywtree.Engine)
  • func (c *Manager) OnMessage(e *ywtree.Engine, msg *ywtree.MessageTopic) *messages.ReplyInfo

Variables

var YwtEgn *ywtree.Engine

Types

type DevRPC

type DevRPC struct{}

func (*DevRPC) AuthFun

func (cs *DevRPC) AuthFun() hbtp.AuthFun

func (*DevRPC) CpuInfos

func (cs *DevRPC) CpuInfos(c *hbtp.Context)

func (*DevRPC) Process

func (cs *DevRPC) Process(c *hbtp.Context)

type Manager

type Manager struct {
	Ctx context.Context
	// contains filtered or unexported fields
}

func NewManager

func NewManager(name string) *Manager

func (*Manager) OnBroadcast

func (c *Manager) OnBroadcast(e *ywtree.Engine, msg *messages.MessageBox) *messages.ReplyInfo

func (*Manager) OnConnect

func (c *Manager) OnConnect(e *ywtree.Engine)

func (*Manager) OnDisconnect

func (c *Manager) OnDisconnect(e *ywtree.Engine)

func (*Manager) OnMessage

func (c *Manager) OnMessage(e *ywtree.Engine, msg *ywtree.MessageTopic) *messages.ReplyInfo