search

type AggQuery struct {
	Field     string
	GroupBy   string
	Func      seq.AggFunc
	Quantiles []float64
	Interval  seq.MID
}

type AsyncRequest struct {
	Query             string
	From              time.Time
	To                time.Time
	Order             seq.DocsOrder
	Aggregations      []AggQuery
	HistogramInterval seq.MID
}

type AsyncResponse struct {
	ID string
}

type Config struct {
	HotStores       *stores.Stores
	HotReadStores   *stores.Stores
	ReadStores      *stores.Stores
	WriteStores     *stores.Stores
	ShuffleReplicas bool
	MirrorAddr      string
}

type DocsIterator interface {
	Next() (StreamingDoc, error)
}

type EmptyDocsStream struct {
}

type FetchAsyncSearchResultRequest struct {
	ID       string
	WithDocs bool
	Size     int
	Offset   int
}

type FetchAsyncSearchResultResponse struct {
	Done       bool
	Expiration time.Time
	QPR        seq.QPR
	AggResult  []seq.AggregationResult
}

type FetchFieldsFilter struct {
	// Fields list of fields to fetch. Empty list means to fetch all fields.
	Fields []string
	// AllowList truth if we need to exclude all fields except the fields from the Fields list
	// and false if we need to exclude given Fields from a fetch result.
	AllowList bool
}

type FetchRequest struct {
	IDs          []seq.ID
	FieldsFilter FetchFieldsFilter
}

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

type IngestorStatus struct {
	NumberOfStores    int
	OldestStorageTime *time.Time
	Stores            []StoreStatus
}

type SearchRequest struct {
	Explain     bool
	Q           []byte
	Offset      int
	Size        int
	Interval    seq.MID
	AggQ        []AggQuery
	From        seq.MID
	To          seq.MID
	WithTotal   bool
	ShouldFetch bool
	Order       seq.DocsOrder
}

type StoreStatus struct {
	Host       string
	OldestTime time.Time
	Error      string
}

type StreamingDoc struct {
	ID     seq.ID
	Data   []byte
	Source uint64
}