cdcmongo

Feb 15, 2022

Changes in this version

type Mongo

+ func (m *Mongo) Tunnel(ctx context.Context, opts *opts.TunnelOptions, tunnelSvc tunnel.ITunnel, ...) error

Dec 6, 2021

Changes in this version

+ const BackendName

+ const ConnectionTimeout

+ const ReadRetryInterval

+ var ErrConnectionFailed = errors.New("could not open mongo connection")

+ var ErrMissingDatabase = errors.New("you must specify the --database flag")

+ type Mongo struct

+ 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(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