eventinput

Documentation

Index

• type AnchorEvent
  • func NewAnchorEvent(streamSource eventmessages.EventSource, ...) *AnchorEvent
  • func (event AnchorEvent) GetPayload() interfaces.IDirBlockInfo
  • func (event AnchorEvent) GetStreamSource() eventmessages.EventSource
• type DirectoryBlockEvent
  • func NewDirectoryBlockEvent(streamSource eventmessages.EventSource, dbState interfaces.IDBState) *DirectoryBlockEvent
  • func (event DirectoryBlockEvent) GetPayload() interfaces.IDBState
  • func (event DirectoryBlockEvent) GetStreamSource() eventmessages.EventSource
• type EventInput
• type NodeMessageEvent
  • func NodeErrorMessage(messageCode eventmessages.NodeMessageCode, message string, values interface{}) *NodeMessageEvent
  • func NodeInfoMessage(messageCode eventmessages.NodeMessageCode, message string) *NodeMessageEvent
  • func NodeInfoMessageF(messageCode eventmessages.NodeMessageCode, format string, ...) *NodeMessageEvent
  • func (event NodeMessageEvent) GetNodeMessage() *eventmessages.NodeMessage
  • func (event NodeMessageEvent) GetStreamSource() eventmessages.EventSource
• type ProcessListEvent
  • func ProcessListEventNewBlock(streamSource eventmessages.EventSource, newBlockHeight uint32) *ProcessListEvent
  • func ProcessListEventNewMinute(streamSource eventmessages.EventSource, newMinute int, blockHeight uint32) *ProcessListEvent
  • func (event ProcessListEvent) GetProcessListEvent() *eventmessages.ProcessListEvent
  • func (event ProcessListEvent) GetStreamSource() eventmessages.EventSource
• type RegistrationEvent
  • func NewRegistrationEvent(streamSource eventmessages.EventSource, msg interfaces.IMsg) *RegistrationEvent
  • func (event RegistrationEvent) GetPayload() interfaces.IMsg
  • func (event RegistrationEvent) GetStreamSource() eventmessages.EventSource
• type ReplayDirectoryBlockEvent
  • func NewReplayDirectoryBlockEvent(streamSource eventmessages.EventSource, dbStateMsg interfaces.IMsg) *ReplayDirectoryBlockEvent
  • func (event ReplayDirectoryBlockEvent) GetPayload() interfaces.IMsg
  • func (event ReplayDirectoryBlockEvent) GetStreamSource() eventmessages.EventSource
• type StateChangeEvent
  • func NewStateChangeEvent(streamSource eventmessages.EventSource, entityState eventmessages.EntityState, ...) *StateChangeEvent
  • func (event StateChangeEvent) GetEntityState() eventmessages.EntityState
  • func (event StateChangeEvent) GetPayload() interfaces.IMsg
  • func (event StateChangeEvent) GetStreamSource() eventmessages.EventSource

Types

type AnchorEvent

type AnchorEvent struct {
	EventSource eventmessages.EventSource
	Payload     interfaces.IDirBlockInfo
}

func NewAnchorEvent

func NewAnchorEvent(streamSource eventmessages.EventSource, dbDirBlockInfo interfaces.IDirBlockInfo) *AnchorEvent

func (AnchorEvent) GetPayload

func (event AnchorEvent) GetPayload() interfaces.IDirBlockInfo

func (AnchorEvent) GetStreamSource

func (event AnchorEvent) GetStreamSource() eventmessages.EventSource

type DirectoryBlockEvent

type DirectoryBlockEvent struct {
	EventSource eventmessages.EventSource
	Payload     interfaces.IDBState
}

func NewDirectoryBlockEvent

func NewDirectoryBlockEvent(streamSource eventmessages.EventSource, dbState interfaces.IDBState) *DirectoryBlockEvent

func (DirectoryBlockEvent) GetPayload

func (event DirectoryBlockEvent) GetPayload() interfaces.IDBState

func (DirectoryBlockEvent) GetStreamSource

func (event DirectoryBlockEvent) GetStreamSource() eventmessages.EventSource

type EventInput

type EventInput interface {
	GetStreamSource() eventmessages.EventSource
}

type NodeMessageEvent

type NodeMessageEvent struct {
	EventSource eventmessages.EventSource
	NodeMessage *eventmessages.NodeMessage
}

func NodeErrorMessage

func NodeErrorMessage(messageCode eventmessages.NodeMessageCode, message string, values interface{}) *NodeMessageEvent

func NodeInfoMessage

func NodeInfoMessage(messageCode eventmessages.NodeMessageCode, message string) *NodeMessageEvent

func NodeInfoMessageF

func NodeInfoMessageF(messageCode eventmessages.NodeMessageCode, format string, values ...interface{}) *NodeMessageEvent

func (NodeMessageEvent) GetNodeMessage

func (event NodeMessageEvent) GetNodeMessage() *eventmessages.NodeMessage

func (NodeMessageEvent) GetStreamSource

func (event NodeMessageEvent) GetStreamSource() eventmessages.EventSource

type ProcessListEvent

type ProcessListEvent struct {
	EventSource              eventmessages.EventSource
	ProcessListEventInstance *eventmessages.ProcessListEvent
}

func ProcessListEventNewBlock

func ProcessListEventNewBlock(streamSource eventmessages.EventSource, newBlockHeight uint32) *ProcessListEvent

func ProcessListEventNewMinute

func ProcessListEventNewMinute(streamSource eventmessages.EventSource, newMinute int, blockHeight uint32) *ProcessListEvent

func (ProcessListEvent) GetProcessListEvent

func (event ProcessListEvent) GetProcessListEvent() *eventmessages.ProcessListEvent

func (ProcessListEvent) GetStreamSource

func (event ProcessListEvent) GetStreamSource() eventmessages.EventSource

type RegistrationEvent

type RegistrationEvent struct {
	EventSource eventmessages.EventSource
	Payload     interfaces.IMsg
}

func NewRegistrationEvent

func NewRegistrationEvent(streamSource eventmessages.EventSource, msg interfaces.IMsg) *RegistrationEvent

func (RegistrationEvent) GetPayload

func (event RegistrationEvent) GetPayload() interfaces.IMsg

func (RegistrationEvent) GetStreamSource

func (event RegistrationEvent) GetStreamSource() eventmessages.EventSource

type ReplayDirectoryBlockEvent

type ReplayDirectoryBlockEvent struct {
	EventSource eventmessages.EventSource
	Payload     interfaces.IMsg
}

func NewReplayDirectoryBlockEvent

func NewReplayDirectoryBlockEvent(streamSource eventmessages.EventSource, dbStateMsg interfaces.IMsg) *ReplayDirectoryBlockEvent

func (ReplayDirectoryBlockEvent) GetPayload

func (event ReplayDirectoryBlockEvent) GetPayload() interfaces.IMsg

func (ReplayDirectoryBlockEvent) GetStreamSource

func (event ReplayDirectoryBlockEvent) GetStreamSource() eventmessages.EventSource

type StateChangeEvent

type StateChangeEvent struct {
	EventSource eventmessages.EventSource
	EntityState eventmessages.EntityState
	Payload     interfaces.IMsg
}

func NewStateChangeEvent

func NewStateChangeEvent(streamSource eventmessages.EventSource, entityState eventmessages.EntityState, msg interfaces.IMsg) *StateChangeEvent

func (StateChangeEvent) GetEntityState

func (event StateChangeEvent) GetEntityState() eventmessages.EntityState

func (StateChangeEvent) GetPayload

func (event StateChangeEvent) GetPayload() interfaces.IMsg

func (StateChangeEvent) GetStreamSource

func (event StateChangeEvent) GetStreamSource() eventmessages.EventSource