Documentation
¶
Index ¶
- Constants
- Variables
- type RedisPubsub
- func (r *RedisPubsub) Close(_ context.Context) error
- func (r *RedisPubsub) DisplayError(msg *records.ErrorRecord) error
- func (r *RedisPubsub) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error
- func (r *RedisPubsub) Name() string
- func (r *RedisPubsub) Read(ctx context.Context, readOpts *opts.ReadOptions, ...) error
- func (r *RedisPubsub) Relay(ctx context.Context, relayOpts *opts.RelayOptions, relayCh chan interface{}, ...) error
- func (r *RedisPubsub) Test(_ context.Context) error
- func (r *RedisPubsub) Tunnel(ctx context.Context, tunnelOpts *opts.TunnelOptions, tunnelSvc tunnel.ITunnel, ...) error
- func (r *RedisPubsub) Write(ctx context.Context, writeOpts *opts.WriteOptions, ...) error
Constants ¶
View Source
const BackendName = "redis-pubsub"
View Source
const (
RetryReadInterval = 5 * time.Second
)
Variables ¶
View Source
var ( ErrMissingChannel = errors.New("you must specify at least one channel") ErrMissingPassword = errors.New("missing password (either use only password or fill out both)") )
Functions ¶
This section is empty.
Types ¶
type RedisPubsub ¶ added in v1.0.0
type RedisPubsub struct {
// contains filtered or unexported fields
}
func New ¶ added in v1.0.0
func New(connOpts *opts.ConnectionOptions) (*RedisPubsub, error)
func (*RedisPubsub) DisplayError ¶ added in v1.0.0
func (r *RedisPubsub) DisplayError(msg *records.ErrorRecord) error
DisplayError will parse an Error record and print (pretty) output to STDOUT
func (*RedisPubsub) DisplayMessage ¶ added in v1.0.0
func (r *RedisPubsub) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error
DisplayMessage will parse a Read record and print (pretty) output to STDOUT
func (*RedisPubsub) Name ¶ added in v1.0.0
func (r *RedisPubsub) Name() string
func (*RedisPubsub) Read ¶ added in v1.0.0
func (r *RedisPubsub) Read(ctx context.Context, readOpts *opts.ReadOptions, resultsChan chan *records.ReadRecord, errorChan chan *records.ErrorRecord) error
func (*RedisPubsub) Relay ¶ added in v1.0.0
func (r *RedisPubsub) Relay(ctx context.Context, relayOpts *opts.RelayOptions, relayCh chan interface{}, errorCh chan<- *records.ErrorRecord) error
func (*RedisPubsub) Tunnel ¶ added in v1.4.0
func (r *RedisPubsub) Tunnel(ctx context.Context, tunnelOpts *opts.TunnelOptions, tunnelSvc tunnel.ITunnel, errorCh chan<- *records.ErrorRecord) error
func (*RedisPubsub) Write ¶ added in v1.0.0
func (r *RedisPubsub) Write(ctx context.Context, writeOpts *opts.WriteOptions, errorCh chan<- *records.ErrorRecord, messages ...*records.WriteRecord) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.