broker

README

broker

Simple event broker

Documentation

Index

• Constants
• type Broker
  • func New[T types.Ordered](ctx context.Context, qsz int) Broker[T]
• type Event
• type Subscription
  • func NewSubscription[T types.Ordered](name string, sz int) Subscription[T]

Constants

const ErrBrokerIsStopped = errors.Const("operation on stopped broker")

Types

type Broker

type Broker[T types.Ordered] interface {
	execs.Runner
	Subscribe(name string) (sub Subscription[T], err error)
	Publish(ev Event[T]) error
	Unsubscribe(sub Subscription[T]) error
}

Broker - simple service event broker

func New

func New[T types.Ordered](ctx context.Context, qsz int) Broker[T]

New - simple broker constructor

type Event

type Event[T types.Ordered] interface {
	SubName() string
	EventType() T
}

Event service event

type Subscription

type Subscription[T types.Ordered] interface {
	GetName() string
	ChanEv() chan Event[T]
}

Subscription - service event subscription

func NewSubscription

func NewSubscription[T types.Ordered](name string, sz int) Subscription[T]

NewSubscription - event subscribe constructor