storage

type Aggregation struct {
	*Selector
	Aggs []*AggregationDescriptor
}

type AggregationBucket struct {
	Key   interface{}
	Count int64
}

type AggregationDescriptor struct {
	Name    string
	Field   string
	Typ     AggregationType
	Options interface{}
}

type AggregationResponse struct {
	Total        int64
	Aggregations map[string]*AggregationResult
}

type AggregationResult struct {
	Buckets []*AggregationBucket
}

type AggregationType string

type Aggregator interface {
	Aggregate(ctx context.Context, req *Aggregation) (*AggregationResponse, error)
}

type Comparer struct{}

type Filter struct {
	Key   string
	Op    Operator
	Value interface{}
}

type HistogramAggOptions struct {
	PreferredPoints int64
	MinimumInterval int64
	FixedInterval   int64
}

type IterateStyle int32

type Logs []*pb.LogItem

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

type Operator int32

type QueryMeta struct {
	OrgNames              []string
	MspEnvIds             []string
	Highlight             bool
	PreferredBufferSize   int
	PreferredIterateStyle IterateStyle
	PreferredReturnFields ReturnFieldMode
}

type ResultSkip struct {
	AfterId    *UniqueId
	FromOffset int
}

type ReturnFieldMode int32

type Selector struct {
	Start   int64
	End     int64
	Scheme  string
	Filters []*Filter
	Debug   bool
	Meta    QueryMeta
	Skip    ResultSkip
	Options map[string]interface{}
}

type Storage interface {
	NewWriter(ctx context.Context) (storekit.BatchWriter, error)
	Iterator(ctx context.Context, sel *Selector) (storekit.Iterator, error)
}

type TermsAggOptions struct {
	Size    int64
	Missing interface{}
}

type UniqueId struct {
	Timestamp int64
	Id        string
	Offset    int64
}