publisher

Documentation

Index

• Constants
• func IsEnabled() bool
• func New(driver Driver) middleware.AnyErrorMiddleware[*event.Event]
• type Driver
• type Publisher
  • func (c *Publisher) Exec(ctx *middleware.AnyErrorContext[*event.Event], ...) (*event.Event, error)

Constants

const (
	Root = middleware.Root + ".publisher"
)

Functions

func IsEnabled

func IsEnabled() bool

func New

func New(driver Driver) middleware.AnyErrorMiddleware[*event.Event]

Types

type Driver

type Driver interface {
	Publish(context.Context, []*cloudevents.Event) 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)