Documentation
¶
Index ¶
- Constants
- func RevisionChanged(action string) bool
- func StateSatisfied(d *Deploy, desiredStage tritonappsv1alpha1.BatchPhase, desiredBatches int) bool
- type Deploy
- func (d *Deploy) Aborted() bool
- func (d *Deploy) AllBatchFinished() bool
- func (d *Deploy) Auto() bool
- func (d *Deploy) BatchIntervalSeconds() int32
- func (d *Deploy) BatchSize() *intstr.IntOrString
- func (d *Deploy) BatchSizeNum() int32
- func (d *Deploy) Canary() int
- func (d *Deploy) CanaryEnabled() bool
- func (d *Deploy) Canceled() bool
- func (d *Deploy) CurrentBatchFailed() bool
- func (d *Deploy) CurrentBatchFinished() bool
- func (d *Deploy) CurrentBatchInfo() *tritonappsv1alpha1.BatchCondition
- func (d *Deploy) CurrentBatchIsCanary() bool
- func (d *Deploy) CurrentBatchIsContainersReady() bool
- func (d *Deploy) CurrentBatchIsPodReady() bool
- func (d *Deploy) CurrentBatchNumber() int
- func (d *Deploy) CurrentBatchPending() bool
- func (d *Deploy) CurrentBatchPhase() tritonappsv1alpha1.BatchPhase
- func (d *Deploy) CurrentBatchPods() []tritonappsv1alpha1.PodInfo
- func (d *Deploy) CurrentBatchPullInAt() metav1.Time
- func (d *Deploy) CurrentBatchPulledIn() bool
- func (d *Deploy) CurrentBatchSize() int
- func (d *Deploy) CurrentBatchSmoked() bool
- func (d *Deploy) CurrentBatchSmoking() bool
- func (d *Deploy) CurrentBatchStarted() bool
- func (d *Deploy) DesiredBatches() int
- func (d *Deploy) DesiredPausedState() *bool
- func (d *Deploy) Failed() bool
- func (d *Deploy) Finished() bool
- func (d *Deploy) GetCloneSetLabels() labels.Set
- func (d *Deploy) GetCondition() []tritonappsv1alpha1.BatchCondition
- func (d *Deploy) GetInstanceName() string
- func (d *Deploy) GetLastApplied() (*tritonappsv1alpha1.ApplicationSpec, error)
- func (d *Deploy) GetNotContainerReadyPods() []string
- func (d *Deploy) GetUpdateRevision() string
- func (d *Deploy) Interruptible() bool
- func (d *Deploy) MarkAsAborted()
- func (d *Deploy) MarkAsBatchFinished()
- func (d *Deploy) MarkAsBatchStarted()
- func (d *Deploy) MarkAsCanceled()
- func (d *Deploy) MarkAsFailed()
- func (d *Deploy) MarkAsInitializing()
- func (d *Deploy) MarkAsPaused()
- func (d *Deploy) MarkAsResumed()
- func (d *Deploy) MarkAsSuccess()
- func (d *Deploy) MarkCurrentBatchAsBaking()
- func (d *Deploy) MarkCurrentBatchAsFinished()
- func (d *Deploy) MarkCurrentBatchAsSmoked()
- func (d *Deploy) MarkCurrentBatchAsStarted(startedAt metav1.Time)
- func (d *Deploy) Mode() tritonappsv1alpha1.DeployMode
- func (d *Deploy) MoveForward() bool
- func (d *Deploy) NextBatchAndPhase() (int, tritonappsv1alpha1.BatchPhase)
- func (d *Deploy) NoChangedDeploy() bool
- func (d *Deploy) NonUpdateStrategy() *tritonappsv1alpha1.DeployNonUpdateStrategy
- func (d *Deploy) NotStarted() bool
- func (d *Deploy) Paused() bool
- func (d *Deploy) Pending() bool
- func (d *Deploy) PrepareNewBatch()
- func (d *Deploy) PrepareNewDeploy()
- func (d *Deploy) RevisionChanged() bool
- func (d *Deploy) SetCondition(c tritonappsv1alpha1.BatchCondition)
- func (d *Deploy) SetPaused(paused bool)
- func (d *Deploy) SetPodsStatus(pods []string)
- func (d *Deploy) SetPulledInAt()
- func (d *Deploy) SetUpdatedAt(updatedAt metav1.Time)
- func (d *Deploy) ShouldCancel() bool
- func (d *Deploy) SkipPullIn() bool
- func (d *Deploy) StartBatch()
- func (d *Deploy) StartProgress()
- func (d *Deploy) StateSatisfied() bool
- func (d Deploy) String() string
- func (d *Deploy) Success() bool
- func (d *Deploy) Unwrap() *tritonappsv1alpha1.DeployFlow
- func (d *Deploy) UpdateStrategy() *tritonappsv1alpha1.DeployUpdateStrategy
Constants ¶
View Source
const (
Separator = '/'
)
Variables ¶
This section is empty.
Functions ¶
func RevisionChanged ¶
func StateSatisfied ¶
func StateSatisfied(d *Deploy, desiredStage tritonappsv1alpha1.BatchPhase, desiredBatches int) bool
Types ¶
type Deploy ¶
type Deploy struct {
*tritonappsv1alpha1.DeployFlow
}
Deploy is the wrapper for tritonappsv1alpha1.DeployFlow type.
func FromDeploy ¶
func FromDeploy(d *tritonappsv1alpha1.DeployFlow) *Deploy
func (*Deploy) AllBatchFinished ¶
func (*Deploy) BatchIntervalSeconds ¶
func (*Deploy) BatchSize ¶
func (d *Deploy) BatchSize() *intstr.IntOrString
func (*Deploy) BatchSizeNum ¶
func (*Deploy) CanaryEnabled ¶
func (*Deploy) CurrentBatchFailed ¶
func (*Deploy) CurrentBatchFinished ¶
func (*Deploy) CurrentBatchInfo ¶
func (d *Deploy) CurrentBatchInfo() *tritonappsv1alpha1.BatchCondition
func (*Deploy) CurrentBatchIsCanary ¶
func (*Deploy) CurrentBatchIsContainersReady ¶
CurrentBatchReady returns true if all pods in this Batch is ready or failed
func (*Deploy) CurrentBatchIsPodReady ¶
CurrentBatchReady returns true if all pods in this Batch is ready or failed
func (*Deploy) CurrentBatchNumber ¶
func (*Deploy) CurrentBatchPending ¶
func (*Deploy) CurrentBatchPhase ¶
func (d *Deploy) CurrentBatchPhase() tritonappsv1alpha1.BatchPhase
func (*Deploy) CurrentBatchPods ¶
func (d *Deploy) CurrentBatchPods() []tritonappsv1alpha1.PodInfo
func (*Deploy) CurrentBatchPullInAt ¶
func (*Deploy) CurrentBatchPulledIn ¶
func (*Deploy) CurrentBatchSize ¶
func (*Deploy) CurrentBatchSmoked ¶
func (*Deploy) CurrentBatchSmoking ¶
func (*Deploy) CurrentBatchStarted ¶
func (*Deploy) DesiredBatches ¶
func (*Deploy) DesiredPausedState ¶
func (*Deploy) GetCloneSetLabels ¶
func (*Deploy) GetCondition ¶
func (d *Deploy) GetCondition() []tritonappsv1alpha1.BatchCondition
func (*Deploy) GetInstanceName ¶
func (*Deploy) GetLastApplied ¶
func (d *Deploy) GetLastApplied() (*tritonappsv1alpha1.ApplicationSpec, error)
func (*Deploy) GetNotContainerReadyPods ¶
func (*Deploy) GetUpdateRevision ¶
func (*Deploy) Interruptible ¶
Interruptible indicates that the deploy can be paused or canceled.
func (*Deploy) MarkAsAborted ¶
func (d *Deploy) MarkAsAborted()
func (*Deploy) MarkAsBatchFinished ¶
func (d *Deploy) MarkAsBatchFinished()
func (*Deploy) MarkAsBatchStarted ¶
func (d *Deploy) MarkAsBatchStarted()
func (*Deploy) MarkAsCanceled ¶
func (d *Deploy) MarkAsCanceled()
func (*Deploy) MarkAsFailed ¶
func (d *Deploy) MarkAsFailed()
func (*Deploy) MarkAsInitializing ¶
func (d *Deploy) MarkAsInitializing()
func (*Deploy) MarkAsPaused ¶
func (d *Deploy) MarkAsPaused()
func (*Deploy) MarkAsResumed ¶
func (d *Deploy) MarkAsResumed()
func (*Deploy) MarkAsSuccess ¶
func (d *Deploy) MarkAsSuccess()
func (*Deploy) MarkCurrentBatchAsBaking ¶
func (d *Deploy) MarkCurrentBatchAsBaking()
func (*Deploy) MarkCurrentBatchAsFinished ¶
func (d *Deploy) MarkCurrentBatchAsFinished()
func (*Deploy) MarkCurrentBatchAsSmoked ¶
func (d *Deploy) MarkCurrentBatchAsSmoked()
func (*Deploy) MarkCurrentBatchAsStarted ¶
func (*Deploy) Mode ¶
func (d *Deploy) Mode() tritonappsv1alpha1.DeployMode
func (*Deploy) MoveForward ¶
func (*Deploy) NextBatchAndPhase ¶
func (d *Deploy) NextBatchAndPhase() (int, tritonappsv1alpha1.BatchPhase)
call NextBatchAndPhase only when current state is satisfied!
func (*Deploy) NoChangedDeploy ¶
func (*Deploy) NonUpdateStrategy ¶
func (d *Deploy) NonUpdateStrategy() *tritonappsv1alpha1.DeployNonUpdateStrategy
func (*Deploy) NotStarted ¶
func (*Deploy) PrepareNewBatch ¶
func (d *Deploy) PrepareNewBatch()
func (*Deploy) PrepareNewDeploy ¶
func (d *Deploy) PrepareNewDeploy()
func (*Deploy) RevisionChanged ¶
func (*Deploy) SetCondition ¶
func (d *Deploy) SetCondition(c tritonappsv1alpha1.BatchCondition)
func (*Deploy) SetPodsStatus ¶
func (*Deploy) SetPulledInAt ¶
func (d *Deploy) SetPulledInAt()
func (*Deploy) SetUpdatedAt ¶
func (*Deploy) ShouldCancel ¶
func (*Deploy) SkipPullIn ¶
func (*Deploy) StartBatch ¶
func (d *Deploy) StartBatch()
func (*Deploy) StartProgress ¶
func (d *Deploy) StartProgress()
func (*Deploy) StateSatisfied ¶
StateSatisfied returns true if current state meets the desired state in updateStrategy/nonUpdateStrategy,
func (*Deploy) Unwrap ¶
func (d *Deploy) Unwrap() *tritonappsv1alpha1.DeployFlow
Unwrap returns the tritonappsv1alpha1.DeployFlow object.
func (*Deploy) UpdateStrategy ¶
func (d *Deploy) UpdateStrategy() *tritonappsv1alpha1.DeployUpdateStrategy
Click to show internal directories.
Click to hide internal directories.