core

Documentation

Index

• type Config
• type Dumper
  • func NewDumper(conf Config) *Dumper
  • func (d *Dumper) Dump()

Types

type Config

type Config struct {
	Input      string
	Output     string
	DumpType   string
	DateField  string
	StartDate  string
	EndDate    string
	Step       time.Duration
	ScrollSize int
	Descending bool
	Zone       string
	Includes   string
	Excludes   string
}

type Dumper

type Dumper struct {
	Conf         Config
	SourceClient *elastic.Client
	TargetClient *elastic.Client
	SourceIndex  string
	SourceType   string
	TargetIndex  string
	TargetType   string
	StartTime    *time.Time
	EndTime      *time.Time
	Zone         *time.Location
	Includes     []string `json:"includes"`
	Excludes     []string `json:"excludes"`
}

func NewDumper

func NewDumper(conf Config) *Dumper

func (*Dumper) Dump

func (d *Dumper) Dump()