eventbus

Documentation

Index

• type ContextPublisher
• type Options
• type Publisher
  • func New(opts Options) (Publisher, error)
  • func NewMock(t *testing.T) Publisher

Types

type ContextPublisher

type ContextPublisher interface {
	// PublishIfNoError publishes an event if the error is nil or returns the error
	PublishIfNoError(event marshaler.Event, err error) error
}

type Options

type Options struct {
	Publisher              message.Publisher
	Config                 config.EventsConfiguration
	Logger                 *slog.Logger
	MarshalerTransformFunc marshaler.TransformFunc
}

type Publisher

type Publisher interface {
	// Publish publishes an event to the event bus
	Publish(ctx context.Context, event marshaler.Event) error

	// WithContext is a convinience method to publish from the router. Usually if we need
	// to publish from the router, a function returns a marshaler.Event and an error. Using this
	// method we can inline the publish call and avoid the need to check for errors:
	//
	//    return p.WithContext(ctx).PublishIfNoError(worker.handleEvent(ctx, event))
	WithContext(ctx context.Context) ContextPublisher

	Marshaler() marshaler.Marshaler
}

func New

func New(opts Options) (Publisher, error)

func NewMock

func NewMock(t *testing.T) Publisher