in api/proto/ratis/raft.pb.go [4110:4733]
func file_raft_proto_init() {
if File_raft_proto != nil {
return
}
if !protoimpl.UnsafeEnabled {
file_raft_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*RaftPeerProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*RaftGroupIdProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*RaftGroupProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*RaftGroupMemberIdProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*RaftConfigurationProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateMachineEntryProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateMachineLogEntryProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MetadataProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*LogEntryProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*TermIndexProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*RaftRpcRequestProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SlidingWindowEntry); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*RaftRpcReplyProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*FileChunkProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*RequestVoteRequestProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*RequestVoteReplyProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CommitInfoProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*AppendEntriesRequestProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*AppendEntriesReplyProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*InstallSnapshotRequestProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*InstallSnapshotReplyProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ClientMessageEntryProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WriteRequestTypeProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ReadRequestTypeProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[24].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StaleReadRequestTypeProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[25].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WatchRequestTypeProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[26].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*RaftClientRequestProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[27].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*NotLeaderExceptionProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[28].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*LeaderNotReadyExceptionProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[29].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*NotReplicatedExceptionProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[30].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateMachineExceptionProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[31].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*RaftClientReplyProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[32].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SetConfigurationRequestProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[33].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GroupAddRequestProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[34].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GroupRemoveRequestProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[35].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GroupManagementRequestProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[36].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GroupListRequestProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[37].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GroupInfoRequestProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[38].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ServerRpcProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[39].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*LeaderInfoProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[40].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*FollowerInfoProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[41].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CandidateInfoProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[42].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*RoleInfoProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[43].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GroupListReplyProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[44].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GroupInfoReplyProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[45].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*InstallSnapshotRequestProto_SnapshotChunkProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_raft_proto_msgTypes[46].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*InstallSnapshotRequestProto_NotificationProto); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
}
file_raft_proto_msgTypes[8].OneofWrappers = []interface{}{
(*LogEntryProto_StateMachineLogEntry)(nil),
(*LogEntryProto_ConfigurationEntry)(nil),
(*LogEntryProto_MetadataEntry)(nil),
}
file_raft_proto_msgTypes[19].OneofWrappers = []interface{}{
(*InstallSnapshotRequestProto_SnapshotChunk)(nil),
(*InstallSnapshotRequestProto_Notification)(nil),
}
file_raft_proto_msgTypes[20].OneofWrappers = []interface{}{
(*InstallSnapshotReplyProto_RequestIndex)(nil),
(*InstallSnapshotReplyProto_SnapshotIndex)(nil),
}
file_raft_proto_msgTypes[26].OneofWrappers = []interface{}{
(*RaftClientRequestProto_Write)(nil),
(*RaftClientRequestProto_Read)(nil),
(*RaftClientRequestProto_StaleRead)(nil),
(*RaftClientRequestProto_Watch)(nil),
}
file_raft_proto_msgTypes[31].OneofWrappers = []interface{}{
(*RaftClientReplyProto_NotLeaderException)(nil),
(*RaftClientReplyProto_NotReplicatedException)(nil),
(*RaftClientReplyProto_StateMachineException)(nil),
(*RaftClientReplyProto_LeaderNotReadyException)(nil),
}
file_raft_proto_msgTypes[35].OneofWrappers = []interface{}{
(*GroupManagementRequestProto_GroupAdd)(nil),
(*GroupManagementRequestProto_GroupRemove)(nil),
}
file_raft_proto_msgTypes[42].OneofWrappers = []interface{}{
(*RoleInfoProto_LeaderInfo)(nil),
(*RoleInfoProto_FollowerInfo)(nil),
(*RoleInfoProto_CandidateInfo)(nil),
}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_raft_proto_rawDesc,
NumEnums: 4,
NumMessages: 47,
NumExtensions: 0,
NumServices: 0,
},
GoTypes: file_raft_proto_goTypes,
DependencyIndexes: file_raft_proto_depIdxs,
EnumInfos: file_raft_proto_enumTypes,
MessageInfos: file_raft_proto_msgTypes,
}.Build()
File_raft_proto = out.File
file_raft_proto_rawDesc = nil
file_raft_proto_goTypes = nil
file_raft_proto_depIdxs = nil
}