Documentation ¶
Overview ¶
Package events does event stuff
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventConsumer ¶
EventConsumer is the interface for consuming events
type EventPublisher ¶
type EventPublisher interface { StartPublisher(context.Context) error Publish(ctx context.Context, topic string, payload interface{}) error Close(context.Context) error }
EventPublisher is the interface for publishing events
type Properties ¶
type Properties map[string]interface{}
Properties is a map of properties to set on an event as a wrapper
func (Properties) Set ¶
func (p Properties) Set(name string, value interface{}) Properties
Set sets a property on the Properties map
Directories ¶
Path | Synopsis |
---|---|
kafka
|
|
config
Package config provides configuration for the Kafka event source
|
Package config provides configuration for the Kafka event source |
kafkaconfig
Package kafkaconfig provides configuration for the Kafka event source
|
Package kafkaconfig provides configuration for the Kafka event source |
publisher
Package publisher provides a basic kafka event publisher
|
Package publisher provides a basic kafka event publisher |
Package soiree provides a simple event emitter that allows you to emit events and listen for them
|
Package soiree provides a simple event emitter that allows you to emit events and listen for them |
Click to show internal directories.
Click to hide internal directories.