Versions in this module Expand all Collapse all v1 v1.13.0 Feb 18, 2021 Changes in this version + type AnchorEvent struct + EventSource eventmessages.EventSource + Payload interfaces.IDirBlockInfo + func NewAnchorEvent(streamSource eventmessages.EventSource, ...) *AnchorEvent + func (event AnchorEvent) GetPayload() interfaces.IDirBlockInfo + func (event AnchorEvent) GetStreamSource() eventmessages.EventSource + type DirectoryBlockEvent struct + EventSource eventmessages.EventSource + Payload interfaces.IDBState + func NewDirectoryBlockEvent(streamSource eventmessages.EventSource, dbState interfaces.IDBState) *DirectoryBlockEvent + func (event DirectoryBlockEvent) GetPayload() interfaces.IDBState + func (event DirectoryBlockEvent) GetStreamSource() eventmessages.EventSource + type EventInput interface + GetStreamSource func() eventmessages.EventSource + type NodeMessageEvent struct + EventSource eventmessages.EventSource + NodeMessage *eventmessages.NodeMessage + 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 struct + EventSource eventmessages.EventSource + ProcessListEventInstance *eventmessages.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 struct + EventSource eventmessages.EventSource + Payload interfaces.IMsg + func NewRegistrationEvent(streamSource eventmessages.EventSource, msg interfaces.IMsg) *RegistrationEvent + func (event RegistrationEvent) GetPayload() interfaces.IMsg + func (event RegistrationEvent) GetStreamSource() eventmessages.EventSource + type ReplayDirectoryBlockEvent struct + EventSource eventmessages.EventSource + Payload interfaces.IMsg + func NewReplayDirectoryBlockEvent(streamSource eventmessages.EventSource, dbStateMsg interfaces.IMsg) *ReplayDirectoryBlockEvent + func (event ReplayDirectoryBlockEvent) GetPayload() interfaces.IMsg + func (event ReplayDirectoryBlockEvent) GetStreamSource() eventmessages.EventSource + type StateChangeEvent struct + EntityState eventmessages.EntityState + EventSource eventmessages.EventSource + Payload interfaces.IMsg + 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 Incompatible versions in this module v6.11.0+incompatible Nov 14, 2020 v6.5.2+incompatible Feb 5, 2020