nats

Documentation

Index

• type Config
  • func (c Config) String() string
• type Option
  • func WithTLS(cfg *tls.Config) Option
• type Publisher
  • func NewPublisher(config Config, opts ...Option) (*Publisher, error)
  • func (p *Publisher) Close()
• type Subscriber
  • func NewSubscriber(config Config, goroutinePoolGo cqrsEventBus.GoroutinePoolGoFunc, ...) (*Subscriber, error)
  • func (p *Subscriber) Close()

Types

type Config

type Config struct {
	URL     string `envconfig:"URL" default:"nats://localhost:4222"`
	Options []nats.Option
}

func (Config) String

func (c Config) String() string

String returns string representation of Config.

type Option

type Option func(Config) Config

Option provides the means to use function call chaining

func WithTLS

func WithTLS(cfg *tls.Config) Option

WithTLS configures connection to use TLS

type Publisher

type Publisher struct {
	*cqrsNats.Publisher
}

func NewPublisher

func NewPublisher(config Config, opts ...Option) (*Publisher, error)

NewPublisher creates new publisher with proto marshaller.

func (*Publisher) Close

func (p *Publisher) Close()

Close closes the publisher.

type Subscriber

type Subscriber struct {
	*cqrsNats.Subscriber
}

func NewSubscriber

func NewSubscriber(config Config, goroutinePoolGo cqrsEventBus.GoroutinePoolGoFunc, errFunc cqrsEventBus.ErrFunc, opts ...Option) (*Subscriber, error)

NewSubscriber create new subscriber with proto unmarshaller.

func (*Subscriber) Close

func (p *Subscriber) Close()

Close closes the publisher.