k8s

Sep 23, 2022

Changes in this version

type VirtualServiceSpec

+ Retries *int32

Aug 4, 2021

Changes in this version

+ func GetPodConditionOf(pod *kcore.Pod, podType kcore.PodConditionType) (*bool, *kcore.PodCondition)

+ func HowManyPodsFitOnNode(podSpec kcore.PodSpec, node kcore.Node, cpuReserved resource.Quantity, ...) int64

+ func IsPodStalled(pod *kcore.Pod) bool

type PodStatus

+ const PodStatusCreating

+ const PodStatusNotReady

+ const PodStatusReady

+ const PodStatusStalled

Jul 6, 2021

Changes in this version

type Client

+ func (c *Client) ClientSet() *kclientset.Clientset

+ func (c *Client) IstioClientSet() *istioclient.Clientset

+ func (c *Client) VirtualServiceClient() istionetworkingclient.VirtualServiceInterface

type Destination

+ Headers *istionetworking.Headers

type VirtualServiceSpec

+ Headers *istionetworking.Headers

Jun 24, 2021

Changes in this version

+ func ToKiCeil(k8sQuantity kresource.Quantity) int64

+ func ToKiCeilStr(k8sQuantity kresource.Quantity) string

+ func ToKiFloor(k8sQuantity kresource.Quantity) int64

+ func ToKiFloorStr(k8sQuantity kresource.Quantity) string

+ func ToKiRounded(k8sQuantity kresource.Quantity) int64

+ func ToKiRoundedStr(k8sQuantity kresource.Quantity) string

+ func ToMiCeil(k8sQuantity kresource.Quantity) int64

+ func ToMiCeilStr(k8sQuantity kresource.Quantity) string

+ func ToMiFloor(k8sQuantity kresource.Quantity) int64

+ func ToMiFloorStr(k8sQuantity kresource.Quantity) string

+ func ToMiRounded(k8sQuantity kresource.Quantity) int64

+ func ToMiRoundedStr(k8sQuantity kresource.Quantity) string

type Quantity

+ func NewSummed(quantities ...kresource.Quantity) *Quantity

+ func (quantity *Quantity) DeepCopy() Quantity

+ func (quantity *Quantity) ToKiCeil() int64

+ func (quantity *Quantity) ToKiCeilStr() string

+ func (quantity *Quantity) ToKiFloor() int64

+ func (quantity *Quantity) ToKiFloorStr() string

+ func (quantity *Quantity) ToKiRounded() int64

+ func (quantity *Quantity) ToKiRoundedStr() string

+ func (quantity *Quantity) ToMiCeil() int64

+ func (quantity *Quantity) ToMiCeilStr() string

+ func (quantity *Quantity) ToMiFloor() int64

+ func (quantity *Quantity) ToMiFloorStr() string

+ func (quantity *Quantity) ToMiRounded() int64

+ func (quantity *Quantity) ToMiRoundedStr() string

Jun 8, 2021

Changes in this version

type ConfigMapSpec

+ BinaryData map[string][]byte

Apr 27, 2021

Changes in this version

+ const ErrServiceNotFound

+ func ErrorServiceNotFound(serviceName string) error

type Client

+ func (c *Client) InternalServiceEndpoint(serviceName string, portNumber int32) string

Apr 13, 2021

Changes in this version

+ const ErrMissingMetrics

+ func ErrorMissingMetrics() error

type HPASpec

+ TargetMemUtilization int32

Mar 30, 2021

Changes in this version

type ServiceSpec

+ PortName string

Mar 17, 2021

Changes in this version

type Destination

+ Shadow bool

Feb 3, 2021

Changes in this version

+ const ReasonCompleted

type ServiceSpec

+ ServiceType kcore.ServiceType

Jan 20, 2021

Changes in this version

+ const ReasonOOMKilled

Oct 27, 2020

Changes in this version

+ func Secret(spec *SecretSpec) *kcore.Secret

+ func SecretMap(secrets []kcore.Secret) map[string]kcore.Secret

type Client

+ func (c *Client) ApplySecret(secret *kcore.Secret) (*kcore.Secret, error)

+ func (c *Client) CreateSecret(secret *kcore.Secret) (*kcore.Secret, error)

+ func (c *Client) DeleteSecret(name string) (bool, error)

+ func (c *Client) GetSecret(name string) (*kcore.Secret, error)

+ func (c *Client) GetSecretData(name string) (map[string][]byte, error)

+ func (c *Client) ListSecrets(opts *kmeta.ListOptions) ([]kcore.Secret, error)

+ func (c *Client) ListSecretsByLabel(labelKey string, labelValue string) ([]kcore.Secret, error)

+ func (c *Client) ListSecretsByLabels(labels map[string]string) ([]kcore.Secret, error)

+ func (c *Client) ListSecretsWithLabelKeys(labelKeys ...string) ([]kcore.Secret, error)

+ func (c *Client) UpdateSecret(secret *kcore.Secret) (*kcore.Secret, error)

+ type SecretSpec struct

+ Annotations map[string]string

+ Data map[string][]byte

+ Labels map[string]string

+ Name string

Aug 25, 2020

Changes in this version

+ func VirtualServicesMatch(vs1, vs2 istionetworking.VirtualService) bool

+ func WasPodOOMKilled(pod *kcore.Pod) bool

type Client

+ func (c *Client) DeleteJobs(opts *kmeta.ListOptions) (bool, error)

+ type Destination struct

+ Port uint32

+ ServiceName string

+ Weight int32

type JobSpec

+ BackoffLimit int32

+ Parallelism int32

type PodStatus

+ const PodStatusErrImagePull

type Quantity

+ func (quantity *Quantity) MilliString() string

type VirtualServiceSpec

+ Destinations []Destination

+ ExactPath *string

+ PrefixPath *string

Jun 24, 2020

Changes in this version

+ func SplitInThree(quantity *kresource.Quantity) (*kresource.Quantity, *kresource.Quantity, *kresource.Quantity)

May 22, 2020

Changes in this version

type Client

+ func (c *Client) ListNodesByLabel(labelKey string, labelValue string) ([]kcore.Node, error)

+ func (c *Client) ListNodesByLabels(labels map[string]string) ([]kcore.Node, error)

+ func (c *Client) ListNodesWithLabelKeys(labelKeys ...string) ([]kcore.Node, error)

type Quantity

+ func WrapQuantity(k8sQuantity kresource.Quantity) *Quantity

+ func (quantity *Quantity) Add(q2 kresource.Quantity)

+ func (quantity *Quantity) AddQty(q2 Quantity)

+ func (quantity *Quantity) Sub(q2 kresource.Quantity)

+ func (quantity *Quantity) SubQty(q2 Quantity)

May 4, 2020

Changes in this version

type Quantity

+ func NewMilliQuantity(milliValue int64) Quantity

+ func NewQuantity(value int64) Quantity

Mar 25, 2020

Changes in this version

+ const ErrAnnotationNotFound

+ const ErrLabelNotFound

+ const ErrParseAnnotation

+ const ErrParseLabel

+ const ErrParseVirtualService

+ func ErrorAnnotationNotFound(annotationName string) error

+ func ErrorLabelNotFound(labelName string) error

+ func ErrorParseAnnotation(annotationName string, annotationVal string, desiredType string) error

+ func ErrorParseLabel(labelName string, labelVal string, desiredType string) error

+ func ErrorParseVirtualService(msg string) error

+ func GetLabel(obj kmeta.Object, key string) (string, error)

+ func ParseBoolLabel(obj kmeta.Object, key string) (bool, error)

+ func ParseDurationLabel(obj kmeta.Object, key string) (time.Duration, error)

+ func ParseFloat32Label(obj kmeta.Object, key string) (float32, error)

+ func ParseFloat64Label(obj kmeta.Object, key string) (float64, error)

+ func ParseInt32Label(obj kmeta.Object, key string) (int32, error)

+ func ParseInt64Label(obj kmeta.Object, key string) (int64, error)

+ func ParseIntLabel(obj kmeta.Object, key string) (int, error)

Mar 5, 2020

Changes in this version

+ func GetAnnotation(obj kmeta.Object, key string) (string, error)

+ func ParseBoolAnnotation(obj kmeta.Object, key string) (bool, error)

+ func ParseDurationAnnotation(obj kmeta.Object, key string) (time.Duration, error)

+ func ParseFloat32Annotation(obj kmeta.Object, key string) (float32, error)

+ func ParseFloat64Annotation(obj kmeta.Object, key string) (float64, error)

+ func ParseInt32Annotation(obj kmeta.Object, key string) (int32, error)

+ func ParseInt64Annotation(obj kmeta.Object, key string) (int64, error)

+ func ParseIntAnnotation(obj kmeta.Object, key string) (int, error)

+ func SplitInTwo(quantity *kresource.Quantity) (*kresource.Quantity, *kresource.Quantity)

type Client

+ func (c *Client) Exec(podName string, containerName string, command []string) (string, error)

Jan 22, 2020

Changes in this version

+ func DeploymentStrategiesMatch(s1, s2 kapps.DeploymentStrategy) bool

+ func ExtractVirtualServiceEndpoints(virtualService *kunstructured.Unstructured) (strset.Set, error)

+ func ExtractVirtualServiceGateways(virtualService *kunstructured.Unstructured) (strset.Set, error)

+ func LabelExistsSelector(labelKeys ...string) string

+ func PodComputesEqual(podSpec1, podSpec2 *kcore.PodSpec) bool

+ func RandomName() string

+ func TotalPodCompute(podSpec *kcore.PodSpec) (Quantity, Quantity, int64)

type Client

+ func (c *Client) ListConfigMapsWithLabelKeys(labelKeys ...string) ([]kcore.ConfigMap, error)

+ func (c *Client) ListDeploymentsWithLabelKeys(labelKeys ...string) ([]kapps.Deployment, error)

+ func (c *Client) ListHPAsWithLabelKeys(labelKeys ...string) ([]kautoscaling.HorizontalPodAutoscaler, error)

+ func (c *Client) ListIngressesWithLabelKeys(labelKeys ...string) ([]kextensions.Ingress, error)

+ func (c *Client) ListJobsWithLabelKeys(labelKeys ...string) ([]kbatch.Job, error)

+ func (c *Client) ListPodsWithLabelKeys(labelKeys ...string) ([]kcore.Pod, error)

+ func (c *Client) ListServicesWithLabelKeys(labelKeys ...string) ([]kcore.Service, error)

+ func (c *Client) ListVirtualServicesWithLabelKeys(labelKeys ...string) ([]kunstructured.Unstructured, error)

+ func (c *Client) UpdateConfigMap(configMap *kcore.ConfigMap) (*kcore.ConfigMap, error)

+ func (c *Client) UpdateVirtualService(existing, updated *kunstructured.Unstructured) (*kunstructured.Unstructured, error)

type DeploymentSpec

+ MaxSurge *string

+ MaxUnavailable *string

Nov 28, 2019

Changes in this version

+ func QuantityParser(v *QuantityValidation) func(string) (interface{}, error)

+ func QuantityPtr(k8sQuantity kresource.Quantity) *kresource.Quantity

+ func QuantityPtrID(quantity *Quantity) string

+ func QuantityPtrsEqual(quantity *Quantity, quantity2 *Quantity) bool

+ type Quantity struct

+ UserString string

+ func (quantity *Quantity) Equal(quantity2 Quantity) bool

+ func (quantity *Quantity) ID() string

+ func (quantity *Quantity) SplitInTwo() (*kresource.Quantity, *kresource.Quantity)

+ func (quantity *Quantity) String() string

+ func (quantity *Quantity) ToFloat32() float32

+ func (quantity *Quantity) ToKi() int64

+ func (quantity *Quantity) UnmarshalBinary(data []byte) error

+ func (quantity *Quantity) UnmarshalJSON(data []byte) error

+ func (quantity *Quantity) UnmarshalText(data []byte) error

+ func (quantity *Quantity) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (quantity Quantity) MarshalBinary() ([]byte, error)

+ func (quantity Quantity) MarshalJSON() ([]byte, error)

+ func (quantity Quantity) MarshalText() ([]byte, error)

+ func (quantity Quantity) MarshalYAML() (interface{}, error)

+ type QuantityValidation struct

+ GreaterThan *kresource.Quantity

+ GreaterThanOrEqualTo *kresource.Quantity

+ LessThan *kresource.Quantity

+ LessThanOrEqualTo *kresource.Quantity

Nov 5, 2019

Changes in this version

+ func GetVirtualServiceEndpoints(virtualService *kunstructured.Unstructured) (strset.Set, error)

+ func GetVirtualServiceGateways(virtualService *kunstructured.Unstructured) (strset.Set, error)

type VirtualServiceSpec

+ Rewrite *string

Oct 15, 2019

Changes in this version

+ func ErrorParseQuantity(qtyStr string) error

+ type Error struct

+ Kind ErrorKind

+ func (e Error) Error() string

+ type ErrorKind int

+ const ErrParseQuantity

+ const ErrUnknown

+ func (t *ErrorKind) UnmarshalBinary(data []byte) error

+ func (t *ErrorKind) UnmarshalText(text []byte) error

+ func (t ErrorKind) MarshalBinary() ([]byte, error)

+ func (t ErrorKind) MarshalText() ([]byte, error)

+ func (t ErrorKind) String() string

Sep 24, 2019

Changes in this version

+ const ReasonEvicted

+ func VirtualService(spec *VirtualServiceSpec) *kunstructured.Unstructured

type Client

+ func (c *Client) ApplyVirtualService(spec *kunstructured.Unstructured) (*kunstructured.Unstructured, error)

+ func (c *Client) CreateVirtualService(spec *kunstructured.Unstructured) (*kunstructured.Unstructured, error)

+ func (c *Client) DeleteVirtualService(name, namespace string) (bool, error)

+ func (c *Client) GetVirtualService(name, namespace string) (*kunstructured.Unstructured, error)

+ func (c *Client) ListNodes(opts *kmeta.ListOptions) ([]kcore.Node, error)

+ func (c *Client) ListVirtualServices(namespace string, opts *kmeta.ListOptions) ([]kunstructured.Unstructured, error)

+ func (c *Client) ListVirtualServicesByLabel(namespace string, labelKey string, labelValue string) ([]kunstructured.Unstructured, error)

+ func (c *Client) ListVirtualServicesByLabels(namespace string, labels map[string]string) ([]kunstructured.Unstructured, error)

+ func (c *Client) VirtualServiceExists(name, namespace string) (bool, error)

type ConfigMapSpec

+ Annotations map[string]string

type DeploymentSpec

+ Annotations map[string]string

type HPASpec

+ Annotations map[string]string

type IngressSpec

+ Annotations map[string]string

type JobSpec

+ Annotations map[string]string

type PodSpec

+ Annotations map[string]string

type PodStatus

+ const PodStatusInitializing

+ func PodStatusFromContainerStatuses(containerStatuses []kcore.ContainerStatus) PodStatus

type ServiceSpec

+ Annotations map[string]string

+ type VirtualServiceSpec struct

+ Annotations map[string]string

+ Gateways []string

+ Labels map[string]string

+ Name string

+ Namespace string

+ Path string

+ ServiceName string

+ ServicePort int32

Jul 30, 2019

Changes in this version

+ func ConfigMap(spec *ConfigMapSpec) *kcore.ConfigMap

+ func ConfigMapMap(configMaps []kcore.ConfigMap) map[string]kcore.ConfigMap

+ func GetPodReadyTime(pod *kcore.Pod) *time.Time

+ func IsHPAUpToDate(hpa *kautoscaling.HorizontalPodAutoscaler, minReplicas int32, ...) bool

+ func IsPodReady(pod *kcore.Pod) bool

type Client

+ func (c *Client) ApplyConfigMap(configMap *kcore.ConfigMap) (*kcore.ConfigMap, error)

+ func (c *Client) ApplyDeployment(deployment *kapps.Deployment) (*kapps.Deployment, error)

+ func (c *Client) ApplyHPA(hpa *kautoscaling.HorizontalPodAutoscaler) (*kautoscaling.HorizontalPodAutoscaler, error)

+ func (c *Client) ApplyIngress(ingress *kextensions.Ingress) (*kextensions.Ingress, error)

+ func (c *Client) ApplyJob(job *kbatch.Job) (*kbatch.Job, error)

+ func (c *Client) ApplyPod(pod *kcore.Pod) (*kcore.Pod, error)

+ func (c *Client) ApplyService(service *kcore.Service) (*kcore.Service, error)

+ func (c *Client) ConfigMapExists(name string) (bool, error)

+ func (c *Client) CreateConfigMap(configMap *kcore.ConfigMap) (*kcore.ConfigMap, error)

+ func (c *Client) DeleteConfigMap(name string) (bool, error)

+ func (c *Client) GetConfigMap(name string) (*kcore.ConfigMap, error)

+ func (c *Client) GetConfigMapData(name string) (map[string]string, error)

+ func (c *Client) IsJobRunning(name string) (bool, error)

+ func (c *Client) ListConfigMaps(opts *kmeta.ListOptions) ([]kcore.ConfigMap, error)

+ func (c *Client) ListConfigMapsByLabel(labelKey string, labelValue string) ([]kcore.ConfigMap, error)

+ func (c *Client) ListConfigMapsByLabels(labels map[string]string) ([]kcore.ConfigMap, error)

+ type ConfigMapSpec struct

+ Data map[string]string

+ Labels map[string]string

+ Name string

+ Namespace string

Jul 8, 2019

Changes in this version

+ func HPA(spec *HPASpec) *autoscaling.HorizontalPodAutoscaler

+ func HPAMap(hpas []autoscaling.HorizontalPodAutoscaler) map[string]autoscaling.HorizontalPodAutoscaler

type Client

+ func (c *Client) CreateHPA(spec *HPASpec) (*autoscaling.HorizontalPodAutoscaler, error)

+ func (c *Client) DeleteHPA(name string) (bool, error)

+ func (c *Client) GetHPA(name string) (*autoscaling.HorizontalPodAutoscaler, error)

+ func (c *Client) HPAExists(name string) (bool, error)

+ func (c *Client) ListHPAs(opts *metav1.ListOptions) ([]autoscaling.HorizontalPodAutoscaler, error)

+ func (c *Client) ListHPAsByLabel(labelKey string, labelValue string) ([]autoscaling.HorizontalPodAutoscaler, error)

+ func (c *Client) ListHPAsByLabels(labels map[string]string) ([]autoscaling.HorizontalPodAutoscaler, error)

+ func (c *Client) UpdateHPA(hpa *autoscaling.HorizontalPodAutoscaler) (*autoscaling.HorizontalPodAutoscaler, error)

+ func (c *Client) UpdateIngress(ingress *v1beta1.Ingress) (*v1beta1.Ingress, error)

+ func (c *Client) UpdatePod(pod *corev1.Pod) (*corev1.Pod, error)

+ func (c *Client) UpdateService(service *corev1.Service) (*corev1.Service, error)

+ type HPASpec struct

+ DeploymentName string

+ Labels map[string]string

+ MaxReplicas int32

+ MinReplicas int32

+ Namespace string

+ TargetCPUUtilization int32

Jun 27, 2019

Changes in this version

+ type PodStatus string

Jun 14, 2019

Changes in this version

+ const DeploymentSuccessConditionAll

+ const JobFailureCondition

+ const JobSuccessCondition

+ const PodStatusFailed

+ const PodStatusKilled

+ const PodStatusKilledOOM

+ const PodStatusPending

+ const PodStatusRunning

+ const PodStatusSucceeded

+ const PodStatusTerminating

+ const PodStatusUnknown

+ func AWSCredentials() []corev1.EnvVar

+ func CPU(cpu string) k8sresource.Quantity

+ func CortexConfigVolume() corev1.Volume

+ func CortexConfigVolumeMount() corev1.VolumeMount

+ func DefaultVolumeMounts() []corev1.VolumeMount

+ func DefaultVolumes() []corev1.Volume

+ func Deployment(spec *DeploymentSpec) *appsv1b1.Deployment

+ 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 GetPodLastContainerStartTime(pod *corev1.Pod) *time.Time

+ func GetPodStatus(pod *corev1.Pod) string

+ func Ingress(spec *IngressSpec) *v1beta1.Ingress

+ func IngressMap(ingresses []v1beta1.Ingress) map[string]v1beta1.Ingress

+ func Job(spec *JobSpec) *batchv1.Job

+ func JobMap(jobs []batchv1.Job) map[string]batchv1.Job

+ func LabelSelector(labels map[string]string) string

+ func Mem(mem string) k8sresource.Quantity

+ func Pod(spec *PodSpec) *corev1.Pod

+ func PodMap(pods []corev1.Pod) map[string]corev1.Pod

+ func Service(spec *ServiceSpec) *corev1.Service

+ func ServiceMap(services []corev1.Service) map[string]corev1.Service

+ func ValidName(name string) string

+ func ValidNameContainer(name string) string

+ type Client struct

+ Namespace string

+ RestConfig *rest.Config

+ func New(namespace string, operatorInCluster bool) (*Client, error)

+ func (c *Client) CreateDeployment(spec *DeploymentSpec) (*appsv1b1.Deployment, error)

+ func (c *Client) CreateIngress(spec *IngressSpec) (*v1beta1.Ingress, error)

+ func (c *Client) CreateJob(spec *JobSpec) (*batchv1.Job, error)

+ func (c *Client) CreatePod(spec *PodSpec) (*corev1.Pod, error)

+ func (c *Client) CreateService(spec *ServiceSpec) (*corev1.Service, error)

+ func (c *Client) DeleteDeployment(name string) (bool, error)

+ func (c *Client) DeleteIngress(name string) (bool, error)

+ func (c *Client) DeleteJob(name string) (bool, error)

+ func (c *Client) DeletePod(name string) (bool, error)

+ func (c *Client) DeleteService(name string) (bool, error)

+ func (c *Client) DeploymentExists(name string) (bool, error)

+ func (c *Client) GetDeployment(name string) (*appsv1b1.Deployment, error)

+ func (c *Client) GetIngress(name string) (*v1beta1.Ingress, error)

+ func (c *Client) GetJob(name string) (*batchv1.Job, error)

+ func (c *Client) GetPod(name string) (*corev1.Pod, error)

+ func (c *Client) GetService(name string) (*corev1.Service, error)

+ func (c *Client) IngressExists(name string) (bool, error)

+ func (c *Client) JobExists(name string) (bool, error)

+ func (c *Client) ListDeployments(opts *metav1.ListOptions) ([]appsv1b1.Deployment, error)

+ func (c *Client) ListDeploymentsByLabel(labelKey string, labelValue string) ([]appsv1b1.Deployment, error)

+ func (c *Client) ListDeploymentsByLabels(labels map[string]string) ([]appsv1b1.Deployment, error)

+ func (c *Client) ListIngresses(opts *metav1.ListOptions) ([]v1beta1.Ingress, error)

+ func (c *Client) ListIngressesByLabel(labelKey string, labelValue string) ([]v1beta1.Ingress, error)

+ func (c *Client) ListIngressesByLabels(labels map[string]string) ([]v1beta1.Ingress, error)

+ func (c *Client) ListJobs(opts *metav1.ListOptions) ([]batchv1.Job, error)

+ func (c *Client) ListJobsByLabel(labelKey string, labelValue string) ([]batchv1.Job, error)

+ func (c *Client) ListJobsByLabels(labels map[string]string) ([]batchv1.Job, error)

+ func (c *Client) ListPods(opts *metav1.ListOptions) ([]corev1.Pod, error)

+ func (c *Client) ListPodsByLabel(labelKey string, labelValue string) ([]corev1.Pod, error)

+ func (c *Client) ListPodsByLabels(labels map[string]string) ([]corev1.Pod, error)

+ func (c *Client) ListServices(opts *metav1.ListOptions) ([]corev1.Service, error)

+ func (c *Client) ListServicesByLabel(labelKey string, labelValue string) ([]corev1.Service, error)

+ func (c *Client) ListServicesByLabels(labels map[string]string) ([]corev1.Service, error)

+ func (c *Client) PodExists(name string) (bool, error)

+ func (c *Client) ServiceExists(name string) (bool, error)

+ func (c *Client) StalledPods() ([]corev1.Pod, error)

+ func (c *Client) UpdateDeployment(deployment *appsv1b1.Deployment) (*appsv1b1.Deployment, error)

+ func (c *Client) UpdateJob(job *batchv1.Job) (*batchv1.Job, error)

+ func (c *Client) 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