nats_streaming

Documentation

Index

• Constants
• Variables
• type NatsStreaming
  • func New(connOpts *opts.ConnectionOptions) (*NatsStreaming, error)
  • func (n *NatsStreaming) Close(_ context.Context) error
  • func (n *NatsStreaming) DisplayError(msg *records.ErrorRecord) error
  • func (n *NatsStreaming) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error
  • func (n *NatsStreaming) Dynamic(ctx context.Context, dynamicOpts *opts.DynamicOptions, ...) error
  • func (n *NatsStreaming) Name() string
  • func (n *NatsStreaming) Read(ctx context.Context, readOpts *opts.ReadOptions, ...) error
  • func (n *NatsStreaming) Relay(ctx context.Context, relayOpts *opts.RelayOptions, relayCh chan interface{}, ...) error
  • func (n *NatsStreaming) Test(_ context.Context) error
  • func (n *NatsStreaming) Write(ctx context.Context, writeOpts *opts.WriteOptions, ...) error

Constants

const BackendName = "nats-streaming"

Variables

var (
	ErrMissingTLSKey     = errors.New("--tls-client-key-file cannot be blank if using ssl")
	ErrMissingTlsCert    = errors.New("--tls-client-cert-file cannot be blank if using ssl")
	ErrMissingTLSCA      = errors.New("--tls-ca-file cannot be blank if using ssl")
	ErrEmptyChannel      = errors.New("channel cannot be empty")
	ErrInvalidReadOption = errors.New("You may only specify one read option of --last, --all, --seq, --since")
)

Types

type NatsStreaming

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

func New

func New(connOpts *opts.ConnectionOptions) (*NatsStreaming, error)

func (*NatsStreaming) Close

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

func (*NatsStreaming) DisplayError

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

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

func (*NatsStreaming) DisplayMessage

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

DisplayMessage will parse a Read record and print (pretty) output to STDOUT

func (*NatsStreaming) Dynamic

func (n *NatsStreaming) Dynamic(ctx context.Context, dynamicOpts *opts.DynamicOptions, dynamicSvc dynamic.IDynamic) error

func (*NatsStreaming) Name

func (n *NatsStreaming) Name() string

func (*NatsStreaming) Read

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

func (*NatsStreaming) Relay

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

func (*NatsStreaming) Test

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

func (*NatsStreaming) Write

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