localmsg

Documentation

Index

• type MsgData
  • func (msg MsgData) GetData(val interface{}) error
  • func (msg MsgData) String() (string, error)
• type MsgQueue
  • func New() *MsgQueue
  • func (m *MsgQueue) SendAsync(msg MsgData)
  • func (m *MsgQueue) SendSync(msg MsgData)
  • func (m *MsgQueue) Start()
  • func (m *MsgQueue) Stop()
• type MsgType

Types

type MsgData

type MsgData struct {
	Type      MsgType
	Data      any   //msg data
	Timestamp int64 //unit timestamp
	Do        func()
}

local msg data struct

func (MsgData) GetData

func (msg MsgData) GetData(val interface{}) error

func (MsgData) String

func (msg MsgData) String() (string, error)

type MsgQueue

type MsgQueue struct {
	// contains filtered or unexported fields
}

func New

func New() *MsgQueue

func (*MsgQueue) SendAsync

func (m *MsgQueue) SendAsync(msg MsgData)

异步发送

func (*MsgQueue) SendSync

func (m *MsgQueue) SendSync(msg MsgData)

同步发送

func (*MsgQueue) Start

func (m *MsgQueue) Start()

func (*MsgQueue) Stop

func (m *MsgQueue) Stop()

type MsgType

type MsgType int

local msg type