publisher

package

v1.4.0 Latest Latest Go to latest Published: Oct 19, 2026 License: MIT Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/xgodev/boost

Links

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 ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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

Publish publishes events and returns an error when the driver fails or when any event fails. Per-event failures are turned into the error only after the middleware chain, so middlewares still see them as outputs.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
driver
contrib/cloud.google.com/pubsub/v1
contrib/cloud.google.com/pubsub/v2
contrib/confluentinc/confluent-kafka-go/v2
contrib/lovoo/goka/v1
contrib/nats-io/nats.go/v1
extra/noop
middleware
prometheus
mocks
util

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL