Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

workloads

package

Go to main page

Versions in this module

v0

v0.2.0

Aug 9, 2022

Changes in this version

+ type NewUnifiedControllerFunc = func(c client.Client, r record.EventRecorder, p *v1alpha1.BatchRelease, ...) UnifiedWorkloadController

+ type StatefulSetLikeController struct

+ func (c *StatefulSetLikeController) ClaimWorkload() (bool, error)

+ func (c *StatefulSetLikeController) GetWorkloadInfo() (*util.WorkloadInfo, error)

+ func (c *StatefulSetLikeController) GetWorkloadObject() (*unstructured.Unstructured, error)

+ func (c *StatefulSetLikeController) IsBatchReady(canaryReplicasGoal, stableReplicasGoal int32) (bool, error)

+ func (c *StatefulSetLikeController) ListOwnedPods() ([]*v1.Pod, error)

+ func (c *StatefulSetLikeController) ReleaseWorkload(cleanup bool) (bool, error)

+ func (c *StatefulSetLikeController) UpgradeBatch(canaryReplicasGoal, stableReplicasGoal int32) (bool, error)

+ type UnifiedWorkloadController interface

+ ClaimWorkload func() (bool, error)

+ GetWorkloadInfo func() (*util.WorkloadInfo, error)

+ IsBatchReady func(canaryReplicasGoal, stableReplicasGoal int32) (bool, error)

+ ListOwnedPods func() ([]*v1.Pod, error)

+ ReleaseWorkload func(cleanup bool) (bool, error)

+ UpgradeBatch func(canaryReplicasGoal, stableReplicasGoal int32) (bool, error)

+ func NewStatefulSetLikeController(c client.Client, r record.EventRecorder, p *appsv1alpha1.BatchRelease, ...) UnifiedWorkloadController

+ type UnifiedWorkloadRolloutControlPlane struct

+ func NewUnifiedWorkloadRolloutControlPlane(f NewUnifiedControllerFunc, c client.Client, r record.EventRecorder, ...) *UnifiedWorkloadRolloutControlPlane

+ func (c *UnifiedWorkloadRolloutControlPlane) CheckOneBatchReady() (bool, error)

+ func (c *UnifiedWorkloadRolloutControlPlane) FinalizeProgress(cleanup bool) (bool, error)

+ func (c *UnifiedWorkloadRolloutControlPlane) PrepareBeforeProgress() (bool, error)

+ func (c *UnifiedWorkloadRolloutControlPlane) RecordWorkloadRevisionAndReplicas() error

+ func (c *UnifiedWorkloadRolloutControlPlane) SyncWorkloadInfo() (WorkloadEventType, *util.WorkloadInfo, error)

+ func (c *UnifiedWorkloadRolloutControlPlane) UpgradeOneBatch() (bool, error)

+ func (c *UnifiedWorkloadRolloutControlPlane) VerifyWorkload() (bool, error)

type WorkloadEventType

+ const WorkloadHasGone

v0.1.1

Jul 12, 2022

v0.1.0

Apr 20, 2022

Changes in this version

+ func CalculateRealCanaryReplicasGoal(expectedStableReplicas, allReplicas int32, canaryReplicas *intstr.IntOrString) int32

+ func ParseIntegerAsPercentageIfPossible(stableReplicas, allReplicas int32, canaryReplicas *intstr.IntOrString) intstr.IntOrString

+ type CloneSetRolloutController struct

+ func NewCloneSetRolloutController(cli client.Client, recorder record.EventRecorder, ...) *CloneSetRolloutController

+ func (c *CloneSetRolloutController) CheckOneBatchReady() (bool, error)

+ func (c *CloneSetRolloutController) FinalizeOneBatch() (bool, error)

+ func (c *CloneSetRolloutController) FinalizeProgress(cleanup bool) bool

+ func (c *CloneSetRolloutController) PrepareBeforeProgress() (bool, error)

+ func (c *CloneSetRolloutController) SyncWorkloadInfo() (WorkloadEventType, *WorkloadInfo, error)

+ func (c *CloneSetRolloutController) UpgradeOneBatch() (bool, error)

+ func (c *CloneSetRolloutController) VerifyWorkload() (bool, error)

+ type DeploymentsRolloutController struct

+ func NewDeploymentRolloutController(cli client.Client, recorder record.EventRecorder, ...) *DeploymentsRolloutController

+ func (c *DeploymentsRolloutController) CheckOneBatchReady() (bool, error)

+ func (c *DeploymentsRolloutController) FinalizeOneBatch() (bool, error)

+ func (c *DeploymentsRolloutController) FinalizeProgress(cleanup bool) bool

+ func (c *DeploymentsRolloutController) GetStablePodTemplateHash(deploy *apps.Deployment) (string, error)

+ func (c *DeploymentsRolloutController) PrepareBeforeProgress() (bool, error)

+ func (c *DeploymentsRolloutController) SyncWorkloadInfo() (WorkloadEventType, *WorkloadInfo, error)

+ func (c *DeploymentsRolloutController) UpgradeOneBatch() (bool, error)

+ func (c *DeploymentsRolloutController) VerifyWorkload() (bool, error)

+ type WorkloadController interface

+ CheckOneBatchReady func() (bool, error)

+ FinalizeOneBatch func() (bool, error)

+ FinalizeProgress func(cleanup bool) bool

+ PrepareBeforeProgress func() (bool, error)

+ SyncWorkloadInfo func() (WorkloadEventType, *WorkloadInfo, error)

+ UpgradeOneBatch func() (bool, error)

+ VerifyWorkload func() (bool, error)

+ type WorkloadEventType string

+ const IgnoreWorkloadEvent

+ const WorkloadPodTemplateChanged

+ const WorkloadReplicasChanged

+ const WorkloadRollback

+ const WorkloadStillReconciling

+ const WorkloadUnHealthy

+ type WorkloadInfo struct

+ Metadata *metav1.ObjectMeta

+ Paused bool

+ Replicas *int32

+ Status *WorkloadStatus

+ UpdateRevision *string

+ type WorkloadStatus struct

+ ObservedGeneration int64

+ ReadyReplicas int32

+ Replicas int32

+ UpdatedReadyReplicas int32

+ UpdatedReplicas int32