bus

Documentation

Index

• Variables
• type Bus
• type HandlerFunc
• type InProcBus
  • func ProvideBus(tracer tracing.Tracer) *InProcBus
  • func (b *InProcBus) AddEventListener(handler HandlerFunc)
  • func (b *InProcBus) Publish(ctx context.Context, msg Msg) error
• type Msg

Variables

var ErrHandlerNotFound = errors.New("handler not found")

ErrHandlerNotFound defines an error if a handler is not found.

Types

type Bus

type Bus interface {
	Publish(ctx context.Context, msg Msg) error
	AddEventListener(handler HandlerFunc)
}

Bus type defines the bus interface structure.

type HandlerFunc

type HandlerFunc any

HandlerFunc defines a handler function interface.

type InProcBus

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

InProcBus defines the bus structure.

func ProvideBus

func ProvideBus(tracer tracing.Tracer) *InProcBus

func (*InProcBus) AddEventListener

func (b *InProcBus) AddEventListener(handler HandlerFunc)

func (*InProcBus) Publish

func (b *InProcBus) Publish(ctx context.Context, msg Msg) error

Publish function publish a message to the bus listener.

type Msg

type Msg any

Msg defines a message interface.