Default package

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc agent_info (google.protobuf.Empty, InfoResponse)

  agent.proto:25

  message InfoResponse

  agent.proto:32

  • string json_info = 1

• rpc read (stream SourceRequest, stream SourceResponse)

  agent.proto:26

  message SourceRequest

  agent.proto:88

  • repeated int64 committed_records = 1

  • optional PermanentFailure permanent_failure = 2

  message SourceResponse

  agent.proto:93

  • optional Schema schema = 1

  • repeated Record records = 2

• rpc process (stream ProcessorRequest, stream ProcessorResponse)

  agent.proto:27

  message ProcessorRequest

  agent.proto:99

  • optional Schema schema = 1

  • repeated Record records = 2

  message ProcessorResponse

  agent.proto:104

  • optional Schema schema = 1

  • repeated ProcessorResult results = 2

• rpc write (stream SinkRequest, stream SinkResponse)

  agent.proto:28

  message SinkRequest

  agent.proto:115

  • optional Schema schema = 1

  • optional Record record = 2

  message SinkResponse

  agent.proto:120

  • int64 record_id = 1

  • optional string error = 2

• rpc get_topic_producer_records (stream TopicProducerWriteResult, stream TopicProducerResponse)

  agent.proto:29

  message TopicProducerWriteResult

  agent.proto:72

  • int64 record_id = 1

  • optional string error = 2

  message TopicProducerResponse

  agent.proto:77

  • string topic = 1

  • optional Schema schema = 2

  • optional Record record = 3

Used in: Record

• string name = 1

• optional Value value = 2

Used in: SourceRequest

• int64 record_id = 1

• string error_message = 2

Used in: ProcessorResponse

• int64 record_id = 1

• optional string error = 2

• repeated Record records = 3

Used in: ProcessorRequest, ProcessorResult, SinkRequest, SourceResponse, TopicProducerResponse

• int64 record_id = 1

• optional Value key = 2

• optional Value value = 3

• repeated Header headers = 4

• string origin = 5

• optional int64 timestamp = 6

Used in: ProcessorRequest, ProcessorResponse, SinkRequest, SourceResponse, TopicProducerResponse

• int32 schema_id = 1

• bytes value = 2

Used in: Header, Record

• int32 schema_id = 1

• oneof type_oneof

  • bytes bytes_value = 2

  • bool boolean_value = 3

  • string string_value = 4

  • int32 byte_value = 5

  • int32 short_value = 6

  • int32 int_value = 7

  • int64 long_value = 8

  • float float_value = 9

  • double double_value = 10

  • string json_value = 11

  • bytes avro_value = 12