pubsub

Documentation

Index

• type LogConsumer
  • func NewLogConsumer(log zerolog.Logger) *LogConsumer
  • func (l *LogConsumer) OnInvalidServiceEvent(event flow.ServiceEvent, err error)
  • func (l *LogConsumer) OnServiceEventProcessed(event flow.ServiceEvent)
  • func (l *LogConsumer) OnServiceEventReceived(event flow.ServiceEvent)

Types

type LogConsumer

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

LogConsumer implements protocol_state.StateMachineTelemetryConsumer and logs all events.

func NewLogConsumer

func NewLogConsumer(log zerolog.Logger) *LogConsumer

func (*LogConsumer) OnInvalidServiceEvent

func (l *LogConsumer) OnInvalidServiceEvent(event flow.ServiceEvent, err error)

func (*LogConsumer) OnServiceEventProcessed

func (l *LogConsumer) OnServiceEventProcessed(event flow.ServiceEvent)

func (*LogConsumer) OnServiceEventReceived

func (l *LogConsumer) OnServiceEventReceived(event flow.ServiceEvent)