zishuo/onepanel
1
0
Fork 0
mirror of https://github.com/onepanelio/onepanel.git synced 2025-10-20 20:25:16 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

add ArgoprojV1alpha1() method to kube.Client

Browse Source
This commit is contained in:
rushtehrani
2020-01-08 16:31:35 -08:00
parent 0d5f91b241
commit 6d32ffff39
2 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
kube/workflow.go
View File

@@ -82,7 +82,7 @@ func (c *Client) create(namespace string, wf *Workflow, opts *WorkflowOptions) (
wf.ObjectMeta.Labels = *opts.Labels
}
createdWorkflow, err = c.argoprojV1alpha1.Workflows(namespace).Create(wf)
createdWorkflow, err = c.ArgoprojV1alpha1().Workflows(namespace).Create(wf)
if err != nil {
return nil, err
}
@@ -114,7 +114,7 @@ func (c *Client) CreateWorkflow(namespace string, manifest []byte, opts *Workflo
}
func (c *Client) GetWorkflow(namespace, name string) (workflow *Workflow, err error) {
workflow, err = c.argoprojV1alpha1.Workflows(namespace).Get(name, v1.GetOptions{})
workflow, err = c.ArgoprojV1alpha1().Workflows(namespace).Get(name, v1.GetOptions{})
return
}
@@ -123,7 +123,7 @@ func (c *Client) ListWorkflows(namespace string, opts *WorkflowOptions) (workflo
if opts.ListOptions == nil {
opts.ListOptions = &ListOptions{}
}
workflowList, err := c.argoprojV1alpha1.Workflows(namespace).List(*opts.ListOptions)
workflowList, err := c.ArgoprojV1alpha1().Workflows(namespace).List(*opts.ListOptions)
if err != nil {
return
}
@@ -140,7 +140,7 @@ func (c *Client) WatchWorkflow(namespace, name string) (watcher watch.Interface,
if err != nil {
return
}
watcher, err = c.argoprojV1alpha1.Workflows(namespace).Watch(metav1.ListOptions{
watcher, err = c.ArgoprojV1alpha1().Workflows(namespace).Watch(metav1.ListOptions{
FieldSelector: fieldSelector.String(),
})