cluster

Documentation

Index

• type ClientInterface
• type Cluster
  • func FromKubeConfig(ctx context.Context, kubeConfig, contextName string, options RestConfigOptions) (*Cluster, error)
  • func (c *Cluster) Close()
  • func (c *Cluster) DefaultNamespace() string
  • func (c *Cluster) DiscoveryClient() (discovery.DiscoveryInterface, error)
  • func (c *Cluster) DynamicClient() (dynamic.Interface, error)
  • func (c *Cluster) InfoClient() (InfoInterface, error)
  • func (c *Cluster) KubernetesClient() (kubernetes.Interface, error)
  • func (c *Cluster) NamespaceClient() (NamespaceInterface, error)
  • func (c *Cluster) Resource(gk schema.GroupKind) (schema.GroupVersionResource, error)
  • func (c *Cluster) ResourceExists(gvr schema.GroupVersionResource) bool
  • func (c *Cluster) RestClient() (rest.Interface, error)
  • func (c *Cluster) RestConfig() *rest.Config
  • func (c *Cluster) Version() (string, error)
• type InfoInterface
• type NamespaceInterface
• type RestConfigOptions
• type RestInterface

Types

type ClientInterface

type ClientInterface interface {
	DefaultNamespace() string
	ResourceExists(schema.GroupVersionResource) bool
	Resource(kind schema.GroupKind) (schema.GroupVersionResource, error)
	KubernetesClient() (kubernetes.Interface, error)
	DynamicClient() (dynamic.Interface, error)
	DiscoveryClient() (discovery.DiscoveryInterface, error)
	NamespaceClient() (NamespaceInterface, error)
	InfoClient() (InfoInterface, error)
	Close()
	RestInterface
}

type Cluster

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

Cluster is a client for cluster operations

func FromKubeConfig

func FromKubeConfig(ctx context.Context, kubeConfig, contextName string, options RestConfigOptions) (*Cluster, error)

FromKubeConfig creates a Cluster from a kubeConfig.

func (*Cluster) Close

func (c *Cluster) Close()

func (*Cluster) DefaultNamespace

func (c *Cluster) DefaultNamespace() string

func (*Cluster) DiscoveryClient

func (c *Cluster) DiscoveryClient() (discovery.DiscoveryInterface, error)

func (*Cluster) DynamicClient

func (c *Cluster) DynamicClient() (dynamic.Interface, error)

func (*Cluster) InfoClient

func (c *Cluster) InfoClient() (InfoInterface, error)

func (*Cluster) KubernetesClient

func (c *Cluster) KubernetesClient() (kubernetes.Interface, error)

func (*Cluster) NamespaceClient

func (c *Cluster) NamespaceClient() (NamespaceInterface, error)

func (*Cluster) Resource

func (c *Cluster) Resource(gk schema.GroupKind) (schema.GroupVersionResource, error)

func (*Cluster) ResourceExists

func (c *Cluster) ResourceExists(gvr schema.GroupVersionResource) bool

func (*Cluster) RestClient

func (c *Cluster) RestClient() (rest.Interface, error)

func (*Cluster) RestConfig

func (c *Cluster) RestConfig() *rest.Config

func (*Cluster) Version

func (c *Cluster) Version() (string, error)

Version returns a ServerVersion for the cluster.

type InfoInterface

type InfoInterface interface {
	Context() string
	Cluster() string
	Server() string
	User() string
}

InfoInterface provides connection details for a cluster

type NamespaceInterface

type NamespaceInterface interface {
	Names() ([]string, error)
	InitialNamespace() string
}

type RestConfigOptions

type RestConfigOptions struct {
	Qps   float32
	Burst int
}

type RestInterface

type RestInterface interface {
	RestClient() (rest.Interface, error)
	RestConfig() *rest.Config
}