const rollbackSuccess … const rollbackSkipped … type Rollbacker … type RollbackVisitor … func (v *RollbackVisitor) VisitDeployment(elem apps.GroupKindElement) { … } func (v *RollbackVisitor) VisitStatefulSet(kind apps.GroupKindElement) { … } func (v *RollbackVisitor) VisitDaemonSet(kind apps.GroupKindElement) { … } func (v *RollbackVisitor) VisitJob(kind apps.GroupKindElement) { … } func (v *RollbackVisitor) VisitPod(kind apps.GroupKindElement) { … } func (v *RollbackVisitor) VisitReplicaSet(kind apps.GroupKindElement) { … } func (v *RollbackVisitor) VisitReplicationController(kind apps.GroupKindElement) { … } func (v *RollbackVisitor) VisitCronJob(kind apps.GroupKindElement) { … } // RollbackerFor returns an implementation of Rollbacker interface for the given schema kind func RollbackerFor(kind schema.GroupKind, c kubernetes.Interface) (Rollbacker, error) { … } type DeploymentRollbacker … func (r *DeploymentRollbacker) Rollback(obj runtime.Object, updatedAnnotations map[string]string, toRevision int64, dryRunStrategy cmdutil.DryRunStrategy) (string, error) { … } // equalIgnoreHash returns true if two given podTemplateSpec are equal, ignoring the diff in value of Labels[pod-template-hash] // We ignore pod-template-hash because: // 1. The hash result would be different upon podTemplateSpec API changes // (e.g. the addition of a new field will cause the hash code to change) // 2. The deployment template won't have hash labels func equalIgnoreHash(template1, template2 *corev1.PodTemplateSpec) bool { … } var annotationsToSkip … // getPatch returns a patch that can be applied to restore a Deployment to a // previous version. If the returned error is nil the patch is valid. func getDeploymentPatch(podTemplate *corev1.PodTemplateSpec, annotations map[string]string) (types.PatchType, []byte, error) { … } func deploymentRevision(deployment *appsv1.Deployment, c kubernetes.Interface, toRevision int64) (revision *appsv1.ReplicaSet, err error) { … } type DaemonSetRollbacker … func (r *DaemonSetRollbacker) Rollback(obj runtime.Object, updatedAnnotations map[string]string, toRevision int64, dryRunStrategy cmdutil.DryRunStrategy) (string, error) { … } // daemonMatch check if the given DaemonSet's template matches the template stored in the given history. func daemonSetMatch(ds *appsv1.DaemonSet, history *appsv1.ControllerRevision) (bool, error) { … } // getPatch returns a strategic merge patch that can be applied to restore a Daemonset to a // previous version. If the returned error is nil the patch is valid. The current state that we save is just the // PodSpecTemplate. We can modify this later to encompass more state (or less) and remain compatible with previously // recorded patches. func getDaemonSetPatch(ds *appsv1.DaemonSet) ([]byte, error) { … } type StatefulSetRollbacker … // toRevision is a non-negative integer, with 0 being reserved to indicate rolling back to previous configuration func (r *StatefulSetRollbacker) Rollback(obj runtime.Object, updatedAnnotations map[string]string, toRevision int64, dryRunStrategy cmdutil.DryRunStrategy) (string, error) { … } var appsCodec … // applyRevision returns a new StatefulSet constructed by restoring the state in revision to set. If the returned error // is nil, the returned StatefulSet is valid. func applyRevision(set *appsv1.StatefulSet, revision *appsv1.ControllerRevision) (*appsv1.StatefulSet, error) { … } // statefulsetMatch check if the given StatefulSet's template matches the template stored in the given history. func statefulsetMatch(ss *appsv1.StatefulSet, history *appsv1.ControllerRevision) (bool, error) { … } // getStatefulSetPatch returns a strategic merge patch that can be applied to restore a StatefulSet to a // previous version. If the returned error is nil the patch is valid. The current state that we save is just the // PodSpecTemplate. We can modify this later to encompass more state (or less) and remain compatible with previously // recorded patches. func getStatefulSetPatch(set *appsv1.StatefulSet) ([]byte, error) { … } // findHistory returns a controllerrevision of a specific revision from the given controllerrevisions. // It returns nil if no such controllerrevision exists. // If toRevision is 0, the last previously used history is returned. func findHistory(toRevision int64, allHistory []*appsv1.ControllerRevision) *appsv1.ControllerRevision { … } // printPodTemplate converts a given pod template into a human-readable string. func printPodTemplate(specTemplate *corev1.PodTemplateSpec) (string, error) { … } func revisionNotFoundErr(r int64) error { … } type historiesByRevision … func (h historiesByRevision) Len() int { … } func (h historiesByRevision) Swap(i, j int) { … } func (h historiesByRevision) Less(i, j int) bool { … }
Codebase Browser
kubernetes