Documentation ¶
Overview ¶
Package releasemanager is a generated GoMock package.
Package releasemanager is a generated GoMock package.
Index ¶
- func Add(mgr manager.Manager, c utils.Config) error
- func LinearScale(i Incarnation, max uint32, t time.Time) uint32
- type ClusterConfig
- type ConfigMapList
- type Controller
- type Deployment
- type DeploymentStateManager
- type HorizontalPodAutoscalerList
- type Incarnation
- type IncarnationCollection
- type IncarnationController
- type Incarnations
- type List
- type MockDeployment
- type MockDeploymentMockRecorder
- type MockIncarnations
- type MockIncarnationsMockRecorder
- type ReconcileReleaseManager
- type ReplicaSetList
- type ResourceSyncer
- type ScalableTargetAdapter
- func (s *ScalableTargetAdapter) CurrentPercent() uint32
- func (s *ScalableTargetAdapter) Delay() time.Duration
- func (s *ScalableTargetAdapter) Increment() uint32
- func (s *ScalableTargetAdapter) IsReconciled() bool
- func (s *ScalableTargetAdapter) LastUpdated() time.Time
- func (s *ScalableTargetAdapter) Max() uint32
- func (s *ScalableTargetAdapter) PeakPercent() uint32
- type SecretList
- type State
- func Canaried(ctx context.Context, deployment Deployment) (State, error)
- func Canarying(ctx context.Context, deployment Deployment) (State, error)
- func Created(ctx context.Context, deployment Deployment) (State, error)
- func Deleted(ctx context.Context, deployment Deployment) (State, error)
- func Deleting(ctx context.Context, deployment Deployment) (State, error)
- func Deployed(ctx context.Context, deployment Deployment) (State, error)
- func Deploying(ctx context.Context, deployment Deployment) (State, error)
- func Failed(ctx context.Context, deployment Deployment) (State, error)
- func Failing(ctx context.Context, deployment Deployment) (State, error)
- func PendingRelease(ctx context.Context, deployment Deployment) (State, error)
- func PendingTest(ctx context.Context, deployment Deployment) (State, error)
- func Released(ctx context.Context, deployment Deployment) (State, error)
- func Releasing(ctx context.Context, deployment Deployment) (State, error)
- func Retired(ctx context.Context, deployment Deployment) (State, error)
- func Retiring(ctx context.Context, deployment Deployment) (State, error)
- func Tested(ctx context.Context, deployment Deployment) (State, error)
- func Testing(ctx context.Context, deployment Deployment) (State, error)
- type StateHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Add ¶
Add creates a new ReleaseManager Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.
func LinearScale ¶
func LinearScale(i Incarnation, max uint32, t time.Time) uint32
Types ¶
type ClusterConfig ¶
type ConfigMapList ¶
type ConfigMapList struct {
Item *corev1.ConfigMapList
}
func NewConfigMapList ¶
func NewConfigMapList() *ConfigMapList
func (*ConfigMapList) GetItems ¶
func (s *ConfigMapList) GetItems() (r []runtime.Object)
func (*ConfigMapList) GetList ¶
func (s *ConfigMapList) GetList() (r runtime.Object)
type Controller ¶
type Controller interface {
// contains filtered or unexported methods
}
type Deployment ¶
type Deployment interface {
// contains filtered or unexported methods
}
type DeploymentStateManager ¶
type DeploymentStateManager struct {
// contains filtered or unexported fields
}
func NewDeploymentStateManager ¶
func NewDeploymentStateManager(deployment Deployment) *DeploymentStateManager
type HorizontalPodAutoscalerList ¶
type HorizontalPodAutoscalerList struct {
Item *autoscalingv1.HorizontalPodAutoscalerList
}
func NewHorizontalPodAutoscalerList ¶
func NewHorizontalPodAutoscalerList() *HorizontalPodAutoscalerList
func (*HorizontalPodAutoscalerList) GetItems ¶
func (s *HorizontalPodAutoscalerList) GetItems() (r []runtime.Object)
func (*HorizontalPodAutoscalerList) GetList ¶
func (s *HorizontalPodAutoscalerList) GetList() (r runtime.Object)
type Incarnation ¶
type Incarnation struct {
// contains filtered or unexported fields
}
func NewIncarnation ¶
func NewIncarnation(controller Controller, tag string, revision *picchuv1alpha1.Revision, log logr.Logger, di *observe.DeploymentInfo, humaneReleasesEnabled bool) *Incarnation
func (*Incarnation) Tag ¶
func (i *Incarnation) Tag() string
type IncarnationCollection ¶
type IncarnationCollection struct {
// contains filtered or unexported fields
}
IncarnationCollection helps us collect and select appropriate incarnations
type IncarnationController ¶
type IncarnationController struct {
// contains filtered or unexported fields
}
type Incarnations ¶
type Incarnations interface {
// contains filtered or unexported methods
}
type MockDeployment ¶
type MockDeployment struct {
// contains filtered or unexported fields
}
MockDeployment is a mock of Deployment interface
func NewMockDeployment ¶
func NewMockDeployment(ctrl *gomock.Controller) *MockDeployment
NewMockDeployment creates a new mock instance
func (*MockDeployment) EXPECT ¶
func (m *MockDeployment) EXPECT() *MockDeploymentMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockDeploymentMockRecorder ¶
type MockDeploymentMockRecorder struct {
// contains filtered or unexported fields
}
MockDeploymentMockRecorder is the mock recorder for MockDeployment
type MockIncarnations ¶
type MockIncarnations struct {
// contains filtered or unexported fields
}
MockIncarnations is a mock of Incarnations interface
func NewMockIncarnations ¶
func NewMockIncarnations(ctrl *gomock.Controller) *MockIncarnations
NewMockIncarnations creates a new mock instance
func (*MockIncarnations) EXPECT ¶
func (m *MockIncarnations) EXPECT() *MockIncarnationsMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockIncarnationsMockRecorder ¶
type MockIncarnationsMockRecorder struct {
// contains filtered or unexported fields
}
MockIncarnationsMockRecorder is the mock recorder for MockIncarnations
type ReconcileReleaseManager ¶
type ReconcileReleaseManager struct {
// contains filtered or unexported fields
}
ReconcileReleaseManager reconciles a ReleaseManager object
type ReplicaSetList ¶
type ReplicaSetList struct {
Item *appsv1.ReplicaSetList
}
func NewReplicaSetList ¶
func NewReplicaSetList() *ReplicaSetList
func (*ReplicaSetList) GetItems ¶
func (s *ReplicaSetList) GetItems() (r []runtime.Object)
func (*ReplicaSetList) GetList ¶
func (s *ReplicaSetList) GetList() (r runtime.Object)
type ResourceSyncer ¶
type ResourceSyncer struct {
// contains filtered or unexported fields
}
type ScalableTargetAdapter ¶
type ScalableTargetAdapter struct {
Incarnation
}
func (*ScalableTargetAdapter) CurrentPercent ¶
func (s *ScalableTargetAdapter) CurrentPercent() uint32
func (*ScalableTargetAdapter) Delay ¶
func (s *ScalableTargetAdapter) Delay() time.Duration
func (*ScalableTargetAdapter) Increment ¶
func (s *ScalableTargetAdapter) Increment() uint32
func (*ScalableTargetAdapter) IsReconciled ¶
func (s *ScalableTargetAdapter) IsReconciled() bool
IsReconciled returns true if the target is considered ready to be scaled to the next increment.
func (*ScalableTargetAdapter) LastUpdated ¶
func (s *ScalableTargetAdapter) LastUpdated() time.Time
func (*ScalableTargetAdapter) Max ¶
func (s *ScalableTargetAdapter) Max() uint32
func (*ScalableTargetAdapter) PeakPercent ¶
func (s *ScalableTargetAdapter) PeakPercent() uint32
type SecretList ¶
type SecretList struct {
Item *corev1.SecretList
}
func NewSecretList ¶
func NewSecretList() *SecretList
func (*SecretList) GetItems ¶
func (s *SecretList) GetItems() (r []runtime.Object)
func (*SecretList) GetList ¶
func (s *SecretList) GetList() (r runtime.Object)
type State ¶
type State string
func PendingRelease ¶
func PendingRelease(ctx context.Context, deployment Deployment) (State, error)
func PendingTest ¶
func PendingTest(ctx context.Context, deployment Deployment) (State, error)
type StateHandler ¶
type StateHandler func(context.Context, Deployment) (State, error)