http1

package
v2.12.13 Latest Latest
Warning

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

 Go to latest Published: Aug 18, 2021 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

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

func NewFacade(baseUrl, authorization string, insecureSkipVerify bool) Facade

func (Facade) Delete 

func (h Facade) Delete(in, out interface{}, path string) error

func (Facade) EventStreamReader 

func (h Facade) EventStreamReader(in interface{}, path string) (*bufio.Reader, error)

func (Facade) Get 

func (h Facade) Get(in, out interface{}, path string) error

func (Facade) Post 

func (h Facade) Post(in, out interface{}, path string) error

func (Facade) Put 

func (h Facade) Put(in, out interface{}, path string) error

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

View all Source files

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.