mgo

type ClearOplogOption struct {
	Thread    int64          //线程数量
	Init      bool           //是否初始化
	Oid       Timestamp      //起始id
	Show      any            //展示的字段
	Filter    map[string]any //查询参数
	BatchSize int32          //服务器每批次多少
}

type ClearOption struct {
	Thread         int64          //线程数量
	Init           bool           //是否初始化
	Oid            ObjectID       //起始id
	Show           any            //展示的字段
	Desc           bool           //是否倒序
	Filter         map[string]any //查询参数
	Bar            bool           //是否开启进度条
	BatchSize      int32          //服务器每批次多少
	ClearBatchSize int64          //每次清洗的批次
}

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

type ClientOption struct {
	Host    string
	Port    int
	Usr     string
	Pwd     string
	Direct  bool
	HostMap map[string]string
}

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

type FindOption struct {
	BatchSize       int32          // 服务器返回的每个批次中包含的最大文件数。
	Limit           int64          //要返回的最大文档数
	Timeout         time.Duration  //超时时间
	NoCursorTimeout bool           //操作所创建的游标在一段时间不活动后不会超时
	Show            any            //描述哪些字段将被包含在操作返回的文件中的文件
	Skip            int64          //在将文档添加到结果中之前要跳过的文档数量
	Sort            map[string]int // 一个文件，指定返回文件的顺序
	Await           bool           //oplog 是否阻塞等待数据
}

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

type ObjectID = primitive.ObjectID

type Oplog struct {
	Op        string    //操作
	Ns        string    //表名
	Timestamp Timestamp //操作时间
	ObjectID  ObjectID
	Data      map[string]any //数据
}

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

type Timestamp = primitive.Timestamp //{T uint32   I uint32}

type UpateResult struct {
	MatchedCount  int64 // 匹配的个数
	ModifiedCount int64 // 文档变更的数量,不包括增加
	UpsertedCount int64 // upsert的数量
	UpsertedID    primitive.ObjectID
	Exists        bool //是否存在
}