issue267

Mar 10, 2025

Changes in this version

+ const AsyncAPIVersion

+ const V2Issue267TestPath

+ var ChannelsPaths = []string

+ type AppController struct

+ func NewAppController(bc extensions.BrokerController, options ...ControllerOption) (*AppController, error)

+ func (c *AppController) Close(ctx context.Context)

+ func (c *AppController) PublishV2Issue267Test(ctx context.Context, msg V2Issue267TestMessage) error

+ type ControllerOption func(controller *controller)

+ func WithErrorHandler(handler extensions.ErrorHandler) ControllerOption

+ func WithLogger(logger extensions.Logger) ControllerOption

+ func WithMiddlewares(middlewares ...extensions.Middleware) ControllerOption

+ type Error struct

+ Channel string

+ Err error

+ func (e *Error) Error() string

+ type MessageWithCorrelationID interface

+ CorrelationID func() string

+ SetCorrelationID func(id string)

+ type TestSchema struct

+ EnumProp string

+ type UserController struct

+ func NewUserController(bc extensions.BrokerController, options ...ControllerOption) (*UserController, error)

+ func (c *UserController) Close(ctx context.Context)

+ func (c *UserController) SubscribeAll(ctx context.Context, as UserSubscriber) error

+ func (c *UserController) SubscribeV2Issue267Test(ctx context.Context, ...) error

+ func (c *UserController) UnsubscribeAll(ctx context.Context)

+ func (c *UserController) UnsubscribeV2Issue267Test(ctx context.Context)

+ type UserSubscriber interface

+ V2Issue267Test func(ctx context.Context, msg V2Issue267TestMessage) error

+ type V2Issue267TestMessage struct

+ Payload TestSchema

+ func NewV2Issue267TestMessage() V2Issue267TestMessage