server

package
v1.0.2 Latest Latest
Warning

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

Go to latest
Published: Oct 28, 2021 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TimeLayout = "2006-01-02 15:04:05"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type AuthServer

type AuthServer struct {
	api.UnimplementedAuthServiceServer
}

AuthServer contains logic for checking Authorization of resources in the system

func NewAuthServer

func NewAuthServer() *AuthServer

NewAuthServer creates a new AuthServer

func (*AuthServer) GetAccessToken added in v0.15.0

func (a *AuthServer) GetAccessToken(ctx context.Context, req *api.GetAccessTokenRequest) (res *api.GetAccessTokenResponse, err error)

GetAccessToken is an alias for IsValidToken. It returns a token given a username and hashed token.

func (*AuthServer) IsAuthorized added in v0.8.0

func (a *AuthServer) IsAuthorized(ctx context.Context, request *api.IsAuthorizedRequest) (res *api.IsAuthorizedResponse, err error)

IsAuthorized checks if the provided action is authorized. No token == unauthorized. This is indicated by a nil ctx. Invalid token == unauthorized. Otherwise, we check with k8s using all of the provided data in the request.

func (*AuthServer) IsValidToken

func (a *AuthServer) IsValidToken(ctx context.Context, req *api.IsValidTokenRequest) (res *api.IsValidTokenResponse, err error)

IsValidToken returns the appropriate token information given an md5 version of the token Deprecated: Use GetAccessToken instead

type ConfigServer added in v0.11.0

type ConfigServer struct {
	api.UnimplementedConfigServiceServer
}

ConfigServer contains actions for system configuration related items

func NewConfigServer added in v0.11.0

func NewConfigServer() *ConfigServer

NewConfigServer creates a new ConfigServer

func (*ConfigServer) GetConfig added in v0.11.0

func (c *ConfigServer) GetConfig(ctx context.Context, req *empty.Empty) (*api.GetConfigResponse, error)

GetConfig returns the system configuration options

func (*ConfigServer) GetNamespaceConfig added in v0.18.0

GetNamespaceConfig returns the namespace configuration

type CronWorkflowServer

type CronWorkflowServer struct {
	api.UnimplementedCronWorkflowServiceServer
}

CronWorkflowServer is an implementation of the grpc CronWorkflowServer

func NewCronWorkflowServer

func NewCronWorkflowServer() *CronWorkflowServer

NewCronWorkflowServer creates a new CronWorkflowServer

func (*CronWorkflowServer) CreateCronWorkflow

func (*CronWorkflowServer) DeleteCronWorkflow added in v0.8.0

func (c *CronWorkflowServer) DeleteCronWorkflow(ctx context.Context, req *api.DeleteCronWorkflowRequest) (*empty.Empty, error)

func (*CronWorkflowServer) GetCronWorkflow

func (*CronWorkflowServer) ListCronWorkflows

func (*CronWorkflowServer) UpdateCronWorkflow

type FileServer added in v1.0.0

type FileServer struct {
	api.UnimplementedFileServiceServer
}

FileServer is an implementation of the grpc WorkflowServer

func NewFileServer added in v1.0.0

func NewFileServer() *FileServer

NewFileServer creates a new FileServer

func (*FileServer) GetObjectDownloadPresignedURL added in v1.0.0

func (s *FileServer) GetObjectDownloadPresignedURL(ctx context.Context, req *api.GetObjectPresignedUrlRequest) (*api.GetPresignedUrlResponse, error)

GetObjectDownloadPresignedURL returns a downloadable url for a given object

func (*FileServer) ListFiles added in v1.0.0

ListFiles returns a list of files from the configured cloud storage Directories come first, and then it is sorted alphabetically

type InferenceServiceServer added in v1.0.0

type InferenceServiceServer struct {
	api.UnimplementedInferenceServiceServer
}

InferenceServiceServer is an implementation of the grpc InferenceServiceServer

func NewInferenceService added in v1.0.0

func NewInferenceService() *InferenceServiceServer

NewInferenceService creates a new InferenceServiceServer

func (*InferenceServiceServer) CreateInferenceService added in v1.0.0

CreateInferenceService deploys an inference service

func (*InferenceServiceServer) DeleteInferenceService added in v1.0.0

func (s *InferenceServiceServer) DeleteInferenceService(ctx context.Context, req *api.InferenceServiceIdentifier) (*empty.Empty, error)

DeleteInferenceService deletes an inference service

func (*InferenceServiceServer) GetInferenceService added in v1.0.0

GetInferenceService returns the status of an inferenceservice

type LabelServer

type LabelServer struct {
	api.UnimplementedLabelServiceServer
}

LabelServer is an implementation of the grpc LabelServer

func NewLabelServer

func NewLabelServer() *LabelServer

NewLabelServer creates a new LabelServer

func (*LabelServer) AddLabels

func (*LabelServer) DeleteLabel

func (*LabelServer) GetAvailableLabels added in v0.15.0

func (s *LabelServer) GetAvailableLabels(ctx context.Context, req *api.GetAvailableLabelsRequest) (*api.GetLabelsResponse, error)

GetAvailableLabels returns the labels available for a resource specified by the GetAvailableLabelsRequest

func (*LabelServer) GetLabels

func (*LabelServer) ReplaceLabels

type NamespaceServer

type NamespaceServer struct {
	api.UnimplementedNamespaceServiceServer
}

NamespaceServer is an implementation of the grpc NamespaceServer

func NewNamespaceServer

func NewNamespaceServer() *NamespaceServer

NewNamespaceServer creates a new NamespaceServer

func (*NamespaceServer) CreateNamespace

func (s *NamespaceServer) CreateNamespace(ctx context.Context, createNamespace *api.CreateNamespaceRequest) (*api.Namespace, error)

CreateNamespace creates a new namespace in the system

func (*NamespaceServer) ListNamespaces

ListNamespaces returns a list of all namespaces available in the system

type SecretServer

type SecretServer struct {
	api.UnimplementedSecretServiceServer
}

SecretServer is an implementation of the grpc SecretServer

func NewSecretServer

func NewSecretServer() *SecretServer

NewSecretServer creates a new SecretServer

func (*SecretServer) AddSecretKeyValue

func (s *SecretServer) AddSecretKeyValue(ctx context.Context, req *api.AddSecretKeyValueRequest) (updated *api.AddSecretKeyValueResponse, err error)

func (*SecretServer) CreateSecret

func (s *SecretServer) CreateSecret(ctx context.Context, req *api.CreateSecretRequest) (*empty.Empty, error)

func (*SecretServer) DeleteSecret

func (s *SecretServer) DeleteSecret(ctx context.Context, req *api.DeleteSecretRequest) (deleted *api.DeleteSecretResponse, err error)

func (*SecretServer) DeleteSecretKey

func (s *SecretServer) DeleteSecretKey(ctx context.Context, req *api.DeleteSecretKeyRequest) (deleted *api.DeleteSecretKeyResponse, err error)

func (*SecretServer) GetSecret

func (s *SecretServer) GetSecret(ctx context.Context, req *api.GetSecretRequest) (*api.Secret, error)

func (*SecretServer) ListSecrets

func (*SecretServer) SecretExists

func (s *SecretServer) SecretExists(ctx context.Context, req *api.SecretExistsRequest) (secretExists *api.SecretExistsResponse, err error)

func (*SecretServer) UpdateSecretKeyValue

func (s *SecretServer) UpdateSecretKeyValue(ctx context.Context, req *api.UpdateSecretKeyValueRequest) (updated *api.UpdateSecretKeyValueResponse, err error)

type ServiceServer added in v0.12.0

type ServiceServer struct {
	api.UnimplementedServiceServiceServer
}

ServiceServer contains actions for installed services

func NewServiceServer added in v0.12.0

func NewServiceServer() *ServiceServer

NewServiceServer creates a new ServiceServer

func (*ServiceServer) GetService added in v0.12.0

func (c *ServiceServer) GetService(ctx context.Context, req *api.GetServiceRequest) (*api.Service, error)

GetService returns a particular service identified by name

func (*ServiceServer) HasService added in v1.0.0

HasService checks if the cluster has a service set up and enabled

func (*ServiceServer) ListServices added in v0.12.0

ListServices returns all of the services in the system

type WorkflowServer

type WorkflowServer struct {
	api.UnimplementedWorkflowServiceServer
}

WorkflowServer is an implementation of the grpc WorkflowServer

func NewWorkflowServer

func NewWorkflowServer() *WorkflowServer

NewWorkflowServer creates a new WorkflowServer

func (*WorkflowServer) AddWorkflowExecutionMetrics added in v0.16.0

AddWorkflowExecutionMetrics merges the input metrics for the workflow execution identified by (namespace,uid)

func (*WorkflowServer) AddWorkflowExecutionStatistics

func (s *WorkflowServer) AddWorkflowExecutionStatistics(ctx context.Context, req *api.AddWorkflowExecutionStatisticRequest) (*empty.Empty, error)

func (*WorkflowServer) CloneWorkflowExecution

func (s *WorkflowServer) CloneWorkflowExecution(ctx context.Context, req *api.CloneWorkflowExecutionRequest) (*api.WorkflowExecution, error)

func (*WorkflowServer) CreateWorkflowExecution

func (s *WorkflowServer) CreateWorkflowExecution(ctx context.Context, req *api.CreateWorkflowExecutionRequest) (*api.WorkflowExecution, error)

func (*WorkflowServer) CronStartWorkflowExecutionStatistic

func (s *WorkflowServer) CronStartWorkflowExecutionStatistic(ctx context.Context, req *api.CronStartWorkflowExecutionStatisticRequest) (*empty.Empty, error)

@todo we should not pass in an id into the request. instead pass in the cron workflow uid, we can load the cron workflow from db that way and get all required data.

func (*WorkflowServer) GetWorkflowExecution

func (*WorkflowServer) GetWorkflowExecutionStatisticsForNamespace added in v0.13.0

GetWorkflowExecutionStatisticsForNamespace returns statistics on workflow executions for a given namespace

func (*WorkflowServer) ListWorkflowExecutions

ListWorkflowExecutions returns a list of workflow executions that are specified by the criteria in the ListWorkflowExecutionsRequest

func (*WorkflowServer) ListWorkflowExecutionsField added in v0.19.0

ListWorkflowExecutionsField returns a list of all the distinct values of a field from WorkflowExecutions

func (*WorkflowServer) ResubmitWorkflowExecution

func (s *WorkflowServer) ResubmitWorkflowExecution(ctx context.Context, req *api.ResubmitWorkflowExecutionRequest) (*api.WorkflowExecution, error)

func (*WorkflowServer) TerminateWorkflowExecution

func (s *WorkflowServer) TerminateWorkflowExecution(ctx context.Context, req *api.TerminateWorkflowExecutionRequest) (*empty.Empty, error)

func (*WorkflowServer) UpdateWorkflowExecutionMetrics added in v0.16.0

UpdateWorkflowExecutionMetrics replaces the metrics with the input metrics for the workflow identified by (namespace, uid)

func (*WorkflowServer) UpdateWorkflowExecutionStatus added in v0.8.0

func (s *WorkflowServer) UpdateWorkflowExecutionStatus(ctx context.Context, req *api.UpdateWorkflowExecutionStatusRequest) (*empty.Empty, error)

type WorkflowTemplateServer

type WorkflowTemplateServer struct {
	api.UnimplementedWorkflowTemplateServiceServer
}

WorkflowTemplateServer is an implementation of the grpc WorkflowTemplateServer

func NewWorkflowTemplateServer

func NewWorkflowTemplateServer() *WorkflowTemplateServer

NewWorkflowTemplateServer creates a new WorkflowTemplateServer

func (*WorkflowTemplateServer) ArchiveWorkflowTemplate

func (*WorkflowTemplateServer) CloneWorkflowTemplate

func (*WorkflowTemplateServer) CreateWorkflowTemplate

CreateWorkflowTemplate creates a workflow template and the initial version

func (*WorkflowTemplateServer) CreateWorkflowTemplateVersion

func (s *WorkflowTemplateServer) CreateWorkflowTemplateVersion(ctx context.Context, req *api.CreateWorkflowTemplateRequest) (*api.WorkflowTemplate, error)

func (*WorkflowTemplateServer) GenerateWorkflowTemplate added in v0.17.0

GenerateWorkflowTemplate generates a workflow template, applying any modifications based on the content of the manifest

func (*WorkflowTemplateServer) GetWorkflowTemplate

func (*WorkflowTemplateServer) ListWorkflowTemplates

func (*WorkflowTemplateServer) ListWorkflowTemplatesField added in v0.19.0

ListWorkflowTemplatesField returns a list of all the distinct values of a field from WorkflowTemplates

type WorkspaceServer

type WorkspaceServer struct {
	api.UnimplementedWorkspaceServiceServer
}

WorkspaceServer is an implementation of the grpc WorkspaceServer

func NewWorkspaceServer

func NewWorkspaceServer() *WorkspaceServer

NewWorkspaceServer creates a new WorkspaceServer

func (*WorkspaceServer) CreateWorkspace

func (s *WorkspaceServer) CreateWorkspace(ctx context.Context, req *api.CreateWorkspaceRequest) (*api.Workspace, error)

CreateWorkspace create a workspace

func (*WorkspaceServer) DeleteWorkspace

func (s *WorkspaceServer) DeleteWorkspace(ctx context.Context, req *api.DeleteWorkspaceRequest) (*empty.Empty, error)

DeleteWorkspace requests to delete a workspace

func (*WorkspaceServer) GetWorkspace added in v0.8.0

func (s *WorkspaceServer) GetWorkspace(ctx context.Context, req *api.GetWorkspaceRequest) (*api.Workspace, error)

GetWorkspace returns Workspace information

func (*WorkspaceServer) GetWorkspaceContainerLogs added in v0.18.0

GetWorkspaceContainerLogs returns logs for a given container name in a Workspace

func (*WorkspaceServer) GetWorkspaceStatisticsForNamespace added in v0.13.0

GetWorkspaceStatisticsForNamespace returns statistics on workflow executions for a given namespace

func (*WorkspaceServer) ListWorkspaces

ListWorkspaces lists the current workspaces for a given namespace

func (*WorkspaceServer) ListWorkspacesField added in v0.19.0

ListWorkspacesField returns a list of all the distinct values of a field from Workspaces

func (*WorkspaceServer) PauseWorkspace

func (s *WorkspaceServer) PauseWorkspace(ctx context.Context, req *api.PauseWorkspaceRequest) (*empty.Empty, error)

PauseWorkspace requests to pause a given workspace

func (*WorkspaceServer) ResumeWorkspace added in v0.8.0

func (s *WorkspaceServer) ResumeWorkspace(ctx context.Context, req *api.ResumeWorkspaceRequest) (*empty.Empty, error)

ResumeWorkspace attempts to resume a workspace

func (*WorkspaceServer) RetryLastWorkspaceAction added in v0.13.0

func (s *WorkspaceServer) RetryLastWorkspaceAction(ctx context.Context, req *api.RetryActionWorkspaceRequest) (*empty.Empty, error)

RetryLastWorkspaceAction will attempt the last action on the workspace again.

func (*WorkspaceServer) UpdateWorkspace added in v0.8.0

func (s *WorkspaceServer) UpdateWorkspace(ctx context.Context, req *api.UpdateWorkspaceRequest) (*empty.Empty, error)

UpdateWorkspace updates a workspace's status

func (*WorkspaceServer) UpdateWorkspaceStatus

func (s *WorkspaceServer) UpdateWorkspaceStatus(ctx context.Context, req *api.UpdateWorkspaceStatusRequest) (*empty.Empty, error)

UpdateWorkspaceStatus updates a given workspaces status such as running, paused, etc.

type WorkspaceTemplateServer

type WorkspaceTemplateServer struct {
	api.UnimplementedWorkspaceTemplateServiceServer
}

WorkspaceTemplateServer is an implementation of the grpc WorkspaceTemplateServer

func NewWorkspaceTemplateServer

func NewWorkspaceTemplateServer() *WorkspaceTemplateServer

NewWorkspaceTemplateServer creates a new WorkspaceTemplateServer

func (*WorkspaceTemplateServer) ArchiveWorkspaceTemplate added in v0.8.0

func (*WorkspaceTemplateServer) CreateWorkspaceTemplate

func (WorkspaceTemplateServer) GenerateWorkspaceTemplateWorkflowTemplate

func (s WorkspaceTemplateServer) GenerateWorkspaceTemplateWorkflowTemplate(ctx context.Context, req *api.GenerateWorkspaceTemplateWorkflowTemplateRequest) (*api.WorkflowTemplate, error)

func (*WorkspaceTemplateServer) GetWorkspaceTemplate

func (*WorkspaceTemplateServer) ListWorkspaceTemplates

func (*WorkspaceTemplateServer) ListWorkspaceTemplatesField added in v0.19.0

ListWorkspaceTemplatesField returns a list of all the distinct values of a field from WorkspaceTemplates

func (*WorkspaceTemplateServer) UpdateWorkspaceTemplate

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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