indexloader

type IndexEntry struct {
	Index       string
	Metric      string
	Namespace   string
	Key         string
	Fixed       bool
	Num         int64
	MinT        time.Time
	MaxT        time.Time
	DocsCount   int
	DocsDeleted int
	StoreBytes  int64
	StoreSize   string
	Active      bool
}

type IndexEntrys []*IndexEntry

type IndexGroup struct {
	Groups map[string]*IndexGroup `json:"groups,omitempty"`
	List   []*IndexEntry          `json:"list,omitempty"`
	Fixed  *IndexEntry            `json:"fixed,omitempty"`
}

type Interface interface {
	WaitAndGetIndices(ctx context.Context) map[string]*IndexGroup
	AllIndices() map[string]*IndexGroup
	ReloadIndices() error
	WatchLoadEvent(func(map[string]*IndexGroup))

	GetReadIndices(metrics []string, namespace []string, start, end int64) []string
	MetricNames() []string

	EmptyIndex() string
	IndexPrefix() string
	RequestTimeout() time.Duration
	QueryIndexTimeRange() bool
	Client() *elastic.Client
	URLs() string
}