package edu.uci.ics.amber.engine.common

Get desktop application:
View/edit binary Protocol Buffers messages

Used in: PythonActorMessage

• oneof sealed_value

  • Backpressure backpressure = 1

  • CreditUpdate creditUpdate = 2

Used in: ActorCommand

• bool enableBackpressure = 1

Used in: OperatorBreakpoints

• string worker_name = 1

• optional BreakpointFault.BreakpointTuple faulted_tuple = 2

Used in: BreakpointFault

• int64 id = 1

• bool is_input = 2

• repeated string tuple = 3

Used in: PythonControlMessage

• oneof value

  • architecture.rpc.ControlInvocation control_invocation = 1

  • architecture.rpc.ReturnInvocation return_invocation = 2

Used in: ActorCommand

(message has no fields)

Used in: OperatorConsole

• repeated architecture.rpc.EvaluatedValue values = 1

• map<string, OperatorBreakpoints> operator_info = 1

• map<string, OperatorConsole> operator_console = 1

• architecture.rpc.WorkflowAggregatedState state = 1

• repeated core.WorkflowFatalError fatal_errors = 2

• optional core.ExecutionIdentity executionId = 3

• bool is_recovering = 4

• int64 startTimeStamp = 1

• int64 endTimeStamp = 2

• map<string, OperatorMetrics> operator_info = 3

• repeated OperatorWorkerMapping operator_worker_mapping = 4

Used in: ExecutionBreakpointStore

• repeated BreakpointFault unresolved_breakpoints = 1

Used in: ExecutionConsoleStore

• repeated architecture.rpc.ConsoleMessage console_messages = 1

• map<string, EvaluatedValueList> evaluate_expr_results = 2

Used in: ExecutionStatsStore

• architecture.rpc.WorkflowAggregatedState operator_state = 1

• optional OperatorStatistics operator_statistics = 2

Used in: OperatorMetrics

• repeated architecture.worker.PortTupleMetricsMapping input_metrics = 1

• repeated architecture.worker.PortTupleMetricsMapping output_metrics = 2

• int32 num_workers = 3

• int64 data_processing_time = 4

• int64 control_processing_time = 5

• int64 idle_time = 6

Used in: ExecutionStatsStore

• string operatorId = 1

• repeated string workerIds = 2

• optional ActorCommand payload = 1

• optional core.ChannelIdentity tag = 1

• optional ControlPayloadV2 payload = 2

• optional core.ChannelIdentity tag = 1

• string payload_type = 2