cmd

type Config struct {
	Regurgitate RegurgitateConf `yaml:"regurgitate"`
	Ruminate    RuminateConf    `yaml:"ruminate"`
	Gulp        GulpConf        `yaml:"gulp"`
	Poop        PoopConf        `yaml:"poop"`
}

type ElasticSearch struct {
	Proto string
	Host  string
	Port  int
}

type EsError struct {
	Error struct {
		RootCause []struct {
			Type   string `json:"type"`
			Reason string `json:"reason"`
			Line   int    `json:"line"`
			Col    int    `json:"col"`
		} `json:"root_cause"`
		Type   string `json:"type"`
		Reason string `json:"reason"`
		Line   int    `json:"line"`
		Col    int    `json:"col"`
	} `json:"error"`
	Status int `json:"status"`
}

type EsResponse struct {
	Took     float64 `json:"took"`
	TimedOut bool    `json:"timed_out"`
	Shards   struct {
		Total   float64 `json:"total"`
		Success float64 `json:"success"`
		Failed  float64 `json:"failed"`
	} `json:"_shards"`
	Hits struct {
		Total    float64     `json:"total"`
		MaxScore float64     `json:"max_score"`
		Hits     interface{} `json:"hits"`
	} `json:"hits"`
	Aggregations interface{} `json:"aggregations"`
	Error        string      `json:"error"`
}

type GulpConf struct {
	Host      string `yaml:"host"`
	Port      int    `yaml:"port"`
	Db        string `yaml:"db"`
	Proto     string `yaml:"proto"`
	Series    string `yaml:"series"`
	User      string `yaml:"user"`
	Pass      string `yaml:"pass"`
	Indicator string `yaml:"indicator"`
}

type Influx struct {
	DB        string
	Client    client.Client
	Series    string
	Indicator string
}

type Iterator struct {
	Selector    string            `yaml:"selector"`
	Time        string            `yaml:"time"`
	Tags        map[string]string `yaml:"tags"`
	FixedTags   map[string]string `yaml:"fixed_tags"`
	Values      map[string]string `yaml:"values"`
	FixedValues map[string]string `yaml:"fixed_values"`
	Iterators   []Iterator        `yaml:"iterators"`
}

type Point struct {
	Timestamp time.Time
	Tags      map[string]string
	Values    map[string]interface{}
}

type PoopConf struct {
	Query      string   `yaml:"query"`
	Fields     []string `yaml:"fields"`
	Start      string   `yaml:"start"`
	End        string   `yaml:"end"`
	Format     string   `yaml:"format"`
	Separator  string   `yaml:"separator"`
	ReplaceNil string   `yaml:"replace_nil"`
}

type RegurgitateConf struct {
	Host    string        `yaml:"host"`
	Port    int           `yaml:"port"`
	Proto   string        `yaml:"proto"`
	Index   string        `yaml:"index"`
	Type    string        `yaml:"type"`
	Query   string        `yaml:"query"`
	Sampler SamplerConfig `yaml:"sampler"`
}

type RuminateConf struct {
	Iterator Iterator `yaml:"iterator"`
}

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

type SamplerConfig struct {
	Offset       time.Duration `yaml:"offset"`
	Samples      int           `yaml:"samples"`
	SampleOffset time.Duration `yaml:"sample_offset"`
	Interval     string        `yaml:"interval"`
}