nsq

Feb 15, 2022

Changes in this version

type NSQ

+ func (n *NSQ) Tunnel(ctx context.Context, tunnelOpts *opts.TunnelOptions, tunnelSvc tunnel.ITunnel, ...) error

Dec 6, 2021

Changes in this version

+ const BackendName

+ var ErrMissingTopic = errors.New("--topic cannot be empty")

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(msg *records.ReadRecord) error

+ func (n *NSQ) Dynamic(ctx context.Context, dynamicOpts *opts.DynamicOptions, ...) error

+ func (n *NSQ) Name() string

+ func (n *NSQ) Relay(ctx context.Context, relayOpts *opts.RelayOptions, relayCh chan interface{}, ...) error

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

Jul 8, 2021

Changes in this version

type NSQ

+ Producer *nsq.Producer

Jun 24, 2021

Changes in this version

type Relayer

+ ShutdownCtx context.Context

Jun 21, 2021

Changes in this version

+ var ErrChooseAddress = errors.New("you must specify either --nsqd-address or --lookupd-address, not both")

+ var ErrMissingAddress = errors.New("you must specify either --nsqd-address or --lookupd-address")

+ var ErrMissingTLSCA = errors.New("--tls-ca-file cannot be blank if using TLS")

+ var ErrMissingTLSKey = errors.New("--tls-client-key-file cannot be blank if using TLS")

+ var ErrMissingTlsCert = errors.New("--tls-client-cert-file cannot be blank if using TLS")

+ func Read(opts *cli.Options) error

+ func Relay(opts *cli.Options) error

+ func Write(opts *cli.Options) error

+ type NSQ struct

+ MsgDesc *desc.MessageDescriptor

+ Options *cli.Options

+ func (n *NSQ) Read() error

+ func (n *NSQ) Write(value []byte) error

+ type NSQLogger struct

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

+ type Relayer struct

+ DefaultContext context.Context

+ Looper *director.FreeLooper

+ MsgDesc *desc.MessageDescriptor

+ Options *cli.Options

+ RelayCh chan interface{}

+ func (r *Relayer) Relay() error