nsq

Documentation

Index

• Constants
• Variables
• type NSQ
  • func New(opts *opts.ConnectionOptions) (*NSQ, error)
  • func (n *NSQ) Close(_ context.Context) error
  • func (n *NSQ) DisplayError(msg *records.ErrorRecord) error
  • func (n *NSQ) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error
  • func (n *NSQ) Name() string
  • func (n *NSQ) Read(ctx context.Context, readOpts *opts.ReadOptions, ...) error
  • func (n *NSQ) Relay(ctx context.Context, relayOpts *opts.RelayOptions, relayCh chan interface{}, ...) error
  • func (n *NSQ) Test(_ context.Context) error
  • func (n *NSQ) Tunnel(ctx context.Context, tunnelOpts *opts.TunnelOptions, tunnelSvc tunnel.ITunnel, ...) error
  • func (n *NSQ) Write(ctx context.Context, writeOpts *opts.WriteOptions, ...) error
• type NSQLogger
  • func (n *NSQLogger) Output(_ int, s string) error

Constants

const BackendName = "NSQ"

Variables

var (
	ErrMissingAddress = errors.New("you must specify either --nsqd-address or --lookupd-address")
	ErrChooseAddress  = errors.New("you must specify either --nsqd-address or --lookupd-address, not both")
	ErrMissingTLSKey  = errors.New("--tls-client-key-file cannot be blank if using TLS")
	ErrMissingTlsCert = errors.New("--tls-client-cert-file cannot be blank if using TLS")
	ErrMissingTLSCA   = errors.New("--tls-ca-file cannot be blank if using TLS")
	ErrMissingTopic   = errors.New("--topic cannot be empty")
)

Types

type NSQ

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

func New

func New(opts *opts.ConnectionOptions) (*NSQ, error)

func (*NSQ) Close

func (n *NSQ) Close(_ context.Context) error

func (*NSQ) DisplayError

func (n *NSQ) DisplayError(msg *records.ErrorRecord) error

DisplayError will parse an Error record and print (pretty) output to STDOUT

func (*NSQ) DisplayMessage

func (n *NSQ) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error

func (*NSQ) Name

func (n *NSQ) Name() string

func (*NSQ) Read

func (n *NSQ) Read(ctx context.Context, readOpts *opts.ReadOptions, resultsChan chan *records.ReadRecord, errorChan chan *records.ErrorRecord) error

func (*NSQ) Relay

func (n *NSQ) Relay(ctx context.Context, relayOpts *opts.RelayOptions, relayCh chan interface{}, errorCh chan<- *records.ErrorRecord) error

func (*NSQ) Test

func (n *NSQ) Test(_ context.Context) error

func (*NSQ) Tunnel

func (n *NSQ) Tunnel(ctx context.Context, tunnelOpts *opts.TunnelOptions, tunnelSvc tunnel.ITunnel, errorCh chan<- *records.ErrorRecord) error

func (*NSQ) Write

func (n *NSQ) Write(ctx context.Context, writeOpts *opts.WriteOptions, errorCh chan<- *records.ErrorRecord, messages ...*records.WriteRecord) error

type NSQLogger

type NSQLogger struct {
	*logrus.Entry
}

NSQLogger wraps logrus and implements the Output() method so we can satisfy the interface requirements for NSQ's logger

func (*NSQLogger) Output

func (n *NSQLogger) Output(_ int, s string) error

Output writes an NSQ log message via logrus