eventmanager

Documentation

Index

• Variables
• type Event
• type EventHandler
• type EventManager
• type EventName
• type Payload

Variables

var ErrInvalidPayload = errors.New("invalid payload")

Types

type Event

type Event interface {
	GetName() EventName
	GetPayload() Payload
}

type EventHandler

type EventHandler func(ctx context.Context, payload json.RawMessage) error

type EventManager

type EventManager interface {
	Publish(ctx context.Context, event Event) error
	PublishMany(ctx context.Context, events ...Event) error
	Subscribe(eventName EventName, handler EventHandler)
	StartHandling(ctx context.Context) error
	Stop(ctx context.Context) error
}

type EventName

type EventName string

type Payload

type Payload interface {
}

Payload Must be json marshalable and unmarshalable