Versions in this module Expand all Collapse all v0 v0.0.5 Dec 23, 2023 v0.0.2 Dec 23, 2023 Changes in this version + const DefaultVersionHeaderKey + var ErrNoVersion = fmt.Errorf("%w: no version present", extensions.ErrAsyncAPI) + type Wrapper struct + func NewWrapper(broker extensions.BrokerController, options ...WrapperOption) *Wrapper + func (w *Wrapper) Publish(ctx context.Context, channel string, mw extensions.BrokerMessage) error + func (w *Wrapper) Subscribe(ctx context.Context, channel string) (extensions.BrokerChannelSubscription, error) + type WrapperOption func(versionWrapper *Wrapper) + func WithDefaultVersion(version string) WrapperOption + func WithLogger(logger extensions.Logger) WrapperOption + func WithVersionHeaderKey(headerKey string) WrapperOption
Go to main page