chore: update accumulator proto (#200)

Signed-off-by: Yashash H L <[email protected]>

Author: yhl25

pkg/accumulator/examples/streamsorter/main.go

@@ -27,7 +27,7 @@ func (s *streamSorter) Accumulate(ctx context.Context, input <-chan accumulator.
 			log.Println("Exiting the Accumulator")
 			return
 		case datum, ok := <-input:
-		// this case happens due to timeout
+			// this case happens due to timeout
 			if !ok {
 				log.Println("Input channel closed")
 				return

pkg/apis/proto/accumulator/v1/accumulator.pb.go

@@ -45,7 +45,6 @@ message AccumulatorRequest {
 
   Payload payload = 1;
   WindowOperation operation = 2;
-  optional Handshake handshake = 3;
 }
 
 
@@ -63,19 +62,12 @@ message AccumulatorResponse {
   // window represents a window to which the result belongs.
   KeyedWindow window = 2;
   repeated string tags = 3;
-  optional Handshake handshake = 4;
   // EOF represents the end of the response for a window.
-  bool EOF = 5;
+  bool EOF = 4;
 }
 
 
 // ReadyResponse is the health check result.
 message ReadyResponse {
   bool ready = 1;
-}
-
-// Handshake message between client and server to indicate the start of transmission.
-message Handshake {
-  // Required field indicating the start of transmission.
-  bool sot = 1;
 }