publisher

Documentation

Index

• func NewAnyErrorMiddleware[T any](publisher *publisher.Publisher) (middleware.AnyErrorMiddleware[T], error)
• func NewAnyErrorMiddlewareWithOptions[T any](publisher *publisher.Publisher, options *Options) middleware.AnyErrorMiddleware[T]
• type DeadletterOptions
• type Options
  • func NewOptions() (*Options, error)
• type Publisher
  • func NewPublisher[T any](publisher *publisher.Publisher) (*Publisher[T], error)
  • func NewPublisherWithOptions[T any](publisher *publisher.Publisher, options *Options) *Publisher[T]
  • func (c *Publisher[T]) Exec(ctx *middleware.AnyErrorContext[T], exec middleware.AnyErrorExecFunc[T], ...) (T, error)

Functions

func NewAnyErrorMiddleware

func NewAnyErrorMiddleware[T any](publisher *publisher.Publisher) (middleware.AnyErrorMiddleware[T], error)

func NewAnyErrorMiddlewareWithOptions

func NewAnyErrorMiddlewareWithOptions[T any](publisher *publisher.Publisher, options *Options) middleware.AnyErrorMiddleware[T]

Types

type DeadletterOptions

type DeadletterOptions struct {
	Enabled bool
	Subject string
	Errors  []string
}

type Options

type Options struct {
	Subject    string
	Deadletter DeadletterOptions
}

func NewOptions

func NewOptions() (*Options, error)

type Publisher

type Publisher[T any] struct {
	// contains filtered or unexported fields
}

func NewPublisher

func NewPublisher[T any](publisher *publisher.Publisher) (*Publisher[T], error)

func NewPublisherWithOptions

func NewPublisherWithOptions[T any](publisher *publisher.Publisher, options *Options) *Publisher[T]

func (*Publisher[T]) Exec

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