Documentation ¶
Index ¶
- Constants
- type AuthServer
- func (a *AuthServer) GetAccessToken(ctx context.Context, req *api.GetAccessTokenRequest) (res *api.GetAccessTokenResponse, err error)
- func (a *AuthServer) IsAuthorized(ctx context.Context, request *api.IsAuthorizedRequest) (res *api.IsAuthorizedResponse, err error)
- func (a *AuthServer) IsValidToken(ctx context.Context, req *api.IsValidTokenRequest) (res *api.IsValidTokenResponse, err error)
- type ConfigServer
- type CronWorkflowServer
- func (c *CronWorkflowServer) CreateCronWorkflow(ctx context.Context, req *api.CreateCronWorkflowRequest) (*api.CronWorkflow, error)
- func (c *CronWorkflowServer) DeleteCronWorkflow(ctx context.Context, req *api.DeleteCronWorkflowRequest) (*empty.Empty, error)
- func (c *CronWorkflowServer) GetCronWorkflow(ctx context.Context, req *api.GetCronWorkflowRequest) (*api.CronWorkflow, error)
- func (c *CronWorkflowServer) ListCronWorkflows(ctx context.Context, req *api.ListCronWorkflowRequest) (*api.ListCronWorkflowsResponse, error)
- func (c *CronWorkflowServer) UpdateCronWorkflow(ctx context.Context, req *api.UpdateCronWorkflowRequest) (*api.CronWorkflow, error)
- type FileServer
- type InferenceServiceServer
- func (s *InferenceServiceServer) CreateInferenceService(ctx context.Context, req *api.CreateInferenceServiceRequest) (*api.GetInferenceServiceResponse, error)
- func (s *InferenceServiceServer) DeleteInferenceService(ctx context.Context, req *api.InferenceServiceIdentifier) (*empty.Empty, error)
- func (s *InferenceServiceServer) GetInferenceService(ctx context.Context, req *api.InferenceServiceIdentifier) (*api.GetInferenceServiceResponse, error)
- type LabelServer
- func (s *LabelServer) AddLabels(ctx context.Context, req *api.AddLabelsRequest) (*api.GetLabelsResponse, error)
- func (s *LabelServer) DeleteLabel(ctx context.Context, req *api.DeleteLabelRequest) (*api.GetLabelsResponse, error)
- func (s *LabelServer) GetAvailableLabels(ctx context.Context, req *api.GetAvailableLabelsRequest) (*api.GetLabelsResponse, error)
- func (s *LabelServer) GetLabels(ctx context.Context, req *api.GetLabelsRequest) (*api.GetLabelsResponse, error)
- func (s *LabelServer) ReplaceLabels(ctx context.Context, req *api.ReplaceLabelsRequest) (*api.GetLabelsResponse, error)
- type NamespaceServer
- type SecretServer
- func (s *SecretServer) AddSecretKeyValue(ctx context.Context, req *api.AddSecretKeyValueRequest) (updated *api.AddSecretKeyValueResponse, err error)
- func (s *SecretServer) CreateSecret(ctx context.Context, req *api.CreateSecretRequest) (*empty.Empty, error)
- func (s *SecretServer) DeleteSecret(ctx context.Context, req *api.DeleteSecretRequest) (deleted *api.DeleteSecretResponse, err error)
- func (s *SecretServer) DeleteSecretKey(ctx context.Context, req *api.DeleteSecretKeyRequest) (deleted *api.DeleteSecretKeyResponse, err error)
- func (s *SecretServer) GetSecret(ctx context.Context, req *api.GetSecretRequest) (*api.Secret, error)
- func (s *SecretServer) ListSecrets(ctx context.Context, req *api.ListSecretsRequest) (*api.ListSecretsResponse, error)
- func (s *SecretServer) SecretExists(ctx context.Context, req *api.SecretExistsRequest) (secretExists *api.SecretExistsResponse, err error)
- func (s *SecretServer) UpdateSecretKeyValue(ctx context.Context, req *api.UpdateSecretKeyValueRequest) (updated *api.UpdateSecretKeyValueResponse, err error)
- type ServiceServer
- func (c *ServiceServer) GetService(ctx context.Context, req *api.GetServiceRequest) (*api.Service, error)
- func (c *ServiceServer) HasService(ctx context.Context, req *api.HasServiceRequest) (*api.HasServiceResponse, error)
- func (c *ServiceServer) ListServices(ctx context.Context, req *api.ListServicesRequest) (*api.ListServicesResponse, error)
- type WorkflowServer
- func (s *WorkflowServer) AddWorkflowExecutionMetrics(ctx context.Context, req *api.AddWorkflowExecutionsMetricsRequest) (*api.WorkflowExecutionsMetricsResponse, error)
- func (s *WorkflowServer) AddWorkflowExecutionStatistics(ctx context.Context, req *api.AddWorkflowExecutionStatisticRequest) (*empty.Empty, error)
- func (s *WorkflowServer) CloneWorkflowExecution(ctx context.Context, req *api.CloneWorkflowExecutionRequest) (*api.WorkflowExecution, error)
- func (s *WorkflowServer) CreateWorkflowExecution(ctx context.Context, req *api.CreateWorkflowExecutionRequest) (*api.WorkflowExecution, error)
- func (s *WorkflowServer) CronStartWorkflowExecutionStatistic(ctx context.Context, req *api.CronStartWorkflowExecutionStatisticRequest) (*empty.Empty, error)
- func (s *WorkflowServer) GetWorkflowExecution(ctx context.Context, req *api.GetWorkflowExecutionRequest) (*api.WorkflowExecution, error)
- func (s *WorkflowServer) GetWorkflowExecutionLogs(req *api.GetWorkflowExecutionLogsRequest, ...) error
- func (s *WorkflowServer) GetWorkflowExecutionMetrics(ctx context.Context, req *api.GetWorkflowExecutionMetricsRequest) (*api.GetWorkflowExecutionMetricsResponse, error)
- func (s *WorkflowServer) GetWorkflowExecutionStatisticsForNamespace(ctx context.Context, ...) (*api.GetWorkflowExecutionStatisticsForNamespaceResponse, error)
- func (s *WorkflowServer) ListWorkflowExecutions(ctx context.Context, req *api.ListWorkflowExecutionsRequest) (*api.ListWorkflowExecutionsResponse, error)
- func (s *WorkflowServer) ListWorkflowExecutionsField(ctx context.Context, req *api.ListWorkflowExecutionsFieldRequest) (*api.ListWorkflowExecutionsFieldResponse, error)
- func (s *WorkflowServer) ResubmitWorkflowExecution(ctx context.Context, req *api.ResubmitWorkflowExecutionRequest) (*api.WorkflowExecution, error)
- func (s *WorkflowServer) TerminateWorkflowExecution(ctx context.Context, req *api.TerminateWorkflowExecutionRequest) (*empty.Empty, error)
- func (s *WorkflowServer) UpdateWorkflowExecutionMetrics(ctx context.Context, req *api.UpdateWorkflowExecutionsMetricsRequest) (*api.WorkflowExecutionsMetricsResponse, error)
- func (s *WorkflowServer) UpdateWorkflowExecutionStatus(ctx context.Context, req *api.UpdateWorkflowExecutionStatusRequest) (*empty.Empty, error)
- func (s *WorkflowServer) WatchWorkflowExecution(req *api.WatchWorkflowExecutionRequest, ...) error
- type WorkflowTemplateServer
- func (s *WorkflowTemplateServer) ArchiveWorkflowTemplate(ctx context.Context, req *api.ArchiveWorkflowTemplateRequest) (*api.ArchiveWorkflowTemplateResponse, error)
- func (s *WorkflowTemplateServer) CloneWorkflowTemplate(ctx context.Context, req *api.CloneWorkflowTemplateRequest) (*api.WorkflowTemplate, error)
- func (s *WorkflowTemplateServer) CreateWorkflowTemplate(ctx context.Context, req *api.CreateWorkflowTemplateRequest) (*api.WorkflowTemplate, error)
- func (s *WorkflowTemplateServer) CreateWorkflowTemplateVersion(ctx context.Context, req *api.CreateWorkflowTemplateRequest) (*api.WorkflowTemplate, error)
- func (s *WorkflowTemplateServer) GenerateWorkflowTemplate(ctx context.Context, req *api.GenerateWorkflowTemplateRequest) (*api.WorkflowTemplate, error)
- func (s *WorkflowTemplateServer) GetWorkflowTemplate(ctx context.Context, req *api.GetWorkflowTemplateRequest) (*api.WorkflowTemplate, error)
- func (s *WorkflowTemplateServer) ListWorkflowTemplateVersions(ctx context.Context, req *api.ListWorkflowTemplateVersionsRequest) (*api.ListWorkflowTemplateVersionsResponse, error)
- func (s *WorkflowTemplateServer) ListWorkflowTemplates(ctx context.Context, req *api.ListWorkflowTemplatesRequest) (*api.ListWorkflowTemplatesResponse, error)
- func (s *WorkflowTemplateServer) ListWorkflowTemplatesField(ctx context.Context, req *api.ListWorkflowTemplatesFieldRequest) (*api.ListWorkflowTemplatesFieldResponse, error)
- type WorkspaceServer
- func (s *WorkspaceServer) CreateWorkspace(ctx context.Context, req *api.CreateWorkspaceRequest) (*api.Workspace, error)
- func (s *WorkspaceServer) DeleteWorkspace(ctx context.Context, req *api.DeleteWorkspaceRequest) (*empty.Empty, error)
- func (s *WorkspaceServer) GetWorkspace(ctx context.Context, req *api.GetWorkspaceRequest) (*api.Workspace, error)
- func (s *WorkspaceServer) GetWorkspaceContainerLogs(req *api.GetWorkspaceContainerLogsRequest, ...) error
- func (s *WorkspaceServer) GetWorkspaceStatisticsForNamespace(ctx context.Context, req *api.GetWorkspaceStatisticsForNamespaceRequest) (*api.GetWorkspaceStatisticsForNamespaceResponse, error)
- func (s *WorkspaceServer) ListWorkspaces(ctx context.Context, req *api.ListWorkspaceRequest) (*api.ListWorkspaceResponse, error)
- func (s *WorkspaceServer) ListWorkspacesField(ctx context.Context, req *api.ListWorkspacesFieldRequest) (*api.ListWorkspacesFieldResponse, error)
- func (s *WorkspaceServer) PauseWorkspace(ctx context.Context, req *api.PauseWorkspaceRequest) (*empty.Empty, error)
- func (s *WorkspaceServer) ResumeWorkspace(ctx context.Context, req *api.ResumeWorkspaceRequest) (*empty.Empty, error)
- func (s *WorkspaceServer) RetryLastWorkspaceAction(ctx context.Context, req *api.RetryActionWorkspaceRequest) (*empty.Empty, error)
- func (s *WorkspaceServer) UpdateWorkspace(ctx context.Context, req *api.UpdateWorkspaceRequest) (*empty.Empty, error)
- func (s *WorkspaceServer) UpdateWorkspaceStatus(ctx context.Context, req *api.UpdateWorkspaceStatusRequest) (*empty.Empty, error)
- type WorkspaceTemplateServer
- func (s *WorkspaceTemplateServer) ArchiveWorkspaceTemplate(ctx context.Context, req *api.ArchiveWorkspaceTemplateRequest) (*api.WorkspaceTemplate, error)
- func (s *WorkspaceTemplateServer) CreateWorkspaceTemplate(ctx context.Context, req *api.CreateWorkspaceTemplateRequest) (*api.WorkspaceTemplate, error)
- func (s WorkspaceTemplateServer) GenerateWorkspaceTemplateWorkflowTemplate(ctx context.Context, req *api.GenerateWorkspaceTemplateWorkflowTemplateRequest) (*api.WorkflowTemplate, error)
- func (s *WorkspaceTemplateServer) GetWorkspaceTemplate(ctx context.Context, req *api.GetWorkspaceTemplateRequest) (*api.WorkspaceTemplate, error)
- func (s *WorkspaceTemplateServer) ListWorkspaceTemplateVersions(ctx context.Context, req *api.ListWorkspaceTemplateVersionsRequest) (*api.ListWorkspaceTemplateVersionsResponse, error)
- func (s *WorkspaceTemplateServer) ListWorkspaceTemplates(ctx context.Context, req *api.ListWorkspaceTemplatesRequest) (*api.ListWorkspaceTemplatesResponse, error)
- func (s *WorkspaceTemplateServer) ListWorkspaceTemplatesField(ctx context.Context, req *api.ListWorkspaceTemplatesFieldRequest) (*api.ListWorkspaceTemplatesFieldResponse, error)
- func (s *WorkspaceTemplateServer) UpdateWorkspaceTemplate(ctx context.Context, req *api.UpdateWorkspaceTemplateRequest) (*api.WorkspaceTemplate, error)
Constants ¶
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 (*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
func (c *ConfigServer) GetNamespaceConfig(ctx context.Context, req *api.GetNamespaceConfigRequest) (*api.GetNamespaceConfigResponse, error)
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 (c *CronWorkflowServer) CreateCronWorkflow(ctx context.Context, req *api.CreateCronWorkflowRequest) (*api.CronWorkflow, error)
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 (c *CronWorkflowServer) GetCronWorkflow(ctx context.Context, req *api.GetCronWorkflowRequest) (*api.CronWorkflow, error)
func (*CronWorkflowServer) ListCronWorkflows ¶
func (c *CronWorkflowServer) ListCronWorkflows(ctx context.Context, req *api.ListCronWorkflowRequest) (*api.ListCronWorkflowsResponse, error)
func (*CronWorkflowServer) UpdateCronWorkflow ¶
func (c *CronWorkflowServer) UpdateCronWorkflow(ctx context.Context, req *api.UpdateCronWorkflowRequest) (*api.CronWorkflow, error)
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
func (s *FileServer) ListFiles(ctx context.Context, req *api.ListFilesRequest) (*api.ListFilesResponse, error)
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
func (s *InferenceServiceServer) CreateInferenceService(ctx context.Context, req *api.CreateInferenceServiceRequest) (*api.GetInferenceServiceResponse, error)
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
func (s *InferenceServiceServer) GetInferenceService(ctx context.Context, req *api.InferenceServiceIdentifier) (*api.GetInferenceServiceResponse, error)
GetInferenceService returns the status of an inferenceservice
type LabelServer ¶
type LabelServer struct {
api.UnimplementedLabelServiceServer
}
LabelServer is an implementation of the grpc LabelServer
func (*LabelServer) AddLabels ¶
func (s *LabelServer) AddLabels(ctx context.Context, req *api.AddLabelsRequest) (*api.GetLabelsResponse, error)
func (*LabelServer) DeleteLabel ¶
func (s *LabelServer) DeleteLabel(ctx context.Context, req *api.DeleteLabelRequest) (*api.GetLabelsResponse, error)
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 (s *LabelServer) GetLabels(ctx context.Context, req *api.GetLabelsRequest) (*api.GetLabelsResponse, error)
func (*LabelServer) ReplaceLabels ¶
func (s *LabelServer) ReplaceLabels(ctx context.Context, req *api.ReplaceLabelsRequest) (*api.GetLabelsResponse, error)
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 ¶
func (s *NamespaceServer) ListNamespaces(ctx context.Context, req *api.ListNamespacesRequest) (*api.ListNamespacesResponse, error)
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 (s *SecretServer) ListSecrets(ctx context.Context, req *api.ListSecretsRequest) (*api.ListSecretsResponse, error)
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
func (c *ServiceServer) HasService(ctx context.Context, req *api.HasServiceRequest) (*api.HasServiceResponse, error)
HasService checks if the cluster has a service set up and enabled
func (*ServiceServer) ListServices ¶ added in v0.12.0
func (c *ServiceServer) ListServices(ctx context.Context, req *api.ListServicesRequest) (*api.ListServicesResponse, error)
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
func (s *WorkflowServer) AddWorkflowExecutionMetrics(ctx context.Context, req *api.AddWorkflowExecutionsMetricsRequest) (*api.WorkflowExecutionsMetricsResponse, error)
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 (s *WorkflowServer) GetWorkflowExecution(ctx context.Context, req *api.GetWorkflowExecutionRequest) (*api.WorkflowExecution, error)
func (*WorkflowServer) GetWorkflowExecutionLogs ¶
func (s *WorkflowServer) GetWorkflowExecutionLogs(req *api.GetWorkflowExecutionLogsRequest, stream api.WorkflowService_GetWorkflowExecutionLogsServer) error
func (*WorkflowServer) GetWorkflowExecutionMetrics ¶
func (s *WorkflowServer) GetWorkflowExecutionMetrics(ctx context.Context, req *api.GetWorkflowExecutionMetricsRequest) (*api.GetWorkflowExecutionMetricsResponse, error)
func (*WorkflowServer) GetWorkflowExecutionStatisticsForNamespace ¶ added in v0.13.0
func (s *WorkflowServer) GetWorkflowExecutionStatisticsForNamespace(ctx context.Context, req *api.GetWorkflowExecutionStatisticsForNamespaceRequest) (*api.GetWorkflowExecutionStatisticsForNamespaceResponse, error)
GetWorkflowExecutionStatisticsForNamespace returns statistics on workflow executions for a given namespace
func (*WorkflowServer) ListWorkflowExecutions ¶
func (s *WorkflowServer) ListWorkflowExecutions(ctx context.Context, req *api.ListWorkflowExecutionsRequest) (*api.ListWorkflowExecutionsResponse, error)
ListWorkflowExecutions returns a list of workflow executions that are specified by the criteria in the ListWorkflowExecutionsRequest
func (*WorkflowServer) ListWorkflowExecutionsField ¶ added in v0.19.0
func (s *WorkflowServer) ListWorkflowExecutionsField(ctx context.Context, req *api.ListWorkflowExecutionsFieldRequest) (*api.ListWorkflowExecutionsFieldResponse, error)
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
func (s *WorkflowServer) UpdateWorkflowExecutionMetrics(ctx context.Context, req *api.UpdateWorkflowExecutionsMetricsRequest) (*api.WorkflowExecutionsMetricsResponse, error)
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)
func (*WorkflowServer) WatchWorkflowExecution ¶
func (s *WorkflowServer) WatchWorkflowExecution(req *api.WatchWorkflowExecutionRequest, stream api.WorkflowService_WatchWorkflowExecutionServer) 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 (s *WorkflowTemplateServer) ArchiveWorkflowTemplate(ctx context.Context, req *api.ArchiveWorkflowTemplateRequest) (*api.ArchiveWorkflowTemplateResponse, error)
func (*WorkflowTemplateServer) CloneWorkflowTemplate ¶
func (s *WorkflowTemplateServer) CloneWorkflowTemplate(ctx context.Context, req *api.CloneWorkflowTemplateRequest) (*api.WorkflowTemplate, error)
func (*WorkflowTemplateServer) CreateWorkflowTemplate ¶
func (s *WorkflowTemplateServer) CreateWorkflowTemplate(ctx context.Context, req *api.CreateWorkflowTemplateRequest) (*api.WorkflowTemplate, error)
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
func (s *WorkflowTemplateServer) GenerateWorkflowTemplate(ctx context.Context, req *api.GenerateWorkflowTemplateRequest) (*api.WorkflowTemplate, error)
GenerateWorkflowTemplate generates a workflow template, applying any modifications based on the content of the manifest
func (*WorkflowTemplateServer) GetWorkflowTemplate ¶
func (s *WorkflowTemplateServer) GetWorkflowTemplate(ctx context.Context, req *api.GetWorkflowTemplateRequest) (*api.WorkflowTemplate, error)
func (*WorkflowTemplateServer) ListWorkflowTemplateVersions ¶
func (s *WorkflowTemplateServer) ListWorkflowTemplateVersions(ctx context.Context, req *api.ListWorkflowTemplateVersionsRequest) (*api.ListWorkflowTemplateVersionsResponse, error)
func (*WorkflowTemplateServer) ListWorkflowTemplates ¶
func (s *WorkflowTemplateServer) ListWorkflowTemplates(ctx context.Context, req *api.ListWorkflowTemplatesRequest) (*api.ListWorkflowTemplatesResponse, error)
func (*WorkflowTemplateServer) ListWorkflowTemplatesField ¶ added in v0.19.0
func (s *WorkflowTemplateServer) ListWorkflowTemplatesField(ctx context.Context, req *api.ListWorkflowTemplatesFieldRequest) (*api.ListWorkflowTemplatesFieldResponse, error)
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
func (s *WorkspaceServer) GetWorkspaceContainerLogs(req *api.GetWorkspaceContainerLogsRequest, stream api.WorkspaceService_GetWorkspaceContainerLogsServer) error
GetWorkspaceContainerLogs returns logs for a given container name in a Workspace
func (*WorkspaceServer) GetWorkspaceStatisticsForNamespace ¶ added in v0.13.0
func (s *WorkspaceServer) GetWorkspaceStatisticsForNamespace(ctx context.Context, req *api.GetWorkspaceStatisticsForNamespaceRequest) (*api.GetWorkspaceStatisticsForNamespaceResponse, error)
GetWorkspaceStatisticsForNamespace returns statistics on workflow executions for a given namespace
func (*WorkspaceServer) ListWorkspaces ¶
func (s *WorkspaceServer) ListWorkspaces(ctx context.Context, req *api.ListWorkspaceRequest) (*api.ListWorkspaceResponse, error)
ListWorkspaces lists the current workspaces for a given namespace
func (*WorkspaceServer) ListWorkspacesField ¶ added in v0.19.0
func (s *WorkspaceServer) ListWorkspacesField(ctx context.Context, req *api.ListWorkspacesFieldRequest) (*api.ListWorkspacesFieldResponse, error)
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 (s *WorkspaceTemplateServer) ArchiveWorkspaceTemplate(ctx context.Context, req *api.ArchiveWorkspaceTemplateRequest) (*api.WorkspaceTemplate, error)
func (*WorkspaceTemplateServer) CreateWorkspaceTemplate ¶
func (s *WorkspaceTemplateServer) CreateWorkspaceTemplate(ctx context.Context, req *api.CreateWorkspaceTemplateRequest) (*api.WorkspaceTemplate, error)
func (WorkspaceTemplateServer) GenerateWorkspaceTemplateWorkflowTemplate ¶
func (s WorkspaceTemplateServer) GenerateWorkspaceTemplateWorkflowTemplate(ctx context.Context, req *api.GenerateWorkspaceTemplateWorkflowTemplateRequest) (*api.WorkflowTemplate, error)
func (*WorkspaceTemplateServer) GetWorkspaceTemplate ¶
func (s *WorkspaceTemplateServer) GetWorkspaceTemplate(ctx context.Context, req *api.GetWorkspaceTemplateRequest) (*api.WorkspaceTemplate, error)
func (*WorkspaceTemplateServer) ListWorkspaceTemplateVersions ¶
func (s *WorkspaceTemplateServer) ListWorkspaceTemplateVersions(ctx context.Context, req *api.ListWorkspaceTemplateVersionsRequest) (*api.ListWorkspaceTemplateVersionsResponse, error)
func (*WorkspaceTemplateServer) ListWorkspaceTemplates ¶
func (s *WorkspaceTemplateServer) ListWorkspaceTemplates(ctx context.Context, req *api.ListWorkspaceTemplatesRequest) (*api.ListWorkspaceTemplatesResponse, error)
func (*WorkspaceTemplateServer) ListWorkspaceTemplatesField ¶ added in v0.19.0
func (s *WorkspaceTemplateServer) ListWorkspaceTemplatesField(ctx context.Context, req *api.ListWorkspaceTemplatesFieldRequest) (*api.ListWorkspaceTemplatesFieldResponse, error)
ListWorkspaceTemplatesField returns a list of all the distinct values of a field from WorkspaceTemplates
func (*WorkspaceTemplateServer) UpdateWorkspaceTemplate ¶
func (s *WorkspaceTemplateServer) UpdateWorkspaceTemplate(ctx context.Context, req *api.UpdateWorkspaceTemplateRequest) (*api.WorkspaceTemplate, error)