handlers

package
v0.0.0-...-5db4967 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ComputePlanServer 

type ComputePlanServer struct {
	asset.UnimplementedComputePlanServiceServer
}

func NewComputePlanServer 

func NewComputePlanServer() *ComputePlanServer

func (*ComputePlanServer) ApplyPlanAction 

func (s *ComputePlanServer) ApplyPlanAction(ctx context.Context, param *asset.ApplyPlanActionParam) (*asset.ApplyPlanActionResponse, error)

func (*ComputePlanServer) GetPlan 

func (s *ComputePlanServer) GetPlan(ctx context.Context, param *asset.GetComputePlanParam) (*asset.ComputePlan, error)

func (*ComputePlanServer) IsPlanRunning 

func (s *ComputePlanServer) IsPlanRunning(ctx context.Context, param *asset.IsPlanRunningParam) (*asset.IsPlanRunningResponse, error)

func (*ComputePlanServer) QueryPlans 

func (s *ComputePlanServer) QueryPlans(ctx context.Context, param *asset.QueryPlansParam) (*asset.QueryPlansResponse, error)

func (*ComputePlanServer) RegisterPlan 

func (s *ComputePlanServer) RegisterPlan(ctx context.Context, in *asset.NewComputePlan) (*asset.ComputePlan, error)

func (*ComputePlanServer) UpdatePlan 

func (s *ComputePlanServer) UpdatePlan(ctx context.Context, params *asset.UpdateComputePlanParam) (*asset.UpdateComputePlanResponse, error)

UpdatePlan will update mutable fields of the existing ComputePlan. List of mutable fields: name.

type ComputeTaskServer 

type ComputeTaskServer struct {
	asset.UnimplementedComputeTaskServiceServer
}

ComputeTaskServer is the gRPC server exposing ComputeTask actions

func NewComputeTaskServer 

func NewComputeTaskServer() *ComputeTaskServer

NewComputeTaskServer creates a Server

func (*ComputeTaskServer) ApplyTaskAction 

func (s *ComputeTaskServer) ApplyTaskAction(ctx context.Context, param *asset.ApplyTaskActionParam) (*asset.ApplyTaskActionResponse, error)

func (*ComputeTaskServer) DisableOutput 

func (s *ComputeTaskServer) DisableOutput(ctx context.Context, param *asset.DisableOutputParam) (*asset.DisableOutputResponse, error)

func (*ComputeTaskServer) GetTask 

func (s *ComputeTaskServer) GetTask(ctx context.Context, in *asset.GetTaskParam) (*asset.ComputeTask, error)

func (*ComputeTaskServer) GetTaskInputAssets 

func (s *ComputeTaskServer) GetTaskInputAssets(ctx context.Context, param *asset.GetTaskInputAssetsParam) (*asset.GetTaskInputAssetsResponse, error)

func (*ComputeTaskServer) QueryTasks 

func (s *ComputeTaskServer) QueryTasks(ctx context.Context, in *asset.QueryTasksParam) (*asset.QueryTasksResponse, error)

func (*ComputeTaskServer) RegisterTasks 

func (s *ComputeTaskServer) RegisterTasks(ctx context.Context, input *asset.RegisterTasksParam) (*asset.RegisterTasksResponse, error)

type DataManagerServer 

type DataManagerServer struct {
	asset.UnimplementedDataManagerServiceServer
}

DataManagerServer is the gRPC facade to DataManager manipulation

func NewDataManagerServer 

func NewDataManagerServer() *DataManagerServer

NewDataManagerServer creates a gRPC server

func (*DataManagerServer) GetDataManager 

func (s *DataManagerServer) GetDataManager(ctx context.Context, params *asset.GetDataManagerParam) (*asset.DataManager, error)

GetDataManager fetches a datamanager by its key

func (*DataManagerServer) QueryDataManagers 

func (s *DataManagerServer) QueryDataManagers(ctx context.Context, params *asset.QueryDataManagersParam) (*asset.QueryDataManagersResponse, error)

QueryDataManagers returns a paginated list of all known datamanagers

func (*DataManagerServer) RegisterDataManager 

func (s *DataManagerServer) RegisterDataManager(ctx context.Context, d *asset.NewDataManager) (*asset.DataManager, error)

RegisterDataManager will persist new DataManagers

func (*DataManagerServer) UpdateDataManager 

func (s *DataManagerServer) UpdateDataManager(ctx context.Context, params *asset.UpdateDataManagerParam) (*asset.UpdateDataManagerResponse, error)

UpdateDataManager will update mutable fields of the existing DataManager. List of mutable fields: name.

type DataSampleServer 

type DataSampleServer struct {
	asset.UnimplementedDataSampleServiceServer
}

DataSampleServer is the gRPC facade to DataSample manipulation

func NewDataSampleServer 

func NewDataSampleServer() *DataSampleServer

NewDataSampleServer creates a gRPC server

func (*DataSampleServer) GetDataSample 

func (s *DataSampleServer) GetDataSample(ctx context.Context, params *asset.GetDataSampleParam) (*asset.DataSample, error)

GetDataSample fetches a datasample by its key

func (*DataSampleServer) QueryDataSamples 

func (s *DataSampleServer) QueryDataSamples(ctx context.Context, params *asset.QueryDataSamplesParam) (*asset.QueryDataSamplesResponse, error)

QueryDataSamples returns a paginated list of all known datasamples

func (*DataSampleServer) RegisterDataSamples 

func (s *DataSampleServer) RegisterDataSamples(ctx context.Context, input *asset.RegisterDataSamplesParam) (*asset.RegisterDataSamplesResponse, error)

RegisterDataSamples will persist new DataSamples

func (*DataSampleServer) UpdateDataSamples 

func (s *DataSampleServer) UpdateDataSamples(ctx context.Context, datasample *asset.UpdateDataSamplesParam) (*asset.UpdateDataSamplesResponse, error)

UpdateDataSamples will update the datamanagers existing DataSamples

type DatasetServer 

type DatasetServer struct {
	asset.UnimplementedDatasetServiceServer
}

DatasetServer is the gRPC facade to Dataset manipulation

func NewDatasetServer 

func NewDatasetServer() *DatasetServer

NewDatasetServer creates a gRPC server

func (*DatasetServer) GetDataset 

func (s *DatasetServer) GetDataset(ctx context.Context, params *asset.GetDatasetParam) (*asset.Dataset, error)

GetDataset fetches a dataset by its key

type EventServer 

type EventServer struct {
	asset.UnimplementedEventServiceServer
}

EventServer is the gRPC facade to Model manipulation

func NewEventServer 

func NewEventServer() *EventServer

NewEventServer creates a grpc server

func (*EventServer) QueryEvents 

func (s *EventServer) QueryEvents(ctx context.Context, params *asset.QueryEventsParam) (*asset.QueryEventsResponse, error)

func (*EventServer) SubscribeToEvents 

func (s *EventServer) SubscribeToEvents(param *asset.SubscribeToEventsParam, stream asset.EventService_SubscribeToEventsServer) error

type FailureReportServer 

type FailureReportServer struct {
	asset.UnimplementedFailureReportServiceServer
}

FailureReportServer is the gRPC facade to FailureReport manipulation

func NewFailureReportServer 

func NewFailureReportServer() *FailureReportServer

NewFailureReportServer creates a gRPC server

func (*FailureReportServer) GetFailureReport 

func (s *FailureReportServer) GetFailureReport(ctx context.Context, in *asset.GetFailureReportParam) (*asset.FailureReport, error)

func (*FailureReportServer) RegisterFailureReport 

func (s *FailureReportServer) RegisterFailureReport(ctx context.Context, newFailureReport *asset.NewFailureReport) (*asset.FailureReport, error)

type FunctionServer 

type FunctionServer struct {
	asset.UnimplementedFunctionServiceServer
}

FunctionServer is the gRPC facade to Function manipulation

func NewFunctionServer 

func NewFunctionServer() *FunctionServer

NewFunctionServer creates a grpc server

func (*FunctionServer) ApplyFunctionAction 

func (s *FunctionServer) ApplyFunctionAction(ctx context.Context, param *asset.ApplyFunctionActionParam) (*asset.ApplyFunctionActionResponse, error)

func (*FunctionServer) GetFunction 

func (s *FunctionServer) GetFunction(ctx context.Context, params *asset.GetFunctionParam) (*asset.Function, error)

GetFunction fetches an function by its key

func (*FunctionServer) QueryFunctions 

func (s *FunctionServer) QueryFunctions(ctx context.Context, params *asset.QueryFunctionsParam) (*asset.QueryFunctionsResponse, error)

QueryFunctions returns a paginated list of all known functions

func (*FunctionServer) RegisterFunction 

func (s *FunctionServer) RegisterFunction(ctx context.Context, a *asset.NewFunction) (*asset.Function, error)

RegisterFunction will persist a new function

func (*FunctionServer) UpdateFunction 

func (s *FunctionServer) UpdateFunction(ctx context.Context, params *asset.UpdateFunctionParam) (*asset.UpdateFunctionResponse, error)

UpdateFunction will update mutable fields of the existing Function. List of mutable fields: name.

type InfoServer 

type InfoServer struct {
	asset.UnimplementedInfoServiceServer
}

InfoServer is the gRPC server exposing info actions

func NewInfoServer 

func NewInfoServer() *InfoServer

NewInfoServer creates a Server

func (*InfoServer) QueryVersion 

func (s *InfoServer) QueryVersion(ctx context.Context, in *asset.QueryVersionParam) (*asset.QueryVersionResponse, error)

type ModelServer 

type ModelServer struct {
	asset.UnimplementedModelServiceServer
}

ModelServer is the gRPC facade to Model manipulation

func NewModelServer 

func NewModelServer() *ModelServer

NewModelServer creates a grpc server

func (*ModelServer) GetComputeTaskOutputModels 

func (s *ModelServer) GetComputeTaskOutputModels(ctx context.Context, param *asset.GetComputeTaskModelsParam) (*asset.GetComputeTaskModelsResponse, error)

func (*ModelServer) GetModel 

func (s *ModelServer) GetModel(ctx context.Context, in *asset.GetModelParam) (*asset.Model, error)

func (*ModelServer) RegisterModel 

func (s *ModelServer) RegisterModel(ctx context.Context, newModel *asset.NewModel) (*asset.Model, error)

func (*ModelServer) RegisterModels 

func (s *ModelServer) RegisterModels(ctx context.Context, param *asset.RegisterModelsParam) (*asset.RegisterModelsResponse, error)

type OrganizationServer 

type OrganizationServer struct {
	asset.UnimplementedOrganizationServiceServer
}

OrganizationServer is the gRPC server exposing organization actions

func NewOrganizationServer 

func NewOrganizationServer() *OrganizationServer

NewOrganizationServer creates a Server

func (*OrganizationServer) GetAllOrganizations 

func (s *OrganizationServer) GetAllOrganizations(ctx context.Context, in *asset.GetAllOrganizationsParam) (*asset.GetAllOrganizationsResponse, error)

GetAllOrganizations will return all known organizations

func (*OrganizationServer) RegisterOrganization 

func (s *OrganizationServer) RegisterOrganization(ctx context.Context, in *asset.RegisterOrganizationParam) (*asset.Organization, error)

RegisterOrganization will add a new organization to the network

type PerformanceServer 

type PerformanceServer struct {
	asset.UnimplementedPerformanceServiceServer
}

PerformanceServer is the gRPC facade to Performance manipulation

func NewPerformanceServer 

func NewPerformanceServer() *PerformanceServer

NewPerformanceServer creates a grpc server

func (*PerformanceServer) QueryPerformances 

func (s *PerformanceServer) QueryPerformances(ctx context.Context, param *asset.QueryPerformancesParam) (*asset.QueryPerformancesResponse, error)

func (*PerformanceServer) RegisterPerformance 

func (s *PerformanceServer) RegisterPerformance(ctx context.Context, newPerf *asset.NewPerformance) (*asset.Performance, error)

type ProfilingServer 

type ProfilingServer struct {
	asset.UnimplementedProfilingServiceServer
}

ProfilingServer is the gRPC facade to Profiling manipulation

func NewProfilingServer 

func NewProfilingServer() *ProfilingServer

NewProfilingServer creates a grpc server

func (*ProfilingServer) RegisterProfilingStep 

func (s *ProfilingServer) RegisterProfilingStep(ctx context.Context, ps *asset.ProfilingStep) (*emptypb.Empty, error)

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.