Skip to content

Commit

Permalink
WIP
Browse files Browse the repository at this point in the history 
Signed-off-by: Derek Su <[email protected]>
  • Loading branch information
@derekbit
derekbit committed Dec 17, 2024
1 parent 480372f commit ad29589
Show file tree
Hide file tree
Showing 2 changed files with 12,305 additions and 0 deletions.
19 changes: 19 additions & 0 deletions controller/node_controller_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -186,6 +186,7 @@ func (s *NodeControllerSuite) TestManagerPodUp(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
newNodeCondition(longhorn.NodeConditionTypeMountPropagation, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeRequiredPackages, longhorn.ConditionStatusFalse, longhorn.NodeConditionReasonUnknownOS),
newNodeCondition(longhorn.NodeConditionTypeMultipathd, longhorn.ConditionStatusTrue, ""),
Expand All @@ -197,6 +198,7 @@ func (s *NodeControllerSuite) TestManagerPodUp(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
},
},
},
Expand Down Expand Up @@ -274,6 +276,7 @@ func (s *NodeControllerSuite) TestManagerPodDown(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusFalse, longhorn.NodeConditionReasonManagerPodDown),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
newNodeCondition(longhorn.NodeConditionTypeMountPropagation, longhorn.ConditionStatusFalse, longhorn.NodeConditionReasonNoMountPropagationSupport),
newNodeCondition(longhorn.NodeConditionTypeRequiredPackages, longhorn.ConditionStatusFalse, longhorn.NodeConditionReasonUnknownOS),
newNodeCondition(longhorn.NodeConditionTypeMultipathd, longhorn.ConditionStatusTrue, ""),
Expand All @@ -285,6 +288,7 @@ func (s *NodeControllerSuite) TestManagerPodDown(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
},
},
},
Expand Down Expand Up @@ -362,6 +366,7 @@ func (s *NodeControllerSuite) TestKubeNodeDown(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusFalse, longhorn.NodeConditionReasonKubernetesNodeNotReady),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
newNodeCondition(longhorn.NodeConditionTypeMountPropagation, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeRequiredPackages, longhorn.ConditionStatusFalse, longhorn.NodeConditionReasonUnknownOS),
newNodeCondition(longhorn.NodeConditionTypeMultipathd, longhorn.ConditionStatusTrue, ""),
Expand All @@ -373,6 +378,7 @@ func (s *NodeControllerSuite) TestKubeNodeDown(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
},
},
},
Expand Down Expand Up @@ -450,6 +456,7 @@ func (s *NodeControllerSuite) TestKubeNodePressure(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusFalse, longhorn.NodeConditionReasonKubernetesNodePressure),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
newNodeCondition(longhorn.NodeConditionTypeMountPropagation, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeRequiredPackages, longhorn.ConditionStatusFalse, longhorn.NodeConditionReasonUnknownOS),
newNodeCondition(longhorn.NodeConditionTypeMultipathd, longhorn.ConditionStatusTrue, ""),
Expand All @@ -461,6 +468,7 @@ func (s *NodeControllerSuite) TestKubeNodePressure(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
},
},
},
Expand Down Expand Up @@ -573,6 +581,7 @@ func (s *NodeControllerSuite) TestUpdateDiskStatus(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
newNodeCondition(longhorn.NodeConditionTypeMountPropagation, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeRequiredPackages, longhorn.ConditionStatusFalse, longhorn.NodeConditionReasonUnknownOS),
newNodeCondition(longhorn.NodeConditionTypeMultipathd, longhorn.ConditionStatusTrue, ""),
Expand Down Expand Up @@ -603,6 +612,7 @@ func (s *NodeControllerSuite) TestUpdateDiskStatus(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
},
DiskStatus: map[string]*longhorn.DiskStatus{
TestDiskID1: {
Expand Down Expand Up @@ -726,6 +736,7 @@ func (s *NodeControllerSuite) TestCleanDiskStatus(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
newNodeCondition(longhorn.NodeConditionTypeMountPropagation, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeRequiredPackages, longhorn.ConditionStatusFalse, longhorn.NodeConditionReasonUnknownOS),
newNodeCondition(longhorn.NodeConditionTypeMultipathd, longhorn.ConditionStatusTrue, ""),
Expand Down Expand Up @@ -755,6 +766,7 @@ func (s *NodeControllerSuite) TestCleanDiskStatus(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
},
DiskStatus: map[string]*longhorn.DiskStatus{
TestDiskID1: {
Expand Down Expand Up @@ -885,6 +897,7 @@ func (s *NodeControllerSuite) TestDisableDiskOnFilesystemChange(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
newNodeCondition(longhorn.NodeConditionTypeMountPropagation, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeRequiredPackages, longhorn.ConditionStatusFalse, longhorn.NodeConditionReasonUnknownOS),
newNodeCondition(longhorn.NodeConditionTypeMultipathd, longhorn.ConditionStatusTrue, ""),
Expand Down Expand Up @@ -914,6 +927,7 @@ func (s *NodeControllerSuite) TestDisableDiskOnFilesystemChange(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
},
DiskStatus: map[string]*longhorn.DiskStatus{
TestDiskID1: {
Expand Down Expand Up @@ -1015,6 +1029,7 @@ func (s *NodeControllerSuite) TestCreateDefaultInstanceManager(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
newNodeCondition(longhorn.NodeConditionTypeMountPropagation, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeRequiredPackages, longhorn.ConditionStatusFalse, longhorn.NodeConditionReasonUnknownOS),
newNodeCondition(longhorn.NodeConditionTypeMultipathd, longhorn.ConditionStatusTrue, ""),
Expand Down Expand Up @@ -1162,6 +1177,7 @@ func (s *NodeControllerSuite) TestCleanupRedundantInstanceManagers(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
newNodeCondition(longhorn.NodeConditionTypeMountPropagation, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeRequiredPackages, longhorn.ConditionStatusFalse, longhorn.NodeConditionReasonUnknownOS),
newNodeCondition(longhorn.NodeConditionTypeMultipathd, longhorn.ConditionStatusTrue, ""),
Expand Down Expand Up @@ -1279,6 +1295,7 @@ func (s *NodeControllerSuite) TestCleanupAllInstanceManagers(c *C) {
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
newNodeCondition(longhorn.NodeConditionTypeMountPropagation, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeRequiredPackages, longhorn.ConditionStatusFalse, longhorn.NodeConditionReasonUnknownOS),
newNodeCondition(longhorn.NodeConditionTypeMultipathd, longhorn.ConditionStatusTrue, ""),
Expand Down Expand Up @@ -2119,6 +2136,7 @@ CONFIG_NFS_V4_2=y`
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
newNodeCondition(longhorn.NodeConditionTypeMountPropagation, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeRequiredPackages, longhorn.ConditionStatusFalse, longhorn.NodeConditionReasonUnknownOS),
newNodeCondition(longhorn.NodeConditionTypeMultipathd, longhorn.ConditionStatusTrue, ""),
Expand All @@ -2130,6 +2148,7 @@ CONFIG_NFS_V4_2=y`
Conditions: []longhorn.Condition{
newNodeCondition(longhorn.NodeConditionTypeSchedulable, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeReady, longhorn.ConditionStatusTrue, ""),
newNodeCondition(longhorn.NodeConditionTypeDataEngineUpgradeRequested, longhorn.ConditionStatusFalse, ""),
},
},
},
Expand Down
Loading

0 comments on commit ad29589

Please sign in to comment.