rstreams

Documentation

Index

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

Constants

const BackendName = "redis-streams"

const RetryReadInterval = 5 * time.Second

RetryReadInterval determines how long to wait before retrying a read, after an error has occurred

Variables

var (
	ErrMissingStream   = errors.New("you must specify at least one stream")
	ErrMissingPassword = errors.New("missing password (either use only password or fill out both)")
)

Types

type RedisStreams

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

func New

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

func (*RedisStreams) Close

func (r *RedisStreams) Close(_ context.Context) error

func (*RedisStreams) DisplayError

func (r *RedisStreams) DisplayError(msg *records.ErrorRecord) error

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

func (*RedisStreams) DisplayMessage

func (r *RedisStreams) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error

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

func (*RedisStreams) Dynamic

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

func (*RedisStreams) Name

func (r *RedisStreams) Name() string

func (*RedisStreams) Read

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

func (*RedisStreams) Relay

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

func (*RedisStreams) Test

func (r *RedisStreams) Test(_ context.Context) error

func (*RedisStreams) Write

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