k8s

Documentation

Index

• func NewClient() (*kubernetes.Clientset, error)
• type DeploymentResource
  • func NewDeploymentResource(clientset *kubernetes.Clientset, namespace string) *DeploymentResource
  • func (r *DeploymentResource) IsReady(resource metav1.Object) bool
  • func (r *DeploymentResource) Watch(ctx context.Context, namespace, name, labelSelector string) (chan metav1.Object, error)
• type JobResource
  • func NewJobResource(clientset *kubernetes.Clientset, namespace string) *JobResource
  • func (jr *JobResource) IsReady(resource runtime.Object) bool
  • func (jr *JobResource) Watch(ctx context.Context, namespace string, name string, labelSelector string) (<-chan runtime.Object, error)
• type PodResource
  • func NewPodResource(clientset *kubernetes.Clientset, namespace string) *PodResource
  • func (r *PodResource) IsReady(resource metav1.Object) bool
  • func (r *PodResource) Watch(ctx context.Context, namespace, name, labelSelector string) (chan metav1.Object, error)
• type Resource
  • func (r *Resource) WaitForReady(namespace string, name string, labelSelector string) error
• type ResourceReadyChecker
• type ResourceWatcher
• type ServiceResource
  • func NewServiceResource(client *corev1.CoreV1Client) *ServiceResource
  • func (sr *ServiceResource) IsReady(resource runtime.Object) bool
  • func (sr *ServiceResource) Watch(ctx context.Context, namespace string, name string, labelSelector string) (chan runtime.Object, error)

Functions

func NewClient

func NewClient() (*kubernetes.Clientset, error)

NewClient creates a new Kubernetes client.

Types

type DeploymentResource

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

func NewDeploymentResource

func NewDeploymentResource(clientset *kubernetes.Clientset, namespace string) *DeploymentResource

func (*DeploymentResource) IsReady

func (r *DeploymentResource) IsReady(resource metav1.Object) bool

func (*DeploymentResource) Watch

func (r *DeploymentResource) Watch(ctx context.Context, namespace, name, labelSelector string) (chan metav1.Object, error)

type JobResource

type JobResource struct {
	Client batchv1.JobInterface
}

func NewJobResource

func NewJobResource(clientset *kubernetes.Clientset, namespace string) *JobResource

func (*JobResource) IsReady

func (jr *JobResource) IsReady(resource runtime.Object) bool

func (*JobResource) Watch

func (jr *JobResource) Watch(ctx context.Context, namespace string, name string, labelSelector string) (<-chan runtime.Object, error)

type PodResource

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

func NewPodResource

func NewPodResource(clientset *kubernetes.Clientset, namespace string) *PodResource

func (*PodResource) IsReady

func (r *PodResource) IsReady(resource metav1.Object) bool

func (*PodResource) Watch

func (r *PodResource) Watch(ctx context.Context, namespace, name, labelSelector string) (chan metav1.Object, error)

type Resource

type Resource struct {
	Watcher      ResourceWatcher
	ReadyChecker ResourceReadyChecker
}

func (*Resource) WaitForReady

func (r *Resource) WaitForReady(namespace string, name string, labelSelector string) error

type ResourceReadyChecker

type ResourceReadyChecker interface {
	IsReady(resource runtime.Object) bool
}

type ResourceWatcher

type ResourceWatcher interface {
	Watch(namespace string, name string, labelSelector string) (<-chan runtime.Object, error)
}

type ServiceResource

type ServiceResource struct {
	Client *corev1.CoreV1Client
}

func NewServiceResource

func NewServiceResource(client *corev1.CoreV1Client) *ServiceResource

func (*ServiceResource) IsReady

func (sr *ServiceResource) IsReady(resource runtime.Object) bool

func (*ServiceResource) Watch

func (sr *ServiceResource) Watch(ctx context.Context, namespace string, name string, labelSelector string) (chan runtime.Object, error)