server

package
v0.78.0 Latest Latest
Warning

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

 Go to latest Published: Dec 22, 2025 License: Apache-2.0 Imports: 74 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

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.

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 (s *Server) AnalyzeConnectors(ctx context.Context, req *runtimev1.AnalyzeConnectorsRequest) (*runtimev1.AnalyzeConnectorsResponse, error)

func (*Server) AnalyzeVariables added in v0.51.0 

func (s *Server) AnalyzeVariables(ctx context.Context, req *runtimev1.AnalyzeVariablesRequest) (*runtimev1.AnalyzeVariablesResponse, error)

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 (s *Server) ColumnCardinality(ctx context.Context, req *runtimev1.ColumnCardinalityRequest) (*runtimev1.ColumnCardinalityResponse, error)

func (*Server) ColumnDescriptiveStatistics added in v0.22.0 

func (s *Server) ColumnDescriptiveStatistics(ctx context.Context, req *runtimev1.ColumnDescriptiveStatisticsRequest) (*runtimev1.ColumnDescriptiveStatisticsResponse, error)

func (*Server) ColumnNullCount added in v0.22.0 

func (s *Server) ColumnNullCount(ctx context.Context, req *runtimev1.ColumnNullCountRequest) (*runtimev1.ColumnNullCountResponse, error)

func (*Server) ColumnNumericHistogram added in v0.22.0 

func (s *Server) ColumnNumericHistogram(ctx context.Context, req *runtimev1.ColumnNumericHistogramRequest) (*runtimev1.ColumnNumericHistogramResponse, error)

func (*Server) ColumnRollupInterval added in v0.22.0 

func (s *Server) ColumnRollupInterval(ctx context.Context, req *runtimev1.ColumnRollupIntervalRequest) (*runtimev1.ColumnRollupIntervalResponse, error)

Metrics/Timeseries APIs

func (*Server) ColumnRugHistogram added in v0.22.0 

func (s *Server) ColumnRugHistogram(ctx context.Context, req *runtimev1.ColumnRugHistogramRequest) (*runtimev1.ColumnRugHistogramResponse, error)

func (*Server) ColumnTimeGrain added in v0.22.0 

func (s *Server) ColumnTimeGrain(ctx context.Context, req *runtimev1.ColumnTimeGrainRequest) (*runtimev1.ColumnTimeGrainResponse, error)

func (*Server) ColumnTimeRange added in v0.22.0 

func (s *Server) ColumnTimeRange(ctx context.Context, req *runtimev1.ColumnTimeRangeRequest) (*runtimev1.ColumnTimeRangeResponse, error)

func (*Server) ColumnTimeSeries added in v0.22.0 

func (s *Server) ColumnTimeSeries(ctx context.Context, req *runtimev1.ColumnTimeSeriesRequest) (*runtimev1.ColumnTimeSeriesResponse, error)

func (*Server) ColumnTopK added in v0.22.0 

func (s *Server) ColumnTopK(ctx context.Context, req *runtimev1.ColumnTopKRequest) (*runtimev1.ColumnTopKResponse, error)

func (*Server) Complete added in v0.78.0 

func (s *Server) Complete(ctx context.Context, req *runtimev1.CompleteRequest) (resp *runtimev1.CompleteResponse, resErr error)

Complete runs a conversational AI completion with tool calling support.

func (*Server) CompleteStreaming added in v0.78.0 

func (s *Server) CompleteStreaming(req *runtimev1.CompleteStreamingRequest, stream runtimev1.RuntimeService_CompleteStreamingServer) (resErr error)

CompleteStreaming implements RuntimeService

func (*Server) CompleteStreamingHandler added in v0.78.0 

func (s *Server) CompleteStreamingHandler(w http.ResponseWriter, req *http.Request)

CompleteStreamingHandler is a HTTP handler that wraps CompleteStreaming and maps it to SSE. This is required as vanguard doesn't currently map streaming RPCs to SSE, so we register this handler manually override the behavior

func (*Server) ConvertExpressionToMetricsSQL added in v0.78.0 

func (s *Server) ConvertExpressionToMetricsSQL(ctx context.Context, req *runtimev1.ConvertExpressionToMetricsSQLRequest) (*runtimev1.ConvertExpressionToMetricsSQLResponse, error)

ConvertExpressionToMetricsSQL implements QueryService.

func (*Server) CreateDirectory added in v0.43.0 

func (s *Server) CreateDirectory(ctx context.Context, req *runtimev1.CreateDirectoryRequest) (*runtimev1.CreateDirectoryResponse, error)

CreateDirectory implements RuntimeService.

func (*Server) CreateInstance 

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

CreateInstance implements RuntimeService.

func (*Server) CreateTrigger added in v0.32.0 

func (s *Server) CreateTrigger(ctx context.Context, req *runtimev1.CreateTriggerRequest) (*runtimev1.CreateTriggerResponse, error)

CreateTrigger implements runtimev1.RuntimeServiceServer

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

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

DeleteInstance implements RuntimeService.

func (*Server) EditInstance added in v0.23.0 

func (s *Server) EditInstance(ctx context.Context, req *runtimev1.EditInstanceRequest) (*runtimev1.EditInstanceResponse, error)

EditInstance implements RuntimeService.

func (*Server) Export added in v0.27.3 

func (s *Server) Export(ctx context.Context, req *runtimev1.ExportRequest) (*runtimev1.ExportResponse, error)

func (*Server) ExportReport added in v0.51.0 

func (s *Server) ExportReport(ctx context.Context, req *runtimev1.ExportReportRequest) (*runtimev1.ExportReportResponse, error)

func (*Server) GenerateCanvasFile added in v0.78.0 

func (s *Server) GenerateCanvasFile(ctx context.Context, req *runtimev1.GenerateCanvasFileRequest) (*runtimev1.GenerateCanvasFileResponse, error)

GenerateCanvasFile generates a canvas YAML file from a metrics view

func (*Server) GenerateMetricsViewFile added in v0.41.0 

func (s *Server) GenerateMetricsViewFile(ctx context.Context, req *runtimev1.GenerateMetricsViewFileRequest) (*runtimev1.GenerateMetricsViewFileResponse, error)

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

func (*Server) GenerateRenderer added in v0.44.0 

func (s *Server) GenerateRenderer(ctx context.Context, req *runtimev1.GenerateRendererRequest) (*runtimev1.GenerateRendererResponse, error)

func (*Server) GenerateResolver added in v0.43.0 

func (s *Server) GenerateResolver(ctx context.Context, req *runtimev1.GenerateResolverRequest) (*runtimev1.GenerateResolverResponse, error)

func (*Server) GetConversation added in v0.78.0 

func (s *Server) GetConversation(ctx context.Context, req *runtimev1.GetConversationRequest) (*runtimev1.GetConversationResponse, error)

func (*Server) GetExplore added in v0.50.0 

func (s *Server) GetExplore(ctx context.Context, req *runtimev1.GetExploreRequest) (*runtimev1.GetExploreResponse, error)

GetExplore implements runtimev1.RuntimeServiceServer

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) GetLogs added in v0.32.0 

func (s *Server) GetLogs(ctx context.Context, req *runtimev1.GetLogsRequest) (*runtimev1.GetLogsResponse, error)

GetLogs implements runtimev1.RuntimeServiceServer

func (*Server) GetModelPartitions added in v0.51.0 

func (s *Server) GetModelPartitions(ctx context.Context, req *runtimev1.GetModelPartitionsRequest) (*runtimev1.GetModelPartitionsResponse, error)

GetModelPartitions implements runtimev1.RuntimeServiceServer

func (*Server) GetResource added in v0.32.0 

func (s *Server) GetResource(ctx context.Context, req *runtimev1.GetResourceRequest) (*runtimev1.GetResourceResponse, error)

GetResource implements runtimev1.RuntimeServiceServer

func (*Server) GetTable added in v0.78.0 

func (s *Server) GetTable(ctx context.Context, req *runtimev1.GetTableRequest) (*runtimev1.GetTableResponse, error)

func (*Server) HTTPHandler added in v0.15.0 

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

HTTPHandler returns a HTTP handler that serves REST and gRPC.

func (*Server) Health added in v0.47.0 

func (s *Server) Health(ctx context.Context, req *runtimev1.HealthRequest) (*runtimev1.HealthResponse, error)

Health implements RuntimeService

func (*Server) InstanceHealth added in v0.47.0 

func (s *Server) InstanceHealth(ctx context.Context, req *runtimev1.InstanceHealthRequest) (*runtimev1.InstanceHealthResponse, error)

InstanceHealth implements RuntimeService

func (*Server) IssueDevJWT added in v0.33.0 

func (s *Server) IssueDevJWT(ctx context.Context, req *runtimev1.IssueDevJWTRequest) (*runtimev1.IssueDevJWTResponse, error)

func (*Server) ListBuckets added in v0.78.0 

func (s *Server) ListBuckets(ctx context.Context, req *runtimev1.ListBucketsRequest) (*runtimev1.ListBucketsResponse, error)

func (*Server) ListConnectorDrivers added in v0.43.0 

func (s *Server) ListConnectorDrivers(ctx context.Context, req *runtimev1.ListConnectorDriversRequest) (*runtimev1.ListConnectorDriversResponse, error)

func (*Server) ListConversations added in v0.78.0 

func (s *Server) ListConversations(ctx context.Context, req *runtimev1.ListConversationsRequest) (*runtimev1.ListConversationsResponse, error)

func (*Server) ListDatabaseSchemas added in v0.78.0 

func (s *Server) ListDatabaseSchemas(ctx context.Context, req *runtimev1.ListDatabaseSchemasRequest) (*runtimev1.ListDatabaseSchemasResponse, error)

func (*Server) ListExamples added in v0.26.0 

func (s *Server) ListExamples(ctx context.Context, req *runtimev1.ListExamplesRequest) (*runtimev1.ListExamplesResponse, error)

ListExamples returns a list of embedded examples

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) ListNotifierConnectors added in v0.43.0 

func (s *Server) ListNotifierConnectors(ctx context.Context, req *runtimev1.ListNotifierConnectorsRequest) (*runtimev1.ListNotifierConnectorsResponse, error)

func (*Server) ListObjects added in v0.78.0 

func (s *Server) ListObjects(ctx context.Context, req *runtimev1.ListObjectsRequest) (*runtimev1.ListObjectsResponse, error)

func (*Server) ListResources added in v0.32.0 

func (s *Server) ListResources(ctx context.Context, req *runtimev1.ListResourcesRequest) (*runtimev1.ListResourcesResponse, error)

ListResources implements runtimev1.RuntimeServiceServer

func (*Server) ListTables added in v0.78.0 

func (s *Server) ListTables(ctx context.Context, req *runtimev1.ListTablesRequest) (*runtimev1.ListTablesResponse, error)

func (*Server) ListTools added in v0.78.0 

func (s *Server) ListTools(ctx context.Context, req *runtimev1.ListToolsRequest) (*runtimev1.ListToolsResponse, error)

func (*Server) MetricsViewAggregation added in v0.33.2 

func (s *Server) MetricsViewAggregation(ctx context.Context, req *runtimev1.MetricsViewAggregationRequest) (*runtimev1.MetricsViewAggregationResponse, error)

MetricsViewAggregation implements QueryService.

func (*Server) MetricsViewAnnotations added in v0.78.0 

func (s *Server) MetricsViewAnnotations(ctx context.Context, req *runtimev1.MetricsViewAnnotationsRequest) (*runtimev1.MetricsViewAnnotationsResponse, error)

func (*Server) MetricsViewComparison added in v0.37.0 

func (s *Server) MetricsViewComparison(ctx context.Context, req *runtimev1.MetricsViewComparisonRequest) (*runtimev1.MetricsViewComparisonResponse, error)

MetricsViewComparison implements QueryService.

func (*Server) MetricsViewRows added in v0.24.4 

func (s *Server) MetricsViewRows(ctx context.Context, req *runtimev1.MetricsViewRowsRequest) (*runtimev1.MetricsViewRowsResponse, error)

MetricsViewRows implements QueryService.

func (*Server) MetricsViewSchema added in v0.40.0 

func (s *Server) MetricsViewSchema(ctx context.Context, req *runtimev1.MetricsViewSchemaRequest) (*runtimev1.MetricsViewSchemaResponse, error)

func (*Server) MetricsViewSearch added in v0.47.0 

func (s *Server) MetricsViewSearch(ctx context.Context, req *runtimev1.MetricsViewSearchRequest) (*runtimev1.MetricsViewSearchResponse, error)

func (*Server) MetricsViewTimeRange added in v0.32.0 

func (s *Server) MetricsViewTimeRange(ctx context.Context, req *runtimev1.MetricsViewTimeRangeRequest) (*runtimev1.MetricsViewTimeRangeResponse, error)

MetricsViewTimeRange implements QueryService.

func (*Server) MetricsViewTimeRanges added in v0.54.0 

func (s *Server) MetricsViewTimeRanges(ctx context.Context, req *runtimev1.MetricsViewTimeRangesRequest) (*runtimev1.MetricsViewTimeRangesResponse, error)

func (*Server) MetricsViewTimeSeries 

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

MetricsViewTimeSeries implements QueryService.

func (*Server) MetricsViewToplist 

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

MetricsViewToplist implements QueryService.

func (*Server) MetricsViewTotals 

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

MetricsViewTotals implements QueryService.

func (*Server) OLAPGetTable added in v0.35.0 

func (s *Server) OLAPGetTable(ctx context.Context, req *runtimev1.OLAPGetTableRequest) (*runtimev1.OLAPGetTableResponse, error)

func (*Server) OLAPListTables added in v0.31.0 

func (s *Server) OLAPListTables(ctx context.Context, req *runtimev1.OLAPListTablesRequest) (*runtimev1.OLAPListTablesResponse, error)

func (*Server) Ping 

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

Ping implements RuntimeService

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

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

Query implements QueryService.

func (*Server) QueryBatch added in v0.29.1 

func (s *Server) QueryBatch(req *runtimev1.QueryBatchRequest, srv runtimev1.QueryService_QueryBatchServer) error

func (*Server) QueryResolver added in v0.56.0 

func (s *Server) QueryResolver(ctx context.Context, req *runtimev1.QueryResolverRequest) (*runtimev1.QueryResolverResponse, error)

QueryResolver enables superusers and project admins to query a resolver within a project

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) ResolveCanvas added in v0.53.0 

func (s *Server) ResolveCanvas(ctx context.Context, req *runtimev1.ResolveCanvasRequest) (*runtimev1.ResolveCanvasResponse, error)

func (*Server) ResolveComponent added in v0.49.0 

func (s *Server) ResolveComponent(ctx context.Context, req *runtimev1.ResolveComponentRequest) (*runtimev1.ResolveComponentResponse, error)

func (*Server) ResolveTemplatedString added in v0.78.0 

func (s *Server) ResolveTemplatedString(ctx context.Context, req *runtimev1.ResolveTemplatedStringRequest) (*runtimev1.ResolveTemplatedStringResponse, error)

func (*Server) ServeHTTP added in v0.15.0 

func (s *Server) ServeHTTP(ctx context.Context, registerAdditionalHandlers func(mux *http.ServeMux), local bool) error

Starts the HTTP server.

func (*Server) TableCardinality added in v0.15.0 

func (s *Server) TableCardinality(ctx context.Context, req *runtimev1.TableCardinalityRequest) (*runtimev1.TableCardinalityResponse, error)

Table level profiling APIs.

func (*Server) TableColumns added in v0.22.0 

func (s *Server) TableColumns(ctx context.Context, req *runtimev1.TableColumnsRequest) (*runtimev1.TableColumnsResponse, error)

func (*Server) TableRows added in v0.15.0 

func (s *Server) TableRows(ctx context.Context, req *runtimev1.TableRowsRequest) (*runtimev1.TableRowsResponse, error)

func (*Server) UnpackEmpty added in v0.26.0 

func (s *Server) UnpackEmpty(ctx context.Context, req *runtimev1.UnpackEmptyRequest) (*runtimev1.UnpackEmptyResponse, error)

func (*Server) UnpackExample added in v0.26.0 

func (s *Server) UnpackExample(ctx context.Context, req *runtimev1.UnpackExampleRequest) (*runtimev1.UnpackExampleResponse, error)

func (*Server) UploadMultipartFile added in v0.15.0 

func (s *Server) UploadMultipartFile(w http.ResponseWriter, req *http.Request)

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 

func (s *Server) WatchFiles(req *runtimev1.WatchFilesRequest, ss runtimev1.RuntimeService_WatchFilesServer) error

WatchFiles implements RuntimeService.

func (*Server) WatchFilesHandler added in v0.78.0 

func (s *Server) WatchFilesHandler(w http.ResponseWriter, req *http.Request)

WatchFilesHandler is a HTTP handler for watching local file changes. This is required as vanguard doesn't currently map streaming RPCs to SSE, so we register this handler manually override the behavior

func (*Server) WatchLogs added in v0.32.0 

func (s *Server) WatchLogs(req *runtimev1.WatchLogsRequest, srv runtimev1.RuntimeService_WatchLogsServer) error

WatchLogs implements runtimev1.RuntimeServiceServer

func (*Server) WatchResources added in v0.32.0 

func (s *Server) WatchResources(req *runtimev1.WatchResourcesRequest, ss runtimev1.RuntimeService_WatchResourcesServer) error

WatchResources implements runtimev1.RuntimeServiceServer

func (*Server) WatchResourcesHandler added in v0.78.0 

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

WatchResourcesHandler implements an HTTP handler for runtimev1.RuntimeServiceServer

Source Files

View all Source files

Directories

Path Synopsis

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.