Versions in this module Expand all Collapse all v3 v3.0.1 Feb 23, 2021 Changes in this version + type ArchivedWorkflowsServiceClient = Facade + func (h ArchivedWorkflowsServiceClient) DeleteArchivedWorkflow(_ context.Context, in *workflowarchivepkg.DeleteArchivedWorkflowRequest, ...) (*workflowarchivepkg.ArchivedWorkflowDeletedResponse, error) + func (h ArchivedWorkflowsServiceClient) DeleteClusterWorkflowTemplate(_ context.Context, ...) (*clusterworkflowtemplate.ClusterWorkflowTemplateDeleteResponse, error) + func (h ArchivedWorkflowsServiceClient) GetArchivedWorkflow(_ context.Context, in *workflowarchivepkg.GetArchivedWorkflowRequest, ...) (*wfv1.Workflow, error) + func (h ArchivedWorkflowsServiceClient) LintClusterWorkflowTemplate(_ context.Context, ...) (*wfv1.ClusterWorkflowTemplate, error) + func (h ArchivedWorkflowsServiceClient) ListArchivedWorkflows(_ context.Context, in *workflowarchivepkg.ListArchivedWorkflowsRequest, ...) (*wfv1.WorkflowList, error) + type ClusterWorkflowTemplateServiceClient = Facade + func (h ClusterWorkflowTemplateServiceClient) CreateClusterWorkflowTemplate(_ context.Context, ...) (*wfv1.ClusterWorkflowTemplate, error) + func (h ClusterWorkflowTemplateServiceClient) GetClusterWorkflowTemplate(_ context.Context, ...) (*wfv1.ClusterWorkflowTemplate, error) + func (h ClusterWorkflowTemplateServiceClient) ListClusterWorkflowTemplates(_ context.Context, ...) (*wfv1.ClusterWorkflowTemplateList, error) + func (h ClusterWorkflowTemplateServiceClient) UpdateClusterWorkflowTemplate(_ context.Context, ...) (*wfv1.ClusterWorkflowTemplate, error) + type CronWorkflowServiceClient = Facade + func (h CronWorkflowServiceClient) CreateCronWorkflow(_ context.Context, in *cronworkflowpkg.CreateCronWorkflowRequest, ...) (*wfv1.CronWorkflow, error) + func (h CronWorkflowServiceClient) DeleteCronWorkflow(_ context.Context, in *cronworkflowpkg.DeleteCronWorkflowRequest, ...) (*cronworkflowpkg.CronWorkflowDeletedResponse, error) + func (h CronWorkflowServiceClient) GetCronWorkflow(_ context.Context, in *cronworkflowpkg.GetCronWorkflowRequest, ...) (*wfv1.CronWorkflow, error) + func (h CronWorkflowServiceClient) LintCronWorkflow(_ context.Context, in *cronworkflowpkg.LintCronWorkflowRequest, ...) (*wfv1.CronWorkflow, error) + func (h CronWorkflowServiceClient) ListCronWorkflows(_ context.Context, in *cronworkflowpkg.ListCronWorkflowsRequest, ...) (*wfv1.CronWorkflowList, error) + func (h CronWorkflowServiceClient) UpdateCronWorkflow(_ context.Context, in *cronworkflowpkg.UpdateCronWorkflowRequest, ...) (*wfv1.CronWorkflow, error) + type Facade struct + func NewFacade(baseUrl, authorization string, insecureSkipVerify bool) Facade + func (h Facade) Delete(in, out interface{}, path string) error + func (h Facade) EventStreamReader(in interface{}, path string) (*bufio.Reader, error) + func (h Facade) Get(in, out interface{}, path string) error + func (h Facade) Post(in, out interface{}, path string) error + func (h Facade) Put(in, out interface{}, path string) error + func (h Facade) ResumeCronWorkflow(ctx context.Context, in *cronworkflowpkg.CronWorkflowResumeRequest, ...) (*wfv1.CronWorkflow, error) + func (h Facade) SuspendCronWorkflow(ctx context.Context, in *cronworkflowpkg.CronWorkflowSuspendRequest, ...) (*wfv1.CronWorkflow, error) + type InfoServiceClient = Facade + func (h InfoServiceClient) GetInfo(_ context.Context, in *infopkg.GetInfoRequest, _ ...grpc.CallOption) (*infopkg.InfoResponse, error) + func (h InfoServiceClient) GetUserInfo(_ context.Context, in *infopkg.GetUserInfoRequest, _ ...grpc.CallOption) (*infopkg.GetUserInfoResponse, error) + func (h InfoServiceClient) GetVersion(_ context.Context, in *infopkg.GetVersionRequest, _ ...grpc.CallOption) (*wfv1.Version, error) + type WorkflowServiceClient = Facade + func (h WorkflowServiceClient) CreateWorkflow(_ context.Context, in *workflowpkg.WorkflowCreateRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error) + func (h WorkflowServiceClient) DeleteWorkflow(_ context.Context, in *workflowpkg.WorkflowDeleteRequest, _ ...grpc.CallOption) (*workflowpkg.WorkflowDeleteResponse, error) + func (h WorkflowServiceClient) GetWorkflow(_ context.Context, in *workflowpkg.WorkflowGetRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error) + func (h WorkflowServiceClient) LintWorkflow(_ context.Context, in *workflowpkg.WorkflowLintRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error) + func (h WorkflowServiceClient) ListWorkflows(_ context.Context, in *workflowpkg.WorkflowListRequest, _ ...grpc.CallOption) (*wfv1.WorkflowList, error) + func (h WorkflowServiceClient) PodLogs(ctx context.Context, in *workflowpkg.WorkflowLogRequest, _ ...grpc.CallOption) (workflowpkg.WorkflowService_PodLogsClient, error) + func (h WorkflowServiceClient) ResubmitWorkflow(_ context.Context, in *workflowpkg.WorkflowResubmitRequest, ...) (*wfv1.Workflow, error) + func (h WorkflowServiceClient) ResumeWorkflow(_ context.Context, in *workflowpkg.WorkflowResumeRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error) + func (h WorkflowServiceClient) RetryWorkflow(_ context.Context, in *workflowpkg.WorkflowRetryRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error) + func (h WorkflowServiceClient) SetWorkflow(_ context.Context, in *workflowpkg.WorkflowSetRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error) + func (h WorkflowServiceClient) StopWorkflow(_ context.Context, in *workflowpkg.WorkflowStopRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error) + func (h WorkflowServiceClient) SubmitWorkflow(_ context.Context, in *workflowpkg.WorkflowSubmitRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error) + func (h WorkflowServiceClient) SuspendWorkflow(_ context.Context, in *workflowpkg.WorkflowSuspendRequest, ...) (*wfv1.Workflow, error) + func (h WorkflowServiceClient) TerminateWorkflow(_ context.Context, in *workflowpkg.WorkflowTerminateRequest, ...) (*wfv1.Workflow, error) + func (h WorkflowServiceClient) WatchEvents(ctx context.Context, in *workflowpkg.WatchEventsRequest, _ ...grpc.CallOption) (workflowpkg.WorkflowService_WatchEventsClient, error) + func (h WorkflowServiceClient) WatchWorkflows(ctx context.Context, in *workflowpkg.WatchWorkflowsRequest, ...) (workflowpkg.WorkflowService_WatchWorkflowsClient, error) + func (h WorkflowServiceClient) WorkflowLogs(ctx context.Context, in *workflowpkg.WorkflowLogRequest, _ ...grpc.CallOption) (workflowpkg.WorkflowService_WorkflowLogsClient, error) + type WorkflowTemplateServiceClient = Facade + func (h WorkflowTemplateServiceClient) CreateWorkflowTemplate(_ context.Context, in *workflowtemplatepkg.WorkflowTemplateCreateRequest, ...) (*wfv1.WorkflowTemplate, error) + func (h WorkflowTemplateServiceClient) DeleteWorkflowTemplate(_ context.Context, in *workflowtemplatepkg.WorkflowTemplateDeleteRequest, ...) (*workflowtemplatepkg.WorkflowTemplateDeleteResponse, error) + func (h WorkflowTemplateServiceClient) GetWorkflowTemplate(_ context.Context, in *workflowtemplatepkg.WorkflowTemplateGetRequest, ...) (*wfv1.WorkflowTemplate, error) + func (h WorkflowTemplateServiceClient) LintWorkflowTemplate(_ context.Context, in *workflowtemplatepkg.WorkflowTemplateLintRequest, ...) (*wfv1.WorkflowTemplate, error) + func (h WorkflowTemplateServiceClient) ListWorkflowTemplates(_ context.Context, in *workflowtemplatepkg.WorkflowTemplateListRequest, ...) (*wfv1.WorkflowTemplateList, error) + func (h WorkflowTemplateServiceClient) UpdateWorkflowTemplate(_ context.Context, in *workflowtemplatepkg.WorkflowTemplateUpdateRequest, ...) (*wfv1.WorkflowTemplate, error)