rpubsub

package
v1.10.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 22, 2022 License: MIT Imports: 19 Imported by: 0

Documentation

Index

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) Close added in v1.0.0 

func (r *RedisPubsub) Close(_ context.Context) 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) Test added in v1.0.0 

func (r *RedisPubsub) Test(_ context.Context) 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

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.