package replication

Get desktop application:
View/edit binary Protocol Buffers messages

coordinator -> node

• rpc PushShardAssignments (stream io.streamnative.oxia.proto.ShardAssignments, CoordinationShardAssignmentsResponse)

  replication.proto:25

  message CoordinationShardAssignmentsResponse

  replication.proto:43

  (message has no fields)

• rpc NewTerm (NewTermRequest, NewTermResponse)

  replication.proto:28

  message NewTermRequest

  replication.proto:69

  • string namespace = 1

  • int64 shard = 2

  • int64 term = 3

  • optional NewTermOptions options = 4

  message NewTermResponse

  replication.proto:77

  • optional EntryId head_entry_id = 1

• rpc BecomeLeader (BecomeLeaderRequest, BecomeLeaderResponse)

  replication.proto:29

  message BecomeLeaderRequest

  replication.proto:81

  • string namespace = 1

  • int64 shard = 2

  • int64 term = 3

  • uint32 replication_factor = 4

  • map<string, EntryId> follower_maps = 5

  message BecomeLeaderResponse

  replication.proto:99

  (message has no fields)

• rpc AddFollower (AddFollowerRequest, AddFollowerResponse)

  replication.proto:30

  message AddFollowerRequest

  replication.proto:90

  • string namespace = 1

  • int64 shard = 2

  • int64 term = 3

  • string follower_name = 4

  • optional EntryId follower_head_entry_id = 5

  message AddFollowerResponse

  replication.proto:101

  (message has no fields)

• rpc GetStatus (GetStatusRequest, GetStatusResponse)

  replication.proto:32

  message GetStatusRequest

  replication.proto:139

  • int64 shard = 1

  message GetStatusResponse

  replication.proto:150

  • int64 term = 1

  • ServingStatus status = 2

  • int64 head_offset = 3

  • int64 commit_offset = 4

• rpc DeleteShard (DeleteShardRequest, DeleteShardResponse)

  replication.proto:33

  message DeleteShardRequest

  replication.proto:129

  • string namespace = 1

  • int64 shard = 2

  • int64 term = 3

  message DeleteShardResponse

  replication.proto:135

  (message has no fields)

node (leader) -> node (follower)

• rpc Truncate (TruncateRequest, TruncateResponse)

  replication.proto:38

  message TruncateRequest

  replication.proto:103

  • string namespace = 1

  • int64 shard = 2

  • int64 term = 3

  • optional EntryId head_entry_id = 4

  message TruncateResponse

  replication.proto:111

  • optional EntryId head_entry_id = 1

• rpc Replicate (stream Append, stream Ack)

  replication.proto:39

  message Append

  replication.proto:115

  • int64 term = 1

  • optional LogEntry entry = 2

  • int64 commit_offset = 3

  message Ack

  replication.proto:121

  • int64 offset = 1

• rpc SendSnapshot (stream SnapshotChunk, SnapshotResponse)

  replication.proto:40

  message SnapshotChunk

  replication.proto:57

  • int64 term = 1

  • string name = 2

  • bytes content = 3

  • int32 chunk_index = 4

  • int32 chunk_count = 5

  message SnapshotResponse

  replication.proto:125

  • int64 ack_offset = 1

Used in: AddFollowerRequest, BecomeLeaderRequest, NewTermResponse, TruncateRequest, TruncateResponse

• int64 term = 1

• int64 offset = 2

Used in: Append

• int64 term = 1

• int64 offset = 2

• bytes value = 3

• fixed64 timestamp = 4

Used in: NewTermRequest

• bool enable_notifications = 1

Used in: GetStatusResponse

• NOT_MEMBER = 0

• FENCED = 1

• FOLLOWER = 2

• LEADER = 3