config

Documentation

Index

• type Config
• type ESConfig
• type GatewayCfg
• type IndexFilePair
• type IndexPair
• type IndexTemplate
• type TaskAction
• type TaskCfg

Types

type Config

type Config struct {
	ESConfigs         map[string]*ESConfig `mapstructure:"elastics"`
	Tasks             []*TaskCfg           `mapstructure:"tasks"`
	Level             string               `mapstructure:"level"`
	IgnoreSystemIndex bool                 `mapstructure:"ignore_system_index"`
	GatewayCfg        *GatewayCfg          `mapstructure:"gateway"`
}

type ESConfig

type ESConfig struct {
	Addresses []string `mapstructure:"addresses"`
	User      string   `mapstructure:"user"`
	Password  string   `mapstructure:"password"`
}

type GatewayCfg

type GatewayCfg struct {
	Address  string `mapstructure:"address"`
	User     string `mapstructure:"user"`
	Password string `mapstructure:"password"`

	SourceES string `mapstructure:"source_es"`
	TargetES string `mapstructure:"target_es"`
	Master   string `mapstructure:"master"`
}

type IndexFilePair

type IndexFilePair struct {
	Index        string `mapstructure:"index"`
	IndexFileDir string `mapstructure:"index_file_dir"`
}

type IndexPair

type IndexPair struct {
	SourceIndex string `mapstructure:"source_index"`
	TargetIndex string `mapstructure:"target_index"`
}

type IndexTemplate

type IndexTemplate struct {
	Name     string   `mapstructure:"name"`
	Patterns []string `mapstructure:"pattern"`
	Order    int      `mapstructure:"order"`
}

type TaskAction

type TaskAction string

const (
	TaskActionCopyIndex TaskAction = "copy_index"
	TaskActionSync      TaskAction = "sync"
	TaskActionSyncDiff  TaskAction = "sync_diff"
	TaskActionCompare   TaskAction = "compare"
	TaskActionImport    TaskAction = "import"
	TaskActionExport    TaskAction = "export"
	TaskActionTemplate  TaskAction = "create_template"
)

type TaskCfg

type TaskCfg struct {
	Name              string           `mapstructure:"name"`
	IndexPattern      *string          `mapstructure:"index_pattern"`
	SourceES          string           `mapstructure:"source_es"`
	TargetES          string           `mapstructure:"target_es"`
	IndexPairs        []*IndexPair     `mapstructure:"index_pairs"`
	IndexTemplates    []*IndexTemplate `mapstructure:"index_templates"`
	TaskAction        TaskAction       `mapstructure:"action"`
	Force             bool             `mapstructure:"force"`
	ScrollSize        uint             `mapstructure:"scroll_size"`
	ScrollTime        uint             `mapstructure:"scroll_time"`
	Parallelism       uint             `mapstructure:"parallelism"`
	SliceSize         uint             `mapstructure:"slice_size"`
	BufferCount       uint             `mapstructure:"buffer_count"`
	ActionParallelism uint             `mapstructure:"action_parallelism"`
	ActionSize        uint             `mapstructure:"action_size"`
	Ids               []string         `mapstructure:"ids"`
	IndexFilePairs    []*IndexFilePair `mapstructure:"index_file_pairs"`
	IndexFileRoot     string           `mapstructure:"index_file_root"`
	Query             string           `mapstructure:"query"`
}