Documentation
¶
Index ¶
- Constants
- Variables
- type Mongo
- 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) Dynamic(ctx context.Context, opts *opts.DynamicOptions, dynamicSvc dynamic.IDynamic, ...) 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) Write(ctx context.Context, writeOpts *opts.WriteOptions, ...) error
Constants ¶
View Source
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 )
View Source
const BackendName = "cdc-mongo"
Variables ¶
View Source
var ( ErrMissingDatabase = errors.New("you must specify the --database flag") ErrConnectionFailed = errors.New("could not open mongo connection") )
Functions ¶
This section is empty.
Types ¶
type Mongo ¶
type Mongo struct {
// contains filtered or unexported fields
}
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) Dynamic ¶
func (m *Mongo) Dynamic(ctx context.Context, opts *opts.DynamicOptions, dynamicSvc dynamic.IDynamic, errorCh chan<- *records.ErrorRecord) error
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) Write ¶
func (m *Mongo) 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.