apiclient

package
v3.2.3-jfd Latest Latest
Warning

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

 Go to latest Published: Nov 9, 2021 License: Apache-2.0 Imports: 34 Imported by: 0

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 NotImplError error = fmt.Errorf("Not implemented for offline client, only valid for kind '--kinds=workflows'")
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
}

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 OfflineWorkflowServiceClient 

type OfflineWorkflowServiceClient struct{}

func (OfflineWorkflowServiceClient) CreateWorkflow 

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

func (OfflineWorkflowServiceClient) DeleteWorkflow 

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

func (OfflineWorkflowServiceClient) GetWorkflow 

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

func (OfflineWorkflowServiceClient) LintWorkflow 

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

func (OfflineWorkflowServiceClient) ListWorkflows 

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

func (OfflineWorkflowServiceClient) PodLogs 

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

func (OfflineWorkflowServiceClient) ResubmitWorkflow 

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

func (OfflineWorkflowServiceClient) ResumeWorkflow 

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

func (OfflineWorkflowServiceClient) RetryWorkflow 

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

func (OfflineWorkflowServiceClient) SetWorkflow 

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

func (OfflineWorkflowServiceClient) StopWorkflow 

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

func (OfflineWorkflowServiceClient) SubmitWorkflow 

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

func (OfflineWorkflowServiceClient) SuspendWorkflow 

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

func (OfflineWorkflowServiceClient) TerminateWorkflow 

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

func (OfflineWorkflowServiceClient) WatchEvents 

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

func (OfflineWorkflowServiceClient) WatchWorkflows 

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

func (OfflineWorkflowServiceClient) WorkflowLogs 

func (o OfflineWorkflowServiceClient) WorkflowLogs(context.Context, *workflowpkg.WorkflowLogRequest, ...grpc.CallOption) (workflowpkg.WorkflowService_WorkflowLogsClient, 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
	Context              context.Context
}

func (*Opts) GetContext 

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 pipeline is a reverse proxy.
 Package pipeline 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.