publisher

Documentation

Index

• func New(publisher *publisher.Publisher, options *Options) middleware.AnyErrorMiddleware[*event.Event]
• type Options
  • func NewOptions() (*Options, error)
• type Publisher
  • func (c *Publisher) Exec(ctx *middleware.AnyErrorContext[*event.Event], ...) (*event.Event, error)

Functions

func New

func New(publisher *publisher.Publisher, options *Options) middleware.AnyErrorMiddleware[*event.Event]

Types

type Options

type Options struct {
	Subject string
}

func NewOptions

func NewOptions() (*Options, error)

type Publisher

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

func (*Publisher) Exec

func (c *Publisher) Exec(ctx *middleware.AnyErrorContext[*event.Event], exec middleware.AnyErrorExecFunc[*event.Event], fallbackFunc middleware.AnyErrorReturnFunc[*event.Event]) (*event.Event, error)