cdc_mongo

Documentation

Index

• Constants
• Variables
• func NewService(opts *cli.Options) (*mongo.Client, error)
• func Read(opts *cli.Options, _ *desc.MessageDescriptor) error
• func Relay(opts *cli.Options, relayCh chan interface{}, shutdownCtx context.Context) (relay.IRelayBackend, error)
• type CDCMongo
  • func (m *CDCMongo) Read() error
• type Relayer
  • func (r *Relayer) Relay() 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
)

Variables

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

Functions

func NewService

func NewService(opts *cli.Options) (*mongo.Client, error)

func Read

func Read(opts *cli.Options, _ *desc.MessageDescriptor) error

func Relay

func Relay(opts *cli.Options, relayCh chan interface{}, shutdownCtx context.Context) (relay.IRelayBackend, error)

Types

type CDCMongo

type CDCMongo struct {
	Id      string
	Service *mongo.Client
	Context context.Context
	Options *cli.Options
	// contains filtered or unexported fields
}

func (*CDCMongo) Read

func (m *CDCMongo) Read() error

Read attempts to read a change stream from mongo

type Relayer

type Relayer struct {
	Options *cli.Options
	RelayCh chan interface{}

	Service     *mongo.Client
	ShutdownCtx context.Context
	// contains filtered or unexported fields
}

func (*Relayer) Relay

func (r *Relayer) Relay() error