eventbus

Documentation

Overview

Package eventbus provides an interface for event bus.

Index

• type Event
• type EventBus
  • func New() *EventBus
  • func (e *EventBus) Publish(event Event, data any)
  • func (e *EventBus) Run(ctx context.Context) error
  • func (e *EventBus) Subscribe(event Event, fn func(any))
• type GroupMutationEvent

Types

type Event

type Event string

const (
	EventLabelMutation    Event = "label.mutation"
	EventLocationMutation Event = "location.mutation"
	EventItemMutation     Event = "item.mutation"
)

type EventBus

type EventBus struct {
	// contains filtered or unexported fields
}

func New

func New() *EventBus

func (*EventBus) Publish

func (e *EventBus) Publish(event Event, data any)

func (*EventBus) Run

func (e *EventBus) Run(ctx context.Context) error

func (*EventBus) Subscribe

func (e *EventBus) Subscribe(event Event, fn func(any))

type GroupMutationEvent

type GroupMutationEvent struct {
	GID uuid.UUID
}