Cluster.Event

yim-lee · yim-lee · commit 7ea7b1f46316 · 2022-07-25T15:08:53.000-07:00
diff --git a/Sources/DistributedActors/Cluster/Cluster+Event.swift b/Sources/DistributedActors/Cluster/Cluster+Event.swift
@@ -24,6 +24,7 @@ extension Cluster {
         case membershipChange(MembershipChange)
         case reachabilityChange(ReachabilityChange)
         case leadershipChange(LeadershipChange)
+        case _PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE
     }
 }
 
diff --git a/Sources/DistributedActors/Cluster/Cluster+Membership.swift b/Sources/DistributedActors/Cluster/Cluster+Membership.swift
@@ -2,7 +2,7 @@
 //
 // This source file is part of the Swift Distributed Actors open source project
 //
-// Copyright (c) 2018-2019 Apple Inc. and the Swift Distributed Actors project authors
+// Copyright (c) 2018-2022 Apple Inc. and the Swift Distributed Actors project authors
 // Licensed under Apache License v2.0
 //
 // See LICENSE.txt for license information
@@ -604,6 +604,9 @@ extension Cluster.Membership {
 
         case .reachabilityChange(let change):
             _ = self.applyReachabilityChange(change)
+
+        case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:
+            () // do nothing
         }
     }
 }
diff --git a/Sources/DistributedActors/Cluster/ClusterShellState.swift b/Sources/DistributedActors/Cluster/ClusterShellState.swift
@@ -456,6 +456,9 @@ extension ClusterShellState {
                 changeWasApplied = changeWasApplied || directive.applied
                 // actions we'll calculate below, once
             }
+        case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:
+            self.log.error("Received Cluster.Event [\(event)]. This should not happen, please file an issue.")
+            changeWasApplied = false
         }
 
         guard changeWasApplied else {
diff --git a/Sources/DistributedActors/Cluster/DistributedNodeDeathWatcher.swift b/Sources/DistributedActors/Cluster/DistributedNodeDeathWatcher.swift
@@ -66,6 +66,8 @@ internal actor DistributedNodeDeathWatcher {
                     }
                 case .leadershipChange, .reachabilityChange:
                     break // ignore those, they don't affect downing
+                case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:
+                    self.log.error("Received Cluster.Event [\(event)]. This should not happen, please file an issue.")
                 }
             }
         }
diff --git a/Sources/DistributedActors/Cluster/Downing/TimeoutBasedDowningStrategy.swift b/Sources/DistributedActors/Cluster/Downing/TimeoutBasedDowningStrategy.swift
@@ -74,6 +74,9 @@ public final class TimeoutBasedDowningStrategy: DowningStrategy {
             } else {
                 return self.onMemberReachable(change)
             }
+
+        case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:
+            return .none // do nothing
         }
     }
 
diff --git a/Sources/DistributedActors/Cluster/Leadership.swift b/Sources/DistributedActors/Cluster/Leadership.swift
@@ -141,6 +141,10 @@ extension Leadership {
 
                 case .leadershipChange:
                     return .same // we are the source of such events!
+
+                case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:
+                    context.log.error("Received Cluster.Event [\(event)]. This should not happen, please file an issue.")
+                    return .same
                 }
             }
         }
diff --git a/Sources/DistributedActors/Cluster/Reception/OperationLogDistributedReceptionist.swift b/Sources/DistributedActors/Cluster/Reception/OperationLogDistributedReceptionist.swift
@@ -866,6 +866,9 @@ extension OpLogDistributedReceptionist {
 
         case .leadershipChange, .reachabilityChange:
             return // we ignore those
+
+        case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:
+            self.log.error("Received Cluster.Event [\(event)]. This should not happen, please file an issue.")
         }
     }
 
diff --git a/Sources/DistributedActors/Cluster/Reception/_OperationLogClusterReceptionistBehavior.swift b/Sources/DistributedActors/Cluster/Reception/_OperationLogClusterReceptionistBehavior.swift
@@ -608,6 +608,9 @@ extension _OperationLogClusterReceptionist {
 
         case .leadershipChange, .reachabilityChange:
             return // we ignore those
+
+        case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:
+            context.log.error("Received Cluster.Event [\(event)]. This should not happen, please file an issue.")
         }
     }
 
diff --git a/Sources/DistributedActors/Gossip/Gossiper+Shell.swift b/Sources/DistributedActors/Gossip/Gossiper+Shell.swift
@@ -328,6 +328,8 @@ extension GossipShell {
                     resolveInsertPeer(context, member: change.member)
                 case .leadershipChange, .reachabilityChange:
                     () // ignore
+                case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:
+                    context.log.error("Received Cluster.Event [\(event)]. This should not happen, please file an issue.")
                 }
             }
             context.system.cluster.events.subscribe(onClusterEventRef)

Original file line number	Diff line number	Diff line change
`@@ -24,6 +24,7 @@ extension Cluster {`
`24`	`24`	`case membershipChange(MembershipChange)`
`25`	`25`	`case reachabilityChange(ReachabilityChange)`
`26`	`26`	`case leadershipChange(LeadershipChange)`
	`27`	`+ case _PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE`
`27`	`28`	`}`
`28`	`29`	`}`
`29`	`30`
Original file line number	Diff line number	Diff line change
`@@ -2,7 +2,7 @@`
`2`	`2`	`//`
`3`	`3`	`// This source file is part of the Swift Distributed Actors open source project`
`4`	`4`	`//`
`5`		`-// Copyright (c) 2018-2019 Apple Inc. and the Swift Distributed Actors project authors`
	`5`	`+// Copyright (c) 2018-2022 Apple Inc. and the Swift Distributed Actors project authors`
`6`	`6`	`// Licensed under Apache License v2.0`
`7`	`7`	`//`
`8`	`8`	`// See LICENSE.txt for license information`
`@@ -604,6 +604,9 @@ extension Cluster.Membership {`
`604`	`604`
`605`	`605`	`case .reachabilityChange(let change):`
`606`	`606`	`_ = self.applyReachabilityChange(change)`
	`607`	`+`
	`608`	`+ case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:`
	`609`	`+ () // do nothing`
`607`	`610`	`}`
`608`	`611`	`}`
`609`	`612`	`}`
Original file line number	Diff line number	Diff line change
`@@ -456,6 +456,9 @@ extension ClusterShellState {`
`456`	`456`	`changeWasApplied = changeWasApplied \|\| directive.applied`
`457`	`457`	`// actions we'll calculate below, once`
`458`	`458`	`}`
	`459`	`+ case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:`
	`460`	`+ self.log.error("Received Cluster.Event [\(event)]. This should not happen, please file an issue.")`
	`461`	`+ changeWasApplied = false`
`459`	`462`	`}`
`460`	`463`
`461`	`464`	`guard changeWasApplied else {`
Original file line number	Diff line number	Diff line change
`@@ -66,6 +66,8 @@ internal actor DistributedNodeDeathWatcher {`
`66`	`66`	`}`
`67`	`67`	`case .leadershipChange, .reachabilityChange:`
`68`	`68`	`break // ignore those, they don't affect downing`
	`69`	`+ case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:`
	`70`	`+ self.log.error("Received Cluster.Event [\(event)]. This should not happen, please file an issue.")`
`69`	`71`	`}`
`70`	`72`	`}`
`71`	`73`	`}`
Original file line number	Diff line number	Diff line change
`@@ -74,6 +74,9 @@ public final class TimeoutBasedDowningStrategy: DowningStrategy {`
`74`	`74`	`} else {`
`75`	`75`	`return self.onMemberReachable(change)`
`76`	`76`	`}`
	`77`	`+`
	`78`	`+ case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:`
	`79`	`+ return .none // do nothing`
`77`	`80`	`}`
`78`	`81`	`}`
`79`	`82`
Original file line number	Diff line number	Diff line change
`@@ -141,6 +141,10 @@ extension Leadership {`
`141`	`141`
`142`	`142`	`case .leadershipChange:`
`143`	`143`	`return .same // we are the source of such events!`
	`144`	`+`
	`145`	`+ case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:`
	`146`	`+ context.log.error("Received Cluster.Event [\(event)]. This should not happen, please file an issue.")`
	`147`	`+ return .same`
`144`	`148`	`}`
`145`	`149`	`}`
`146`	`150`	`}`
Original file line number	Diff line number	Diff line change
`@@ -866,6 +866,9 @@ extension OpLogDistributedReceptionist {`
`866`	`866`
`867`	`867`	`case .leadershipChange, .reachabilityChange:`
`868`	`868`	`return // we ignore those`
	`869`	`+`
	`870`	`+ case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:`
	`871`	`+ self.log.error("Received Cluster.Event [\(event)]. This should not happen, please file an issue.")`
`869`	`872`	`}`
`870`	`873`	`}`
`871`	`874`
Original file line number	Diff line number	Diff line change
`@@ -608,6 +608,9 @@ extension _OperationLogClusterReceptionist {`
`608`	`608`
`609`	`609`	`case .leadershipChange, .reachabilityChange:`
`610`	`610`	`return // we ignore those`
	`611`	`+`
	`612`	`+ case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:`
	`613`	`+ context.log.error("Received Cluster.Event [\(event)]. This should not happen, please file an issue.")`
`611`	`614`	`}`
`612`	`615`	`}`
`613`	`616`
Original file line number	Diff line number	Diff line change
`@@ -328,6 +328,8 @@ extension GossipShell {`
`328`	`328`	`resolveInsertPeer(context, member: change.member)`
`329`	`329`	`case .leadershipChange, .reachabilityChange:`
`330`	`330`	`() // ignore`
	`331`	`+ case ._PLEASE_DO_NOT_EXHAUSTIVELY_MATCH_THIS_ENUM_NEW_CASES_MIGHT_BE_ADDED_IN_THE_FUTURE:`
	`332`	`+ context.log.error("Received Cluster.Event [\(event)]. This should not happen, please file an issue.")`
`331`	`333`	`}`
`332`	`334`	`}`
`333`	`335`	`context.system.cluster.events.subscribe(onClusterEventRef)`