nats

Documentation

Index

• type Nats
  • func (d *Nats) Cleanup() error
  • func (d *Nats) ClearWork() error
  • func (d *Nats) GetWork() (io.Reader, error)
  • func (d *Nats) HandleFailure() error
  • func (d *Nats) Init() error
  • func (d *Nats) LoadEnv(prefix string) error
  • func (d *Nats) LoadFlags() error

Types

type Nats

type Nats struct {
	Client        *nats.Conn
	URL           string
	Subject       *string
	QueueGroup    *string
	CredsFile     *string
	JWTFile       *string
	NKeyFile      *string
	Username      *string
	Password      *string
	Token         *string
	EnableTLS     *bool
	TLSInsecure   *bool
	TLSCA         *string
	TLSCert       *string
	TLSKey        *string
	ClearResponse *string
	FailResponse  *string
	Key           *string
}

func (*Nats) Cleanup

func (d *Nats) Cleanup() error

func (*Nats) ClearWork

func (d *Nats) ClearWork() error

func (*Nats) GetWork

func (d *Nats) GetWork() (io.Reader, error)

func (*Nats) HandleFailure

func (d *Nats) HandleFailure() error

func (*Nats) Init

func (d *Nats) Init() error

func (*Nats) LoadEnv

func (d *Nats) LoadEnv(prefix string) error

func (*Nats) LoadFlags

func (d *Nats) LoadFlags() error