builder

type BuildInfo struct {
	TotalNumber     int64            `json:"total_num"`
	ErrorNumber     int64            `json:"error_num"`
	AddNum          int64            `json:"add_num,"`
	DeleteNum       int64            `json:"delete_num,"`
	MergeTime       time.Duration    `json:"merge_time,"`
	LastBaseUpdated time.Time        `json:"last_base_updated,omitempty"`
	LastIncUpdated  time.Time        `json:"last_inc_updated,omitempty"`
	IndexInfo       *index.IndexInfo `json:"index_info,omitempty"`
}

type Builder interface {
	Build(ctx context.Context) error
	GetIndex() index.Index
	GetBuilderInfo() *BuildInfo
}

type DataMod int

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

type MongoIndexManagerOps struct {
	Name           string
	IncInterval    int
	BaseInterval   int
	URI            string
	DB             string
	Collection     string
	ConnectTimeout int
	ReadTimeout    int
	BaseParser     MongoParser
	IncParser      MongoParser
	BaseQuery      interface{}
	IncQuery       interface{}
	UserData       interface{}
	FindOpt        *options.FindOptions
	Logger         log.Logger
	OnBeforeBase   func(interface{}) interface{}
	OnBeforeInc    func(interface{}) interface{}
	OnFinishBase   func(interface{})
	OnFinishInc    func(interface{})
}

type MongoParser interface {
	Parse([]byte, interface{}) *ParserResult
}

type ParserResult struct {
	DataMod DataMod
	Value   *document.DocInfo
}