package rudder

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc AddKeyRanges (AddKeyRangesRequest, AddKeyRangesResponse)

  rudder.proto:93

  message AddKeyRangesRequest

  rudder.proto:78

  • repeated meta.KeyRangeInfo key_ranges = 1

  message AddKeyRangesResponse

  rudder.proto:82

  (message has no fields)

• rpc AddWheels (AddWheelsRequest, AddWheelsResponse)

  rudder.proto:92

  message AddWheelsRequest

  rudder.proto:71

  • map<uint64, common.Endpoint> wheels = 1

    { node id -> endpoint }

  message AddWheelsResponse

  rudder.proto:76

  (message has no fields)

• rpc Router (RouterRequest, RouterResponse)

  rudder.proto:94

  message RouterRequest

  rudder.proto:84

  (message has no fields)

  message RouterResponse

  rudder.proto:86

  • repeated meta.KeyRangeInfo key_ranges = 1

  • map<uint64, common.Endpoint> wheels = 2

• rpc Heartbeat (HeartbeatRequest, HeartbeatResponse)

  rudder.proto:62

  Called by `wheel` and `exhauster`.

  message HeartbeatRequest

  rudder.proto:28

  TODO: Add status report.

  • uint64 node_id = 1

  • optional common.Endpoint endpoint = 2

  • oneof heartbeat_message

    • WheelHeartbeatRequest wheel_heartbeat = 3

    • ExhausterHeartbeatRequest exhauster_heartbeat = 4

  message HeartbeatResponse

  rudder.proto:37

  • oneof heartbeat_message

    • WheelHeartbeatResponse wheel_heartbeat = 1

    • ExhausterHeartbeatResponse exhauster_heartbeat = 2

• rpc InsertL0 (InsertL0Request, InsertL0Response)

  rudder.proto:64

  Called by `wheel` when sstable uploader finish upload new L0 sstable to S3.

  message InsertL0Request

  rudder.proto:44

  • uint64 node_id = 1

  • repeated manifest.SstableInfo sst_infos = 2

  • uint64 next_version_id = 3

  message InsertL0Response

  rudder.proto:50

  • repeated manifest.VersionDiff version_diffs = 1

• rpc Tso (TsoRequest, TsoResponse)

  rudder.proto:66

  TODO: Implement transaction.

  message TsoRequest

  rudder.proto:54

  (message has no fields)

  message TsoResponse

  rudder.proto:56

  • uint32 timestamp = 1

Used in: HeartbeatRequest

(message has no fields)

Used in: HeartbeatResponse

(message has no fields)

Used in: WheelHeartbeatRequest

• bool is_leader = 1

Used in: HeartbeatRequest

• uint64 watermark = 1

• uint64 next_version_id = 2

• map<uint64, RaftState> raft_states = 3

Used in: HeartbeatResponse

• repeated manifest.VersionDiff version_diffs = 1