Github user danny0405 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2433#discussion_r163215412
--- Diff: storm-client/src/storm.thrift ---
@@ -836,3 +848,33 @@ exception HBAuthorizationException {
exception HBExecutionException {
1: required string msg;
}
+
+struct SupervisorAssignments {
+ 1: optional map<string, Assignment> storm_assignment = {}
+}
+
+service Supervisor {
+ /**
+ * Send node specific assignments to supervisor
+ */
+ void sendSupervisorAssignments(1: SupervisorAssignments assignments)
throws (1: AuthorizationException aze);
+ /**
+ * Get local assignment for a storm
+ */
+ Assignment getLocalAssignmentForStorm(1: string id) throws (1:
NotAliveException e, 2: AuthorizationException aze);
+ /**
+ * Send worker heartbeat to local supervisor
+ */
+ void sendSupervisorWorkerHeartbeat(1: SupervisorWorkerHeartbeat
heartbeat) throws (1: AuthorizationException aze);
+}
+
+struct SupervisorWorkerHeartbeat {
--- End diff --
@HeartSaVioR
I have tweaked the position of structs in storm.thrift.
---
