resources

Documentation

Index

• type ConfigMapManager
  • func NewConfigMapManager(k8sClient client.Client) ConfigMapManager
• type CustomResourceManager
  • func NewCustomResourceManager(k8sClient client.Client) CustomResourceManager
• type DaemonSetManager
  • func NewDefaultDaemonSetManager(k8sClient client.Client) DaemonSetManager
• type DeploymentManager
  • func NewDefaultDeploymentManager(k8sClient client.Client) DeploymentManager
• type EventManager
  • func NewEventManager(k8sClient client.Client) EventManager
• type JobManager
  • func NewDefaultJobManager(k8sClient client.Client) JobManager
• type NamespaceManager
  • func NewDefaultNamespaceManager(k8sClient client.Client) NamespaceManager
• type NetworkPolicyManager
  • func NewNetworkPolicyManager(client client.Client) NetworkPolicyManager
• type NodeManager
  • func NewDefaultNodeManager(k8sClient client.Client) NodeManager
• type PodManager
  • func NewDefaultPodManager(k8sClient client.Client, k8sSchema *runtime.Scheme, config *rest.Config) PodManager
• type ServiceManager
  • func NewDefaultServiceManager(k8sClient client.Client) ServiceManager

Types

type ConfigMapManager

type ConfigMapManager interface {
	GetConfigMap(namespace string, name string) (*v1.ConfigMap, error)
	UpdateConfigMap(oldConfigMap *v1.ConfigMap, newConfigMap *v1.ConfigMap) error
}

func NewConfigMapManager

func NewConfigMapManager(k8sClient client.Client) ConfigMapManager

type CustomResourceManager

type CustomResourceManager interface {
	CreateResource(resource client.Object) error
	DeleteResource(resource client.Object) error
}

func NewCustomResourceManager

func NewCustomResourceManager(k8sClient client.Client) CustomResourceManager

type DaemonSetManager

type DaemonSetManager interface {
	GetDaemonSet(namespace string, name string) (*v1.DaemonSet, error)
	UpdateAndWaitTillDaemonSetReady(old *v1.DaemonSet, new *v1.DaemonSet) (*v1.DaemonSet, error)
	CheckIfDaemonSetIsReady(namespace string, name string) error
}

func NewDefaultDaemonSetManager

func NewDefaultDaemonSetManager(k8sClient client.Client) DaemonSetManager

type DeploymentManager

type DeploymentManager interface {
	CreateAndWaitTillDeploymentIsReady(deployment *v1.Deployment, timeout time.Duration) (*v1.Deployment, error)
	DeleteAndWaitTillDeploymentIsDeleted(deployment *v1.Deployment) error
	UpdateAndWaitTillDeploymentIsReady(deployment *v1.Deployment, timeout time.Duration) error
	GetDeployment(name, namespace string) (*v1.Deployment, error)
	WaitTillDeploymentReady(deployment *v1.Deployment, timeout time.Duration) (*v1.Deployment, error)

	WaitUntilDeploymentReady(ctx context.Context, dp *v1.Deployment) (*v1.Deployment, error)
	WaitUntilDeploymentDeleted(ctx context.Context, dp *v1.Deployment) error
}

func NewDefaultDeploymentManager

func NewDefaultDeploymentManager(k8sClient client.Client) DeploymentManager

type EventManager

type EventManager interface {
	GetEventsWithOptions(opts *client.ListOptions) (v1.EventList, error)
}

func NewEventManager

func NewEventManager(k8sClient client.Client) EventManager

type JobManager

type JobManager interface {
	CreateAndWaitTillJobCompleted(job *v1.Job) (*v1.Job, error)
	DeleteAndWaitTillJobIsDeleted(job *v1.Job) error
}

func NewDefaultJobManager

func NewDefaultJobManager(k8sClient client.Client) JobManager

type NamespaceManager

type NamespaceManager interface {
	CreateNamespace(namespace string) error
	CreateNamespaceWithLabels(namespace string, labels map[string]string) error
	DeleteAndWaitTillNamespaceDeleted(namespace string) error

	WaitUntilNamespaceDeleted(ctx context.Context, ns *v1.Namespace) error
}

func NewDefaultNamespaceManager

func NewDefaultNamespaceManager(k8sClient client.Client) NamespaceManager

type NetworkPolicyManager

type NetworkPolicyManager interface {
	CreateNetworkPolicy(networkPolicy client.Object) error
	DeleteNetworkPolicy(networkPolicy client.Object) error
}

func NewNetworkPolicyManager

func NewNetworkPolicyManager(client client.Client) NetworkPolicyManager

type NodeManager

type NodeManager interface {
	GetNodes(nodeLabelKey string, nodeLabelVal string) (v1.NodeList, error)
	GetAllNodes() (v1.NodeList, error)
	UpdateNode(oldNode *v1.Node, newNode *v1.Node) error
	WaitTillNodesReady(nodeLabelKey string, nodeLabelVal string, asgSize int) error
}

func NewDefaultNodeManager

func NewDefaultNodeManager(k8sClient client.Client) NodeManager

type PodManager

type PodManager interface {
	PodExec(namespace string, name string, command []string) (string, string, error)
	PodLogs(namespace string, name string) (string, error)
	GetPodsWithLabelSelector(labelKey string, labelVal string) (v1.PodList, error)
	GetPodsWithLabelSelectorMap(labels map[string]string) (v1.PodList, error)
	GetPod(podNamespace string, podName string) (*v1.Pod, error)
	CreatAndWaitTillRunning(pod *v1.Pod) (*v1.Pod, error)
	CreateAndWaitTillPodCompleted(pod *v1.Pod) (*v1.Pod, error)
	DeleteAndWaitTillPodDeleted(pod *v1.Pod) error

	WaitUntilPodRunning(ctx context.Context, pod *v1.Pod) error
	WaitUntilPodDeleted(ctx context.Context, pod *v1.Pod) error
}

func NewDefaultPodManager

func NewDefaultPodManager(k8sClient client.Client, k8sSchema *runtime.Scheme,
	config *rest.Config) PodManager

type ServiceManager

type ServiceManager interface {
	GetService(ctx context.Context, namespace string, name string) (*v1.Service, error)
	CreateService(ctx context.Context, service *v1.Service) (*v1.Service, error)
	DeleteAndWaitTillServiceDeleted(ctx context.Context, service *v1.Service) error
}

func NewDefaultServiceManager

func NewDefaultServiceManager(k8sClient client.Client) ServiceManager