Documentation
¶
Index ¶
- Constants
- func Add(mgr manager.Manager) error
- func HasTerminatingCondition(status v1alpha1.BatchReleaseStatus) bool
- func IsAllBatchReady(plan *v1alpha1.ReleasePlan, status *v1alpha1.BatchReleaseStatus) bool
- func IsPartitioned(plan *v1alpha1.ReleasePlan, status *v1alpha1.BatchReleaseStatus) bool
- type BatchReleaseReconciler
- type EventAction
- type Executor
Constants ¶
View Source
const (
DefaultDuration = (50 * 1000) * time.Microsecond
)
View Source
const ReleaseFinalizer = "rollouts.kruise.io/batch-release-finalizer"
Variables ¶
This section is empty.
Functions ¶
func Add ¶
Add creates a new Rollout Controller and adds it to the Manager with default RBAC. The Manager will set fields on the Controller and Start it when the Manager is Started.
func HasTerminatingCondition ¶
func HasTerminatingCondition(status v1alpha1.BatchReleaseStatus) bool
func IsAllBatchReady ¶
func IsAllBatchReady(plan *v1alpha1.ReleasePlan, status *v1alpha1.BatchReleaseStatus) bool
func IsPartitioned ¶
func IsPartitioned(plan *v1alpha1.ReleasePlan, status *v1alpha1.BatchReleaseStatus) bool
Types ¶
type BatchReleaseReconciler ¶
type BatchReleaseReconciler struct {
client.Client
Scheme *runtime.Scheme
// contains filtered or unexported fields
}
BatchReleaseReconciler reconciles a BatchRelease object
type EventAction ¶
type EventAction string
const ( CreateEventAction EventAction = "Create" DeleteEventAction EventAction = "Delete" )
type Executor ¶
type Executor struct {
// contains filtered or unexported fields
}
Executor is the controller that controls the release plan resource
func NewReleasePlanExecutor ¶
func NewReleasePlanExecutor(client client.Client, recorder record.EventRecorder) *Executor
NewReleasePlanExecutor creates a RolloutPlanController
func (*Executor) Do ¶
func (r *Executor) Do() (reconcile.Result, *v1alpha1.BatchReleaseStatus)
Do execute the release plan
func (*Executor) GetWorkloadController ¶
func (r *Executor) GetWorkloadController() (workloads.WorkloadController, error)
GetWorkloadController pick the right workload controller to work on the workload
func (*Executor) SetReleaseInfo ¶
func (r *Executor) SetReleaseInfo(release *v1alpha1.BatchRelease)
Source Files
¶
Click to show internal directories.
Click to hide internal directories.