Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AwaitRpcEventMsg ¶
type AwaitRpcEventMsg struct { MsgType EventType Sender Agent RpcName string Data []interface{} Await chan []interface{} }
func (*AwaitRpcEventMsg) GetSender ¶
func (m *AwaitRpcEventMsg) GetSender() Agent
func (*AwaitRpcEventMsg) GetType ¶
func (m *AwaitRpcEventMsg) GetType() EventType
func (*AwaitRpcEventMsg) Reset ¶
func (m *AwaitRpcEventMsg) Reset()
type ComponentEventMsg ¶
func (*ComponentEventMsg) GetSender ¶
func (m *ComponentEventMsg) GetSender() interface{}
func (*ComponentEventMsg) GetType ¶
func (m *ComponentEventMsg) GetType() EventType
func (*ComponentEventMsg) Reset ¶
func (m *ComponentEventMsg) Reset()
type ComponentID ¶
type ComponentID = component.ComponentID
type CustomActionEventMsg ¶
type CustomActionEventMsg interface { GetType() EventType GetSender() Agent GetAction() func(CustomActionEventMsg) }
type DataEventMsg ¶
type DataEventMsg struct { MsgType EventType Sender Agent TypeID ProtoTypeID MsgData interface{} }
func (*DataEventMsg) GetSender ¶
func (m *DataEventMsg) GetSender() Agent
func (*DataEventMsg) GetType ¶
func (m *DataEventMsg) GetType() EventType
func (*DataEventMsg) Reset ¶
func (m *DataEventMsg) Reset()
type EventQueue ¶
type EventQueue struct {
// contains filtered or unexported fields
}
func NewEventQueue ¶
func NewEventQueue() *EventQueue
func (*EventQueue) Get ¶
func (q *EventQueue) Get(event_list []interface{}, count uint32) uint32
func (*EventQueue) Push ¶
func (q *EventQueue) Push(event EventMsg)
func (*EventQueue) SemaChan ¶
func (q *EventQueue) SemaChan() EventChan
func (*EventQueue) WaitNotify ¶
func (q *EventQueue) WaitNotify() bool
func (*EventQueue) WaiterWake ¶
func (q *EventQueue) WaiterWake()
type EventReceiver ¶
type EventReceiver interface { PostEvent(EventType, Agent, ComponentID, ...interface{}) PostData(EventType, ProtoTypeID, Agent, interface{}) PushEventMsg(ev EventMsg) }
type ProtoTypeID ¶
type ProtoTypeID = agent.ProtoTypeID
type RpcEventMsg ¶
func (*RpcEventMsg) GetSender ¶
func (m *RpcEventMsg) GetSender() Agent
func (*RpcEventMsg) GetType ¶
func (m *RpcEventMsg) GetType() EventType
func (*RpcEventMsg) Reset ¶
func (m *RpcEventMsg) Reset()
type SessionEventMsg ¶
type SessionEventMsg struct { MsgType EventType Sender Agent Cid ComponentID Args []interface{} }
func (*SessionEventMsg) GetSender ¶
func (m *SessionEventMsg) GetSender() Agent
func (*SessionEventMsg) GetType ¶
func (m *SessionEventMsg) GetType() EventType
func (*SessionEventMsg) Reset ¶
func (m *SessionEventMsg) Reset()
Click to show internal directories.
Click to hide internal directories.