package cluster

import "gvisor.dev/gvisor/tools/gvisor_k8s_tool/cluster"

Package cluster provides functions for dealing with Kubernetes clusters.

Index ¶

• Constants
• type Cluster
• func New(config *rest.Config) (*Cluster, error)
• func (c *Cluster) Client() kubernetes.Interface
• func (c *Cluster) CreateDaemonset(ctx context.Context, ds *appsv1.DaemonSet) (*appsv1.DaemonSet, error)
• func (c *Cluster) DeleteDaemonset(ctx context.Context, ds *appsv1.DaemonSet) error
• func (c *Cluster) WaitForDaemonset(ctx context.Context, ds *appsv1.DaemonSet) error

Constants ¶

const (
	// NamespaceDefault is the name of the default Kubernetes namespace.
	NamespaceDefault = "default"
)

Types ¶

type Cluster ¶

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

Cluster presents Kubernetes API method over a Kubernetes cluster.

func New ¶

func New(config *rest.Config) (*Cluster, error)

New initializes a new Cluster from the given client REST config.

func (*Cluster) Client ¶

func (c *Cluster) Client() kubernetes.Interface

Client returns the underlying Kubernetes client.

func (*Cluster) CreateDaemonset ¶

func (c *Cluster) CreateDaemonset(ctx context.Context, ds *appsv1.DaemonSet) (*appsv1.DaemonSet, error)

CreateDaemonset creates a daemonset with default options.

func (*Cluster) DeleteDaemonset ¶

func (c *Cluster) DeleteDaemonset(ctx context.Context, ds *appsv1.DaemonSet) error

DeleteDaemonset deletes a daemonset from this cluster.

func (*Cluster) WaitForDaemonset ¶

func (c *Cluster) WaitForDaemonset(ctx context.Context, ds *appsv1.DaemonSet) error

WaitForDaemonset waits until a daemonset has propagated containers across the affected nodes.

Source Files ¶

cluster.go