events

package
v0.5.2 Latest Latest
Warning

This package is not in the latest version of its module.

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

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

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

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

Jump to

Keyboard shortcuts

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