events

package

v0.5.2 Latest Latest Go to latest Published: May 17, 2024 License: Apache-2.0 Imports: 1 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/datumforge/datum

Links

Open Source Insights

Documentation ¶

Overview ¶

Package events does event stuff

Index ¶

type EventConsumer
type EventPublisher
type Properties
- func NewProperties() Properties
- func (p Properties) Set(name string, value interface{}) Properties

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type EventConsumer ¶

type EventConsumer interface {
	Subscribe(ctx context.Context) error
	Close(context.Context) error
}

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 NewProperties ¶

func NewProperties() Properties

NewProperties creates a new Properties map

func (Properties) Set ¶

func (p Properties) Set(name string, value interface{}) Properties

Set sets a property on the Properties map

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
kafka
config Package config provides configuration for the Kafka event source	Package config provides configuration for the Kafka event source
consumer command
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
soiree 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
examples/error-handling command
examples/metrics command
examples/ordering command
examples/panics command
examples/pools command
examples/uniqueID command

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL