Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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)
Source Files
Click to show internal directories.
Click to hide internal directories.