server

package
v0.16.0-rc8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 9, 2022 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

View Source 
const IsoFormat string = "2006-01-02T15:04:05.000Z"

Variables

This section is empty.

Functions

func ErrorToCode added in v0.16.0 

func ErrorToCode(err error) codes.Code

ErrorToCode returns the Code of the error if it is a Status error otherwise use status.FromContextError to determine the Code. Log level for error codes is defined in logging.DefaultServerCodeToLevel

func EscapeDoubleQuotes added in v0.15.0 

func EscapeDoubleQuotes(column string) string

func EscapeHyphen added in v0.16.0 

func EscapeHyphen(column string) string

func EscapeSingleQuotes added in v0.15.0 

func EscapeSingleQuotes(value string) string

func GRPCCodeToLevel added in v0.16.0 

func GRPCCodeToLevel(code codes.Code) logging.Level

GRPCCodeToLevel overrides the log level of various gRPC codes. We're currently not doing very granular error handling, so we get quite a lot of codes.Unknown errors, which we do not want to emit as error logs.

Types

type ColumnInfo added in v0.15.0 

type ColumnInfo struct {
	Name    string
	Type    string
	Unknown int
}

type Options added in v0.16.0 

type Options struct {
	HTTPPort int
	GRPCPort int
}

type Server 

type Server struct {
	runtimev1.UnsafeRuntimeServiceServer
	// contains filtered or unexported fields
}

func NewServer 

func NewServer(opts *Options, rt *runtime.Runtime, logger *zap.Logger) (*Server, error)

func (*Server) CreateInstance 

func (s *Server) CreateInstance(ctx context.Context, req *runtimev1.CreateInstanceRequest) (*runtimev1.CreateInstanceResponse, error)

CreateInstance implements RuntimeService

func (*Server) DeleteFile added in v0.15.0 

func (s *Server) DeleteFile(ctx context.Context, req *runtimev1.DeleteFileRequest) (*runtimev1.DeleteFileResponse, error)

DeleteFile implements RuntimeService

func (*Server) DeleteFileAndReconcile added in v0.16.0 

func (s *Server) DeleteFileAndReconcile(ctx context.Context, req *runtimev1.DeleteFileAndReconcileRequest) (*runtimev1.DeleteFileAndReconcileResponse, error)

DeleteFileAndReconcile implements RuntimeService

func (*Server) DeleteInstance 

func (s *Server) DeleteInstance(ctx context.Context, req *runtimev1.DeleteInstanceRequest) (*runtimev1.DeleteInstanceResponse, error)

DeleteInstance implements RuntimeService

func (*Server) EstimateRollupInterval added in v0.15.0 

func (s *Server) EstimateRollupInterval(ctx context.Context, request *runtimev1.EstimateRollupIntervalRequest) (*runtimev1.EstimateRollupIntervalResponse, error)

Metrics/Timeseries APIs

func (*Server) EstimateSmallestTimeGrain added in v0.15.0 

func (s *Server) EstimateSmallestTimeGrain(ctx context.Context, request *runtimev1.EstimateSmallestTimeGrainRequest) (*runtimev1.EstimateSmallestTimeGrainResponse, error)

func (*Server) ExportTable added in v0.16.0 

func (s *Server) ExportTable(w http.ResponseWriter, req *http.Request, pathParams map[string]string)

ExportTable exports a table or view as a flat file and triggers a HTTP download of it. It's mounted as a REST API only, and is not available over gRPC.

TODO: This is a temporary hack that only supports DuckDB. We should add a generic workflow for data export that also supports possibly very large tables.

func (*Server) GenerateTimeSeries added in v0.15.0 

func (s *Server) GenerateTimeSeries(ctx context.Context, request *runtimev1.GenerateTimeSeriesRequest) (*runtimev1.GenerateTimeSeriesResponse, error)

func (*Server) GetCardinalityOfColumn added in v0.15.0 

func (s *Server) GetCardinalityOfColumn(ctx context.Context, request *runtimev1.GetCardinalityOfColumnRequest) (*runtimev1.GetCardinalityOfColumnResponse, error)

func (*Server) GetCatalogEntry added in v0.16.0 

func (s *Server) GetCatalogEntry(ctx context.Context, req *runtimev1.GetCatalogEntryRequest) (*runtimev1.GetCatalogEntryResponse, error)

GetCatalogEntry implements RuntimeService

func (*Server) GetDescriptiveStatistics added in v0.15.0 

func (s *Server) GetDescriptiveStatistics(ctx context.Context, request *runtimev1.GetDescriptiveStatisticsRequest) (*runtimev1.GetDescriptiveStatisticsResponse, error)

func (*Server) GetFile added in v0.15.0 

func (s *Server) GetFile(ctx context.Context, req *runtimev1.GetFileRequest) (*runtimev1.GetFileResponse, error)

GetFile implements RuntimeService

func (*Server) GetInstance 

func (s *Server) GetInstance(ctx context.Context, req *runtimev1.GetInstanceRequest) (*runtimev1.GetInstanceResponse, error)

GetInstance implements RuntimeService

func (*Server) GetNullCount added in v0.15.0 

func (s *Server) GetNullCount(ctx context.Context, nullCountRequest *runtimev1.GetNullCountRequest) (*runtimev1.GetNullCountResponse, error)

func (*Server) GetNumericHistogram added in v0.15.0 

func (s *Server) GetNumericHistogram(ctx context.Context, request *runtimev1.GetNumericHistogramRequest) (*runtimev1.GetNumericHistogramResponse, error)

func (*Server) GetRugHistogram added in v0.15.0 

func (s *Server) GetRugHistogram(ctx context.Context, request *runtimev1.GetRugHistogramRequest) (*runtimev1.GetRugHistogramResponse, error)

func (*Server) GetTableCardinality added in v0.16.0 

func (s *Server) GetTableCardinality(ctx context.Context, req *runtimev1.GetTableCardinalityRequest) (*runtimev1.GetTableCardinalityResponse, error)

Table level profiling APIs

func (*Server) GetTableRows added in v0.16.0 

func (s *Server) GetTableRows(ctx context.Context, req *runtimev1.GetTableRowsRequest) (*runtimev1.GetTableRowsResponse, error)

func (*Server) GetTimeRangeSummary added in v0.15.0 

func (s *Server) GetTimeRangeSummary(ctx context.Context, request *runtimev1.GetTimeRangeSummaryRequest) (*runtimev1.GetTimeRangeSummaryResponse, error)

func (*Server) GetTopK added in v0.14.0 

func (s *Server) GetTopK(ctx context.Context, req *runtimev1.GetTopKRequest) (*runtimev1.GetTopKResponse, error)

func (*Server) HTTPHandler added in v0.15.0 

func (s *Server) HTTPHandler(ctx context.Context) (http.Handler, error)

HTTPHandler HTTP handler serving REST gateway

func (*Server) ListCatalogEntries added in v0.16.0 

func (s *Server) ListCatalogEntries(ctx context.Context, req *runtimev1.ListCatalogEntriesRequest) (*runtimev1.ListCatalogEntriesResponse, error)

ListCatalogEntries implements RuntimeService

func (*Server) ListConnectors 

func (s *Server) ListConnectors(ctx context.Context, req *runtimev1.ListConnectorsRequest) (*runtimev1.ListConnectorsResponse, error)

ListConnectors implements RuntimeService

func (*Server) ListFiles added in v0.15.0 

func (s *Server) ListFiles(ctx context.Context, req *runtimev1.ListFilesRequest) (*runtimev1.ListFilesResponse, error)

ListFiles implements RuntimeService

func (*Server) ListInstances 

func (s *Server) ListInstances(ctx context.Context, req *runtimev1.ListInstancesRequest) (*runtimev1.ListInstancesResponse, error)

ListInstances implements RuntimeService

func (*Server) MetricsViewTimeSeries 

func (s *Server) MetricsViewTimeSeries(ctx context.Context, req *runtimev1.MetricsViewTimeSeriesRequest) (*runtimev1.MetricsViewTimeSeriesResponse, error)

MetricsViewTimeSeries implements RuntimeService

func (*Server) MetricsViewToplist 

func (s *Server) MetricsViewToplist(ctx context.Context, req *runtimev1.MetricsViewToplistRequest) (*runtimev1.MetricsViewToplistResponse, error)

MetricsViewToplist implements RuntimeService

func (*Server) MetricsViewTotals 

func (s *Server) MetricsViewTotals(ctx context.Context, req *runtimev1.MetricsViewTotalsRequest) (*runtimev1.MetricsViewTotalsResponse, error)

MetricsViewTotals implements RuntimeService

func (*Server) Ping 

func (s *Server) Ping(ctx context.Context, req *runtimev1.PingRequest) (*runtimev1.PingResponse, error)

Ping implements RuntimeService

func (*Server) ProfileColumns added in v0.15.0 

func (s *Server) ProfileColumns(ctx context.Context, req *runtimev1.ProfileColumnsRequest) (*runtimev1.ProfileColumnsResponse, error)

func (*Server) PutFile added in v0.15.0 

func (s *Server) PutFile(ctx context.Context, req *runtimev1.PutFileRequest) (*runtimev1.PutFileResponse, error)

PutFile implements RuntimeService

func (*Server) PutFileAndReconcile added in v0.16.0 

func (s *Server) PutFileAndReconcile(ctx context.Context, req *runtimev1.PutFileAndReconcileRequest) (*runtimev1.PutFileAndReconcileResponse, error)

PutFileAndReconcile implements RuntimeService

func (*Server) Query 

func (s *Server) Query(ctx context.Context, req *runtimev1.QueryRequest) (*runtimev1.QueryResponse, error)

Query implements RuntimeService

func (*Server) Reconcile added in v0.16.0 

func (s *Server) Reconcile(ctx context.Context, req *runtimev1.ReconcileRequest) (*runtimev1.ReconcileResponse, error)

Reconcile implements RuntimeService

func (*Server) RefreshAndReconcile added in v0.16.0 

func (s *Server) RefreshAndReconcile(ctx context.Context, req *runtimev1.RefreshAndReconcileRequest) (*runtimev1.RefreshAndReconcileResponse, error)

RefreshAndReconcile implements RuntimeService

func (*Server) RenameFile added in v0.15.0 

func (s *Server) RenameFile(ctx context.Context, req *runtimev1.RenameFileRequest) (*runtimev1.RenameFileResponse, error)

RenameFile implements RuntimeService

func (*Server) RenameFileAndReconcile added in v0.16.0 

func (s *Server) RenameFileAndReconcile(ctx context.Context, req *runtimev1.RenameFileAndReconcileRequest) (*runtimev1.RenameFileAndReconcileResponse, error)

RenameFileAndReconcile implements RuntimeService

func (*Server) ServeGRPC added in v0.15.0 

func (s *Server) ServeGRPC(ctx context.Context) error

ServeGRPC Starts the gRPC server

func (*Server) ServeHTTP added in v0.15.0 

func (s *Server) ServeHTTP(ctx context.Context) error

Starts the HTTP server

func (*Server) TriggerRefresh 

func (s *Server) TriggerRefresh(ctx context.Context, req *runtimev1.TriggerRefreshRequest) (*runtimev1.TriggerRefreshResponse, error)

TriggerRefresh implements RuntimeService

func (*Server) TriggerSync added in v0.15.0 

func (s *Server) TriggerSync(ctx context.Context, req *runtimev1.TriggerSyncRequest) (*runtimev1.TriggerSyncResponse, error)

TriggerSync implements RuntimeService

func (*Server) UploadMultipartFile added in v0.15.0 

func (s *Server) UploadMultipartFile(w http.ResponseWriter, req *http.Request, pathParams map[string]string)

UploadMultipartFile implements the same functionality as PutFile, but for multipart HTTP upload. It's mounted only on as a REST API and enables upload of large files (such as data files).

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.