statefulset

Sep 30, 2020

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 ConfigureStatefulSetForInitialRollout(statefulSet *appsv1.StatefulSet)

+ func ConfigureStatefulSetForRollout(statefulSet *appsv1.StatefulSet)

+ 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)