Versions in this module Expand all Collapse all v0 v0.3.0 Apr 14, 2019 Changes in this version + const PodStatusKilledOOM v0.2.0 Mar 12, 2019 Changes in this version + func CPU(cpu string) k8sresource.Quantity v0.1.0 Feb 14, 2019 Changes in this version + const DeploymentSuccessConditionAll + const JobFailureCondition + const JobSuccessCondition + const PodStatusFailed + const PodStatusKilled + const PodStatusPending + const PodStatusRunning + const PodStatusSucceeded + const PodStatusTerminating + const PodStatusUnknown + var Config *rest.Config + func AWSCredentials() []corev1.EnvVar + func CortexConfigVolume() corev1.Volume + func CortexConfigVolumeMount() corev1.VolumeMount + func Cpu(cpu string) k8sresource.Quantity + func CreateDeployment(spec *DeploymentSpec) (*appsv1b1.Deployment, error) + func CreateIngress(spec *IngressSpec) (*v1beta1.Ingress, error) + func CreateJob(spec *JobSpec) (*batchv1.Job, error) + func CreatePod(spec *PodSpec) (*corev1.Pod, error) + func CreateService(spec *ServiceSpec) (*corev1.Service, error) + func DefaultVolumeMounts() []corev1.VolumeMount + func DefaultVolumes() []corev1.Volume + func DeleteDeployment(name string) (bool, error) + func DeleteIngress(name string) (bool, error) + func DeleteJob(name string) (bool, error) + func DeletePod(name string) (bool, error) + func DeleteService(name string) (bool, error) + func Deployment(spec *DeploymentSpec) *appsv1b1.Deployment + func DeploymentExists(name string) (bool, error) + func DeploymentMap(deployments []appsv1b1.Deployment) map[string]appsv1b1.Deployment + func DeploymentStartTime(deployment *appsv1b1.Deployment) *time.Time + func EmptyDirVolume() corev1.Volume + func EmptyDirVolumeMount() corev1.VolumeMount + func FieldSelectorNotIn(key string, values []string) string + func GetDeployment(name string) (*appsv1b1.Deployment, error) + func GetIngress(name string) (*v1beta1.Ingress, error) + func GetJob(name string) (*batchv1.Job, error) + func GetPod(name string) (*corev1.Pod, error) + func GetPodLastContainerStartTime(pod *corev1.Pod) *time.Time + func GetPodStatus(pod *corev1.Pod) string + func GetService(name string) (*corev1.Service, error) + func Ingress(spec *IngressSpec) *v1beta1.Ingress + func IngressExists(name string) (bool, error) + func IngressMap(ingresses []v1beta1.Ingress) map[string]v1beta1.Ingress + func Job(spec *JobSpec) *batchv1.Job + func JobExists(name string) (bool, error) + func JobMap(jobs []batchv1.Job) map[string]batchv1.Job + func LabelSelector(labels map[string]string) string + func ListDeployments(opts *metav1.ListOptions) ([]appsv1b1.Deployment, error) + func ListDeploymentsByLabel(labelKey string, labelValue string) ([]appsv1b1.Deployment, error) + func ListDeploymentsByLabels(labels map[string]string) ([]appsv1b1.Deployment, error) + func ListIngresses(opts *metav1.ListOptions) ([]v1beta1.Ingress, error) + func ListIngressesByLabel(labelKey string, labelValue string) ([]v1beta1.Ingress, error) + func ListIngressesByLabels(labels map[string]string) ([]v1beta1.Ingress, error) + func ListJobs(opts *metav1.ListOptions) ([]batchv1.Job, error) + func ListJobsByLabel(labelKey string, labelValue string) ([]batchv1.Job, error) + func ListJobsByLabels(labels map[string]string) ([]batchv1.Job, error) + func ListPods(opts *metav1.ListOptions) ([]corev1.Pod, error) + func ListPodsByLabel(labelKey string, labelValue string) ([]corev1.Pod, error) + func ListPodsByLabels(labels map[string]string) ([]corev1.Pod, error) + func ListServices(opts *metav1.ListOptions) ([]corev1.Service, error) + func ListServicesByLabel(labelKey string, labelValue string) ([]corev1.Service, error) + func ListServicesByLabels(labels map[string]string) ([]corev1.Service, error) + func Mem(mem string) k8sresource.Quantity + func Pod(spec *PodSpec) *corev1.Pod + func PodExists(name string) (bool, error) + func PodMap(pods []corev1.Pod) map[string]corev1.Pod + func Service(spec *ServiceSpec) *corev1.Service + func ServiceExists(name string) (bool, error) + func ServiceMap(services []corev1.Service) map[string]corev1.Service + func StalledPods() ([]corev1.Pod, error) + func UpdateDeployment(deployment *appsv1b1.Deployment) (*appsv1b1.Deployment, error) + func UpdateJob(job *batchv1.Job) (*batchv1.Job, error) + func ValidName(name string) string + func ValidNameContainer(name string) string + func WaitForPodRunning(name string, numSeconds int) error + type DeploymentSpec struct + Labels map[string]string + Name string + Namespace string + PodSpec PodSpec + Replicas int32 + Selector map[string]string + type IngressSpec struct + IngressClass string + Labels map[string]string + Name string + Namespace string + Path string + ServiceName string + ServicePort int32 + type JobSpec struct + Labels map[string]string + Name string + Namespace string + PodSpec PodSpec + type PodSpec struct + K8sPodSpec corev1.PodSpec + Labels map[string]string + Name string + Namespace string + type ServiceSpec struct + Labels map[string]string + Name string + Namespace string + Port int32 + Selector map[string]string + TargetPort int32