mongodb

Documentation

Index

• type ChangeEvent
• type ErrorEvent
• type MongoDriver
  • func (d *MongoDriver) Init(config []byte)
  • func (d *MongoDriver) Read(ctx context.Context, eventCh chan ChangeEvent) error
• type MongoOptions

Types

type ChangeEvent

type ChangeEvent struct {
	ID            changeID            `bson:"_id"`
	OperationType string              `bson:"operationType"`
	ClusterTime   primitive.Timestamp `bson:"clusterTime"`
	FullDocument  bson.D              `bson:"fullDocument"`
	DocumentKey   documentKey         `bson:"documentKey"`
	Ns            namespace           `bson:"ns"`
}

type ErrorEvent

type ErrorEvent struct {
	Event ChangeEvent
	Err   error
}

type MongoDriver

type MongoDriver struct {
	Config *MongoOptions
	Driver *mongo.Client
}

func (*MongoDriver) Init

func (d *MongoDriver) Init(config []byte)

func (*MongoDriver) Read

func (d *MongoDriver) Read(ctx context.Context, eventCh chan ChangeEvent) error

type MongoOptions

type MongoOptions struct {
	MongoURI string `yaml:"URI"`
	Database string `yaml:"database"`
}