Versions in this module Expand all Collapse all v1 v1.0.3 Jan 13, 2020 v1.0.0 Dec 20, 2019 Changes in this version + var AnnotationCanaryRollout = fmt.Sprintf("%s/canary-rollout", apis.GroupName) + var AnnotationCanaryRolloutEnabled = fmt.Sprintf("%s/canary-rollout-enabled", apis.GroupName) + var AnnotationCanaryWatchTime = fmt.Sprintf("%s/canary-watch-time-ms", apis.GroupName) + var AnnotationUpdateStartTime = fmt.Sprintf("%s/update-start-time", apis.GroupName) + var AnnotationUpdateWatchTime = fmt.Sprintf("%s/update-watch-time-ms", apis.GroupName) + func AddStatefulSetRollout(ctx context.Context, config *config.Config, mgr manager.Manager) error + func CheckUpdate(e event.UpdateEvent) bool + func CleanupNonReadyPod(ctx context.Context, client crc.Client, statefulSet *appsv1.StatefulSet, ...) error + func ComputeAnnotations(ig *manifest.InstanceGroup) (map[string]string, error) + func ConfigureStatefulSetForInitialRollout(statefulSet *appsv1.StatefulSet) + func ConfigureStatefulSetForRollout(statefulSet *appsv1.StatefulSet) + func ExtractWatchTime(rawWatchTime string, field string) (string, error) + func FilterLabels(labels map[string]string) map[string]string + func NewMutator(log *zap.SugaredLogger, config *config.Config) admission.Handler + func NewStatefulSetRolloutMutator(log *zap.SugaredLogger, config *config.Config) *wh.OperatorWebhook + func NewStatefulSetRolloutReconciler(ctx context.Context, config *config.Config, mgr manager.Manager) reconcile.Reconciler + type Mutator struct + func (m *Mutator) Handle(ctx context.Context, req admission.Request) admission.Response + func (m *Mutator) InjectDecoder(d *admission.Decoder) error + type ReconcileStatefulSetRollout struct + func (r *ReconcileStatefulSetRollout) Reconcile(request reconcile.Request) (reconcile.Result, error)