1// Code generated by protoc-gen-go. DO NOT EDIT. 2// versions: 3// protoc-gen-go v1.25.0 4// protoc v3.15.8 5// source: physical/raft/types.proto 6 7package raft 8 9import ( 10 proto "github.com/golang/protobuf/proto" 11 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 12 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 13 reflect "reflect" 14 sync "sync" 15) 16 17const ( 18 // Verify that this generated code is sufficiently up-to-date. 19 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 20 // Verify that runtime/protoimpl is sufficiently up-to-date. 21 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 22) 23 24// This is a compile-time assertion that a sufficiently up-to-date version 25// of the legacy proto package is being used. 26const _ = proto.ProtoPackageIsVersion4 27 28type LogOperation struct { 29 state protoimpl.MessageState 30 sizeCache protoimpl.SizeCache 31 unknownFields protoimpl.UnknownFields 32 33 // OpType is the Operation type 34 OpType uint32 `protobuf:"varint,1,opt,name=op_type,json=opType,proto3" json:"op_type,omitempty"` 35 // Flags is an opaque value, currently unused. Reserved. 36 Flags uint64 `protobuf:"varint,2,opt,name=flags,proto3" json:"flags,omitempty"` 37 // Key that is being affected 38 Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` 39 // Value is optional, corresponds to the key 40 Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` 41} 42 43func (x *LogOperation) Reset() { 44 *x = LogOperation{} 45 if protoimpl.UnsafeEnabled { 46 mi := &file_physical_raft_types_proto_msgTypes[0] 47 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 48 ms.StoreMessageInfo(mi) 49 } 50} 51 52func (x *LogOperation) String() string { 53 return protoimpl.X.MessageStringOf(x) 54} 55 56func (*LogOperation) ProtoMessage() {} 57 58func (x *LogOperation) ProtoReflect() protoreflect.Message { 59 mi := &file_physical_raft_types_proto_msgTypes[0] 60 if protoimpl.UnsafeEnabled && x != nil { 61 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 62 if ms.LoadMessageInfo() == nil { 63 ms.StoreMessageInfo(mi) 64 } 65 return ms 66 } 67 return mi.MessageOf(x) 68} 69 70// Deprecated: Use LogOperation.ProtoReflect.Descriptor instead. 71func (*LogOperation) Descriptor() ([]byte, []int) { 72 return file_physical_raft_types_proto_rawDescGZIP(), []int{0} 73} 74 75func (x *LogOperation) GetOpType() uint32 { 76 if x != nil { 77 return x.OpType 78 } 79 return 0 80} 81 82func (x *LogOperation) GetFlags() uint64 { 83 if x != nil { 84 return x.Flags 85 } 86 return 0 87} 88 89func (x *LogOperation) GetKey() string { 90 if x != nil { 91 return x.Key 92 } 93 return "" 94} 95 96func (x *LogOperation) GetValue() []byte { 97 if x != nil { 98 return x.Value 99 } 100 return nil 101} 102 103type LogData struct { 104 state protoimpl.MessageState 105 sizeCache protoimpl.SizeCache 106 unknownFields protoimpl.UnknownFields 107 108 Operations []*LogOperation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"` 109} 110 111func (x *LogData) Reset() { 112 *x = LogData{} 113 if protoimpl.UnsafeEnabled { 114 mi := &file_physical_raft_types_proto_msgTypes[1] 115 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 116 ms.StoreMessageInfo(mi) 117 } 118} 119 120func (x *LogData) String() string { 121 return protoimpl.X.MessageStringOf(x) 122} 123 124func (*LogData) ProtoMessage() {} 125 126func (x *LogData) ProtoReflect() protoreflect.Message { 127 mi := &file_physical_raft_types_proto_msgTypes[1] 128 if protoimpl.UnsafeEnabled && x != nil { 129 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 130 if ms.LoadMessageInfo() == nil { 131 ms.StoreMessageInfo(mi) 132 } 133 return ms 134 } 135 return mi.MessageOf(x) 136} 137 138// Deprecated: Use LogData.ProtoReflect.Descriptor instead. 139func (*LogData) Descriptor() ([]byte, []int) { 140 return file_physical_raft_types_proto_rawDescGZIP(), []int{1} 141} 142 143func (x *LogData) GetOperations() []*LogOperation { 144 if x != nil { 145 return x.Operations 146 } 147 return nil 148} 149 150type IndexValue struct { 151 state protoimpl.MessageState 152 sizeCache protoimpl.SizeCache 153 unknownFields protoimpl.UnknownFields 154 155 Term uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"` 156 Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` 157} 158 159func (x *IndexValue) Reset() { 160 *x = IndexValue{} 161 if protoimpl.UnsafeEnabled { 162 mi := &file_physical_raft_types_proto_msgTypes[2] 163 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 164 ms.StoreMessageInfo(mi) 165 } 166} 167 168func (x *IndexValue) String() string { 169 return protoimpl.X.MessageStringOf(x) 170} 171 172func (*IndexValue) ProtoMessage() {} 173 174func (x *IndexValue) ProtoReflect() protoreflect.Message { 175 mi := &file_physical_raft_types_proto_msgTypes[2] 176 if protoimpl.UnsafeEnabled && x != nil { 177 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 178 if ms.LoadMessageInfo() == nil { 179 ms.StoreMessageInfo(mi) 180 } 181 return ms 182 } 183 return mi.MessageOf(x) 184} 185 186// Deprecated: Use IndexValue.ProtoReflect.Descriptor instead. 187func (*IndexValue) Descriptor() ([]byte, []int) { 188 return file_physical_raft_types_proto_rawDescGZIP(), []int{2} 189} 190 191func (x *IndexValue) GetTerm() uint64 { 192 if x != nil { 193 return x.Term 194 } 195 return 0 196} 197 198func (x *IndexValue) GetIndex() uint64 { 199 if x != nil { 200 return x.Index 201 } 202 return 0 203} 204 205type Server struct { 206 state protoimpl.MessageState 207 sizeCache protoimpl.SizeCache 208 unknownFields protoimpl.UnknownFields 209 210 Suffrage int32 `protobuf:"varint,1,opt,name=suffrage,proto3" json:"suffrage,omitempty"` 211 Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` 212 Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` 213} 214 215func (x *Server) Reset() { 216 *x = Server{} 217 if protoimpl.UnsafeEnabled { 218 mi := &file_physical_raft_types_proto_msgTypes[3] 219 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 220 ms.StoreMessageInfo(mi) 221 } 222} 223 224func (x *Server) String() string { 225 return protoimpl.X.MessageStringOf(x) 226} 227 228func (*Server) ProtoMessage() {} 229 230func (x *Server) ProtoReflect() protoreflect.Message { 231 mi := &file_physical_raft_types_proto_msgTypes[3] 232 if protoimpl.UnsafeEnabled && x != nil { 233 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 234 if ms.LoadMessageInfo() == nil { 235 ms.StoreMessageInfo(mi) 236 } 237 return ms 238 } 239 return mi.MessageOf(x) 240} 241 242// Deprecated: Use Server.ProtoReflect.Descriptor instead. 243func (*Server) Descriptor() ([]byte, []int) { 244 return file_physical_raft_types_proto_rawDescGZIP(), []int{3} 245} 246 247func (x *Server) GetSuffrage() int32 { 248 if x != nil { 249 return x.Suffrage 250 } 251 return 0 252} 253 254func (x *Server) GetId() string { 255 if x != nil { 256 return x.Id 257 } 258 return "" 259} 260 261func (x *Server) GetAddress() string { 262 if x != nil { 263 return x.Address 264 } 265 return "" 266} 267 268type ConfigurationValue struct { 269 state protoimpl.MessageState 270 sizeCache protoimpl.SizeCache 271 unknownFields protoimpl.UnknownFields 272 273 Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` 274 Servers []*Server `protobuf:"bytes,2,rep,name=servers,proto3" json:"servers,omitempty"` 275} 276 277func (x *ConfigurationValue) Reset() { 278 *x = ConfigurationValue{} 279 if protoimpl.UnsafeEnabled { 280 mi := &file_physical_raft_types_proto_msgTypes[4] 281 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 282 ms.StoreMessageInfo(mi) 283 } 284} 285 286func (x *ConfigurationValue) String() string { 287 return protoimpl.X.MessageStringOf(x) 288} 289 290func (*ConfigurationValue) ProtoMessage() {} 291 292func (x *ConfigurationValue) ProtoReflect() protoreflect.Message { 293 mi := &file_physical_raft_types_proto_msgTypes[4] 294 if protoimpl.UnsafeEnabled && x != nil { 295 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 296 if ms.LoadMessageInfo() == nil { 297 ms.StoreMessageInfo(mi) 298 } 299 return ms 300 } 301 return mi.MessageOf(x) 302} 303 304// Deprecated: Use ConfigurationValue.ProtoReflect.Descriptor instead. 305func (*ConfigurationValue) Descriptor() ([]byte, []int) { 306 return file_physical_raft_types_proto_rawDescGZIP(), []int{4} 307} 308 309func (x *ConfigurationValue) GetIndex() uint64 { 310 if x != nil { 311 return x.Index 312 } 313 return 0 314} 315 316func (x *ConfigurationValue) GetServers() []*Server { 317 if x != nil { 318 return x.Servers 319 } 320 return nil 321} 322 323type LocalNodeConfigValue struct { 324 state protoimpl.MessageState 325 sizeCache protoimpl.SizeCache 326 unknownFields protoimpl.UnknownFields 327 328 DesiredSuffrage string `protobuf:"bytes,1,opt,name=desired_suffrage,json=desiredSuffrage,proto3" json:"desired_suffrage,omitempty"` 329} 330 331func (x *LocalNodeConfigValue) Reset() { 332 *x = LocalNodeConfigValue{} 333 if protoimpl.UnsafeEnabled { 334 mi := &file_physical_raft_types_proto_msgTypes[5] 335 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 336 ms.StoreMessageInfo(mi) 337 } 338} 339 340func (x *LocalNodeConfigValue) String() string { 341 return protoimpl.X.MessageStringOf(x) 342} 343 344func (*LocalNodeConfigValue) ProtoMessage() {} 345 346func (x *LocalNodeConfigValue) ProtoReflect() protoreflect.Message { 347 mi := &file_physical_raft_types_proto_msgTypes[5] 348 if protoimpl.UnsafeEnabled && x != nil { 349 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 350 if ms.LoadMessageInfo() == nil { 351 ms.StoreMessageInfo(mi) 352 } 353 return ms 354 } 355 return mi.MessageOf(x) 356} 357 358// Deprecated: Use LocalNodeConfigValue.ProtoReflect.Descriptor instead. 359func (*LocalNodeConfigValue) Descriptor() ([]byte, []int) { 360 return file_physical_raft_types_proto_rawDescGZIP(), []int{5} 361} 362 363func (x *LocalNodeConfigValue) GetDesiredSuffrage() string { 364 if x != nil { 365 return x.DesiredSuffrage 366 } 367 return "" 368} 369 370var File_physical_raft_types_proto protoreflect.FileDescriptor 371 372var file_physical_raft_types_proto_rawDesc = []byte{ 373 0x0a, 0x19, 0x70, 0x68, 0x79, 0x73, 0x69, 0x63, 0x61, 0x6c, 0x2f, 0x72, 0x61, 0x66, 0x74, 0x2f, 374 0x74, 0x79, 0x70, 0x65, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x04, 0x72, 0x61, 0x66, 375 0x74, 0x22, 0x65, 0x0a, 0x0c, 0x4c, 0x6f, 0x67, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 376 0x6e, 0x12, 0x17, 0x0a, 0x07, 0x6f, 0x70, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 377 0x28, 0x0d, 0x52, 0x06, 0x6f, 0x70, 0x54, 0x79, 0x70, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x66, 0x6c, 378 0x61, 0x67, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x05, 0x66, 0x6c, 0x61, 0x67, 0x73, 379 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 380 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 381 0x0c, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x3d, 0x0a, 0x07, 0x4c, 0x6f, 0x67, 0x44, 382 0x61, 0x74, 0x61, 0x12, 0x32, 0x0a, 0x0a, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 383 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x72, 0x61, 0x66, 0x74, 0x2e, 0x4c, 384 0x6f, 0x67, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0a, 0x6f, 0x70, 0x65, 385 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x22, 0x36, 0x0a, 0x0a, 0x49, 0x6e, 0x64, 0x65, 0x78, 386 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x74, 0x65, 0x72, 0x6d, 0x18, 0x01, 0x20, 387 0x01, 0x28, 0x04, 0x52, 0x04, 0x74, 0x65, 0x72, 0x6d, 0x12, 0x14, 0x0a, 0x05, 0x69, 0x6e, 0x64, 388 0x65, 0x78, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x05, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x22, 389 0x4e, 0x0a, 0x06, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x12, 0x1a, 0x0a, 0x08, 0x73, 0x75, 0x66, 390 0x66, 0x72, 0x61, 0x67, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x73, 0x75, 0x66, 391 0x66, 0x72, 0x61, 0x67, 0x65, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 392 0x09, 0x52, 0x02, 0x69, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 393 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x22, 394 0x52, 0x0a, 0x12, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 395 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x18, 0x01, 396 0x20, 0x01, 0x28, 0x04, 0x52, 0x05, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x12, 0x26, 0x0a, 0x07, 0x73, 397 0x65, 0x72, 0x76, 0x65, 0x72, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x72, 398 0x61, 0x66, 0x74, 0x2e, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x52, 0x07, 0x73, 0x65, 0x72, 0x76, 399 0x65, 0x72, 0x73, 0x22, 0x41, 0x0a, 0x14, 0x4c, 0x6f, 0x63, 0x61, 0x6c, 0x4e, 0x6f, 0x64, 0x65, 400 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x29, 0x0a, 0x10, 0x64, 401 0x65, 0x73, 0x69, 0x72, 0x65, 0x64, 0x5f, 0x73, 0x75, 0x66, 0x66, 0x72, 0x61, 0x67, 0x65, 0x18, 402 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0f, 0x64, 0x65, 0x73, 0x69, 0x72, 0x65, 0x64, 0x53, 0x75, 403 0x66, 0x66, 0x72, 0x61, 0x67, 0x65, 0x42, 0x2a, 0x5a, 0x28, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 404 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x68, 0x61, 0x73, 0x68, 0x69, 0x63, 0x6f, 0x72, 0x70, 0x2f, 0x76, 405 0x61, 0x75, 0x6c, 0x74, 0x2f, 0x70, 0x68, 0x79, 0x73, 0x69, 0x63, 0x61, 0x6c, 0x2f, 0x72, 0x61, 406 0x66, 0x74, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 407} 408 409var ( 410 file_physical_raft_types_proto_rawDescOnce sync.Once 411 file_physical_raft_types_proto_rawDescData = file_physical_raft_types_proto_rawDesc 412) 413 414func file_physical_raft_types_proto_rawDescGZIP() []byte { 415 file_physical_raft_types_proto_rawDescOnce.Do(func() { 416 file_physical_raft_types_proto_rawDescData = protoimpl.X.CompressGZIP(file_physical_raft_types_proto_rawDescData) 417 }) 418 return file_physical_raft_types_proto_rawDescData 419} 420 421var file_physical_raft_types_proto_msgTypes = make([]protoimpl.MessageInfo, 6) 422var file_physical_raft_types_proto_goTypes = []interface{}{ 423 (*LogOperation)(nil), // 0: raft.LogOperation 424 (*LogData)(nil), // 1: raft.LogData 425 (*IndexValue)(nil), // 2: raft.IndexValue 426 (*Server)(nil), // 3: raft.Server 427 (*ConfigurationValue)(nil), // 4: raft.ConfigurationValue 428 (*LocalNodeConfigValue)(nil), // 5: raft.LocalNodeConfigValue 429} 430var file_physical_raft_types_proto_depIdxs = []int32{ 431 0, // 0: raft.LogData.operations:type_name -> raft.LogOperation 432 3, // 1: raft.ConfigurationValue.servers:type_name -> raft.Server 433 2, // [2:2] is the sub-list for method output_type 434 2, // [2:2] is the sub-list for method input_type 435 2, // [2:2] is the sub-list for extension type_name 436 2, // [2:2] is the sub-list for extension extendee 437 0, // [0:2] is the sub-list for field type_name 438} 439 440func init() { file_physical_raft_types_proto_init() } 441func file_physical_raft_types_proto_init() { 442 if File_physical_raft_types_proto != nil { 443 return 444 } 445 if !protoimpl.UnsafeEnabled { 446 file_physical_raft_types_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 447 switch v := v.(*LogOperation); i { 448 case 0: 449 return &v.state 450 case 1: 451 return &v.sizeCache 452 case 2: 453 return &v.unknownFields 454 default: 455 return nil 456 } 457 } 458 file_physical_raft_types_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 459 switch v := v.(*LogData); i { 460 case 0: 461 return &v.state 462 case 1: 463 return &v.sizeCache 464 case 2: 465 return &v.unknownFields 466 default: 467 return nil 468 } 469 } 470 file_physical_raft_types_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 471 switch v := v.(*IndexValue); i { 472 case 0: 473 return &v.state 474 case 1: 475 return &v.sizeCache 476 case 2: 477 return &v.unknownFields 478 default: 479 return nil 480 } 481 } 482 file_physical_raft_types_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 483 switch v := v.(*Server); i { 484 case 0: 485 return &v.state 486 case 1: 487 return &v.sizeCache 488 case 2: 489 return &v.unknownFields 490 default: 491 return nil 492 } 493 } 494 file_physical_raft_types_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 495 switch v := v.(*ConfigurationValue); i { 496 case 0: 497 return &v.state 498 case 1: 499 return &v.sizeCache 500 case 2: 501 return &v.unknownFields 502 default: 503 return nil 504 } 505 } 506 file_physical_raft_types_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 507 switch v := v.(*LocalNodeConfigValue); i { 508 case 0: 509 return &v.state 510 case 1: 511 return &v.sizeCache 512 case 2: 513 return &v.unknownFields 514 default: 515 return nil 516 } 517 } 518 } 519 type x struct{} 520 out := protoimpl.TypeBuilder{ 521 File: protoimpl.DescBuilder{ 522 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 523 RawDescriptor: file_physical_raft_types_proto_rawDesc, 524 NumEnums: 0, 525 NumMessages: 6, 526 NumExtensions: 0, 527 NumServices: 0, 528 }, 529 GoTypes: file_physical_raft_types_proto_goTypes, 530 DependencyIndexes: file_physical_raft_types_proto_depIdxs, 531 MessageInfos: file_physical_raft_types_proto_msgTypes, 532 }.Build() 533 File_physical_raft_types_proto = out.File 534 file_physical_raft_types_proto_rawDesc = nil 535 file_physical_raft_types_proto_goTypes = nil 536 file_physical_raft_types_proto_depIdxs = nil 537} 538