Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ApplyCloudEventOptions ¶ added in v0.0.55
Types ¶
type Option ¶
type Option struct {
// contains filtered or unexported fields
}
func WithExtensions ¶ added in v0.0.55
func WithOrderingKey ¶
type PanicPublisher ¶ added in v0.0.49
type PanicPublisher[EV any] struct { // contains filtered or unexported fields }
PanicPublisher wraps a Publisher. Panics if publishing fails.
func NewPanicPublisher ¶ added in v0.0.49
func NewPanicPublisher[EV any](er *errorreporting.Client, base Publisher[EV]) *PanicPublisher[EV]
func (*PanicPublisher[EV]) PublishWithNACKPanic ¶ added in v0.0.49
func (p *PanicPublisher[EV]) PublishWithNACKPanic(ctx context.Context, event *EV, opts ...Option) errorreports.Error
type PublishError ¶ added in v0.0.48
type PublishError interface { errorreports.Error // IsACK returns true if recipient acknowledged the event. IsACK() bool }
Click to show internal directories.
Click to hide internal directories.