Versions in this module Expand all Collapse all v0 v0.1.0 Oct 9, 2023 Changes in this version + func CalculatePodSliceSize(pods []*v1.Pod, replicas int) int + func CalculateServiceSliceSize(services []*v1.Service, replicas int) int + func FilterPodsForReplicaType(pods []*v1.Pod, replicaType string) ([]*v1.Pod, error) + func FilterServicesForReplicaType(services []*v1.Service, replicaType string) ([]*v1.Service, error) + func GenGeneralName(clusterName string, rtype string, index string) string + func GetPodSlices(pods []*v1.Pod, replicas int, logger *log.Entry) [][]*v1.Pod + func GetPortsFromCluster(spec *kubeclusterorgv1alpha1.ReplicaSpec, defaultContainerName string) (map[string]int32, error) + func GetServiceSlices(services []*v1.Service, replicas int, logger *log.Entry) [][]*v1.Service + func InitializeReplicaStatuses(clusterStatus *kubeclusterorgv1alpha1.ClusterStatus, ...) + func MaxInt(x, y int) int + func PastActiveDeadline(runPolicy *v1alpha1.RunPolicy, clusterStatus v1alpha1.ClusterStatus) bool + func PastBackoffLimit(clusterName string, runPolicy *v1alpha1.RunPolicy, ...) (bool, error) + func RecordAbnormalPods(activePods []*v1.Pod, object runtime.Object, recorder record.EventRecorder) + func SetRestartPolicy(podTemplateSpec *v1.PodTemplateSpec, spec *kubeclusterorgv1alpha1.ReplicaSpec) + func UpdateClusterReplicaStatuses(clusterStatus *kubeclusterorgv1alpha1.ClusterStatus, ...)