server

package
v0.47.3 Latest Latest
Warning

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

Go to latest
Published: Jul 14, 2024 License: Apache-2.0 Imports: 60 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrForbidden = status.Error(codes.Unauthenticated, "action not allowed")

Functions

func BakeQuery added in v0.36.0

func BakeQuery(qry *runtimev1.Query) (string, error)

func HTTPErrorHandler added in v0.17.0

func HTTPErrorHandler(ctx context.Context, mux *gateway.ServeMux, marshaler gateway.Marshaler, w http.ResponseWriter, r *http.Request, err error)

HTTPErrorHandler wraps gateway.DefaultHTTPErrorHandler to map gRPC unknown errors (i.e. errors without an explicit code) to HTTP status code 400 instead of 500.

func UnbakeQuery added in v0.36.0

func UnbakeQuery(bakedQry string) (*runtimev1.Query, error)

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
	AllowedOrigins  []string
	ServePrometheus bool
	SessionKeyPairs [][]byte
	AuthEnable      bool
	AuthIssuerURL   string
	AuthAudienceURL string
	TLSCertPath     string
	TLSKeyPath      string
}

type Server

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

func NewServer

func NewServer(ctx context.Context, opts *Options, rt *runtime.Runtime, logger *zap.Logger, limiter ratelimit.Limiter, activityClient *activity.Client) (*Server, error)

NewServer creates a new runtime server. The provided ctx is used for the lifetime of the server for background refresh of the JWKS that is used to validate auth tokens.

func (*Server) AnalyzeConnectors added in v0.43.0

func (*Server) BigQueryListDatasets added in v0.31.0

func (*Server) BigQueryListTables added in v0.31.0

func (*Server) Close added in v0.22.0

func (s *Server) Close() error

Close should be called when the server is done

func (*Server) ColumnCardinality added in v0.22.0

func (*Server) ColumnDescriptiveStatistics added in v0.22.0

func (*Server) ColumnNullCount added in v0.22.0

func (*Server) ColumnNumericHistogram added in v0.22.0

func (*Server) ColumnRollupInterval added in v0.22.0

Metrics/Timeseries APIs

func (*Server) ColumnRugHistogram added in v0.22.0

func (*Server) ColumnTimeGrain added in v0.22.0

func (*Server) ColumnTimeRange added in v0.22.0

func (*Server) ColumnTimeSeries added in v0.22.0

func (*Server) ColumnTopK added in v0.22.0

func (*Server) CreateDirectory added in v0.43.0

CreateDirectory implements RuntimeService.

func (*Server) CreateInstance

CreateInstance implements RuntimeService.

func (*Server) CreateTrigger added in v0.32.0

CreateTrigger implements runtimev1.RuntimeServiceServer

func (*Server) DeleteFile added in v0.15.0

DeleteFile implements RuntimeService.

func (*Server) DeleteInstance

DeleteInstance implements RuntimeService.

func (*Server) EditInstance added in v0.23.0

EditInstance implements RuntimeService.

func (*Server) Export added in v0.27.3

func (*Server) GCSGetCredentialsInfo added in v0.27.0

func (*Server) GCSListBuckets added in v0.27.0

func (*Server) GCSListObjects added in v0.27.0

func (*Server) GenerateMetricsViewFile added in v0.41.0

GenerateMetricsViewFile generates a metrics view YAML file from a table in an OLAP database

func (*Server) GenerateRenderer added in v0.44.0

func (*Server) GenerateResolver added in v0.43.0

func (*Server) GetFile added in v0.15.0

GetFile implements RuntimeService.

func (*Server) GetInstance

GetInstance implements RuntimeService.

func (*Server) GetLogs added in v0.32.0

GetLogs implements runtimev1.RuntimeServiceServer

func (*Server) GetResource added in v0.32.0

GetResource implements runtimev1.RuntimeServiceServer

func (*Server) HTTPHandler added in v0.15.0

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

HTTPHandler HTTP handler serving REST gateway.

func (*Server) Health added in v0.47.0

Health implements RuntimeService

func (*Server) InstanceHealth added in v0.47.0

InstanceHealth implements RuntimeService

func (*Server) IssueDevJWT added in v0.33.0

func (*Server) ListConnectorDrivers added in v0.43.0

func (*Server) ListExamples added in v0.26.0

ListExamples returns a list of embedded examples

func (*Server) ListFiles added in v0.15.0

ListFiles implements RuntimeService.

func (*Server) ListInstances

ListInstances implements RuntimeService.

func (*Server) ListNotifierConnectors added in v0.43.0

func (*Server) ListResources added in v0.32.0

ListResources implements runtimev1.RuntimeServiceServer

func (*Server) MetricsViewAggregation added in v0.33.2

MetricsViewAggregation implements QueryService.

func (*Server) MetricsViewComparison added in v0.37.0

MetricsViewComparison implements QueryService.

func (*Server) MetricsViewRows added in v0.24.4

MetricsViewRows implements QueryService.

func (*Server) MetricsViewSchema added in v0.40.0

func (*Server) MetricsViewSearch added in v0.47.0

func (*Server) MetricsViewTimeRange added in v0.32.0

MetricsViewTimeRange implements QueryService.

func (*Server) MetricsViewTimeSeries

MetricsViewTimeSeries implements QueryService.

func (*Server) MetricsViewToplist

MetricsViewToplist implements QueryService.

func (*Server) MetricsViewTotals

MetricsViewTotals implements QueryService.

func (*Server) OLAPGetTable added in v0.35.0

func (*Server) OLAPListTables added in v0.31.0

func (*Server) Ping

Ping implements RuntimeService

func (*Server) PutFile added in v0.15.0

PutFile implements RuntimeService.

func (*Server) Query

Query implements QueryService.

func (*Server) QueryBatch added in v0.29.1

func (*Server) RenameFile added in v0.15.0

RenameFile implements RuntimeService.

func (*Server) S3GetBucketMetadata added in v0.27.0

func (*Server) S3GetCredentialsInfo added in v0.27.0

func (*Server) S3ListBuckets added in v0.27.0

func (*Server) S3ListObjects added in v0.27.0

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, registerAdditionalHandlers func(mux *http.ServeMux)) error

Starts the HTTP server.

func (*Server) TableCardinality added in v0.15.0

Table level profiling APIs.

func (*Server) TableColumns added in v0.22.0

func (*Server) TableRows added in v0.15.0

func (*Server) UnpackEmpty added in v0.26.0

func (*Server) UnpackExample added in v0.26.0

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).

func (*Server) WatchFiles added in v0.30.0

WatchFiles implements RuntimeService.

func (*Server) WatchLogs added in v0.32.0

WatchLogs implements runtimev1.RuntimeServiceServer

func (*Server) WatchResources added in v0.32.0

WatchResources implements runtimev1.RuntimeServiceServer

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL