querier

Jul 22, 2025

Changes in this version

type QueryClient

+ func (c *QueryClient) QueryArrow(ctx context.Context, query string) (array.RecordReader, *arrow.Schema, error)

May 23, 2025

Changes in this version

+ func StopFlightSQLServer()

May 18, 2025

Changes in this version

+ func JsonFormatter(data []map[string]any, w http.ResponseWriter) error

+ func NDJsonFormatter(data []map[string]any, w http.ResponseWriter) error

May 15, 2025

Changes in this version

+ func GetRootDir() string

type Server

+ UIFS afero.Fs

Apr 29, 2025

Changes in this version

+ func ProcessResultsForJSON(results []map[string]interface{}) []map[string]interface

+ func StartFlightSQLServer(port int, queryClient *QueryClient) error

+ type ErrorResponse struct

+ Error string

+ type FlightSQLServer struct

+ func NewFlightSQLServer(queryClient *QueryClient) *FlightSQLServer

+ func (s *FlightSQLServer) DoAction(action *flight.Action, stream flight.FlightService_DoActionServer) error

+ func (s *FlightSQLServer) DoExchange(stream flight.FlightService_DoExchangeServer) error

+ func (s *FlightSQLServer) DoGet(ticket *flight.Ticket, stream flight.FlightService_DoGetServer) error

+ func (s *FlightSQLServer) DoPut(stream flight.FlightService_DoPutServer) error

+ func (s *FlightSQLServer) GetFlightInfo(ctx context.Context, desc *flight.FlightDescriptor) (*flight.FlightInfo, error)

+ func (s *FlightSQLServer) GetFlightInfoStatement(ctx context.Context, cmd *flightsql.StatementQuery, ...) (*flight.FlightInfo, error)

+ func (s *FlightSQLServer) GetSchema(ctx context.Context, desc *flight.FlightDescriptor) (*flight.SchemaResult, error)

+ func (s *FlightSQLServer) Handshake(stream flight.FlightService_HandshakeServer) error

+ func (s *FlightSQLServer) ListActions(request *flight.Empty, stream flight.FlightService_ListActionsServer) error

+ func (s *FlightSQLServer) ListFlights(criteria *flight.Criteria, stream flight.FlightService_ListFlightsServer) error

+ func (s *FlightSQLServer) PollFlightInfo(ctx context.Context, desc *flight.FlightDescriptor) (*flight.PollInfo, error)

+ type MetadataFile struct

+ Files []ParquetFile

+ MaxTime int64

+ MinTime int64

+ ParquetSizeBytes int

+ RowCount int

+ Type string

+ type ParquetFile struct

+ MaxTime int64

+ MinTime int64

+ Path string

+ RowCount int

+ SizeBytes int

+ type ParsedQuery struct

+ Columns string

+ DbName string

+ GroupBy string

+ Having string

+ Limit int

+ Measurement string

+ OrderBy string

+ TimeRange TimeRange

+ WhereConditions string

+ type QueryClient struct

+ DB *sql.DB

+ DataDir string

+ DefaultTimeRange int64

+ func NewQueryClient(dataDir string) *QueryClient

+ func (c *QueryClient) Query(ctx context.Context, query, dbName string) ([]map[string]interface{}, error)

+ func (q *QueryClient) Close() error

+ func (q *QueryClient) FindRelevantFiles(ctx context.Context, dbName, measurement string, timeRange TimeRange) ([]string, error)

+ func (q *QueryClient) Initialize() error

+ func (q *QueryClient) ParseQuery(sql, dbName string) (*ParsedQuery, error)

+ type QueryRequest struct

+ DB string

+ Query string

+ type QueryResponse struct

+ Results []map[string]interface{}

+ type Server struct

+ DisableUI bool

+ QueryClient *QueryClient

+ func NewServer(dataDir string) (*Server, error)

+ func (s *Server) Close() error

+ func (s *Server) HandleHealth(w http.ResponseWriter, r *http.Request)

+ func (s *Server) HandleQuery(w http.ResponseWriter, r *http.Request)

+ func (s *Server) HandleUI(w http.ResponseWriter, r *http.Request)

+ type TimeRange struct

+ End *int64

+ Start *int64

+ TimeCondition string