batchrelease

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 12, 2022 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

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

func Add(mgr manager.Manager) error

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

func (*BatchReleaseReconciler) Reconcile

func (r *BatchReleaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile reads that state of the cluster for a Rollout object and makes changes based on the state read and what is in the Rollout.Spec

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

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)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL