nats

Documentation

Index

• Constants
• func NewSubscriber(opts *subscribe.NewSubscriberOptions) (subscribe.Subscriber, error)
• type Config
• type Subscriber
  • func (s *Subscriber) Connect(ctx context.Context) error
  • func (s *Subscriber) Disconnect(ctx context.Context) error
  • func (s *Subscriber) Subscribe(ctx context.Context) error
  • func (s *Subscriber) Unsubscribe(ctx context.Context) error

Constants

const (
	ProviderName = "nats"
)

Functions

func NewSubscriber

func NewSubscriber(opts *subscribe.NewSubscriberOptions) (subscribe.Subscriber, error)

NewSubscriber create a new subscriber

Types

type Config

type Config struct {
	Servers      []string `yaml:"servers" json:"servers"`
	MaxReconnect int      `yaml:"max_reconnect" json:"max_reconnect"`
}

Config provides configuration information to nats client

type Subscriber

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

Subscriber implements the subscriber interface for nats

func (*Subscriber) Connect

func (s *Subscriber) Connect(ctx context.Context) error

Connect connects to nats server

func (*Subscriber) Disconnect

func (s *Subscriber) Disconnect(ctx context.Context) error

Disconnect disconnects from nats server

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe(ctx context.Context) error

Subscribe subscribes to bundle updates

func (*Subscriber) Unsubscribe

func (s *Subscriber) Unsubscribe(ctx context.Context) error

Unsubscribe unsubscribes from bundle updates