actor

May 27, 2021

Changes in this version

+ var DEBUGLEVEL = int(zapcore.DebugLevel)

+ var WARNLEVEL = int(zapcore.WarnLevel)

Apr 15, 2021

Changes in this version

+ var Log = logf.Log.WithName("action")

+ func CancelLoop(ctx context.Context)

+ func ContextWithCancelFn(ctx context.Context, fn context.CancelFunc) context.Context

+ func IsContainerStatusImagePullBackoff(ctx context.Context, clientset kubernetes.Interface, job *kbatch.Job, ...) error

+ func IsJobPodRunning(ctx context.Context, clientset kubernetes.Interface, job *kbatch.Job, ...) error

+ func LogError(msg string, err error, l logr.Logger) error

+ func WaitUntilJobPodIsRunning(ctx context.Context, clientset kubernetes.Interface, job *kbatch.Job, ...) error

+ type Actor interface

+ Act func(context.Context, *resource.Cluster) error

+ GetActionType func() api.ActionType

+ Handles func([]api.ClusterCondition) bool

+ func NewOperatorActions(scheme *runtime.Scheme, cl client.Client, config *rest.Config) []Actor

+ type InvalidContainerVersionError struct

+ Err error

+ func (e InvalidContainerVersionError) Error() string

+ type NotReadyErr struct

+ Err error

+ func (e NotReadyErr) Error() string

+ type PermanentErr struct

+ Err error

+ func (e PermanentErr) Error() string

+ type ValidationError struct

+ Err error

+ func (e ValidationError) Error() string