rabbit_streams

package

v1.16.0 Latest Latest Go to latest Published: Jan 10, 2023 License: MIT Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/batchcorp/plumber

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type RabbitStreams
- func New(connOpts *opts.ConnectionOptions) (*RabbitStreams, error)

Constants ¶

View Source

const BackendName = "rabbitmq-streams"

Variables ¶

View Source

var (
	ErrEmptyStream     = errors.New("stream cannot be empty")
	ErrEmptyDSN        = errors.New("DSN cannot be empty")
	ErrEmptyStreamSize = errors.New("You must specify --declare-stream-size if you specify" +
		" the --declare-stream option")
)

Functions ¶

This section is empty.

Types ¶

type RabbitStreams ¶

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

func New ¶

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

func (*RabbitStreams) Close ¶

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

func (*RabbitStreams) DisplayError ¶

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

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

func (*RabbitStreams) DisplayMessage ¶

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

func (*RabbitStreams) Name ¶

func (r *RabbitStreams) Name() string

func (*RabbitStreams) Read ¶

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

func (*RabbitStreams) Relay ¶

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

func (*RabbitStreams) Test ¶

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

func (*RabbitStreams) Tunnel ¶ added in v1.4.0

func (r *RabbitStreams) Tunnel(ctx context.Context, tunnelOpts *opts.TunnelOptions, tunnelSvc tunnel.ITunnel, errorCh chan<- *records.ErrorRecord) error

func (*RabbitStreams) Write ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL