eventbus

Documentation

Index

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

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
	TopicMapping           TopicMapping
	Logger                 *slog.Logger
	MarshalerTransformFunc marshaler.TransformFunc
}

func (Options) Validate

func (o Options) Validate() error

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

type TopicMapping

type TopicMapping struct {
	IngestEventsTopic string
	SystemEventsTopic string
}

func (TopicMapping) Validate

func (t TopicMapping) Validate() error