issue333

Jun 27, 2024

Changes in this version

+ const AsyncAPIVersion

+ const TestChannelPath

+ var ChannelsPaths = []string

+ type AppController struct

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

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

+ 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 EventIdSchema string

+ type HeadersFromPingMessageFromTestChannel struct

+ EventId EventIdSchema

+ OptionalEventId *EventIdSchema

+ type MessageWithCorrelationID interface

+ CorrelationID func() string

+ SetCorrelationID func(id string)

+ type PingMessageFromTestChannel struct

+ Headers HeadersFromPingMessageFromTestChannel

+ Payload PingMessageFromTestChannelPayload

+ func NewPingMessageFromTestChannel() PingMessageFromTestChannel

+ type PingMessageFromTestChannelPayload struct

+ Event *string

+ type UserController struct

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

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