Documentation ¶
Index ¶
- type ArchivedWorkflowsServiceClient
- 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) ListArchivedWorkflowLabelKeys(_ context.Context, in *workflowarchivepkg.ListArchivedWorkflowLabelKeysRequest, ...) (*wfv1.LabelKeys, error)
- func (h ArchivedWorkflowsServiceClient) ListArchivedWorkflowLabelValues(_ context.Context, ...) (*wfv1.LabelValues, error)
- func (h ArchivedWorkflowsServiceClient) ListArchivedWorkflows(_ context.Context, in *workflowarchivepkg.ListArchivedWorkflowsRequest, ...) (*wfv1.WorkflowList, error)
- type ClusterWorkflowTemplateServiceClient
- 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
- 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
- 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
- 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
- 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
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ArchivedWorkflowsServiceClient ¶
type ArchivedWorkflowsServiceClient = Facade
func (ArchivedWorkflowsServiceClient) DeleteArchivedWorkflow ¶
func (h ArchivedWorkflowsServiceClient) DeleteArchivedWorkflow(_ context.Context, in *workflowarchivepkg.DeleteArchivedWorkflowRequest, _ ...grpc.CallOption) (*workflowarchivepkg.ArchivedWorkflowDeletedResponse, error)
func (ArchivedWorkflowsServiceClient) DeleteClusterWorkflowTemplate ¶
func (h ArchivedWorkflowsServiceClient) DeleteClusterWorkflowTemplate(_ context.Context, in *clusterworkflowtemplate.ClusterWorkflowTemplateDeleteRequest, _ ...grpc.CallOption) (*clusterworkflowtemplate.ClusterWorkflowTemplateDeleteResponse, error)
func (ArchivedWorkflowsServiceClient) GetArchivedWorkflow ¶
func (h ArchivedWorkflowsServiceClient) GetArchivedWorkflow(_ context.Context, in *workflowarchivepkg.GetArchivedWorkflowRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)
func (ArchivedWorkflowsServiceClient) LintClusterWorkflowTemplate ¶
func (h ArchivedWorkflowsServiceClient) LintClusterWorkflowTemplate(_ context.Context, in *clusterworkflowtemplate.ClusterWorkflowTemplateLintRequest, _ ...grpc.CallOption) (*wfv1.ClusterWorkflowTemplate, error)
func (ArchivedWorkflowsServiceClient) ListArchivedWorkflowLabelKeys ¶
func (h ArchivedWorkflowsServiceClient) ListArchivedWorkflowLabelKeys(_ context.Context, in *workflowarchivepkg.ListArchivedWorkflowLabelKeysRequest, _ ...grpc.CallOption) (*wfv1.LabelKeys, error)
func (ArchivedWorkflowsServiceClient) ListArchivedWorkflowLabelValues ¶
func (h ArchivedWorkflowsServiceClient) ListArchivedWorkflowLabelValues(_ context.Context, in *workflowarchivepkg.ListArchivedWorkflowLabelValuesRequest, _ ...grpc.CallOption) (*wfv1.LabelValues, error)
func (ArchivedWorkflowsServiceClient) ListArchivedWorkflows ¶
func (h ArchivedWorkflowsServiceClient) ListArchivedWorkflows(_ context.Context, in *workflowarchivepkg.ListArchivedWorkflowsRequest, _ ...grpc.CallOption) (*wfv1.WorkflowList, error)
type ClusterWorkflowTemplateServiceClient ¶
type ClusterWorkflowTemplateServiceClient = Facade
func (ClusterWorkflowTemplateServiceClient) CreateClusterWorkflowTemplate ¶
func (h ClusterWorkflowTemplateServiceClient) CreateClusterWorkflowTemplate(_ context.Context, in *clusterworkflowtemplate.ClusterWorkflowTemplateCreateRequest, _ ...grpc.CallOption) (*wfv1.ClusterWorkflowTemplate, error)
func (ClusterWorkflowTemplateServiceClient) GetClusterWorkflowTemplate ¶
func (h ClusterWorkflowTemplateServiceClient) GetClusterWorkflowTemplate(_ context.Context, in *clusterworkflowtemplate.ClusterWorkflowTemplateGetRequest, _ ...grpc.CallOption) (*wfv1.ClusterWorkflowTemplate, error)
func (ClusterWorkflowTemplateServiceClient) ListClusterWorkflowTemplates ¶
func (h ClusterWorkflowTemplateServiceClient) ListClusterWorkflowTemplates(_ context.Context, in *clusterworkflowtemplate.ClusterWorkflowTemplateListRequest, _ ...grpc.CallOption) (*wfv1.ClusterWorkflowTemplateList, error)
func (ClusterWorkflowTemplateServiceClient) UpdateClusterWorkflowTemplate ¶
func (h ClusterWorkflowTemplateServiceClient) UpdateClusterWorkflowTemplate(_ context.Context, in *clusterworkflowtemplate.ClusterWorkflowTemplateUpdateRequest, _ ...grpc.CallOption) (*wfv1.ClusterWorkflowTemplate, error)
type CronWorkflowServiceClient ¶
type CronWorkflowServiceClient = Facade
func (CronWorkflowServiceClient) CreateCronWorkflow ¶
func (h CronWorkflowServiceClient) CreateCronWorkflow(_ context.Context, in *cronworkflowpkg.CreateCronWorkflowRequest, _ ...grpc.CallOption) (*wfv1.CronWorkflow, error)
func (CronWorkflowServiceClient) DeleteCronWorkflow ¶
func (h CronWorkflowServiceClient) DeleteCronWorkflow(_ context.Context, in *cronworkflowpkg.DeleteCronWorkflowRequest, _ ...grpc.CallOption) (*cronworkflowpkg.CronWorkflowDeletedResponse, error)
func (CronWorkflowServiceClient) GetCronWorkflow ¶
func (h CronWorkflowServiceClient) GetCronWorkflow(_ context.Context, in *cronworkflowpkg.GetCronWorkflowRequest, _ ...grpc.CallOption) (*wfv1.CronWorkflow, error)
func (CronWorkflowServiceClient) LintCronWorkflow ¶
func (h CronWorkflowServiceClient) LintCronWorkflow(_ context.Context, in *cronworkflowpkg.LintCronWorkflowRequest, _ ...grpc.CallOption) (*wfv1.CronWorkflow, error)
func (CronWorkflowServiceClient) ListCronWorkflows ¶
func (h CronWorkflowServiceClient) ListCronWorkflows(_ context.Context, in *cronworkflowpkg.ListCronWorkflowsRequest, _ ...grpc.CallOption) (*wfv1.CronWorkflowList, error)
func (CronWorkflowServiceClient) UpdateCronWorkflow ¶
func (h CronWorkflowServiceClient) UpdateCronWorkflow(_ context.Context, in *cronworkflowpkg.UpdateCronWorkflowRequest, _ ...grpc.CallOption) (*wfv1.CronWorkflow, error)
type Facade ¶
type Facade struct {
// contains filtered or unexported fields
}
Facade provides a adapter from GRPC interface, but uses HTTP to send the messages. Errors are extracted from message body and returned as GRPC status errors.
func (Facade) EventStreamReader ¶
func (Facade) ResumeCronWorkflow ¶
func (h Facade) ResumeCronWorkflow(ctx context.Context, in *cronworkflowpkg.CronWorkflowResumeRequest, opts ...grpc.CallOption) (*wfv1.CronWorkflow, error)
func (Facade) SuspendCronWorkflow ¶
func (h Facade) SuspendCronWorkflow(ctx context.Context, in *cronworkflowpkg.CronWorkflowSuspendRequest, opts ...grpc.CallOption) (*wfv1.CronWorkflow, error)
type InfoServiceClient ¶
type InfoServiceClient = Facade
func (InfoServiceClient) GetInfo ¶
func (h InfoServiceClient) GetInfo(_ context.Context, in *infopkg.GetInfoRequest, _ ...grpc.CallOption) (*infopkg.InfoResponse, error)
func (InfoServiceClient) GetUserInfo ¶
func (h InfoServiceClient) GetUserInfo(_ context.Context, in *infopkg.GetUserInfoRequest, _ ...grpc.CallOption) (*infopkg.GetUserInfoResponse, error)
func (InfoServiceClient) GetVersion ¶
func (h InfoServiceClient) GetVersion(_ context.Context, in *infopkg.GetVersionRequest, _ ...grpc.CallOption) (*wfv1.Version, error)
type WorkflowServiceClient ¶
type WorkflowServiceClient = Facade
func (WorkflowServiceClient) CreateWorkflow ¶
func (h WorkflowServiceClient) CreateWorkflow(_ context.Context, in *workflowpkg.WorkflowCreateRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)
func (WorkflowServiceClient) DeleteWorkflow ¶
func (h WorkflowServiceClient) DeleteWorkflow(_ context.Context, in *workflowpkg.WorkflowDeleteRequest, _ ...grpc.CallOption) (*workflowpkg.WorkflowDeleteResponse, error)
func (WorkflowServiceClient) GetWorkflow ¶
func (h WorkflowServiceClient) GetWorkflow(_ context.Context, in *workflowpkg.WorkflowGetRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)
func (WorkflowServiceClient) LintWorkflow ¶
func (h WorkflowServiceClient) LintWorkflow(_ context.Context, in *workflowpkg.WorkflowLintRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)
func (WorkflowServiceClient) ListWorkflows ¶
func (h WorkflowServiceClient) ListWorkflows(_ context.Context, in *workflowpkg.WorkflowListRequest, _ ...grpc.CallOption) (*wfv1.WorkflowList, error)
func (WorkflowServiceClient) PodLogs ¶
func (h WorkflowServiceClient) PodLogs(ctx context.Context, in *workflowpkg.WorkflowLogRequest, _ ...grpc.CallOption) (workflowpkg.WorkflowService_PodLogsClient, error)
func (WorkflowServiceClient) ResubmitWorkflow ¶
func (h WorkflowServiceClient) ResubmitWorkflow(_ context.Context, in *workflowpkg.WorkflowResubmitRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)
func (WorkflowServiceClient) ResumeWorkflow ¶
func (h WorkflowServiceClient) ResumeWorkflow(_ context.Context, in *workflowpkg.WorkflowResumeRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)
func (WorkflowServiceClient) RetryWorkflow ¶
func (h WorkflowServiceClient) RetryWorkflow(_ context.Context, in *workflowpkg.WorkflowRetryRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)
func (WorkflowServiceClient) SetWorkflow ¶
func (h WorkflowServiceClient) SetWorkflow(_ context.Context, in *workflowpkg.WorkflowSetRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)
func (WorkflowServiceClient) StopWorkflow ¶
func (h WorkflowServiceClient) StopWorkflow(_ context.Context, in *workflowpkg.WorkflowStopRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)
func (WorkflowServiceClient) SubmitWorkflow ¶
func (h WorkflowServiceClient) SubmitWorkflow(_ context.Context, in *workflowpkg.WorkflowSubmitRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)
func (WorkflowServiceClient) SuspendWorkflow ¶
func (h WorkflowServiceClient) SuspendWorkflow(_ context.Context, in *workflowpkg.WorkflowSuspendRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)
func (WorkflowServiceClient) TerminateWorkflow ¶
func (h WorkflowServiceClient) TerminateWorkflow(_ context.Context, in *workflowpkg.WorkflowTerminateRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)
func (WorkflowServiceClient) WatchEvents ¶
func (h WorkflowServiceClient) WatchEvents(ctx context.Context, in *workflowpkg.WatchEventsRequest, _ ...grpc.CallOption) (workflowpkg.WorkflowService_WatchEventsClient, error)
func (WorkflowServiceClient) WatchWorkflows ¶
func (h WorkflowServiceClient) WatchWorkflows(ctx context.Context, in *workflowpkg.WatchWorkflowsRequest, _ ...grpc.CallOption) (workflowpkg.WorkflowService_WatchWorkflowsClient, error)
func (WorkflowServiceClient) WorkflowLogs ¶
func (h WorkflowServiceClient) WorkflowLogs(ctx context.Context, in *workflowpkg.WorkflowLogRequest, _ ...grpc.CallOption) (workflowpkg.WorkflowService_WorkflowLogsClient, error)
type WorkflowTemplateServiceClient ¶
type WorkflowTemplateServiceClient = Facade
func (WorkflowTemplateServiceClient) CreateWorkflowTemplate ¶
func (h WorkflowTemplateServiceClient) CreateWorkflowTemplate(_ context.Context, in *workflowtemplatepkg.WorkflowTemplateCreateRequest, _ ...grpc.CallOption) (*wfv1.WorkflowTemplate, error)
func (WorkflowTemplateServiceClient) DeleteWorkflowTemplate ¶
func (h WorkflowTemplateServiceClient) DeleteWorkflowTemplate(_ context.Context, in *workflowtemplatepkg.WorkflowTemplateDeleteRequest, _ ...grpc.CallOption) (*workflowtemplatepkg.WorkflowTemplateDeleteResponse, error)
func (WorkflowTemplateServiceClient) GetWorkflowTemplate ¶
func (h WorkflowTemplateServiceClient) GetWorkflowTemplate(_ context.Context, in *workflowtemplatepkg.WorkflowTemplateGetRequest, _ ...grpc.CallOption) (*wfv1.WorkflowTemplate, error)
func (WorkflowTemplateServiceClient) LintWorkflowTemplate ¶
func (h WorkflowTemplateServiceClient) LintWorkflowTemplate(_ context.Context, in *workflowtemplatepkg.WorkflowTemplateLintRequest, _ ...grpc.CallOption) (*wfv1.WorkflowTemplate, error)
func (WorkflowTemplateServiceClient) ListWorkflowTemplates ¶
func (h WorkflowTemplateServiceClient) ListWorkflowTemplates(_ context.Context, in *workflowtemplatepkg.WorkflowTemplateListRequest, _ ...grpc.CallOption) (*wfv1.WorkflowTemplateList, error)
func (WorkflowTemplateServiceClient) UpdateWorkflowTemplate ¶
func (h WorkflowTemplateServiceClient) UpdateWorkflowTemplate(_ context.Context, in *workflowtemplatepkg.WorkflowTemplateUpdateRequest, _ ...grpc.CallOption) (*wfv1.WorkflowTemplate, error)
Source Files ¶
- archived-workflows-service-client.go
- cluster-workflow-template-service-client.go
- cron-workflow-service-client.go
- event-watch-client.go
- facade.go
- info-service-client.go
- pod-logs-client.go
- server-sent-events-client.go
- watch-workflows-client.go
- workflow-service-client.go
- workflow-template-service-client.go
Click to show internal directories.
Click to hide internal directories.