server

package
v0.12.0-rc.3 Latest Latest
Warning

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

 Go to latest Published: Jul 24, 2020 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func GenApiWorkflowExecution 

func GenApiWorkflowExecution(wf *v1.WorkflowExecution) (workflow *api.WorkflowExecution)

Types

type AuthServer 

type AuthServer struct {
}

AuthServer contains logic for checking Authorization of resources in the system

func NewAuthServer 

func NewAuthServer() *AuthServer

NewAuthServer creates a new AuthServer

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)

type ConfigServer added in v0.11.0 

type ConfigServer struct{}

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{}

func NewCronWorkflowServer 

func NewCronWorkflowServer() *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{}

func NewLabelServer 

func NewLabelServer() *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) 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{}

func NewNamespaceServer 

func NewNamespaceServer() *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{}

func NewSecretServer 

func NewSecretServer() *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 WorkflowServer 

type WorkflowServer struct{}

func NewWorkflowServer 

func NewWorkflowServer() *WorkflowServer

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

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

func NewWorkflowTemplateServer 

func NewWorkflowTemplateServer() *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)

func (*WorkflowTemplateServer) CreateWorkflowTemplateVersion 

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

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{}

func NewWorkspaceServer 

func NewWorkspaceServer() *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) 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) 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{}

func NewWorkspaceTemplateServer 

func NewWorkspaceTemplateServer() *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.