cdcmongo

Documentation

Index

• Constants
• Variables
• type Mongo
  • func New(connOpts *opts.ConnectionOptions) (*Mongo, error)
  • func (m *Mongo) Close(ctx context.Context) error
  • func (m *Mongo) DisplayError(msg *records.ErrorRecord) error
  • func (m *Mongo) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error
  • func (m *Mongo) Name() string
  • func (m *Mongo) Read(ctx context.Context, readOpts *opts.ReadOptions, ...) error
  • func (m *Mongo) Relay(ctx context.Context, relayOpts *opts.RelayOptions, relayCh chan interface{}, ...) error
  • func (m *Mongo) Test(_ context.Context) error
  • func (m *Mongo) Tunnel(ctx context.Context, opts *opts.TunnelOptions, tunnelSvc tunnel.ITunnel, ...) error
  • func (m *Mongo) Write(ctx context.Context, writeOpts *opts.WriteOptions, ...) error

Constants

const (
	// ConnectionTimeout determines how long before a connection attempt to mongo is timed out
	ConnectionTimeout = time.Second * 10

	// ReadRetryInterval is how long to wait between read errors before plumber tries reading again
	ReadRetryInterval = time.Second * 5
)

const BackendName = "cdc-mongo"

Variables

var (
	ErrMissingDatabase  = errors.New("you must specify the --database flag")
	ErrConnectionFailed = errors.New("could not open mongo connection")
)

Types

type Mongo

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

func New

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

func (*Mongo) Close

func (m *Mongo) Close(ctx context.Context) error

func (*Mongo) DisplayError

func (m *Mongo) DisplayError(msg *records.ErrorRecord) error

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

func (*Mongo) DisplayMessage

func (m *Mongo) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error

func (*Mongo) Name

func (m *Mongo) Name() string

func (*Mongo) Read

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

func (*Mongo) Relay

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

func (*Mongo) Test

func (m *Mongo) Test(_ context.Context) error

func (*Mongo) Tunnel

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

func (*Mongo) Write

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