Documentation ¶
Overview ¶
Package event implements an event streaming platform to communcate to allow sharing of all events to different servers.
Index ¶
- func WithTraces(cfg config.Trace, logs *zap.Logger) func(*Event)
- type Event
- func (e *Event) CloseReaders()
- func (e *Event) CloseTraceReader(c trace.Channel)
- func (e *Event) NewBlockReader() chan validator.Validator
- func (e *Event) NewReader() chan Message
- func (e *Event) NewTraceReader() *trace.Channel
- func (e *Event) Push(m Message)
- func (e *Event) PushBlock(block validator.Validator)
- func (e *Event) PushTrace(blockID string, state trace.State)
- type EventType
- type Message
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Event ¶
type Event struct {
// contains filtered or unexported fields
}
Event represent a new adapter Event.
func (*Event) CloseTraceReader ¶
CloseTraceReader must close trace reader.
func (*Event) NewBlockReader ¶
func (*Event) NewTraceReader ¶
Click to show internal directories.
Click to hide internal directories.