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.