Skip to content

Commit 5702fde

Browse files
committed
fix rebase issues
1 parent 90180f0 commit 5702fde

File tree

2 files changed

+8
-0
lines changed

2 files changed

+8
-0
lines changed

cluster-autoscaler/config/autoscaling_options.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -345,6 +345,10 @@ type AutoscalingOptions struct {
345345
// NodeDeletionCandidateTTL is the maximum time a node can be marked as removable without being deleted.
346346
// This is used to prevent nodes from being stuck in the removable state during if the CA deployment becomes inactive.
347347
NodeDeletionCandidateTTL time.Duration
348+
//CapacitybufferControllerEnabled tells if CA should run default capacity buffer as sub-process or not
349+
CapacitybufferControllerEnabled bool
350+
// CapacitybufferPodInjectionEnabled tells if CA should injects fake pods for capacity buffers that are ready for provisioning
351+
CapacitybufferPodInjectionEnabled bool
348352
// NodeRemovalLatencyTrackingEnabled is used to enable/disable node removal latency tracking.
349353
NodeRemovalLatencyTrackingEnabled bool
350354
}

cluster-autoscaler/config/flags/flags.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -228,6 +228,8 @@ var (
228228
clusterSnapshotParallelism = flag.Int("cluster-snapshot-parallelism", 16, "Maximum parallelism of cluster snapshot creation.")
229229
checkCapacityProcessorInstance = flag.String("check-capacity-processor-instance", "", "Name of the processor instance. Only ProvisioningRequests that define this name in their parameters with the key \"processorInstance\" will be processed by this CA instance. It only refers to check capacity ProvisioningRequests, but if not empty, best-effort atomic ProvisioningRequests processing is disabled in this instance. Not recommended: Until CA 1.35, ProvisioningRequests with this name as prefix in their class will be also processed.")
230230
nodeDeletionCandidateTTL = flag.Duration("node-deletion-candidate-ttl", time.Duration(0), "Maximum time a node can be marked as removable before the marking becomes stale. This sets the TTL of Cluster-Autoscaler's state if the Cluste-Autoscaler deployment becomes inactive")
231+
capacitybufferControllerEnabled = flag.Bool("capacity-buffer-controller-enabled", false, "Whether to enable the default controller for capacity buffers or not")
232+
capacitybufferPodInjectionEnabled = flag.Bool("capacity-buffer-pod-injection-enabled", false, "Whether to enable pod list processor that processes ready capacity buffers and injects fake pods accordingly")
231233
nodeRemovalLatencyTrackingEnabled = flag.Bool("enable-node-removal-latency-tracking", false, "Whether to track latency from when a node is marked unneeded until it is removed or needed again.")
232234

233235
// Deprecated flags
@@ -411,6 +413,8 @@ func createAutoscalingOptions() config.AutoscalingOptions {
411413
ProactiveScaleupEnabled: *proactiveScaleupEnabled,
412414
PodInjectionLimit: *podInjectionLimit,
413415
NodeDeletionCandidateTTL: *nodeDeletionCandidateTTL,
416+
CapacitybufferControllerEnabled: *capacitybufferControllerEnabled,
417+
CapacitybufferPodInjectionEnabled: *capacitybufferPodInjectionEnabled,
414418
NodeRemovalLatencyTrackingEnabled: *nodeRemovalLatencyTrackingEnabled,
415419
}
416420
}

0 commit comments

Comments
 (0)