gcppubsub

package
v1.7.1 Latest Latest
Warning

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

Go to latest
Published: May 20, 2022 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const BackendName = "gcp-pubsub"
View Source
const RetryReadInterval = 5 * time.Second

Variables

This section is empty.

Functions

This section is empty.

Types

type GCPPubSub

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

func New

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

func (*GCPPubSub) Close

func (g *GCPPubSub) Close(_ context.Context) error

func (*GCPPubSub) DisplayError

func (g *GCPPubSub) DisplayError(msg *records.ErrorRecord) error

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

func (*GCPPubSub) DisplayMessage

func (g *GCPPubSub) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error

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

func (*GCPPubSub) Name

func (g *GCPPubSub) Name() string

func (*GCPPubSub) Read

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

func (*GCPPubSub) Relay

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

func (*GCPPubSub) Test

func (g *GCPPubSub) Test(_ context.Context) error

func (*GCPPubSub) Tunnel added in v1.4.0

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

func (*GCPPubSub) Write

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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