partition

type ChunkInfo struct {
	// Id the chunk id
	Id chunk.Id
	// Size contains chunk size in bytes
	Size int64
	// Records contains number of records in the chunk
	Records uint32
	// MinTs contains minimal timestamp value for the chunk records
	MinTs int64
	// MaxTs contains maximal timestamp value for the chunk records
	MaxTs int64
	// Comment any supplemental info
	Comment string
}

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

type OnTruncateF func(ti TruncateInfo)

type PartitionInfo struct {
	// Tags contains the partition tags
	Tags tag.Set
	// Size contains the size of the partition
	Size uint64
	// Records contains number of records in the partition
	Records uint64

	//Journal id contains the journal identifier
	JournalId string

	// Chunks contains information about the journal chunks
	Chunks []*ChunkInfo
}

type PartitionsInfo struct {
	// Partitions contains list of partitions for the query (with limit and offset)
	Partitions []*PartitionInfo
	// Count contains total number of partitions found
	Count int
	// TotalSize contains summarized size of all partitions which match the criteria
	TotalSize uint64
	// TotalRecords contains summarized number of records in all matched partitions
	TotalRecords uint64
}

type Service struct {
	Pool      *bytes.Pool        `inject:""`
	Journals  journal.Controller `inject:""`
	TIndex    tindex.Service     `inject:""`
	MainCtx   context.Context    `inject:"mainCtx"`
	TsIndexer tmindex.TsIndexer  `inject:""`
	// contains filtered or unexported fields
}

type TmIndexRebuilder interface {
	// RebuildIndex sends request for rebuilding time index. It works asynchronously
	// and should not block the go-routine
	// if force is true the index will be rebuilt even if it is alive
	RebuildIndex(src string, cid chunk.Id, force bool)
}

type TruncateInfo struct {
	// LatestTs contains timestamp for latest record in the partition
	LatestTs      int64
	Tags          tag.Set
	Src           string
	BeforeSize    uint64
	AfterSize     uint64
	BeforeRecs    uint64
	AfterRecs     uint64
	ChunksDeleted int
	Deleted       bool
}

type TruncateParams struct {
	DryRun bool
	// TagsExpr contains the tags condition to select journals to be truncated
	TagsExpr *lql.Source
	// MaxSrcSize defines the upper level of a partition size, which will be truncated, if reached
	MaxSrcSize uint64
	// MinSrcSize defines the lower level of a partition size, which will not be cut if the partition will be less
	// than this parameter after truncation
	MinSrcSize uint64
	// OldestTs defines the oldest record timestamp. Chunks with records less than the parameter are candidates
	// for truncation
	OldestTs int64
	// Max Global size
	MaxDBSize uint64
}

type WriteEvent struct {
	Tags tag.Set
	//Src the partition Id
	Src      string
	StartPos journal.Pos
	EndPos   journal.Pos
}