nats

Documentation

Index

• type Broker
  • func NewNatsBroker(cfg config.Nats, logger logger.Logger) (*Broker, error)
  • func (b *Broker) Publish(_ context.Context, topic string, message []byte) error
  • func (b *Broker) SubscribeQueue(ctx context.Context, topic, group string, ...) error

Types

type Broker

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

func NewNatsBroker

func NewNatsBroker(cfg config.Nats, logger logger.Logger) (*Broker, error)

func (*Broker) Publish

func (b *Broker) Publish(_ context.Context, topic string, message []byte) error

func (*Broker) SubscribeQueue

func (b *Broker) SubscribeQueue(
	ctx context.Context,
	topic,
	group string,
	handle func(ctx context.Context, message []byte) error,
) error