FazBrowse GitHub Viewer | Trending |
URL:
| Home
Tools: [Download Repo ZIP]   [Original HTTPS Page]

CKS: change the node settings of a cluster and restart its nodes with them, a few at a time by bhouse-nexthop · Pull Request #14616 · apache/cloudstack · GitHub

  1. apache
  2. cloudstack

Repository navigation

CKS: change the node settings of a cluster and restart its nodes with them, a few at a time #14616

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
bhouse-nexthop wants to merge 3 commits into
base: main
Choose a base branch
Could not load branches
Branch not found: {{ refName }}

Are you sure you want to change the base?

Some commits from the old base branch may be removed from the timeline, and old review comments may become outdated.
from
Conversation 3 Commits 3 Checks 27 Files changed
Draft

CKS: change the node settings of a cluster and restart its nodes with them, a few at a time #14616

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
3c8049c
Stop concurrent CKS operations clobbering each other, recover stuck s…
bhouse-nexthop Nov 7, 2026
8a8b89e
CKS: fix node drain on scale-down and upgrade, make a failed upgrade …
bhouse-nexthop Nov 7, 2026
124ecf2
CKS: restart the nodes of a cluster with new node settings, a few at …
bhouse-nexthop Nov 8, 2026
File filter

Filter by extension

Filter by extension .java  (37) .js  (1) .sql  (1) All 3 file types selected
Viewed files
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Unified
Split
Hide whitespace
Diff view
Unified
Split
Hide whitespace
13 changes: 13 additions & 0 deletions api/src/main/java/com/cloud/kubernetes/cluster/KubernetesCluster.java
Show comments
View file
Open in desktop
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters
Show hidden characters
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,7 @@ enum Event {
AddNodeRequested,
RemoveNodeRequested,
UpgradeRequested,
UpdateRequested,
OperationSucceeded,
OperationFailed,
CreateFailed,
Expand All @@ -62,6 +63,7 @@ enum State {
Scaling("Transient state in which resources are either getting scaled up/down"),
ScalingStoppedCluster("Transient state in which the service offerings of stopped clusters are getting scaled"),
Upgrading("Transient state in which cluster is getting upgraded"),
Updating("Transient state in which the nodes of the cluster are restarted with their stored settings, a few at a time"),
Importing("Transient state in which additional nodes are added as worker nodes to a cluster"),
RemovingNodes("Transient state in which additional nodes are removed from a cluster"),
Alert("State to represent Kubernetes clusters which are not in expected desired state (operationally in active control place, stopped cluster VM's etc)."),
Expand All @@ -88,6 +90,7 @@ enum State {
s_fsm.addTransition(State.Stopping, Event.OperationFailed, State.Alert);

s_fsm.addTransition(State.Stopped, Event.StartRequested, State.Starting);
s_fsm.addTransition(State.Alert, Event.StartRequested, State.Starting);
s_fsm.addTransition(State.Stopped, Event.OperationSucceeded, State.Stopped);
s_fsm.addTransition(State.Running, Event.OperationSucceeded, State.Running);

Expand All @@ -103,9 +106,16 @@ enum State {
s_fsm.addTransition(State.ScalingStoppedCluster, Event.OperationFailed, State.Alert);

s_fsm.addTransition(State.Running, Event.UpgradeRequested, State.Upgrading);
s_fsm.addTransition(State.Alert, Event.UpgradeRequested, State.Upgrading);
s_fsm.addTransition(State.Upgrading, Event.OperationSucceeded, State.Running);
s_fsm.addTransition(State.Upgrading, Event.OperationFailed, State.Alert);

// a rollout ends in Running if the cluster is healthy, and in Alert otherwise
s_fsm.addTransition(State.Running, Event.UpdateRequested, State.Updating);
s_fsm.addTransition(State.Alert, Event.UpdateRequested, State.Updating);
s_fsm.addTransition(State.Updating, Event.OperationSucceeded, State.Running);
s_fsm.addTransition(State.Updating, Event.OperationFailed, State.Alert);

s_fsm.addTransition(State.Running, Event.AddNodeRequested, State.Importing);
s_fsm.addTransition(State.Alert, Event.AddNodeRequested, State.Importing);
s_fsm.addTransition(State.Importing, Event.OperationSucceeded, State.Running);
Expand Down Expand Up @@ -153,6 +163,9 @@ enum State {
long getCores();
long getMemory();
long getNodeRootDiskSize();
Long getControlNodeRootDiskSize();
Long getWorkerNodeRootDiskSize();
Long getEtcdNodeRootDiskSize();
String getEndpoint();
boolean isCheckForGc();
@Override
Expand Down
10 changes: 10 additions & 0 deletions api/src/main/java/org/apache/cloudstack/api/ApiConstants.java
Show comments
View file
Open in desktop
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters
Show hidden characters
Original file line number Diff line number Diff line change
Expand Up @@ -1324,6 +1324,16 @@ public class ApiConstants {
public static final String NODE_TYPE_OFFERING_MAP = "nodeofferings";
public static final String NODE_TYPE_TEMPLATE_MAP = "nodetemplates";
public static final String NODE_TYPE_AFFINITY_GROUP_MAP = "nodeaffinitygroups";
public static final String NODE_TYPE_ROOT_DISK_SIZE_MAP = "noderootdisksizes";
public static final String CONTROL_ROOT_DISK_SIZE = "controlrootdisksize";
public static final String WORKER_ROOT_DISK_SIZE = "workerrootdisksize";
public static final String ETCD_ROOT_DISK_SIZE = "etcdrootdisksize";
public static final String CONTROL_NODES_OUT_OF_DATE = "controlnodesoutofdate";
public static final String WORKER_NODES_OUT_OF_DATE = "workernodesoutofdate";
public static final String ETCD_NODES_OUT_OF_DATE = "etcdnodesoutofdate";
public static final String ROLLOUT = "rollout";
public static final String CANCEL_ROLLOUT = "cancelrollout";
public static final String MAX_UNAVAILABLE = "maxunavailable";
public static final String CONTROL_AFFINITY_GROUP_IDS = "controlaffinitygroupids";
public static final String CONTROL_AFFINITY_GROUP_NAMES = "controlaffinitygroupnames";
public static final String WORKER_AFFINITY_GROUP_IDS = "workeraffinitygroupids";
Expand Down
5 changes: 5 additions & 0 deletions engine/schema/src/main/resources/META-INF/db/schema-42300to2400.sql
Show comments
View file
Open in desktop
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters
Show hidden characters
Original file line number Diff line number Diff line change
Expand Up @@ -239,3 +239,8 @@ CREATE TABLE IF NOT EXISTS `cloud`.`instance_boot_group_details` (
PRIMARY KEY (`id`),
CONSTRAINT `fk_instance_boot_group_details__group_id` FOREIGN KEY (`boot_group_id`) REFERENCES `instance_boot_group` (`id`) ON DELETE CASCADE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

-- CKS: root disk size per node type. When not set, the cluster wide node_root_disk_size is used, as before.
CALL `cloud`.`IDEMPOTENT_ADD_COLUMN`('cloud.kubernetes_cluster', 'control_node_root_disk_size', 'bigint unsigned DEFAULT NULL COMMENT "root disk size in GB of the control nodes, node_root_disk_size when not set"');
CALL `cloud`.`IDEMPOTENT_ADD_COLUMN`('cloud.kubernetes_cluster', 'worker_node_root_disk_size', 'bigint unsigned DEFAULT NULL COMMENT "root disk size in GB of the worker nodes, node_root_disk_size when not set"');
CALL `cloud`.`IDEMPOTENT_ADD_COLUMN`('cloud.kubernetes_cluster', 'etcd_node_root_disk_size', 'bigint unsigned DEFAULT NULL COMMENT "root disk size in GB of the etcd nodes, the size of the template when not set"');
1 change: 1 addition & 0 deletions ...netes-service/src/main/java/com/cloud/kubernetes/cluster/KubernetesClusterEventTypes.java
Show comments
View file
Open in desktop
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters
Show hidden characters
Original file line number Diff line number Diff line change
Expand Up @@ -26,4 +26,5 @@ public class KubernetesClusterEventTypes {
public static final String EVENT_KUBERNETES_CLUSTER_NODES_ADD = "KUBERNETES.CLUSTER.NODES.ADD";
public static final String EVENT_KUBERNETES_CLUSTER_NODES_REMOVE = "KUBERNETES.CLUSTER.NODES.REMOVE";
public static final String EVENT_KUBERNETES_CLUSTER_AFFINITY_UPDATE = "KUBERNETES.CLUSTER.AFFINITY.UPDATE";
public static final String EVENT_KUBERNETES_CLUSTER_UPDATE = "KUBERNETES.CLUSTER.UPDATE";
}
Loading
Loading
Back | FazBrowse Home | New Git URL