indexmanager

Documentation

Index

• type IndexMatcher
• type Interface
• type MergeGroup
• type NodeDiskUsage

Types

type IndexMatcher

type IndexMatcher func(index *indexloader.IndexEntry) bool

IndexMatcher .

type Interface

type Interface interface {
	GetWriteIndex(m *metric.Metric) (string, bool)
	GetWriteFixedIndex(m *metric.Metric) string
	CreateIndex(m *metric.Metric) error

	CleanIndices(ctx context.Context, filter IndexMatcher) error                                                               // 清理匹配且过期的索引数据
	RolloverIndices(ctx context.Context, filter IndexMatcher) error                                                            // 滚动匹配的索引
	MergeIndices(ctx context.Context, filter IndexMatcher, min string, merge, delete bool) ([]*MergeGroup, interface{}, error) // 合并匹配的索引

	IndexType() string
	IndexPrefix() string
	RequestTimeout() time.Duration
	Client() *elastic.Client
	EnableRollover() bool
}

Interface .

type MergeGroup

type MergeGroup struct {
	List []*indexloader.IndexEntry

	Indices     string
	MergedSize  string
	MergedDocs  int
	MergedIndex string
	// contains filtered or unexported fields
}

MergeGroup .

type NodeDiskUsage

type NodeDiskUsage struct {
	ID           string
	Total        int64
	Used         int64
	Store        int64
	UsedPercent  float64
	StorePercent float64
	ExpectDelete int64
	Deleted      int64
}

NodeDiskUsage .