package sessionreduce.v1

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc IsReady (google.protobuf.Empty, ReadyResponse)

  sessionreduce.proto:17

  IsReady is the heartbeat endpoint for gRPC.

  message ReadyResponse

  sessionreduce.proto:88

  * ReadyResponse is the health check result.

  • bool ready = 1

• rpc SessionReduceFn (stream SessionReduceRequest, stream SessionReduceResponse)

  sessionreduce.proto:14

  SessionReduceFn applies a reduce function to a request stream.

  message SessionReduceRequest

  sessionreduce.proto:32

  * SessionReduceRequest represents a request element.

  • optional SessionReduceRequest.Payload payload = 1

  • optional SessionReduceRequest.WindowOperation operation = 2

  message SessionReduceResponse

  sessionreduce.proto:66

  * SessionReduceResponse represents a response element.

  • optional SessionReduceResponse.Result result = 1

  • optional KeyedWindow keyedWindow = 2

    keyedWindow represents a window to which the result belongs.

  • bool EOF = 3

    EOF represents the end of the response for a window.

KeyedWindow represents a window with keys. since the client track the keys, we use keyed window.

Used in: SessionReduceRequest.WindowOperation, SessionReduceResponse

• optional google.protobuf.Timestamp start = 1

• optional google.protobuf.Timestamp end = 2

• string slot = 3

• repeated string keys = 4

Payload represents a payload element.

Used in: SessionReduceRequest

• repeated string keys = 1

• bytes value = 2

• optional google.protobuf.Timestamp event_time = 3

• optional google.protobuf.Timestamp watermark = 4

• map<string, string> headers = 5

• optional common.Metadata metadata = 6

  Metadata is the metadata of the message

WindowOperation represents a window operation. For Aligned window values can be one of OPEN, CLOSE, EXPAND, MERGE and APPEND.

Used in: SessionReduceRequest

• WindowOperation.Event event = 1

• repeated KeyedWindow keyedWindows = 2

Used in: WindowOperation

• OPEN = 0

• CLOSE = 1

• EXPAND = 2

• MERGE = 3

• APPEND = 4

Result represents a result element. It contains the result of the reduce function.

Used in: SessionReduceResponse

• repeated string keys = 1

• bytes value = 2

• repeated string tags = 3

• optional common.Metadata metadata = 4

  Metadata is the metadata of the message