indexloader

Documentation

Index

• type IndexEntry
• type IndexEntrys
  • func (entrys IndexEntrys) Len() int
  • func (entrys IndexEntrys) Less(i, j int) bool
  • func (entrys IndexEntrys) Swap(i, j int)
• type IndexGroup
• type Interface

Types

type IndexEntry

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
}

IndexEntry .

type IndexEntrys

type IndexEntrys []*IndexEntry

IndexEntrys .

func (IndexEntrys) Len

func (entrys IndexEntrys) Len() int

func (IndexEntrys) Less

func (entrys IndexEntrys) Less(i, j int) bool

func (IndexEntrys) Swap

func (entrys IndexEntrys) Swap(i, j int)

type IndexGroup

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

IndexGroup .

type Interface

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
}

Index .