producers

Documentation

Index

• type Kubernetes
  • func New(client kubernetes.Interface, config *restclient.Config) *Kubernetes
  • func (k *Kubernetes) APIVersions(ctx context.Context) (interface{}, error)
  • func (k *Kubernetes) ClusterInfo(ctx context.Context) (interface{}, error)
  • func (k *Kubernetes) ContainerCp(pod, container, namespace, path string) types.StreamsProducer
  • func (k *Kubernetes) Logs(opts types.KubernetesLogsOptions) types.StreamProducer
  • func (k *Kubernetes) ResourceList(opts types.KubernetesResourceListOptions) types.StructuredProducer
  • func (k *Kubernetes) Version(ctx context.Context) (interface{}, error)

Types

type Kubernetes

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

func New

func New(client kubernetes.Interface, config *restclient.Config) *Kubernetes

func (*Kubernetes) APIVersions

func (k *Kubernetes) APIVersions(ctx context.Context) (interface{}, error)

func (*Kubernetes) ClusterInfo

func (k *Kubernetes) ClusterInfo(ctx context.Context) (interface{}, error)

func (*Kubernetes) ContainerCp

func (k *Kubernetes) ContainerCp(pod, container, namespace, path string) types.StreamsProducer

ContainerCp copies a file/folder from the provided directory within the pod+container. if container=="", it copies that file/folder from all containers in the pod.

func (*Kubernetes) Logs

func (k *Kubernetes) Logs(opts types.KubernetesLogsOptions) types.StreamProducer

func (*Kubernetes) ResourceList

func (k *Kubernetes) ResourceList(opts types.KubernetesResourceListOptions) types.StructuredProducer

func (*Kubernetes) Version

func (k *Kubernetes) Version(ctx context.Context) (interface{}, error)