nats

Documentation

Index

• type AcknowledgementHandler
  • func (k AcknowledgementHandler) AckMessage()
  • func (k AcknowledgementHandler) NakMessage()
• type Controller
  • func NewController(url string, options ...ControllerOption) (*Controller, error)
  • func (c *Controller) Close()
  • func (c *Controller) Publish(_ context.Context, channel string, bm extensions.BrokerMessage) error
  • func (c *Controller) Subscribe(ctx context.Context, channel string) (extensions.BrokerChannelSubscription, error)
• type ControllerOption
  • func WithLogger(logger extensions.Logger) ControllerOption
  • func WithNakDelay(duration time.Duration) ControllerOption
  • func WithQueueGroup(name string) ControllerOption

Types

type AcknowledgementHandler

type AcknowledgementHandler struct {
	// contains filtered or unexported fields
}

AcknowledgementHandler for nats broker.

func (AcknowledgementHandler) AckMessage

func (k AcknowledgementHandler) AckMessage()

AckMessage acknowledges the message.

func (AcknowledgementHandler) NakMessage

func (k AcknowledgementHandler) NakMessage()

NakMessage negatively acknowledges the message.

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

Controller is the Controller implementation for asyncapi-codegen.

func NewController

func NewController(url string, options ...ControllerOption) (*Controller, error)

NewController creates a new NATS controller.

func (*Controller) Close

func (c *Controller) Close()

Close closes everything related to the broker.

func (*Controller) Publish

func (c *Controller) Publish(_ context.Context, channel string, bm extensions.BrokerMessage) error

Publish a message to the broker.

func (*Controller) Subscribe

func (c *Controller) Subscribe(ctx context.Context, channel string) (extensions.BrokerChannelSubscription, error)

Subscribe to messages from the broker.

type ControllerOption

type ControllerOption func(controller *Controller)

ControllerOption is a function that can be used to configure a NATS controller Examples: WithQueueGroup(), WithLogger().

func WithLogger

func WithLogger(logger extensions.Logger) ControllerOption

WithLogger set a custom logger that will log operations on broker controller.

func WithNakDelay

func WithNakDelay(duration time.Duration) ControllerOption

WithNakDelay set the delay when redeliver messages via nak.

func WithQueueGroup

func WithQueueGroup(name string) ControllerOption

WithQueueGroup set a custom queue group for channel subscription.