model

type ChangeEvent struct {
	ID                bson.Raw  `bson:"_id" json:"_id"`
	OperationType     string    `bson:"operationType" json:"operationType"`
	FullDocument      bson.Raw  `bson:"fullDocument,omitempty" json:"fullDocument,omitempty"`
	Namespace         Namespace `bson:"ns" json:"ns"`
	To                Namespace `bson:"to,omitempty" json:"to,omitempty"`
	DocumentKey       bson.Raw  `bson:"documentKey,omitempty" json:"documentKey,omitempty"`
	UpdateDescription struct {
		UpdatedFields bson.M   `bson:"updatedFields,omitempty" json:"updatedFields,omitempty"`
		RemovedFields []string `bson:"removedFields,omitempty" json:"removedFields,omitempty"`
	} `bson:"updateDescription,omitempty" json:"updateDescription,omitempty"`
	ClusterTime       primitive.Timestamp `bson:"clusterTime" json:"clusterTime"`
	TransactionNumber int64               `bson:"txnNumber,omitempty" json:"txnNumber,omitempty"`
	SessionIdentifier bson.Raw            `bson:"lsid,omitempty" json:"lsid,omitempty"`
}

type Namespace struct {
	Database   string `bson:"db,omitempty" json:"db,omitempty"`
	Collection string `bson:"coll,omitempty" json:"coll,omitempty"`
}

type OpLog struct {
	OpTime        primitive.Timestamp `bson:"ts" json:"ts"`
	Hash          int64               `bson:"h" json:"h"`
	Version       int                 `bson:"v" json:"v"`
	OperationType string              `bson:"op" json:"op"`
	Namespace     string              `bson:"ns" json:"ns"`
	WallClockTime time.Time           `bson:"wall" json:"wall"`
	Operation     bson.Raw            `bson:"o" json:"o"`
	Update        bson.Raw            `bson:"o2,omitempty" json:"o2,omitempty"`
}