nats

Documentation

Index

• type Client
  • func NewNatsClient(natsConfig *Config) Client
• type Config
• type Conn

Types

type Client

type Client interface {
	// initialize NATS connection
	Init() error
	// check if any stream exists in NATS JetStream
	StreamExists() (bool, error)
	// GetStreams returns all the streams in NATS JetStream
	GetStreams() ([]*nats.StreamInfo, error)
	// ConsumersExist checks if any consumer exists for the given stream
	ConsumersExist(streamName string) (bool, error)
	// close NATS connection
	Close()
}

func NewNatsClient

func NewNatsClient(natsConfig *Config) Client

type Config

type Config struct {
	URL     string
	Timeout time.Duration `default:"5s"`
}

type Conn

type Conn interface {
	Status() nats.Status
	JetStream() (nats.JetStreamContext, error)
	IsConnected() bool
	Close()
}