util

package

Go to main page

Versions in this module

v0

v0.5.0

Dec 21, 2023

v0.4.2

Apr 8, 2024

v0.4.1

Aug 9, 2023

v0.4.0

Jul 11, 2023

Changes in this version

+ const DaemonSetType

+ const TrafficRoutingFinalizer

+ var ControllerKruiseKindDS = appsv1alpha1.SchemeGroupVersion.WithKind("DaemonSet")

+ func EqualIgnoreSpecifyMetadata(template1, template2 *v1.PodTemplateSpec, ignoreLabels, ignoreAnno []string) bool

+ func GetTypeMeta(object client.Object) *metav1.TypeMeta

+ func ProgressingRolloutFinalizer(name string) string

v0.3.0

Feb 13, 2023

Changes in this version

+ const DeploymentRevisionAnnotation

+ const NoNeedUpdatePodLabel

+ func DeploymentMaxUnavailable(deployment *apps.Deployment) int32

+ func EncodeHash(data string) string

+ func FindCanaryAndStableReplicaSet(rss []*apps.ReplicaSet, d *apps.Deployment) (*apps.ReplicaSet, *apps.ReplicaSet)

+ func GetDeploymentExtraStatus(deployment *apps.Deployment) v1alpha1.DeploymentExtraStatus

+ func GetDeploymentStrategy(deployment *apps.Deployment) v1alpha1.DeploymentStrategy

+ func GetEmptyObjectWithKey(object client.Object) client.Object

+ func GetLuaConfigurationContent(key string) string

+ func GetMetadata(object client.Object) *metav1.ObjectMeta

+ func GetReplicas(object client.Object) int32

+ func GetRolloutNamespace() string

+ func GetTemplate(object client.Object) *corev1.PodTemplateSpec

+ func IsEqualRevision(a, b *v1.Pod) bool

+ func IsRollbackInBatchPolicy(rollout *rolloutv1alpha1.Rollout, labels map[string]string) bool

+ func IsStatefulSetUnorderedUpdate(object client.Object) bool

+ func WrappedPodCount(pods []*v1.Pod, filter func(pod *v1.Pod) bool) int

+ type RolloutContext struct

+ NewStatus *v1alpha1.RolloutStatus

+ RecheckTime *time.Time

+ Rollout *v1alpha1.Rollout

+ WaitReady bool

+ Workload *Workload

type WorkloadInfo

+ LogKey string

+ func ParseWorkload(object client.Object) *WorkloadInfo

+ func (w *WorkloadInfo) IsPromoted() bool

+ func (w *WorkloadInfo) IsRevisionNotEqual(observed string) bool

+ func (w *WorkloadInfo) IsRollback(observedStable, observedUpdate string) bool

+ func (w *WorkloadInfo) IsScaling(observed int32) bool

+ func (w *WorkloadInfo) IsStable() bool

v0.3.0-rc.0

Dec 20, 2022

v0.2.0

Aug 9, 2022

Changes in this version

+ const RolloutBatchIDLabel

+ const RolloutIDLabel

+ const WorkloadTypeLabel

+ var ControllerKindRS = apps.SchemeGroupVersion.WithKind("ReplicaSet")

+ var ControllerKindSts = apps.SchemeGroupVersion.WithKind("StatefulSet")

+ var ControllerKruiseKindSts = appsv1beta1.SchemeGroupVersion.WithKind("StatefulSet")

+ var ControllerKruiseOldKindSts = appsv1alpha1.SchemeGroupVersion.WithKind("StatefulSet")

+ func AddWatcherDynamically(c controller.Controller, h handler.EventHandler, gvk schema.GroupVersionKind) (bool, error)

+ func AddWorkloadWatcher(c controller.Controller, handler handler.EventHandler) error

+ func ClaimWorkload(c client.Client, planController *v1alpha1.BatchRelease, object client.Object, ...) error

+ func FilterActivePods(pods []*v1.Pod) []*v1.Pod

+ func GetEmptyWorkloadObject(gvk schema.GroupVersionKind) client.Object

+ func GetGVKFrom(workloadRef *rolloutv1alpha1.WorkloadRef) schema.GroupVersionKind

+ func GetOwnerWorkload(r client.Reader, object client.Object) (client.Object, error)

+ func GetPodCondition(status *v1.PodStatus, conditionType v1.PodConditionType) (int, *v1.PodCondition)

+ func GetPodConditionFromList(conditions []v1.PodCondition, conditionType v1.PodConditionType) (int, *v1.PodCondition)

+ func GetPodReadyCondition(status v1.PodStatus) *v1.PodCondition

+ func GetStatefulSetMaxUnavailable(object *unstructured.Unstructured) *intstr.IntOrString

+ func GetStatefulSetPartition(object *unstructured.Unstructured) int32

+ func IsCompletedPod(pod *v1.Pod) bool

+ func IsConsistentWithRevision(pod *v1.Pod, revision string) bool

+ func IsOwnedBy(r client.Reader, child, parent client.Object) (bool, error)

+ func IsPodReady(pod *v1.Pod) bool

+ func IsPodReadyConditionTrue(status v1.PodStatus) bool

+ func IsStatefulSetRollingUpdate(object *unstructured.Unstructured) bool

+ func IsSupportedWorkload(gvk schema.GroupVersionKind) bool

+ func IsWorkloadType(object client.Object, t WorkloadType) bool

+ func ListOwnedPods(c client.Client, object client.Object) ([]*v1.Pod, error)

+ func ParseReplicasFrom(object *unstructured.Unstructured) int32

+ func ParseStatusIntFrom(object *unstructured.Unstructured, field string) int64

+ func ParseStatusStringFrom(object *unstructured.Unstructured, field string) string

+ func ParseTemplateFrom(object *unstructured.Unstructured) *v1.PodTemplateSpec

+ func PatchPodBatchLabel(c client.Client, pods []*v1.Pod, rolloutID string, batchID int32, ...) (bool, error)

+ func PatchSpec(c client.Client, object client.Object, spec map[string]interface{}) error

+ func ReleaseWorkload(c client.Client, object client.Object) error

+ func SetStatefulSetPartition(object *unstructured.Unstructured, partition int32)

type Workload

+ RevisionLabelKey string

+ type WorkloadInfo struct

+ GVKWithName string

+ MaxUnavailable *intstr.IntOrString

+ Metadata *metav1.ObjectMeta

+ Paused bool

+ Replicas *int32

+ Selector labels.Selector

+ Status *WorkloadStatus

+ func NewWorkloadInfo() *WorkloadInfo

+ func ParseStatefulSetInfo(object *unstructured.Unstructured, namespacedName types.NamespacedName) *WorkloadInfo

+ type WorkloadStatus struct

+ AvailableReplicas int32

+ ObservedGeneration int64

+ ReadyReplicas int32

+ Replicas int32

+ StableRevision string

+ UpdateRevision string

+ UpdatedReadyReplicas int32

+ UpdatedReplicas int32

+ func ParseWorkloadStatus(object client.Object) *WorkloadStatus

+ type WorkloadType string

+ const CloneSetType

+ const DeploymentType

+ const StatefulSetType

v0.1.1

Jul 12, 2022

v0.1.0

Apr 20, 2022

Changes in this version

+ const BatchReleaseControlAnnotation

+ const CanaryDeploymentFinalizer

+ const CanaryDeploymentLabel

+ const CanaryDeploymentLabelKey

+ const InRolloutProgressingAnnotation

+ const KruiseRolloutFinalizer

+ const RolloutHashAnnotation

+ const StashCloneSetPartition

+ var CloneSetGVK = appsv1alpha1.SchemeGroupVersion.WithKind("CloneSet")

+ var ControllerKindDep = apps.SchemeGroupVersion.WithKind("Deployment")

+ var ControllerKruiseKindCS = appsv1alpha1.SchemeGroupVersion.WithKind("CloneSet")

+ func CalculateNewBatchTarget(rolloutSpec *v1alpha1.ReleasePlan, workloadReplicas, currentBatch int) int

+ func ComputeHash(template *v1.PodTemplateSpec, collisionCount *int32) string

+ func DeepHashObject(hasher hash.Hash, objectToWrite interface{})

+ func DiscoverGVK(gvk schema.GroupVersionKind) bool

+ func DumpJSON(o interface{}) string

+ func EqualIgnoreHash(template1, template2 *v1.PodTemplateSpec) bool

+ func FilterActiveDeployment(ds []*apps.Deployment) []*apps.Deployment

+ func GenRandomStr(length int) string

+ func GetRolloutCondition(status rolloutv1alpha1.RolloutStatus, ...) *rolloutv1alpha1.RolloutCondition

+ func HashReleasePlanBatches(releasePlan *v1alpha1.ReleasePlan) string

+ func IsControlledBy(object, owner metav1.Object) bool

+ func NewRegistry(c *rest.Config) error

+ func NewRolloutCondition(condType rolloutv1alpha1.RolloutConditionType, status corev1.ConditionStatus, ...) *rolloutv1alpha1.RolloutCondition

+ func RemoveRolloutCondition(status *rolloutv1alpha1.RolloutStatus, ...)

+ func SafeEncodeString(s string) string

+ func SetRolloutCondition(status *rolloutv1alpha1.RolloutStatus, ...) bool

+ func UpdateFinalizer(c client.Client, object client.Object, op FinalizerOpType, finalizer string) error

+ type ControllerFinder struct

+ func NewControllerFinder(c client.Client) *ControllerFinder

+ func (r *ControllerFinder) GetReplicaSetsForDeployment(obj *apps.Deployment) ([]apps.ReplicaSet, error)

+ func (r *ControllerFinder) GetWorkloadForRef(namespace string, ref *rolloutv1alpha1.WorkloadRef) (*Workload, error)

+ type ControllerFinderFunc func(namespace string, ref *rolloutv1alpha1.WorkloadRef) (*Workload, error)

+ type FinalizerOpType string

+ const AddFinalizerOpType

+ const RemoveFinalizerOpType

+ type GenericClientset struct

+ DiscoveryClient discovery.DiscoveryInterface

+ KruiseClient kruiseclientset.Interface

+ KubeClient kubeclientset.Interface

+ func GetGenericClient() *GenericClientset

+ type RolloutState struct

+ RolloutName string

+ func GetRolloutState(annotations map[string]string) (*RolloutState, error)

+ type Workload struct

+ CanaryReadyReplicas int32

+ CanaryReplicas int32

+ CanaryRevision string

+ InRolloutProgressing bool

+ IsInRollback bool

+ IsStatusConsistent bool

+ PodTemplateHash string

+ Replicas int32

+ StableRevision string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL