nats

Documentation

Index

• func DeleteConsumer(ctx context.Context, jc *nats.JetstreamClient, consumer *JetstreamConsumer) error
• type ConsumerConfig
• type JetstreamConsumer
  • func NewJetstreamConsumer(ctx context.Context, jc *nats.JetstreamClient, args JetstreamConsumerArgs) (*JetstreamConsumer, error)
  • func (jc *JetstreamConsumer) Consume(consumeFn func(msg *types.ConsumeMsg) error, opts types.ConsumeOpts) error
  • func (nc *JetstreamConsumer) Stop(context.Context) error
• type JetstreamConsumerArgs
• type JetstreamProducer
  • func NewJetstreamProducer(jc *nats.JetstreamClient) *JetstreamProducer
  • func (c *JetstreamProducer) Produce(ctx context.Context, msg types.ProduceMsg) error
  • func (c *JetstreamProducer) ProduceAsync(ctx context.Context, msg types.ProduceMsg) error
  • func (c *JetstreamProducer) Stop(ctx context.Context) error

Functions

func DeleteConsumer

func DeleteConsumer(ctx context.Context, jc *nats.JetstreamClient, consumer *JetstreamConsumer) error

Types

type ConsumerConfig

type ConsumerConfig jetstream.ConsumerConfig

type JetstreamConsumer

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

func NewJetstreamConsumer

func NewJetstreamConsumer(ctx context.Context, jc *nats.JetstreamClient, args JetstreamConsumerArgs) (*JetstreamConsumer, error)

func (*JetstreamConsumer) Consume

func (jc *JetstreamConsumer) Consume(consumeFn func(msg *types.ConsumeMsg) error, opts types.ConsumeOpts) error

Consume implements messaging.Consumer.

func (*JetstreamConsumer) Stop

func (nc *JetstreamConsumer) Stop(context.Context) error

Stop implements Consumer.

type JetstreamConsumerArgs

type JetstreamConsumerArgs struct {
	Stream         string
	ConsumerConfig ConsumerConfig
}

type JetstreamProducer

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

func NewJetstreamProducer

func NewJetstreamProducer(jc *nats.JetstreamClient) *JetstreamProducer

func (*JetstreamProducer) Produce

func (c *JetstreamProducer) Produce(ctx context.Context, msg types.ProduceMsg) error

Produce implements messaging.Producer.

func (*JetstreamProducer) ProduceAsync

func (c *JetstreamProducer) ProduceAsync(ctx context.Context, msg types.ProduceMsg) error

ProduceAsync implements messaging.Producer.

func (*JetstreamProducer) Stop

func (c *JetstreamProducer) Stop(ctx context.Context) error

Stop implements messaging.Producer.