util

Documentation

Index

• Variables
• func GetKubeClient() (client *kubernetes.Clientset, config *rest.Config, err error)
• type PipelineClient
  • func NewPipelineClient(cfg *rest.Config, namespace string) (*PipelineClient, error)
  • func (c *PipelineClient) Create(obj *v1beta1.Pipeline) (*v1beta1.Pipeline, error)
  • func (c *PipelineClient) CreatePipelineRun(obj *v1beta1.PipelineRun) (*v1beta1.PipelineRun, error)
  • func (c *PipelineClient) Delete(name string, options *metav1.DeleteOptions) error
  • func (c *PipelineClient) DeletePipelineRun(name string, options *metav1.DeleteOptions) error
  • func (c *PipelineClient) Get(name string) (*v1beta1.Pipeline, error)
  • func (c *PipelineClient) GetPipelineRun(name string) (*v1beta1.PipelineRun, error)
  • func (c *PipelineClient) Update(obj *v1beta1.Pipeline) (*v1beta1.Pipeline, error)
  • func (c *PipelineClient) UpdatePipelineRun(obj *v1beta1.PipelineRun) (*v1beta1.PipelineRun, error)
• type TaskClient
  • func NewClient(cfg *rest.Config, namespace string) (*TaskClient, error)
  • func (c *TaskClient) Create(obj *v1beta1.Task) (*v1beta1.Task, error)
  • func (c *TaskClient) CreateTaskRun(obj *v1beta1.TaskRun) (*v1beta1.TaskRun, error)
  • func (c *TaskClient) Delete(name string, options *metav1.DeleteOptions) error
  • func (c *TaskClient) DeleteTaskRun(name string, options *metav1.DeleteOptions) error
  • func (c *TaskClient) Get(name string) (*v1beta1.Task, error)
  • func (c *TaskClient) GetTaskRun(name string) (*v1beta1.TaskRun, error)
  • func (c *TaskClient) Update(obj *v1beta1.Task) (*v1beta1.Task, error)
  • func (c *TaskClient) UpdateTaskRun(obj *v1beta1.TaskRun) (*v1beta1.TaskRun, error)

Variables

var SchemeGroupVersion = schema.GroupVersion{Group: pipeline.GroupName, Version: "v1beta1"}

Functions

func GetKubeClient

func GetKubeClient() (client *kubernetes.Clientset, config *rest.Config, err error)

GetKubeClient will get a kubernetes client from the following sources:

• a path to the kubeconfig file passed on the command line (--kubeconfig)
• an environment variable that specifies the path (export KUBECONFIG)
• the user's $HOME/.kube/config file
• in-cluster connection for when the sdk is run within a cluster instead of the command line

Types

type PipelineClient

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

func NewPipelineClient

func NewPipelineClient(cfg *rest.Config, namespace string) (*PipelineClient, error)

func (*PipelineClient) Create

func (c *PipelineClient) Create(obj *v1beta1.Pipeline) (*v1beta1.Pipeline, error)

func (*PipelineClient) CreatePipelineRun

func (c *PipelineClient) CreatePipelineRun(obj *v1beta1.PipelineRun) (*v1beta1.PipelineRun, error)

func (*PipelineClient) Delete

func (c *PipelineClient) Delete(name string, options *metav1.DeleteOptions) error

func (*PipelineClient) DeletePipelineRun

func (c *PipelineClient) DeletePipelineRun(name string, options *metav1.DeleteOptions) error

func (*PipelineClient) Get

func (c *PipelineClient) Get(name string) (*v1beta1.Pipeline, error)

func (*PipelineClient) GetPipelineRun

func (c *PipelineClient) GetPipelineRun(name string) (*v1beta1.PipelineRun, error)

func (*PipelineClient) Update

func (c *PipelineClient) Update(obj *v1beta1.Pipeline) (*v1beta1.Pipeline, error)

func (*PipelineClient) UpdatePipelineRun

func (c *PipelineClient) UpdatePipelineRun(obj *v1beta1.PipelineRun) (*v1beta1.PipelineRun, error)

type TaskClient

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

func NewClient

func NewClient(cfg *rest.Config, namespace string) (*TaskClient, error)

func (*TaskClient) Create

func (c *TaskClient) Create(obj *v1beta1.Task) (*v1beta1.Task, error)

func (*TaskClient) CreateTaskRun

func (c *TaskClient) CreateTaskRun(obj *v1beta1.TaskRun) (*v1beta1.TaskRun, error)

func (*TaskClient) Delete

func (c *TaskClient) Delete(name string, options *metav1.DeleteOptions) error

func (*TaskClient) DeleteTaskRun

func (c *TaskClient) DeleteTaskRun(name string, options *metav1.DeleteOptions) error

func (*TaskClient) Get

func (c *TaskClient) Get(name string) (*v1beta1.Task, error)

func (*TaskClient) GetTaskRun

func (c *TaskClient) GetTaskRun(name string) (*v1beta1.TaskRun, error)

func (*TaskClient) Update

func (c *TaskClient) Update(obj *v1beta1.Task) (*v1beta1.Task, error)

func (*TaskClient) UpdateTaskRun

func (c *TaskClient) UpdateTaskRun(obj *v1beta1.TaskRun) (*v1beta1.TaskRun, error)