cdc_mongo

Documentation

Index

• func NewService(opts *cli.Options) (*mongo.Client, error)
• func Read(opts *cli.Options) error
• func Relay(opts *cli.Options) error
• type CDCMongo
  • func (m *CDCMongo) Read() error
• type Relayer
  • func (r *Relayer) Relay() error

Functions

func NewService

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

func Read

func Read(opts *cli.Options) error

func Relay

func Relay(opts *cli.Options) 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
	DefaultContext context.Context
	// contains filtered or unexported fields
}

func (*Relayer) Relay

func (r *Relayer) Relay() error