nats

Documentation

Overview

Package nats provides a NATS adapter for Kiara.

Index

• Variables
• type Adapter
  • func NewAdapter(conn *nats.Conn, options ...Option) *Adapter
  • func (a *Adapter) Start(pipe *types.Pipe)
  • func (a *Adapter) Stop()
  • func (a *Adapter) Subscribe(topic string) error
  • func (a *Adapter) Unsubscribe(topic string) error
• type Option
  • func FlushInterval(interval time.Duration) Option

Variables

var (
	// This error is reported via Adapter.Errors() when the adapter can't deliver
	// succeeding messages arrived from NATS because Adapter.Delivered() is already full.
	ErrSlowConsumer = errors.New("slow consumer")

	// This error is returned by Adapter.Subscribe() when the topic is already subscribed.
	ErrAlreadySubscribed = errors.New("already subscribed")
)

Types

type Adapter

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

Adapter is an adapter that sends messages through NATS.

func NewAdapter

func NewAdapter(conn *nats.Conn, options ...Option) *Adapter

NewAdapter creates a new Adapter.

func (*Adapter) Start

func (a *Adapter) Start(pipe *types.Pipe)

func (*Adapter) Stop

func (a *Adapter) Stop()

func (*Adapter) Subscribe

func (a *Adapter) Subscribe(topic string) error

func (*Adapter) Unsubscribe

func (a *Adapter) Unsubscribe(topic string) error

type Option

type Option interface {
	// contains filtered or unexported methods
}

Option configures the Adapter.

func FlushInterval

func FlushInterval(interval time.Duration) Option

FlushInterval sets the interval for flushing.