querier

type ErrorResponse struct {
	Error string `json:"error"`
}

type FlightSQLServer struct {
	flightgen.UnimplementedFlightServiceServer
	flightsql.BaseServer
	// contains filtered or unexported fields
}

type MetadataFile struct {
	Type             string        `json:"type"`
	ParquetSizeBytes int           `json:"parquet_size_bytes"`
	RowCount         int           `json:"row_count"`
	MinTime          int64         `json:"min_time"`
	MaxTime          int64         `json:"max_time"`
	Files            []ParquetFile `json:"files"`
}

type ParquetFile struct {
	Path      string `json:"path"`
	SizeBytes int    `json:"size_bytes"`
	RowCount  int    `json:"row_count"`
	MinTime   int64  `json:"min_time"`
	MaxTime   int64  `json:"max_time"`
}

type ParsedQuery struct {
	Columns         string
	DbName          string
	Measurement     string
	TimeRange       TimeRange
	WhereConditions string
	OrderBy         string
	GroupBy         string
	Having          string
	Limit           int
}

type QueryClient struct {
	DataDir          string
	DB               *sql.DB
	DefaultTimeRange int64 // 10 minutes in nanoseconds
}

type QueryRequest struct {
	Query string `json:"query"`
	DB    string `json:"db,omitempty"`
}

type QueryResponse struct {
	Results []map[string]interface{} `json:"results"`
}

type Server struct {
	QueryClient *QueryClient
	DisableUI   bool
	UIFS        afero.Fs
}

type TimeRange struct {
	Start         *int64
	End           *int64
	TimeCondition string
}