apiclient

package
v3.1.5 Latest Latest
Warning

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

Go to latest
Published: Jul 29, 2021 License: Apache-2.0 Imports: 33 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 (OfflineWorkflowServiceClient) GetWorkflow

func (OfflineWorkflowServiceClient) LintWorkflow

func (OfflineWorkflowServiceClient) ListWorkflows

func (OfflineWorkflowServiceClient) ResubmitWorkflow

func (OfflineWorkflowServiceClient) ResumeWorkflow

func (OfflineWorkflowServiceClient) RetryWorkflow

func (OfflineWorkflowServiceClient) SetWorkflow

func (OfflineWorkflowServiceClient) StopWorkflow

func (OfflineWorkflowServiceClient) SubmitWorkflow

func (OfflineWorkflowServiceClient) SuspendWorkflow

func (OfflineWorkflowServiceClient) TerminateWorkflow

type Opts

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

func (Opts) String

func (o Opts) String() string

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL