generated

Aug 27, 2023

Changes in this version

type ClientController

+ func (c *ClientController) AddMiddlewares(middleware ...middleware.Middleware)

Aug 18, 2023

Changes in this version

type BrokerController

+ SetLogger func(logger log.Logger)

type ClientController

+ func (c *ClientController) SetLogger(logger log.Logger)

+ func (c ClientController) LogError(ctx log.Context, msg string)

+ func (c ClientController) LogInfo(ctx log.Context, msg string)

type NATSController

+ func (c *NATSController) SetLogger(logger log.Logger)

Aug 17, 2023

Changes in this version

type BrokerController

+ SetQueueName func(name string)

type NATSController

+ func (c *NATSController) SetQueueName(name string)

Apr 2, 2023

Changes in this version

type BrokerController

+ AttachLogger func(logger Logger)

type ClientController

+ func (c *ClientController) AttachLogger(logger Logger)

+ type Logger interface

+ Error func(msg string, keyvals ...interface{})

+ Info func(msg string, keyvals ...interface{})

type NATSController

+ func (c NATSController) AttachLogger(logger Logger)

Mar 3, 2023

Changes in this version

+ var ErrContextCanceled = fmt.Errorf("%w: context canceled", ErrAsyncAPI)

+ var ErrSubscriptionCanceled = fmt.Errorf("%w: the subscription has been canceled", ErrAsyncAPI)

Feb 20, 2023

Changes in this version

+ var ErrContextCancelled = fmt.Errorf("%w: context cancelled", ErrAsyncAPI)

Feb 15, 2023

Changes in this version

type PingMessage

+ func (msg *PingMessage) SetAsResponseFrom(req MessageWithCorrelationID)

type PongMessage

+ func (msg *PongMessage) SetAsResponseFrom(req MessageWithCorrelationID)

Feb 12, 2023

Changes in this version

+ type MessageWithCorrelationID interface

+ CorrelationID func() string

type PingMessage

+ func (msg PingMessage) CorrelationID() string

type PongMessage

+ func (msg PongMessage) CorrelationID() string

Feb 10, 2023

Changes in this version

+ var ErrAlreadySubscribedChannel = fmt.Errorf("%w: the channel has already been subscribed", ErrAsyncAPI)

+ var ErrNilAppSubscriber = fmt.Errorf("%w: nil app subscriber has been used", ErrAsyncAPI)

+ var ErrNilBrokerController = fmt.Errorf("%w: nil broker controller has been used", ErrAsyncAPI)

+ var ErrNilClientSubscriber = fmt.Errorf("%w: nil client subscriber has been used", ErrAsyncAPI)

type ClientController

+ func (cc ClientController) Errors() <-chan Error

+ type Error struct

+ Channel string

+ Err error

+ func (e *Error) Error() string

Feb 8, 2023

Changes in this version

+ const CorrelationIDField

+ var ErrAsyncAPI = errors.New("error when using AsyncAPI")

+ var ErrTimedOut = fmt.Errorf("%w: time out", ErrAsyncAPI)

+ type Book struct

+ Title string

+ type BrokerController interface

+ Publish func(channel string, mw UniversalMessage) error

+ Subscribe func(channel string) (msgs chan UniversalMessage, stop chan interface{}, err error)

+ type ClientController struct

+ func NewClientController(bs BrokerController) *ClientController

+ func (cc *ClientController) Close()

+ func (cc *ClientController) Listen(irq chan interface{})

+ func (cc *ClientController) PublishPing(msg PingMessage) error

+ func (cc *ClientController) SubscribeAll(cs ClientSubscriber) error

+ func (cc *ClientController) SubscribePong(fn func(msg PongMessage)) error

+ func (cc *ClientController) UnsubscribeAll()

+ func (cc *ClientController) UnsubscribePong()

+ func (cc *ClientController) WaitForPong(correlationID string, pub func() error, timeout time.Duration) (PongMessage, error)

+ type ClientSubscriber interface

+ Pong func(msg PongMessage)

+ type NATSController struct

+ func NewNATSController(connection *nats.Conn) *NATSController

+ func (c *NATSController) Publish(channel string, um UniversalMessage) error

+ func (c *NATSController) Subscribe(channel string) (msgs chan UniversalMessage, stop chan interface{}, err error)

+ type PingMessage struct

+ Headers struct{ ... }

+ Payload string

+ func NewPingMessage() PingMessage

+ type PongMessage struct

+ Headers struct{ ... }

+ Payload string

+ func NewPongMessage() PongMessage

+ type UniversalMessage struct

+ CorrelationID string

+ Payload []byte