provider

Documentation

Index

• Variables
• func OptionArgs(args *NatsOptions)
• type Nats
  • func NewNats(ctx context.Context, options NatsOptions) *Nats
  • func (n *Nats) NC() messaging.NC
  • func (n *Nats) Publish(ctx context.Context, subject string, message *messaging.Message) error
  • func (n *Nats) Request(ctx context.Context, subject string, message *messaging.Message) (*messaging.Message, error)
  • func (n *Nats) RequestWithTimeout(ctx context.Context, subject string, message *messaging.Message, ...) (*messaging.Message, error)
  • func (n *Nats) Subscribe(ctx context.Context, subject string, handle messaging.MessageHandler)
  • func (n *Nats) SubscribeWorkers(ctx context.Context, subject string, workerCount int, ...)
• type NatsOptions
  • func DefaultOptions() NatsOptions

Variables

var (
	ErrInvalidSubject = errors.New("Invalid Subject")
	ErrInvalidHandler = errors.New("Invalid Handler")

	ErrRequest  = errors.New("Request error")
	ErrEncoding = errors.New("Encoding error")
	ErrDecoding = errors.New("Decoding error")
)

Functions

func OptionArgs

func OptionArgs(args *NatsOptions)

Types

type Nats

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

func NewNats

func NewNats(ctx context.Context, options NatsOptions) *Nats

NewNats returns Nats messaging. panic on connection error

func (*Nats) NC

func (n *Nats) NC() messaging.NC

func (*Nats) Publish

func (n *Nats) Publish(ctx context.Context, subject string, message *messaging.Message) error

Publish perform nats Publish with subject and message. panic if subject or message are invalid

func (*Nats) Request

func (n *Nats) Request(ctx context.Context, subject string, message *messaging.Message) (*messaging.Message, error)

Request perform nats Request with subject and message. use default timout panic if subject or message are invalid

func (*Nats) RequestWithTimeout

func (n *Nats) RequestWithTimeout(ctx context.Context, subject string, message *messaging.Message, timeout time.Duration) (*messaging.Message, error)

RequestWithTimeout perform nats Request with subject and message. panic if subject or message are invalid

func (*Nats) Subscribe

func (n *Nats) Subscribe(ctx context.Context, subject string, handle messaging.MessageHandler)

Subscribe

func (*Nats) SubscribeWorkers

func (n *Nats) SubscribeWorkers(ctx context.Context, subject string, workerCount int, handle messaging.MessageHandler)

SubscribeWorkers

type NatsOptions

type NatsOptions struct {
	Protocol string
	HostName string
	Port     int
}

func DefaultOptions

func DefaultOptions() NatsOptions