apiclient

package
v3.5.5 Latest Latest
Warning

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

 Go to latest Published: Feb 29, 2024 License: Apache-2.0 Imports: 41 Imported by: 11

Documentation

Index

Constants

View Source 
const (
	// MaxGRPCMessageSize contains max grpc message size supported by the client
	MaxClientGRPCMessageSize = 100 * 1024 * 1024
)

Variables

View Source 
var (
	NoArgoServerErr = fmt.Errorf("this is impossible if you are not using the Argo Server, see " + help.CLI)
)
View Source 
var OfflineErr = fmt.Errorf("not supported when you are in offline mode")

Functions

This section is empty.

Types

type ArgoServerOpts 

type ArgoServerOpts struct {
	// argo server host port, must be `host:port`, e.g. localhost:2746
	URL string
	// any base path needed (e.g. due to being behind an ingress)
	Path               string
	Secure             bool
	InsecureSkipVerify bool
	// whether or not to use HTTP1
	HTTP1   bool
	Headers []string
}

func (ArgoServerOpts) GetURL 

func (o ArgoServerOpts) GetURL() string

func (ArgoServerOpts) String 

func (o ArgoServerOpts) String() string

type Client 

type Client interface {
	NewArchivedWorkflowServiceClient() (workflowarchivepkg.ArchivedWorkflowServiceClient, error)
	NewWorkflowServiceClient() workflowpkg.WorkflowServiceClient
	NewCronWorkflowServiceClient() (cronworkflowpkg.CronWorkflowServiceClient, error)
	NewWorkflowTemplateServiceClient() (workflowtemplatepkg.WorkflowTemplateServiceClient, error)
	NewClusterWorkflowTemplateServiceClient() (clusterworkflowtmplpkg.ClusterWorkflowTemplateServiceClient, error)
	NewInfoServiceClient() (infopkg.InfoServiceClient, error)
}

func NewClient 

func NewClient(argoServer string, authSupplier func() string, clientConfig clientcmd.ClientConfig) (context.Context, Client, error)

DEPRECATED: use NewClientFromOpts

func NewClientFromOpts 

func NewClientFromOpts(opts Opts) (context.Context, Client, error)

type OfflineClusterWorkflowTemplateServiceClient added in v3.4.7 

type OfflineClusterWorkflowTemplateServiceClient struct {
	// contains filtered or unexported fields
}

func (OfflineClusterWorkflowTemplateServiceClient) CreateClusterWorkflowTemplate added in v3.4.7 

func (o OfflineClusterWorkflowTemplateServiceClient) CreateClusterWorkflowTemplate(ctx context.Context, req *clusterworkflowtmplpkg.ClusterWorkflowTemplateCreateRequest, opts ...grpc.CallOption) (*v1alpha1.ClusterWorkflowTemplate, error)

func (OfflineClusterWorkflowTemplateServiceClient) DeleteClusterWorkflowTemplate added in v3.4.7 

func (o OfflineClusterWorkflowTemplateServiceClient) DeleteClusterWorkflowTemplate(ctx context.Context, req *clusterworkflowtmplpkg.ClusterWorkflowTemplateDeleteRequest, opts ...grpc.CallOption) (*clusterworkflowtmplpkg.ClusterWorkflowTemplateDeleteResponse, error)

func (OfflineClusterWorkflowTemplateServiceClient) GetClusterWorkflowTemplate added in v3.4.7 

func (o OfflineClusterWorkflowTemplateServiceClient) GetClusterWorkflowTemplate(ctx context.Context, req *clusterworkflowtmplpkg.ClusterWorkflowTemplateGetRequest, opts ...grpc.CallOption) (*v1alpha1.ClusterWorkflowTemplate, error)

func (OfflineClusterWorkflowTemplateServiceClient) LintClusterWorkflowTemplate added in v3.4.7 

func (o OfflineClusterWorkflowTemplateServiceClient) LintClusterWorkflowTemplate(ctx context.Context, req *clusterworkflowtmplpkg.ClusterWorkflowTemplateLintRequest, opts ...grpc.CallOption) (*v1alpha1.ClusterWorkflowTemplate, error)

func (OfflineClusterWorkflowTemplateServiceClient) ListClusterWorkflowTemplates added in v3.4.7 

func (o OfflineClusterWorkflowTemplateServiceClient) ListClusterWorkflowTemplates(ctx context.Context, req *clusterworkflowtmplpkg.ClusterWorkflowTemplateListRequest, opts ...grpc.CallOption) (*v1alpha1.ClusterWorkflowTemplateList, error)

func (OfflineClusterWorkflowTemplateServiceClient) UpdateClusterWorkflowTemplate added in v3.4.7 

func (o OfflineClusterWorkflowTemplateServiceClient) UpdateClusterWorkflowTemplate(ctx context.Context, req *clusterworkflowtmplpkg.ClusterWorkflowTemplateUpdateRequest, opts ...grpc.CallOption) (*v1alpha1.ClusterWorkflowTemplate, error)

type OfflineCronWorkflowServiceClient added in v3.4.7 

type OfflineCronWorkflowServiceClient struct {
	// contains filtered or unexported fields
}

func (OfflineCronWorkflowServiceClient) CreateCronWorkflow added in v3.4.7 

func (o OfflineCronWorkflowServiceClient) CreateCronWorkflow(ctx context.Context, req *cronworkflow.CreateCronWorkflowRequest, _ ...grpc.CallOption) (*v1alpha1.CronWorkflow, error)

func (OfflineCronWorkflowServiceClient) DeleteCronWorkflow added in v3.4.7 

func (o OfflineCronWorkflowServiceClient) DeleteCronWorkflow(ctx context.Context, req *cronworkflow.DeleteCronWorkflowRequest, _ ...grpc.CallOption) (*cronworkflow.CronWorkflowDeletedResponse, error)

func (OfflineCronWorkflowServiceClient) GetCronWorkflow added in v3.4.7 

func (o OfflineCronWorkflowServiceClient) GetCronWorkflow(ctx context.Context, req *cronworkflow.GetCronWorkflowRequest, _ ...grpc.CallOption) (*v1alpha1.CronWorkflow, error)

func (OfflineCronWorkflowServiceClient) LintCronWorkflow added in v3.4.7 

func (o OfflineCronWorkflowServiceClient) LintCronWorkflow(ctx context.Context, req *cronworkflow.LintCronWorkflowRequest, _ ...grpc.CallOption) (*v1alpha1.CronWorkflow, error)

func (OfflineCronWorkflowServiceClient) ListCronWorkflows added in v3.4.7 

func (o OfflineCronWorkflowServiceClient) ListCronWorkflows(ctx context.Context, req *cronworkflow.ListCronWorkflowsRequest, _ ...grpc.CallOption) (*v1alpha1.CronWorkflowList, error)

func (OfflineCronWorkflowServiceClient) ResumeCronWorkflow added in v3.4.7 

func (o OfflineCronWorkflowServiceClient) ResumeCronWorkflow(ctx context.Context, req *cronworkflow.CronWorkflowResumeRequest, _ ...grpc.CallOption) (*v1alpha1.CronWorkflow, error)

func (OfflineCronWorkflowServiceClient) SuspendCronWorkflow added in v3.4.7 

func (o OfflineCronWorkflowServiceClient) SuspendCronWorkflow(ctx context.Context, req *cronworkflow.CronWorkflowSuspendRequest, _ ...grpc.CallOption) (*v1alpha1.CronWorkflow, error)

func (OfflineCronWorkflowServiceClient) UpdateCronWorkflow added in v3.4.7 

func (o OfflineCronWorkflowServiceClient) UpdateCronWorkflow(ctx context.Context, req *cronworkflow.UpdateCronWorkflowRequest, _ ...grpc.CallOption) (*v1alpha1.CronWorkflow, error)

type OfflineWorkflowServiceClient added in v3.1.0 

type OfflineWorkflowServiceClient struct {
	// contains filtered or unexported fields
}

func (OfflineWorkflowServiceClient) CreateWorkflow added in v3.1.0 

func (o OfflineWorkflowServiceClient) CreateWorkflow(context.Context, *workflowpkg.WorkflowCreateRequest, ...grpc.CallOption) (*wfv1.Workflow, error)

func (OfflineWorkflowServiceClient) DeleteWorkflow added in v3.1.0 

func (o OfflineWorkflowServiceClient) DeleteWorkflow(context.Context, *workflowpkg.WorkflowDeleteRequest, ...grpc.CallOption) (*workflowpkg.WorkflowDeleteResponse, error)

func (OfflineWorkflowServiceClient) GetWorkflow added in v3.1.0 

func (o OfflineWorkflowServiceClient) GetWorkflow(context.Context, *workflowpkg.WorkflowGetRequest, ...grpc.CallOption) (*wfv1.Workflow, error)

func (OfflineWorkflowServiceClient) LintWorkflow added in v3.1.0 

func (o OfflineWorkflowServiceClient) LintWorkflow(_ context.Context, req *workflowpkg.WorkflowLintRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error)

func (OfflineWorkflowServiceClient) ListWorkflows added in v3.1.0 

func (o OfflineWorkflowServiceClient) ListWorkflows(context.Context, *workflowpkg.WorkflowListRequest, ...grpc.CallOption) (*wfv1.WorkflowList, error)

func (OfflineWorkflowServiceClient) PodLogs added in v3.1.0 

func (o OfflineWorkflowServiceClient) PodLogs(context.Context, *workflowpkg.WorkflowLogRequest, ...grpc.CallOption) (workflowpkg.WorkflowService_PodLogsClient, error)

func (OfflineWorkflowServiceClient) ResubmitWorkflow added in v3.1.0 

func (o OfflineWorkflowServiceClient) ResubmitWorkflow(context.Context, *workflowpkg.WorkflowResubmitRequest, ...grpc.CallOption) (*wfv1.Workflow, error)

func (OfflineWorkflowServiceClient) ResumeWorkflow added in v3.1.0 

func (o OfflineWorkflowServiceClient) ResumeWorkflow(context.Context, *workflowpkg.WorkflowResumeRequest, ...grpc.CallOption) (*wfv1.Workflow, error)

func (OfflineWorkflowServiceClient) RetryWorkflow added in v3.1.0 

func (o OfflineWorkflowServiceClient) RetryWorkflow(context.Context, *workflowpkg.WorkflowRetryRequest, ...grpc.CallOption) (*wfv1.Workflow, error)

func (OfflineWorkflowServiceClient) SetWorkflow added in v3.1.0 

func (o OfflineWorkflowServiceClient) SetWorkflow(context.Context, *workflowpkg.WorkflowSetRequest, ...grpc.CallOption) (*wfv1.Workflow, error)

func (OfflineWorkflowServiceClient) StopWorkflow added in v3.1.0 

func (o OfflineWorkflowServiceClient) StopWorkflow(context.Context, *workflowpkg.WorkflowStopRequest, ...grpc.CallOption) (*wfv1.Workflow, error)

func (OfflineWorkflowServiceClient) SubmitWorkflow added in v3.1.0 

func (o OfflineWorkflowServiceClient) SubmitWorkflow(context.Context, *workflowpkg.WorkflowSubmitRequest, ...grpc.CallOption) (*wfv1.Workflow, error)

func (OfflineWorkflowServiceClient) SuspendWorkflow added in v3.1.0 

func (o OfflineWorkflowServiceClient) SuspendWorkflow(context.Context, *workflowpkg.WorkflowSuspendRequest, ...grpc.CallOption) (*wfv1.Workflow, error)

func (OfflineWorkflowServiceClient) TerminateWorkflow added in v3.1.0 

func (o OfflineWorkflowServiceClient) TerminateWorkflow(context.Context, *workflowpkg.WorkflowTerminateRequest, ...grpc.CallOption) (*wfv1.Workflow, error)

func (OfflineWorkflowServiceClient) WatchEvents added in v3.1.0 

func (o OfflineWorkflowServiceClient) WatchEvents(context.Context, *workflowpkg.WatchEventsRequest, ...grpc.CallOption) (workflowpkg.WorkflowService_WatchEventsClient, error)

func (OfflineWorkflowServiceClient) WatchWorkflows added in v3.1.0 

func (o OfflineWorkflowServiceClient) WatchWorkflows(context.Context, *workflowpkg.WatchWorkflowsRequest, ...grpc.CallOption) (workflowpkg.WorkflowService_WatchWorkflowsClient, error)

func (OfflineWorkflowServiceClient) WorkflowLogs added in v3.1.0 

func (o OfflineWorkflowServiceClient) WorkflowLogs(context.Context, *workflowpkg.WorkflowLogRequest, ...grpc.CallOption) (workflowpkg.WorkflowService_WorkflowLogsClient, error)

type OfflineWorkflowTemplateServiceClient added in v3.4.7 

type OfflineWorkflowTemplateServiceClient struct {
	// contains filtered or unexported fields
}

func (OfflineWorkflowTemplateServiceClient) CreateWorkflowTemplate added in v3.4.7 

func (o OfflineWorkflowTemplateServiceClient) CreateWorkflowTemplate(ctx context.Context, req *workflowtemplatepkg.WorkflowTemplateCreateRequest, _ ...grpc.CallOption) (*v1alpha1.WorkflowTemplate, error)

func (OfflineWorkflowTemplateServiceClient) DeleteWorkflowTemplate added in v3.4.7 

func (o OfflineWorkflowTemplateServiceClient) DeleteWorkflowTemplate(ctx context.Context, req *workflowtemplatepkg.WorkflowTemplateDeleteRequest, _ ...grpc.CallOption) (*workflowtemplatepkg.WorkflowTemplateDeleteResponse, error)

func (OfflineWorkflowTemplateServiceClient) GetWorkflowTemplate added in v3.4.7 

func (o OfflineWorkflowTemplateServiceClient) GetWorkflowTemplate(ctx context.Context, req *workflowtemplatepkg.WorkflowTemplateGetRequest, _ ...grpc.CallOption) (*v1alpha1.WorkflowTemplate, error)

func (OfflineWorkflowTemplateServiceClient) LintWorkflowTemplate added in v3.4.7 

func (o OfflineWorkflowTemplateServiceClient) LintWorkflowTemplate(ctx context.Context, req *workflowtemplatepkg.WorkflowTemplateLintRequest, _ ...grpc.CallOption) (*v1alpha1.WorkflowTemplate, error)

func (OfflineWorkflowTemplateServiceClient) ListWorkflowTemplates added in v3.4.7 

func (o OfflineWorkflowTemplateServiceClient) ListWorkflowTemplates(ctx context.Context, req *workflowtemplatepkg.WorkflowTemplateListRequest, _ ...grpc.CallOption) (*v1alpha1.WorkflowTemplateList, error)

func (OfflineWorkflowTemplateServiceClient) UpdateWorkflowTemplate added in v3.4.7 

func (o OfflineWorkflowTemplateServiceClient) UpdateWorkflowTemplate(ctx context.Context, req *workflowtemplatepkg.WorkflowTemplateUpdateRequest, _ ...grpc.CallOption) (*v1alpha1.WorkflowTemplate, error)

type Opts 

type Opts struct {
	ArgoServerOpts ArgoServerOpts
	InstanceID     string
	AuthSupplier   func() string
	// DEPRECATED: use `ClientConfigSupplier`
	ClientConfig         clientcmd.ClientConfig
	ClientConfigSupplier func() clientcmd.ClientConfig
	Offline              bool
	OfflineFiles         []string
	Context              context.Context
}

func (*Opts) GetContext added in v3.2.0 

func (o *Opts) GetContext() context.Context

func (Opts) String 

func (o Opts) String() string

Source Files

View all Source files

Directories

Path Synopsis
Package clusterworkflowtemplate is a reverse proxy.
 Package clusterworkflowtemplate is a reverse proxy.
Package cronworkflow is a reverse proxy.
 Package cronworkflow is a reverse proxy.
Package event is a reverse proxy.
 Package event is a reverse proxy.
Package eventsource is a reverse proxy.
 Package eventsource is a reverse proxy.
Package info is a reverse proxy.
 Package info is a reverse proxy.
Package sensor is a reverse proxy.
 Package sensor is a reverse proxy.
Package workflow is a reverse proxy.
 Package workflow is a reverse proxy.
mocks
Package workflowarchive is a reverse proxy.
 Package workflowarchive is a reverse proxy.
Package workflowtemplate is a reverse proxy.
 Package workflowtemplate is a reverse proxy.
mocks

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.