kube

Documentation

Index

• type Agent
• type DefaultAgent
  • func (k DefaultAgent) GetClusterDeployments(kube kubernetes.Interface, name string) ([]appsv1.Deployment, error)
  • func (k DefaultAgent) GetClusterStatefulSets(kube kubernetes.Interface, name string) ([]appsv1.StatefulSet, error)
  • func (k DefaultAgent) GetClusterStatus(kube kubernetes.Interface, name string) bool

Types

type Agent

type Agent interface {
	GetClusterDeployments(kubernetes.Interface, string) ([]appsv1.Deployment, error)
	GetClusterStatefulSets(kubernetes.Interface, string) ([]appsv1.StatefulSet, error)
	GetClusterStatus(kubernetes.Interface, string) bool
}

Agent is used for communication with Kubernetes, made into an interface for testability

type DefaultAgent

type DefaultAgent struct{}

DefaultAgent is the default implementation of the KubeAgent

func (DefaultAgent) GetClusterDeployments

func (k DefaultAgent) GetClusterDeployments(kube kubernetes.Interface, name string) ([]appsv1.Deployment, error)

GetClusterDeployments gets all the deployments for a particular cluster

func (DefaultAgent) GetClusterStatefulSets

func (k DefaultAgent) GetClusterStatefulSets(kube kubernetes.Interface, name string) ([]appsv1.StatefulSet, error)

GetClusterStatefulSets gets all the statefulsets for a particular cluster

func (DefaultAgent) GetClusterStatus

func (k DefaultAgent) GetClusterStatus(kube kubernetes.Interface, name string) bool

GetClusterStatus returns the status of a cluster by ensuring each node is in a ready state