package com.webank.ai.fate.api.networking.proxy

Get desktop application:
View/edit binary Protocol Buffers messages

data transfer service

• rpc unaryCall (Packet, Packet)

  proxy.proto:97

  message Packet

  proxy.proto:84

  data streaming packet

  • optional Metadata header = 1

    packet header

  • optional Data body = 2

    packet body

  • optional AuthInfo auth = 3

    authentication info, optional

authentication info

Used in: Packet

• int64 timestamp = 1

  timestamp of request, millisecond

• string appKey = 2

• string signature = 3

  signature

• string applyId = 4

• string nonce = 5

• string version = 6

• string serviceId = 7

task admin command

Used in: Metadata

• string name = 1

Used in: Metadata

• int64 overallTimeout = 1

  total timeout, in ms

• int64 completionWaitTimeout = 2

  timeout for waiting for complete, in ms

• int64 packetIntervalTimeout = 3

  timeout for packet interval, in ms

• int32 maxRetries = 4

includes key and value field, supporting sequential and random data transfer

Used in: Packet

• string key = 1

  compatible with list / dict

• bytes value = 2

  actual value

metadata used for network data transfer

Used in: Packet

• optional Task task = 1

  task description

• optional Topic src = 2

  source topic

• optional Topic dst = 3

  destincation topic

• optional Command command = 4

  task managing command (if any)

• string operator = 5

  model operator

• int64 version = 6

  接口版本

• int64 ack = 7

  stream ack (reserved)

• optional Conf conf = 8

  operation config

metadata of event

Used in: Task

• string namespace = 1

• string tableName = 2

metadata of task

Used in: Metadata

• string taskId = 1

• optional Model model = 2

Used in: Metadata

• string name = 1

• string partyId = 2

• string role = 3

• optional core.Endpoint callback = 4

  implication of pub/sub model, necessary for http-based senario