events

Documentation

Overview

Package events is the definition for event consumer & producer.

Index

• Variables
• type Consumer
• type Producer

Variables

var ErrUnknownConsumerType = fmt.Errorf("unknown consumer type")

ErrUnknownConsumerType is returned when the consumer type is unknown.

Types

type Consumer

type Consumer interface {
	// Consume consumes a message from the queue.
	Consume() error
	// Shutdown shuts down the consumer.
	Shutdown(ctx context.Context) error
}

Consumer consumes messages from the queue.

type Producer

type Producer[T any] interface {
	// Produce produces a message to the queue.
	Produce(ctx context.Context, runID T) error
}

Producer produces messages to the queue.