source

type ChangeEvent struct {
	ID            token.Data             `bson:"_id" json:"_id"`
	FullDocument  map[string]interface{} `bson:"fullDocument" json:"fullDocument"`
	OperationType string                 `bson:"operationType" json:"operationType"`
	DocumentKey   struct {
		Id primitive.ObjectID `bson:"_id" json:"_id"`
	} `bson:"documentKey" json:"documentKey"`
	Ns struct {
		Coll string `bson:"coll" json:"coll"`
		Db   string `bson:"db" json:"db"`
	} `bson:"ns" json:"ns"`
}

type Params struct {
	DbName  string
	ColName string
	Time    string
	Token   token.Data
}

type Source struct {
	// contains filtered or unexported fields
}