server

package
v0.14.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Server 

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

func NewServer 

func NewServer(opts *ServerOptions, metastore drivers.Connection, logger *zap.Logger) (*Server, error)

func (*Server) CreateInstance 

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

CreateInstance implements RuntimeService

func (*Server) CreateRepo 

func (s *Server) CreateRepo(ctx context.Context, req *api.CreateRepoRequest) (*api.CreateRepoResponse, error)

CreateRepo implements RuntimeService

func (*Server) DeleteInstance 

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

DeleteInstance implements RuntimeService

func (*Server) DeleteRepo 

func (s *Server) DeleteRepo(ctx context.Context, req *api.DeleteRepoRequest) (*api.DeleteRepoResponse, error)

DeleteRepo implements RuntimeService

func (*Server) GetCatalogObject 

func (s *Server) GetCatalogObject(ctx context.Context, req *api.GetCatalogObjectRequest) (*api.GetCatalogObjectResponse, error)

GetCatalogObject implements RuntimeService

func (*Server) GetInstance 

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

GetInstance implements RuntimeService

func (*Server) GetRepo 

func (s *Server) GetRepo(ctx context.Context, req *api.GetRepoRequest) (*api.GetRepoResponse, error)

GetRepo implements RuntimeService

func (*Server) GetRepoObject 

func (s *Server) GetRepoObject(ctx context.Context, req *api.GetRepoObjectRequest) (*api.GetRepoObjectResponse, error)

GetRepoObject implements RuntimeService

func (*Server) GetTopK added in v0.14.0 

func (s *Server) GetTopK(ctx context.Context, topKRequest *api.TopKRequest) (*api.TopKResponse, error)

func (*Server) ListCatalogObjects 

func (s *Server) ListCatalogObjects(ctx context.Context, req *api.ListCatalogObjectsRequest) (*api.ListCatalogObjectsResponse, error)

ListCatalogObjects implements RuntimeService

func (*Server) ListConnectors 

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

ListConnectors implements RuntimeService

func (*Server) ListInstances 

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

ListInstances implements RuntimeService

func (*Server) ListRepoObjects 

func (s *Server) ListRepoObjects(ctx context.Context, req *api.ListRepoObjectsRequest) (*api.ListRepoObjectsResponse, error)

ListRepoObjects implements RuntimeService

func (*Server) ListRepos 

func (s *Server) ListRepos(ctx context.Context, req *api.ListReposRequest) (*api.ListReposResponse, error)

ListRepos implements RuntimeService

func (*Server) MetricsViewMeta 

func (s *Server) MetricsViewMeta(
	ctx context.Context,
	req *api.MetricsViewMetaRequest,
) (*api.MetricsViewMetaResponse, error)

MetricsViewMeta implements RuntimeService

func (*Server) MetricsViewTimeSeries 

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

MetricsViewTimeSeries implements RuntimeService

func (*Server) MetricsViewToplist 

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

MetricsViewToplist implements RuntimeService

func (*Server) MetricsViewTotals 

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

MetricsViewTotals implements RuntimeService

func (*Server) Migrate 

func (s *Server) Migrate(ctx context.Context, req *api.MigrateRequest) (*api.MigrateResponse, error)

Migrate implements RuntimeService

func (*Server) MigrateDelete 

func (s *Server) MigrateDelete(ctx context.Context, req *api.MigrateDeleteRequest) (*api.MigrateDeleteResponse, error)

MigrateDelete implements RuntimeService

func (*Server) MigrateSingle 

func (s *Server) MigrateSingle(ctx context.Context, req *api.MigrateSingleRequest) (*api.MigrateSingleResponse, error)

MigrateSingle implements RuntimeService NOTE: This is an initial migration implementation with several flaws.

func (*Server) Ping 

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

Ping implements RuntimeService

func (*Server) PutRepoObject 

func (s *Server) PutRepoObject(ctx context.Context, req *api.PutRepoObjectRequest) (*api.PutRepoObjectResponse, error)

PutRepoObject implements RuntimeService

func (*Server) PutRepoObjectFromHTTPRequest added in v0.13.0 

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

func (*Server) Query 

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

Query implements RuntimeService

func (*Server) QueryDirect 

func (s *Server) QueryDirect(ctx context.Context, req *api.QueryDirectRequest) (*api.QueryDirectResponse, error)

QueryDirect implements RuntimeService

func (*Server) Serve 

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

Serve starts a gRPC server and a gRPC REST gateway server

func (*Server) TriggerRefresh 

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

TriggerRefresh implements RuntimeService

type ServerOptions 

type ServerOptions struct {
	HTTPPort            int
	GRPCPort            int
	ConnectionCacheSize int
}

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.