http1

package
v4.0.8 Latest Latest
Warning

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

 Go to latest Published: Jul 22, 2026 License: Apache-2.0 Imports: 25 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(ctx context.Context, in *workflowarchivepkg.DeleteArchivedWorkflowRequest, _ ...grpc.CallOption) (*workflowarchivepkg.ArchivedWorkflowDeletedResponse, error)

func (ArchivedWorkflowsServiceClient) DeleteClusterWorkflowTemplate 

func (h ArchivedWorkflowsServiceClient) DeleteClusterWorkflowTemplate(ctx context.Context, in *clusterworkflowtemplate.ClusterWorkflowTemplateDeleteRequest, _ ...grpc.CallOption) (*clusterworkflowtemplate.ClusterWorkflowTemplateDeleteResponse, error)

func (ArchivedWorkflowsServiceClient) GetArchivedWorkflow 

func (h ArchivedWorkflowsServiceClient) GetArchivedWorkflow(ctx context.Context, in *workflowarchivepkg.GetArchivedWorkflowRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)

func (ArchivedWorkflowsServiceClient) LintClusterWorkflowTemplate 

func (h ArchivedWorkflowsServiceClient) LintClusterWorkflowTemplate(ctx context.Context, in *clusterworkflowtemplate.ClusterWorkflowTemplateLintRequest, _ ...grpc.CallOption) (*wfv1.ClusterWorkflowTemplate, error)

func (ArchivedWorkflowsServiceClient) ListArchivedWorkflowLabelKeys 

func (h ArchivedWorkflowsServiceClient) ListArchivedWorkflowLabelKeys(ctx context.Context, in *workflowarchivepkg.ListArchivedWorkflowLabelKeysRequest, _ ...grpc.CallOption) (*wfv1.LabelKeys, error)

func (ArchivedWorkflowsServiceClient) ListArchivedWorkflowLabelValues 

func (h ArchivedWorkflowsServiceClient) ListArchivedWorkflowLabelValues(ctx context.Context, in *workflowarchivepkg.ListArchivedWorkflowLabelValuesRequest, _ ...grpc.CallOption) (*wfv1.LabelValues, error)

func (ArchivedWorkflowsServiceClient) ListArchivedWorkflows 

func (h ArchivedWorkflowsServiceClient) ListArchivedWorkflows(ctx context.Context, in *workflowarchivepkg.ListArchivedWorkflowsRequest, _ ...grpc.CallOption) (*wfv1.WorkflowList, error)

func (ArchivedWorkflowsServiceClient) ResubmitArchivedWorkflow 

func (h ArchivedWorkflowsServiceClient) ResubmitArchivedWorkflow(ctx context.Context, in *workflowarchivepkg.ResubmitArchivedWorkflowRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)

func (ArchivedWorkflowsServiceClient) RetryArchivedWorkflow 

func (h ArchivedWorkflowsServiceClient) RetryArchivedWorkflow(ctx context.Context, in *workflowarchivepkg.RetryArchivedWorkflowRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)

type ClusterWorkflowTemplateServiceClient 

type ClusterWorkflowTemplateServiceClient = Facade

func (ClusterWorkflowTemplateServiceClient) CreateClusterWorkflowTemplate 

func (h ClusterWorkflowTemplateServiceClient) CreateClusterWorkflowTemplate(ctx context.Context, in *clusterworkflowtemplate.ClusterWorkflowTemplateCreateRequest, _ ...grpc.CallOption) (*wfv1.ClusterWorkflowTemplate, error)

func (ClusterWorkflowTemplateServiceClient) GetClusterWorkflowTemplate 

func (h ClusterWorkflowTemplateServiceClient) GetClusterWorkflowTemplate(ctx context.Context, in *clusterworkflowtemplate.ClusterWorkflowTemplateGetRequest, _ ...grpc.CallOption) (*wfv1.ClusterWorkflowTemplate, error)

func (ClusterWorkflowTemplateServiceClient) ListClusterWorkflowTemplates 

func (h ClusterWorkflowTemplateServiceClient) ListClusterWorkflowTemplates(ctx context.Context, in *clusterworkflowtemplate.ClusterWorkflowTemplateListRequest, _ ...grpc.CallOption) (*wfv1.ClusterWorkflowTemplateList, error)

func (ClusterWorkflowTemplateServiceClient) UpdateClusterWorkflowTemplate 

func (h ClusterWorkflowTemplateServiceClient) UpdateClusterWorkflowTemplate(ctx context.Context, in *clusterworkflowtemplate.ClusterWorkflowTemplateUpdateRequest, _ ...grpc.CallOption) (*wfv1.ClusterWorkflowTemplate, error)

type CronWorkflowServiceClient 

type CronWorkflowServiceClient = Facade

func (CronWorkflowServiceClient) CreateCronWorkflow 

func (h CronWorkflowServiceClient) CreateCronWorkflow(ctx context.Context, in *cronworkflowpkg.CreateCronWorkflowRequest, _ ...grpc.CallOption) (*wfv1.CronWorkflow, error)

func (CronWorkflowServiceClient) DeleteCronWorkflow 

func (h CronWorkflowServiceClient) DeleteCronWorkflow(ctx context.Context, in *cronworkflowpkg.DeleteCronWorkflowRequest, _ ...grpc.CallOption) (*cronworkflowpkg.CronWorkflowDeletedResponse, error)

func (CronWorkflowServiceClient) GetCronWorkflow 

func (h CronWorkflowServiceClient) GetCronWorkflow(ctx context.Context, in *cronworkflowpkg.GetCronWorkflowRequest, _ ...grpc.CallOption) (*wfv1.CronWorkflow, error)

func (CronWorkflowServiceClient) LintCronWorkflow 

func (h CronWorkflowServiceClient) LintCronWorkflow(ctx context.Context, in *cronworkflowpkg.LintCronWorkflowRequest, _ ...grpc.CallOption) (*wfv1.CronWorkflow, error)

func (CronWorkflowServiceClient) ListCronWorkflows 

func (h CronWorkflowServiceClient) ListCronWorkflows(ctx context.Context, in *cronworkflowpkg.ListCronWorkflowsRequest, _ ...grpc.CallOption) (*wfv1.CronWorkflowList, error)

func (CronWorkflowServiceClient) UpdateCronWorkflow 

func (h CronWorkflowServiceClient) UpdateCronWorkflow(ctx 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, headers []string, httpClient *http.Client) Facade

func (Facade) Delete 

func (h Facade) Delete(ctx context.Context, in, out interface{}, path string) error

func (Facade) EventStreamReader 

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

func (Facade) Get 

func (h Facade) Get(ctx context.Context, in, out interface{}, path string) error

func (Facade) Post 

func (h Facade) Post(ctx context.Context, in, out interface{}, path string) error

func (Facade) Put 

func (h Facade) Put(ctx context.Context, 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) CollectEvent 

func (h InfoServiceClient) CollectEvent(ctx context.Context, in *infopkg.CollectEventRequest, _ ...grpc.CallOption) (*infopkg.CollectEventResponse, error)

func (InfoServiceClient) GetInfo 

func (h InfoServiceClient) GetInfo(ctx context.Context, in *infopkg.GetInfoRequest, _ ...grpc.CallOption) (*infopkg.InfoResponse, error)

func (InfoServiceClient) GetUserInfo 

func (h InfoServiceClient) GetUserInfo(ctx context.Context, in *infopkg.GetUserInfoRequest, _ ...grpc.CallOption) (*infopkg.GetUserInfoResponse, error)

func (InfoServiceClient) GetVersion 

func (h InfoServiceClient) GetVersion(ctx context.Context, in *infopkg.GetVersionRequest, _ ...grpc.CallOption) (*wfv1.Version, error)

type SyncServiceClient 

type SyncServiceClient = Facade

func (SyncServiceClient) CreateSyncLimit 

func (h SyncServiceClient) CreateSyncLimit(ctx context.Context, in *syncpkg.CreateSyncLimitRequest, _ ...grpc.CallOption) (*syncpkg.SyncLimitResponse, error)

func (SyncServiceClient) DeleteSyncLimit 

func (h SyncServiceClient) DeleteSyncLimit(ctx context.Context, in *syncpkg.DeleteSyncLimitRequest, _ ...grpc.CallOption) (*syncpkg.DeleteSyncLimitResponse, error)

func (SyncServiceClient) GetSyncLimit 

func (h SyncServiceClient) GetSyncLimit(ctx context.Context, in *syncpkg.GetSyncLimitRequest, _ ...grpc.CallOption) (*syncpkg.SyncLimitResponse, error)

func (SyncServiceClient) UpdateSyncLimit 

func (h SyncServiceClient) UpdateSyncLimit(ctx context.Context, in *syncpkg.UpdateSyncLimitRequest, _ ...grpc.CallOption) (*syncpkg.SyncLimitResponse, error)

type WorkflowServiceClient 

type WorkflowServiceClient = Facade

func (WorkflowServiceClient) CreateWorkflow 

func (h WorkflowServiceClient) CreateWorkflow(ctx context.Context, in *workflowpkg.WorkflowCreateRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)

func (WorkflowServiceClient) DeleteWorkflow 

func (h WorkflowServiceClient) DeleteWorkflow(ctx context.Context, in *workflowpkg.WorkflowDeleteRequest, _ ...grpc.CallOption) (*workflowpkg.WorkflowDeleteResponse, error)

func (WorkflowServiceClient) GetWorkflow 

func (h WorkflowServiceClient) GetWorkflow(ctx context.Context, in *workflowpkg.WorkflowGetRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)

func (WorkflowServiceClient) LintWorkflow 

func (h WorkflowServiceClient) LintWorkflow(ctx context.Context, in *workflowpkg.WorkflowLintRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)

func (WorkflowServiceClient) ListWorkflows 

func (h WorkflowServiceClient) ListWorkflows(ctx 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(ctx context.Context, in *workflowpkg.WorkflowResubmitRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)

func (WorkflowServiceClient) ResumeWorkflow 

func (h WorkflowServiceClient) ResumeWorkflow(ctx context.Context, in *workflowpkg.WorkflowResumeRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)

func (WorkflowServiceClient) RetryWorkflow 

func (h WorkflowServiceClient) RetryWorkflow(ctx context.Context, in *workflowpkg.WorkflowRetryRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)

func (WorkflowServiceClient) SetWorkflow 

func (h WorkflowServiceClient) SetWorkflow(ctx context.Context, in *workflowpkg.WorkflowSetRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)

func (WorkflowServiceClient) StopWorkflow 

func (h WorkflowServiceClient) StopWorkflow(ctx context.Context, in *workflowpkg.WorkflowStopRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)

func (WorkflowServiceClient) SubmitWorkflow 

func (h WorkflowServiceClient) SubmitWorkflow(ctx context.Context, in *workflowpkg.WorkflowSubmitRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)

func (WorkflowServiceClient) SuspendWorkflow 

func (h WorkflowServiceClient) SuspendWorkflow(ctx context.Context, in *workflowpkg.WorkflowSuspendRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)

func (WorkflowServiceClient) TerminateWorkflow 

func (h WorkflowServiceClient) TerminateWorkflow(ctx 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(ctx context.Context, in *workflowtemplatepkg.WorkflowTemplateCreateRequest, _ ...grpc.CallOption) (*wfv1.WorkflowTemplate, error)

func (WorkflowTemplateServiceClient) DeleteWorkflowTemplate 

func (h WorkflowTemplateServiceClient) DeleteWorkflowTemplate(ctx context.Context, in *workflowtemplatepkg.WorkflowTemplateDeleteRequest, _ ...grpc.CallOption) (*workflowtemplatepkg.WorkflowTemplateDeleteResponse, error)

func (WorkflowTemplateServiceClient) GetWorkflowTemplate 

func (h WorkflowTemplateServiceClient) GetWorkflowTemplate(ctx context.Context, in *workflowtemplatepkg.WorkflowTemplateGetRequest, _ ...grpc.CallOption) (*wfv1.WorkflowTemplate, error)

func (WorkflowTemplateServiceClient) LintWorkflowTemplate 

func (h WorkflowTemplateServiceClient) LintWorkflowTemplate(ctx context.Context, in *workflowtemplatepkg.WorkflowTemplateLintRequest, _ ...grpc.CallOption) (*wfv1.WorkflowTemplate, error)

func (WorkflowTemplateServiceClient) ListWorkflowTemplates 

func (h WorkflowTemplateServiceClient) ListWorkflowTemplates(ctx context.Context, in *workflowtemplatepkg.WorkflowTemplateListRequest, _ ...grpc.CallOption) (*wfv1.WorkflowTemplateList, error)

func (WorkflowTemplateServiceClient) UpdateWorkflowTemplate 

func (h WorkflowTemplateServiceClient) UpdateWorkflowTemplate(ctx 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.