Versions in this module Expand all Collapse all v0 v0.0.5 Dec 23, 2023 Changes in this version + const AsyncAPIVersion + type ActionSchema struct + Action *string + type AppController struct + func NewAppController(bc extensions.BrokerController, options ...ControllerOption) (*AppController, error) + func (c *AppController) Close(ctx context.Context) + func (c *AppController) PublishDisconnect(ctx context.Context, msg OkMessage) error + func (c *AppController) SubscribeAll(ctx context.Context, as AppSubscriber) error + func (c *AppController) SubscribeDisconnect(ctx context.Context, fn func(ctx context.Context, msg OkMessage)) error + func (c *AppController) SubscribeFoo(ctx context.Context, fn func(ctx context.Context, msg FooMessage)) error + func (c *AppController) UnsubscribeAll(ctx context.Context) + func (c *AppController) UnsubscribeDisconnect(ctx context.Context) + func (c *AppController) UnsubscribeFoo(ctx context.Context) + type AppSubscriber interface + Disconnect func(ctx context.Context, msg OkMessage) + Foo func(ctx context.Context, msg FooMessage) + type ControllerOption func(controller *controller) + 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 FooMessage struct + Payload struct{ ... } + func NewFooMessage() FooMessage + type MessageWithCorrelationID interface + CorrelationID func() string + SetCorrelationID func(id string) + type OkMessage struct + Payload ActionSchema + func NewOkMessage() OkMessage + type PersonSchema struct + Action *string + AdditionalProperty *string + type RegistrationSchema struct + CallId *string + type UserController struct + func NewUserController(bc extensions.BrokerController, options ...ControllerOption) (*UserController, error) + func (c *UserController) Close(ctx context.Context) + func (c *UserController) PublishDisconnect(ctx context.Context, msg OkMessage) error + func (c *UserController) PublishFoo(ctx context.Context, msg FooMessage) error + func (c *UserController) SubscribeAll(ctx context.Context, as UserSubscriber) error + func (c *UserController) SubscribeDisconnect(ctx context.Context, fn func(ctx context.Context, msg OkMessage)) error + func (c *UserController) UnsubscribeAll(ctx context.Context) + func (c *UserController) UnsubscribeDisconnect(ctx context.Context) + type UserSchema struct + Action *string + AdditionalProperty *string + type UserSubscriber interface + Disconnect func(ctx context.Context, msg OkMessage)
Go to main page