Versions in this module Expand all Collapse all v3 v3.1.5 Jul 29, 2021 Changes in this version + const MaxClientGRPCMessageSize + var NoArgoServerErr = fmt.Errorf("this is impossible if you are not using the Argo Server, see " + help.CLI) + var NotImplError error = fmt.Errorf("Not implemented for offline client, only valid for kind '--kinds=workflows'") + var OfflineErr = fmt.Errorf("not supported when you are in offline mode") + type ArgoServerOpts struct + HTTP1 bool + InsecureSkipVerify bool + Path string + Secure bool + URL string + func (o ArgoServerOpts) GetURL() string + func (o ArgoServerOpts) String() string + type Client interface + NewArchivedWorkflowServiceClient func() (workflowarchivepkg.ArchivedWorkflowServiceClient, error) + NewClusterWorkflowTemplateServiceClient func() (clusterworkflowtmplpkg.ClusterWorkflowTemplateServiceClient, error) + NewCronWorkflowServiceClient func() (cronworkflowpkg.CronWorkflowServiceClient, error) + NewInfoServiceClient func() (infopkg.InfoServiceClient, error) + NewWorkflowServiceClient func() workflowpkg.WorkflowServiceClient + NewWorkflowTemplateServiceClient func() (workflowtemplatepkg.WorkflowTemplateServiceClient, error) + func NewClient(argoServer string, authSupplier func() string, ...) (context.Context, Client, error) + func NewClientFromOpts(opts Opts) (context.Context, Client, error) + type OfflineWorkflowServiceClient struct + func (o OfflineWorkflowServiceClient) CreateWorkflow(context.Context, *workflowpkg.WorkflowCreateRequest, ...grpc.CallOption) (*wfv1.Workflow, error) + func (o OfflineWorkflowServiceClient) DeleteWorkflow(context.Context, *workflowpkg.WorkflowDeleteRequest, ...grpc.CallOption) (*workflowpkg.WorkflowDeleteResponse, error) + func (o OfflineWorkflowServiceClient) GetWorkflow(context.Context, *workflowpkg.WorkflowGetRequest, ...grpc.CallOption) (*wfv1.Workflow, error) + func (o OfflineWorkflowServiceClient) LintWorkflow(_ context.Context, req *workflowpkg.WorkflowLintRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error) + func (o OfflineWorkflowServiceClient) ListWorkflows(context.Context, *workflowpkg.WorkflowListRequest, ...grpc.CallOption) (*wfv1.WorkflowList, error) + func (o OfflineWorkflowServiceClient) PodLogs(context.Context, *workflowpkg.WorkflowLogRequest, ...grpc.CallOption) (workflowpkg.WorkflowService_PodLogsClient, error) + func (o OfflineWorkflowServiceClient) ResubmitWorkflow(context.Context, *workflowpkg.WorkflowResubmitRequest, ...grpc.CallOption) (*wfv1.Workflow, error) + func (o OfflineWorkflowServiceClient) ResumeWorkflow(context.Context, *workflowpkg.WorkflowResumeRequest, ...grpc.CallOption) (*wfv1.Workflow, error) + func (o OfflineWorkflowServiceClient) RetryWorkflow(context.Context, *workflowpkg.WorkflowRetryRequest, ...grpc.CallOption) (*wfv1.Workflow, error) + func (o OfflineWorkflowServiceClient) SetWorkflow(context.Context, *workflowpkg.WorkflowSetRequest, ...grpc.CallOption) (*wfv1.Workflow, error) + func (o OfflineWorkflowServiceClient) StopWorkflow(context.Context, *workflowpkg.WorkflowStopRequest, ...grpc.CallOption) (*wfv1.Workflow, error) + func (o OfflineWorkflowServiceClient) SubmitWorkflow(context.Context, *workflowpkg.WorkflowSubmitRequest, ...grpc.CallOption) (*wfv1.Workflow, error) + func (o OfflineWorkflowServiceClient) SuspendWorkflow(context.Context, *workflowpkg.WorkflowSuspendRequest, ...grpc.CallOption) (*wfv1.Workflow, error) + func (o OfflineWorkflowServiceClient) TerminateWorkflow(context.Context, *workflowpkg.WorkflowTerminateRequest, ...grpc.CallOption) (*wfv1.Workflow, error) + func (o OfflineWorkflowServiceClient) WatchEvents(context.Context, *workflowpkg.WatchEventsRequest, ...grpc.CallOption) (workflowpkg.WorkflowService_WatchEventsClient, error) + func (o OfflineWorkflowServiceClient) WatchWorkflows(context.Context, *workflowpkg.WatchWorkflowsRequest, ...grpc.CallOption) (workflowpkg.WorkflowService_WatchWorkflowsClient, error) + func (o OfflineWorkflowServiceClient) WorkflowLogs(context.Context, *workflowpkg.WorkflowLogRequest, ...grpc.CallOption) (workflowpkg.WorkflowService_WorkflowLogsClient, error) + type Opts struct + ArgoServerOpts ArgoServerOpts + AuthSupplier func() string + ClientConfig clientcmd.ClientConfig + ClientConfigSupplier func() clientcmd.ClientConfig + InstanceID string + Offline bool + func (o Opts) String() string Other modules containing this package github.com/kostas-theo/argo-workflows
Go to main page