rawmessagesfilter

Documentation

Index

• type ConsensusMessagesHandler
• type RawMessageFilter
  • func NewConsensusMessageFilter(instanceId primitives.InstanceId, myMemberId primitives.MemberId, ...) *RawMessageFilter
  • func (f *RawMessageFilter) ConsumeCacheMessages(consensusMessagesHandler ConsensusMessagesHandler)
  • func (f *RawMessageFilter) HandleConsensusRawMessage(rawMessage *interfaces.ConsensusRawMessage)

Types

type ConsensusMessagesHandler

type ConsensusMessagesHandler interface {
	HandleConsensusMessage(message interfaces.ConsensusMessage) error
}

type RawMessageFilter

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

func NewConsensusMessageFilter

func NewConsensusMessageFilter(instanceId primitives.InstanceId, myMemberId primitives.MemberId, logger L.LHLogger, state *state.State) *RawMessageFilter

func (*RawMessageFilter) ConsumeCacheMessages

func (f *RawMessageFilter) ConsumeCacheMessages(consensusMessagesHandler ConsensusMessagesHandler)

func (*RawMessageFilter) HandleConsensusRawMessage

func (f *RawMessageFilter) HandleConsensusRawMessage(rawMessage *interfaces.ConsensusRawMessage)

TODO Consider passing ConsensusMessage instead of *interfaces.ConsensusRawMessage