client

Documentation

Index

• func CreateCustomResourceDefinition(clientset apiextensionsclient.Interface) (*apiextensionsv1beta1.CustomResourceDefinition, error)
• func DeleteCustomResourceDefinition(clientset apiextensionsclient.Interface) error
• func NewRESTClient(cfg *rest.Config) (*rest.RESTClient, *runtime.Scheme, error)
• type WorkflowClient
  • func NewWorkflowClient(cl *rest.RESTClient, scheme *runtime.Scheme, namespace string) *WorkflowClient
  • func (f *WorkflowClient) CreateWorkflow(obj *wfv1.Workflow) (*wfv1.Workflow, error)
  • func (f *WorkflowClient) DeleteWorkflow(name string, options *metav1.DeleteOptions) error
  • func (f *WorkflowClient) GetWorkflow(name string) (*wfv1.Workflow, error)
  • func (f *WorkflowClient) ListWorkflows(opts metav1.ListOptions) (*wfv1.WorkflowList, error)
  • func (f *WorkflowClient) UpdateWorkflow(obj *wfv1.Workflow) (*wfv1.Workflow, error)

Functions

func CreateCustomResourceDefinition

func CreateCustomResourceDefinition(clientset apiextensionsclient.Interface) (*apiextensionsv1beta1.CustomResourceDefinition, error)

func DeleteCustomResourceDefinition

func DeleteCustomResourceDefinition(clientset apiextensionsclient.Interface) error

DeleteCustomResourceDefinition deletes the Workflow CRD

func NewRESTClient

func NewRESTClient(cfg *rest.Config) (*rest.RESTClient, *runtime.Scheme, error)

NewRESTClient returns a generic RESTClient that operates on kubernetes-like APIs

Types

type WorkflowClient

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

func NewWorkflowClient

func NewWorkflowClient(cl *rest.RESTClient, scheme *runtime.Scheme, namespace string) *WorkflowClient

func (*WorkflowClient) CreateWorkflow

func (f *WorkflowClient) CreateWorkflow(obj *wfv1.Workflow) (*wfv1.Workflow, error)

func (*WorkflowClient) DeleteWorkflow

func (f *WorkflowClient) DeleteWorkflow(name string, options *metav1.DeleteOptions) error

func (*WorkflowClient) GetWorkflow

func (f *WorkflowClient) GetWorkflow(name string) (*wfv1.Workflow, error)

func (*WorkflowClient) ListWorkflows

func (f *WorkflowClient) ListWorkflows(opts metav1.ListOptions) (*wfv1.WorkflowList, error)

func (*WorkflowClient) UpdateWorkflow

func (f *WorkflowClient) UpdateWorkflow(obj *wfv1.Workflow) (*wfv1.Workflow, error)