index_diff

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

type CompareItem struct {
	Doc  interface{} `json:"doc,omitempty"`
	Key  string      `json:"key,omitempty"`
	Hash string      `json:"hash,omitempty"`
}

type Config struct {
	PartitionSize      int  `config:"partition_size"`
	TextReportEnabled  bool `config:"text_report"`
	KeepSourceInResult bool `config:"keep_source"`
	BufferSize         int  `config:"buffer_size"`

	Queue            *OutputQueueConfig `config:"output_queue"`
	CleanOldFiles    bool               `config:"clean_old_files"`
	SourceInputQueue string             `config:"source_queue"`
	TargetInputQueue string             `config:"target_queue"`
	// DEPRECATED, use `output_queue` instead
	DiffQueue string `config:"diff_queue"`
}

type DiffResult struct {
	DiffType string       `json:"type,omitempty"`
	Key      string       `json:"key,omitempty"`
	Source   *CompareItem `json:"source,omitempty"`
	Target   *CompareItem `json:"target,omitempty"`
}

type DiffStat struct {
	Count int
	Keys  []string
}

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

type OutputQueueConfig struct {
	Name   string                 `config:"name"`
	Labels map[string]interface{} `config:"labels"`
}