Documentation ¶
Index ¶
- Constants
- Variables
- type ArgoServerOpts
- type Client
- type OfflineWorkflowServiceClient
- 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
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) }
type OfflineWorkflowServiceClient ¶ added in v3.1.0
type OfflineWorkflowServiceClient struct{}
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 Opts ¶
type Opts struct { ArgoServerOpts ArgoServerOpts InstanceID string AuthSupplier func() string // DEPRECATED: use `ClientConfigSupplier` ClientConfig clientcmd.ClientConfig ClientConfigSupplier func() clientcmd.ClientConfig Offline bool }
Source Files ¶
- abstract-intermediary.go
- apiclient.go
- argo-kube-client.go
- argo-kube-cluster-workflow-template-service-client.go
- argo-kube-cron-workflow-service-client.go
- argo-kube-workflow-service-client.go
- argo-kube-workflow-template-service-client.go
- argo-server-client.go
- argo-server-opts.go
- error-translating-cluster-workflow-template-service-client.go
- error-translating-cron-workflow-service-client.go
- error-translating-workflow-service-client.go
- error-translating-workflow-template-service-client.go
- http1-client.go
- logs-intermediary.go
- offline-client.go
- offline-workflow-service-client.go
- panic-intermediary.go
- watch-intermediary.go
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. |
Click to show internal directories.
Click to hide internal directories.