search

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

type AsyncRequest struct {
	Retention         time.Duration
	Query             string
	From              time.Time
	To                time.Time
	Aggregations      []AggQuery
	HistogramInterval seq.MID
	WithDocs          bool
	Size              int64
}

type AsyncResponse struct {
	ID string
}

type AsyncSearchesListItem struct {
	ID     string
	Status asyncsearcher.AsyncSearchStatus

	StartedAt  time.Time
	ExpiresAt  time.Time
	CanceledAt time.Time

	Progress  float64
	DiskUsage uint64

	Request AsyncRequest
	Error   error
}

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

type ControlBroadcaster interface {
	SendControl(storeapi.ControlAction)
}

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

type EmptyDocsStream struct {
}

type FetchAsyncSearchResultRequest struct {
	ID     string
	Size   int
	Offset int
	Order  seq.DocsOrder
}

type FetchAsyncSearchResultResponse struct {
	Status     asyncsearcher.AsyncSearchStatus
	QPR        seq.QPR
	CanceledAt time.Time

	StartedAt time.Time
	ExpiresAt time.Time

	Progress  float64
	DiskUsage uint64

	AggResult []seq.AggregationResult

	Request AsyncRequest
}

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 GetAsyncSearchesListRequest struct {
	Status *asyncsearcher.AsyncSearchStatus
	Size   int
	Offset int
	IDs    []string
}

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
	OffsetId    string
	Size        int
	Interval    seq.MID
	AggQ        []AggQuery
	From        seq.MID
	To          seq.MID
	WithTotal   bool
	ShouldFetch bool
	Order       seq.DocsOrder
	Downsample  uint32
}

type SearchStats struct {
	Query   string
	Size    int
	HasHist bool
	HasAgg  bool

	StorageTier         StorageTier
	HotSearchDuration   time.Duration
	ColdSearchDuration  time.Duration
	TotalSearchDuration time.Duration

	FetchStart    time.Time
	FetchDuration time.Duration
}

type StorageTier string

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

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

type StreamSearchRequest struct {
	Query     string
	From      seq.MID
	To        seq.MID
	Explain   bool
	OffsetId  string
	WithTotal bool
	Agg       *AggQuery
	Order     seq.DocsOrder
	Size      int
	Offset    int
}

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