kube

Documentation

Index

• type Client
  • func New(getter genericclioptions.RESTClientGetter, log func(string, ...interface{})) (*Client, error)
  • func (c *Client) Build(reader io.Reader, validate bool) (kube.ResourceList, error)
  • func (c *Client) Create(resources kube.ResourceList) (*kube.Result, error)
  • func (c *Client) Delete(resources kube.ResourceList) (*kube.Result, []error)
  • func (c *Client) IsReachable() error
  • func (c *Client) Update(original_nee_current, target kube.ResourceList, force bool) (*kube.Result, error)
  • func (c *Client) Wait(resources kube.ResourceList, timeout time.Duration) error
  • func (c *Client) WaitAndGetCompletedPodPhase(name string, timeout time.Duration) (v1.PodPhase, error)
  • func (c *Client) WaitWithJobs(resources kube.ResourceList, timeout time.Duration) error
  • func (c *Client) WatchUntilReady(resources kube.ResourceList, timeout time.Duration) error

Types

type Client

type Client struct {
	*kube.Client
	// contains filtered or unexported fields
}

func New

func New(getter genericclioptions.RESTClientGetter, log func(string, ...interface{})) (*Client, error)

func (*Client) Build

func (c *Client) Build(reader io.Reader, validate bool) (kube.ResourceList, error)

func (*Client) Create

func (c *Client) Create(resources kube.ResourceList) (*kube.Result, error)

func (*Client) Delete

func (c *Client) Delete(resources kube.ResourceList) (*kube.Result, []error)

func (*Client) IsReachable

func (c *Client) IsReachable() error

func (*Client) Update

func (c *Client) Update(original_nee_current, target kube.ResourceList, force bool) (*kube.Result, error)

Update takes the current list of objects and target list of objects and creates resources that don't already exist, updates resources that have been modified in the target configuration, and deletes resources from the current configuration that are not present in the target configuration. If an error occurs, a Result will still be returned with the error, containing all resource updates, creations, and deletions that were attempted. These can be used for cleanup or other logging purposes.

func (*Client) Wait

func (c *Client) Wait(resources kube.ResourceList, timeout time.Duration) error

func (*Client) WaitAndGetCompletedPodPhase

func (c *Client) WaitAndGetCompletedPodPhase(name string, timeout time.Duration) (v1.PodPhase, error)

func (*Client) WaitWithJobs

func (c *Client) WaitWithJobs(resources kube.ResourceList, timeout time.Duration) error

func (*Client) WatchUntilReady

func (c *Client) WatchUntilReady(resources kube.ResourceList, timeout time.Duration) error