influxql

type CollectorFn func() Statistics

type EncodingFormat int

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

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

type NotImplementedError struct {
	Op string // Op is the name of the unimplemented operation
}

type ProxyMode byte

type ProxyQueryService interface {
	check.Checker
	Query(ctx context.Context, w io.Writer, req *QueryRequest) (Statistics, error)
}

type QueryRequest struct {
	Authorization  *influxdb.Authorization `json:"authorization,omitempty"`
	OrganizationID platform.ID             `json:"organization_id"`
	DB             string                  `json:"db"`
	RP             string                  `json:"rp"`
	Epoch          string                  `json:"epoch"`
	EncodingFormat EncodingFormat          `json:"encoding_format"`
	ContentType    string                  `json:"content_type"` // Content type is the desired response format.
	Chunked        bool                    `json:"chunked"`      // Chunked indicates responses should be chunked using ChunkSize
	ChunkSize      int                     `json:"chunk_size"`   // ChunkSize is the number of points to be encoded per batch. 0 indicates no chunking.
	Query          string                  `json:"query"`        // Query contains the InfluxQL.
	Params         map[string]interface{}  `json:"params,omitempty"`
	Source         string                  `json:"source"` // Source represents the ultimate source of the request.
}

type RequestMode byte

type Statistics struct {
	PlanDuration    time.Duration `json:"plan_duration"`    // PlanDuration is the duration spent planning the query.
	ExecuteDuration time.Duration `json:"execute_duration"` // ExecuteDuration is the duration spent executing the query.
	StatementCount  int           `json:"statement_count"`  // StatementCount is the number of InfluxQL statements executed
	ScannedValues   int           `json:"scanned_values"`   // ScannedValues is the number of values scanned from storage
	ScannedBytes    int           `json:"scanned_bytes"`    // ScannedBytes is the number of bytes scanned from storage
}

type StatisticsCollector interface {
	Statistics() Statistics
}

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