workload

type GetOptions struct {
	Client        k8s.Client
	Recorder      record.EventRecorder
	Log           logr.Logger
	DClient       k8s.DClient
	Scheme        *runtime.Scheme
	Labels        map[string]string
	Observers     *observer.Manager
	ZKClient      *zk.BaseClient
	ObservedState *observer.State
	Monitor       *prometheus.GenericClientset
	Finalizers    finalizer.Handler
	ExpectSts     *appsv1.StatefulSet
	ActualSts     *appsv1.StatefulSet
}

type Getter interface {
	// For Provision
	ProvisionWorkload(ctx context.Context, workload *cachev1alpha1.Workload, options *GetOptions) Reconciler

	// For Scale
	ScaleWorkload(ctx context.Context, workload *cachev1alpha1.Workload, options *GetOptions) Reconciler

	// For Rollout
	RolloutWorkload(ctx context.Context, workload *cachev1alpha1.Workload, options *GetOptions) Reconciler
}

type GetterImpl struct {
}

type ReconcileWorkload struct {
	Getter
	Workload      *cachev1alpha1.Workload
	CTX           context.Context
	Client        k8s.Client
	Recorder      record.EventRecorder
	Log           logr.Logger
	DClient       k8s.DClient
	Scheme        *runtime.Scheme
	Observers     *observer.Manager
	Monitor       *prometheus.GenericClientset
	Labels        map[string]string
	ZKClient      *zk.BaseClient
	ObservedState *observer.State
	Finalizers    finalizer.Handler
}

type Reconciler interface {
	// Reconcile the dependent service.
	Reconcile() error
}