publisher

Documentation

Index

• Constants
• type Driver
• type PublishOutput
• type Publisher
  • func New(driver Driver, mid ...middleware.AnyErrorMiddleware[[]PublishOutput]) *Publisher
  • func (p *Publisher) Publish(ctx context.Context, events []*cloudevents.Event) error

Constants

const (
	Root = "boost.wrapper.publisher"
)

Types

type Driver

type Driver interface {
	Publish(context.Context, []*cloudevents.Event) ([]PublishOutput, error)
}

type PublishOutput

type PublishOutput struct {
	Event *cloudevents.Event
	Error error
}

type Publisher

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

func New

func New(driver Driver, mid ...middleware.AnyErrorMiddleware[[]PublishOutput]) *Publisher

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, events []*cloudevents.Event) error