package dozer.ingest

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc ingest (IngestRequest, IngestResponse)

  ingest.proto:7

• rpc ingest_stream (stream IngestRequest, IngestResponse)

  ingest.proto:9

• rpc ingest_arrow (IngestArrowRequest, IngestResponse)

  ingest.proto:11

• rpc ingest_arrow_stream (stream IngestArrowRequest, IngestResponse)

  ingest.proto:13

Used as request type in: IngestService.ingest_arrow, IngestService.ingest_arrow_stream

• string schema_name = 1

• bytes records = 2

  Old record data, only applicable for UPDATE type.

• uint32 seq_no = 3

• map<uint32, IngestMetadata> metadata = 4

Used in: IngestArrowRequest

• OperationType typ = 1

  The operation type.

• uint32 version = 2

  Records with same primary key will have increasing version.

Used as request type in: IngestService.ingest, IngestService.ingest_stream

• string schema_name = 1

• types.OperationType typ = 2

  The operation type.

• repeated types.Value old = 3

  Old record data, only applicable for UPDATE type.

• repeated types.Value new = 4

  New record data.

• uint32 seq_no = 5

Used as response type in: IngestService.ingest, IngestService.ingest_arrow, IngestService.ingest_arrow_stream, IngestService.ingest_stream

• uint32 seq_no = 1

The event types.

Used in: IngestMetadata

• INSERT = 0

  INSERT operation.

• DELETE = 1

  DELETE operation.

• UPDATE = 2

  UPDATE operation.