server

package
v0.17.0 Latest Latest
Warning

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

 Go to latest Published: Jan 12, 2021 License: Apache-2.0 Imports: 24 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

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

func (*NamespaceServer) ListNamespaces 

func (s *NamespaceServer) ListNamespaces(ctx context.Context, req *api.ListNamespacesRequest) (*api.ListNamespacesResponse, error)

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

func (s *WorkflowServer) GetArtifact(ctx context.Context, req *api.GetArtifactRequest) (*api.ArtifactResponse, error)

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

func (s *WorkflowServer) ListFiles(ctx context.Context, req *api.ListFilesRequest) (*api.ListFilesResponse, error)

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

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)

func (*WorkspaceServer) DeleteWorkspace 

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

func (*WorkspaceServer) GetWorkspace added in v0.8.0 

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

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)

func (*WorkspaceServer) PauseWorkspace 

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

func (*WorkspaceServer) ResumeWorkspace added in v0.8.0 

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

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)

func (*WorkspaceServer) UpdateWorkspaceStatus 

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

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

func (s *WorkspaceTemplateServer) UpdateWorkspaceTemplate(ctx context.Context, req *api.UpdateWorkspaceTemplateRequest) (*api.WorkspaceTemplate, error)

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.