elasticsearch

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

type Config struct {
	PipelineName  string
	Name          string
	Hosts         []string `yaml:"hosts,omitempty" validate:"required"`
	UserName      string   `yaml:"username,omitempty"`
	Password      string   `yaml:"password,omitempty"`
	Schema        string   `yaml:"schema,omitempty"`
	Sniff         *bool    `yaml:"sniff,omitempty"`
	Gzip          *bool    `yaml:"gzip,omitempty"`
	IncludeFields []string `yaml:"includeFields,omitempty"`
	ExcludeFields []string `yaml:"excludeFields,omitempty"`
	Query         string   `yaml:"query,omitempty"`
	SortBy        []SortBy `yaml:"sortBy,omitempty" validate:"required"`
	Indices       []string `yaml:"indices,omitempty" validate:"required"`
	Size          int      `yaml:"size,omitempty" default:"100"`

	Interval time.Duration `yaml:"interval,omitempty" default:"30s"`
	Timeout  time.Duration `yaml:"timeout,omitempty" default:"5s"`

	DBConfig DBConfig `yaml:"db,omitempty"`
}

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

type DBConfig struct {
	IndexPrefix          string        `yaml:"indexPrefix,omitempty" default:".loggie-db"`
	FlushTimeout         time.Duration `yaml:"flushTimeout,omitempty" default:"2s"`
	CleanInactiveTimeout time.Duration `yaml:"cleanInactiveTimeout,omitempty" default:"504h"` // default records not updated in 21 days will be deleted
	CleanScanInterval    time.Duration `yaml:"cleanScanInterval,omitempty" default:"1h"`
}

type Offset struct {
	Sort      []interface{}          `json:"-"`
	Body      map[string]interface{} `json:"sorts"`
	CreatedAt time.Time              `json:"created_at"`
}

type SortBy struct {
	Fields    string `yaml:"fields,omitempty"`
	Ascending bool   `yaml:"ascending,omitempty" default:"true"`
}

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