1// Code generated by protoc-gen-go. DO NOT EDIT. 2// versions: 3// protoc-gen-go v1.27.1 4// protoc v3.17.3 5// source: client.proto 6 7package protocol 8 9import ( 10 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 11 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 12 reflect "reflect" 13 sync "sync" 14) 15 16const ( 17 // Verify that this generated code is sufficiently up-to-date. 18 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 19 // Verify that runtime/protoimpl is sufficiently up-to-date. 20 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 21) 22 23type Command_MethodType int32 24 25const ( 26 Command_CONNECT Command_MethodType = 0 27 Command_SUBSCRIBE Command_MethodType = 1 28 Command_UNSUBSCRIBE Command_MethodType = 2 29 Command_PUBLISH Command_MethodType = 3 30 Command_PRESENCE Command_MethodType = 4 31 Command_PRESENCE_STATS Command_MethodType = 5 32 Command_HISTORY Command_MethodType = 6 33 Command_PING Command_MethodType = 7 34 Command_SEND Command_MethodType = 8 35 Command_RPC Command_MethodType = 9 36 Command_REFRESH Command_MethodType = 10 37 Command_SUB_REFRESH Command_MethodType = 11 38) 39 40// Enum value maps for Command_MethodType. 41var ( 42 Command_MethodType_name = map[int32]string{ 43 0: "CONNECT", 44 1: "SUBSCRIBE", 45 2: "UNSUBSCRIBE", 46 3: "PUBLISH", 47 4: "PRESENCE", 48 5: "PRESENCE_STATS", 49 6: "HISTORY", 50 7: "PING", 51 8: "SEND", 52 9: "RPC", 53 10: "REFRESH", 54 11: "SUB_REFRESH", 55 } 56 Command_MethodType_value = map[string]int32{ 57 "CONNECT": 0, 58 "SUBSCRIBE": 1, 59 "UNSUBSCRIBE": 2, 60 "PUBLISH": 3, 61 "PRESENCE": 4, 62 "PRESENCE_STATS": 5, 63 "HISTORY": 6, 64 "PING": 7, 65 "SEND": 8, 66 "RPC": 9, 67 "REFRESH": 10, 68 "SUB_REFRESH": 11, 69 } 70) 71 72func (x Command_MethodType) Enum() *Command_MethodType { 73 p := new(Command_MethodType) 74 *p = x 75 return p 76} 77 78func (x Command_MethodType) String() string { 79 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 80} 81 82func (Command_MethodType) Descriptor() protoreflect.EnumDescriptor { 83 return file_client_proto_enumTypes[0].Descriptor() 84} 85 86func (Command_MethodType) Type() protoreflect.EnumType { 87 return &file_client_proto_enumTypes[0] 88} 89 90func (x Command_MethodType) Number() protoreflect.EnumNumber { 91 return protoreflect.EnumNumber(x) 92} 93 94// Deprecated: Use Command_MethodType.Descriptor instead. 95func (Command_MethodType) EnumDescriptor() ([]byte, []int) { 96 return file_client_proto_rawDescGZIP(), []int{1, 0} 97} 98 99type Push_PushType int32 100 101const ( 102 Push_PUBLICATION Push_PushType = 0 103 Push_JOIN Push_PushType = 1 104 Push_LEAVE Push_PushType = 2 105 Push_UNSUBSCRIBE Push_PushType = 3 106 Push_MESSAGE Push_PushType = 4 107 Push_SUBSCRIBE Push_PushType = 5 108 Push_CONNECT Push_PushType = 6 109 Push_DISCONNECT Push_PushType = 7 110 Push_REFRESH Push_PushType = 8 111) 112 113// Enum value maps for Push_PushType. 114var ( 115 Push_PushType_name = map[int32]string{ 116 0: "PUBLICATION", 117 1: "JOIN", 118 2: "LEAVE", 119 3: "UNSUBSCRIBE", 120 4: "MESSAGE", 121 5: "SUBSCRIBE", 122 6: "CONNECT", 123 7: "DISCONNECT", 124 8: "REFRESH", 125 } 126 Push_PushType_value = map[string]int32{ 127 "PUBLICATION": 0, 128 "JOIN": 1, 129 "LEAVE": 2, 130 "UNSUBSCRIBE": 3, 131 "MESSAGE": 4, 132 "SUBSCRIBE": 5, 133 "CONNECT": 6, 134 "DISCONNECT": 7, 135 "REFRESH": 8, 136 } 137) 138 139func (x Push_PushType) Enum() *Push_PushType { 140 p := new(Push_PushType) 141 *p = x 142 return p 143} 144 145func (x Push_PushType) String() string { 146 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 147} 148 149func (Push_PushType) Descriptor() protoreflect.EnumDescriptor { 150 return file_client_proto_enumTypes[1].Descriptor() 151} 152 153func (Push_PushType) Type() protoreflect.EnumType { 154 return &file_client_proto_enumTypes[1] 155} 156 157func (x Push_PushType) Number() protoreflect.EnumNumber { 158 return protoreflect.EnumNumber(x) 159} 160 161// Deprecated: Use Push_PushType.Descriptor instead. 162func (Push_PushType) EnumDescriptor() ([]byte, []int) { 163 return file_client_proto_rawDescGZIP(), []int{3, 0} 164} 165 166type Error struct { 167 state protoimpl.MessageState 168 sizeCache protoimpl.SizeCache 169 unknownFields protoimpl.UnknownFields 170 171 Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` 172 Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` 173} 174 175func (x *Error) Reset() { 176 *x = Error{} 177 if protoimpl.UnsafeEnabled { 178 mi := &file_client_proto_msgTypes[0] 179 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 180 ms.StoreMessageInfo(mi) 181 } 182} 183 184func (x *Error) String() string { 185 return protoimpl.X.MessageStringOf(x) 186} 187 188func (*Error) ProtoMessage() {} 189 190func (x *Error) ProtoReflect() protoreflect.Message { 191 mi := &file_client_proto_msgTypes[0] 192 if protoimpl.UnsafeEnabled && x != nil { 193 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 194 if ms.LoadMessageInfo() == nil { 195 ms.StoreMessageInfo(mi) 196 } 197 return ms 198 } 199 return mi.MessageOf(x) 200} 201 202// Deprecated: Use Error.ProtoReflect.Descriptor instead. 203func (*Error) Descriptor() ([]byte, []int) { 204 return file_client_proto_rawDescGZIP(), []int{0} 205} 206 207func (x *Error) GetCode() uint32 { 208 if x != nil { 209 return x.Code 210 } 211 return 0 212} 213 214func (x *Error) GetMessage() string { 215 if x != nil { 216 return x.Message 217 } 218 return "" 219} 220 221type Command struct { 222 state protoimpl.MessageState 223 sizeCache protoimpl.SizeCache 224 unknownFields protoimpl.UnknownFields 225 226 Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` 227 Method Command_MethodType `protobuf:"varint,2,opt,name=method,proto3,enum=centrifugal.centrifuge.protocol.Command_MethodType" json:"method,omitempty"` 228 Params Raw `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"` 229} 230 231func (x *Command) Reset() { 232 *x = Command{} 233 if protoimpl.UnsafeEnabled { 234 mi := &file_client_proto_msgTypes[1] 235 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 236 ms.StoreMessageInfo(mi) 237 } 238} 239 240func (x *Command) String() string { 241 return protoimpl.X.MessageStringOf(x) 242} 243 244func (*Command) ProtoMessage() {} 245 246func (x *Command) ProtoReflect() protoreflect.Message { 247 mi := &file_client_proto_msgTypes[1] 248 if protoimpl.UnsafeEnabled && x != nil { 249 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 250 if ms.LoadMessageInfo() == nil { 251 ms.StoreMessageInfo(mi) 252 } 253 return ms 254 } 255 return mi.MessageOf(x) 256} 257 258// Deprecated: Use Command.ProtoReflect.Descriptor instead. 259func (*Command) Descriptor() ([]byte, []int) { 260 return file_client_proto_rawDescGZIP(), []int{1} 261} 262 263func (x *Command) GetId() uint32 { 264 if x != nil { 265 return x.Id 266 } 267 return 0 268} 269 270func (x *Command) GetMethod() Command_MethodType { 271 if x != nil { 272 return x.Method 273 } 274 return Command_CONNECT 275} 276 277func (x *Command) GetParams() []byte { 278 if x != nil { 279 return x.Params 280 } 281 return nil 282} 283 284type Reply struct { 285 state protoimpl.MessageState 286 sizeCache protoimpl.SizeCache 287 unknownFields protoimpl.UnknownFields 288 289 Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` 290 Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` 291 Result Raw `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"` 292} 293 294func (x *Reply) Reset() { 295 *x = Reply{} 296 if protoimpl.UnsafeEnabled { 297 mi := &file_client_proto_msgTypes[2] 298 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 299 ms.StoreMessageInfo(mi) 300 } 301} 302 303func (x *Reply) String() string { 304 return protoimpl.X.MessageStringOf(x) 305} 306 307func (*Reply) ProtoMessage() {} 308 309func (x *Reply) ProtoReflect() protoreflect.Message { 310 mi := &file_client_proto_msgTypes[2] 311 if protoimpl.UnsafeEnabled && x != nil { 312 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 313 if ms.LoadMessageInfo() == nil { 314 ms.StoreMessageInfo(mi) 315 } 316 return ms 317 } 318 return mi.MessageOf(x) 319} 320 321// Deprecated: Use Reply.ProtoReflect.Descriptor instead. 322func (*Reply) Descriptor() ([]byte, []int) { 323 return file_client_proto_rawDescGZIP(), []int{2} 324} 325 326func (x *Reply) GetId() uint32 { 327 if x != nil { 328 return x.Id 329 } 330 return 0 331} 332 333func (x *Reply) GetError() *Error { 334 if x != nil { 335 return x.Error 336 } 337 return nil 338} 339 340func (x *Reply) GetResult() []byte { 341 if x != nil { 342 return x.Result 343 } 344 return nil 345} 346 347type Push struct { 348 state protoimpl.MessageState 349 sizeCache protoimpl.SizeCache 350 unknownFields protoimpl.UnknownFields 351 352 Type Push_PushType `protobuf:"varint,1,opt,name=type,proto3,enum=centrifugal.centrifuge.protocol.Push_PushType" json:"type,omitempty"` 353 Channel string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"` 354 Data Raw `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` 355} 356 357func (x *Push) Reset() { 358 *x = Push{} 359 if protoimpl.UnsafeEnabled { 360 mi := &file_client_proto_msgTypes[3] 361 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 362 ms.StoreMessageInfo(mi) 363 } 364} 365 366func (x *Push) String() string { 367 return protoimpl.X.MessageStringOf(x) 368} 369 370func (*Push) ProtoMessage() {} 371 372func (x *Push) ProtoReflect() protoreflect.Message { 373 mi := &file_client_proto_msgTypes[3] 374 if protoimpl.UnsafeEnabled && x != nil { 375 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 376 if ms.LoadMessageInfo() == nil { 377 ms.StoreMessageInfo(mi) 378 } 379 return ms 380 } 381 return mi.MessageOf(x) 382} 383 384// Deprecated: Use Push.ProtoReflect.Descriptor instead. 385func (*Push) Descriptor() ([]byte, []int) { 386 return file_client_proto_rawDescGZIP(), []int{3} 387} 388 389func (x *Push) GetType() Push_PushType { 390 if x != nil { 391 return x.Type 392 } 393 return Push_PUBLICATION 394} 395 396func (x *Push) GetChannel() string { 397 if x != nil { 398 return x.Channel 399 } 400 return "" 401} 402 403func (x *Push) GetData() []byte { 404 if x != nil { 405 return x.Data 406 } 407 return nil 408} 409 410type ClientInfo struct { 411 state protoimpl.MessageState 412 sizeCache protoimpl.SizeCache 413 unknownFields protoimpl.UnknownFields 414 415 User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user"` 416 Client string `protobuf:"bytes,2,opt,name=client,proto3" json:"client"` 417 ConnInfo Raw `protobuf:"bytes,3,opt,name=conn_info,json=connInfo,proto3" json:"conn_info,omitempty"` 418 ChanInfo Raw `protobuf:"bytes,4,opt,name=chan_info,json=chanInfo,proto3" json:"chan_info,omitempty"` 419} 420 421func (x *ClientInfo) Reset() { 422 *x = ClientInfo{} 423 if protoimpl.UnsafeEnabled { 424 mi := &file_client_proto_msgTypes[4] 425 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 426 ms.StoreMessageInfo(mi) 427 } 428} 429 430func (x *ClientInfo) String() string { 431 return protoimpl.X.MessageStringOf(x) 432} 433 434func (*ClientInfo) ProtoMessage() {} 435 436func (x *ClientInfo) ProtoReflect() protoreflect.Message { 437 mi := &file_client_proto_msgTypes[4] 438 if protoimpl.UnsafeEnabled && x != nil { 439 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 440 if ms.LoadMessageInfo() == nil { 441 ms.StoreMessageInfo(mi) 442 } 443 return ms 444 } 445 return mi.MessageOf(x) 446} 447 448// Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead. 449func (*ClientInfo) Descriptor() ([]byte, []int) { 450 return file_client_proto_rawDescGZIP(), []int{4} 451} 452 453func (x *ClientInfo) GetUser() string { 454 if x != nil { 455 return x.User 456 } 457 return "" 458} 459 460func (x *ClientInfo) GetClient() string { 461 if x != nil { 462 return x.Client 463 } 464 return "" 465} 466 467func (x *ClientInfo) GetConnInfo() []byte { 468 if x != nil { 469 return x.ConnInfo 470 } 471 return nil 472} 473 474func (x *ClientInfo) GetChanInfo() []byte { 475 if x != nil { 476 return x.ChanInfo 477 } 478 return nil 479} 480 481type Publication struct { 482 state protoimpl.MessageState 483 sizeCache protoimpl.SizeCache 484 unknownFields protoimpl.UnknownFields 485 486 // 1-3 skipped here for backwards compatibility. 487 Data Raw `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` 488 Info *ClientInfo `protobuf:"bytes,5,opt,name=info,proto3" json:"info,omitempty"` 489 Offset uint64 `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"` 490} 491 492func (x *Publication) Reset() { 493 *x = Publication{} 494 if protoimpl.UnsafeEnabled { 495 mi := &file_client_proto_msgTypes[5] 496 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 497 ms.StoreMessageInfo(mi) 498 } 499} 500 501func (x *Publication) String() string { 502 return protoimpl.X.MessageStringOf(x) 503} 504 505func (*Publication) ProtoMessage() {} 506 507func (x *Publication) ProtoReflect() protoreflect.Message { 508 mi := &file_client_proto_msgTypes[5] 509 if protoimpl.UnsafeEnabled && x != nil { 510 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 511 if ms.LoadMessageInfo() == nil { 512 ms.StoreMessageInfo(mi) 513 } 514 return ms 515 } 516 return mi.MessageOf(x) 517} 518 519// Deprecated: Use Publication.ProtoReflect.Descriptor instead. 520func (*Publication) Descriptor() ([]byte, []int) { 521 return file_client_proto_rawDescGZIP(), []int{5} 522} 523 524func (x *Publication) GetData() []byte { 525 if x != nil { 526 return x.Data 527 } 528 return nil 529} 530 531func (x *Publication) GetInfo() *ClientInfo { 532 if x != nil { 533 return x.Info 534 } 535 return nil 536} 537 538func (x *Publication) GetOffset() uint64 { 539 if x != nil { 540 return x.Offset 541 } 542 return 0 543} 544 545type Join struct { 546 state protoimpl.MessageState 547 sizeCache protoimpl.SizeCache 548 unknownFields protoimpl.UnknownFields 549 550 Info *ClientInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"` 551} 552 553func (x *Join) Reset() { 554 *x = Join{} 555 if protoimpl.UnsafeEnabled { 556 mi := &file_client_proto_msgTypes[6] 557 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 558 ms.StoreMessageInfo(mi) 559 } 560} 561 562func (x *Join) String() string { 563 return protoimpl.X.MessageStringOf(x) 564} 565 566func (*Join) ProtoMessage() {} 567 568func (x *Join) ProtoReflect() protoreflect.Message { 569 mi := &file_client_proto_msgTypes[6] 570 if protoimpl.UnsafeEnabled && x != nil { 571 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 572 if ms.LoadMessageInfo() == nil { 573 ms.StoreMessageInfo(mi) 574 } 575 return ms 576 } 577 return mi.MessageOf(x) 578} 579 580// Deprecated: Use Join.ProtoReflect.Descriptor instead. 581func (*Join) Descriptor() ([]byte, []int) { 582 return file_client_proto_rawDescGZIP(), []int{6} 583} 584 585func (x *Join) GetInfo() *ClientInfo { 586 if x != nil { 587 return x.Info 588 } 589 return nil 590} 591 592type Leave struct { 593 state protoimpl.MessageState 594 sizeCache protoimpl.SizeCache 595 unknownFields protoimpl.UnknownFields 596 597 Info *ClientInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"` 598} 599 600func (x *Leave) Reset() { 601 *x = Leave{} 602 if protoimpl.UnsafeEnabled { 603 mi := &file_client_proto_msgTypes[7] 604 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 605 ms.StoreMessageInfo(mi) 606 } 607} 608 609func (x *Leave) String() string { 610 return protoimpl.X.MessageStringOf(x) 611} 612 613func (*Leave) ProtoMessage() {} 614 615func (x *Leave) ProtoReflect() protoreflect.Message { 616 mi := &file_client_proto_msgTypes[7] 617 if protoimpl.UnsafeEnabled && x != nil { 618 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 619 if ms.LoadMessageInfo() == nil { 620 ms.StoreMessageInfo(mi) 621 } 622 return ms 623 } 624 return mi.MessageOf(x) 625} 626 627// Deprecated: Use Leave.ProtoReflect.Descriptor instead. 628func (*Leave) Descriptor() ([]byte, []int) { 629 return file_client_proto_rawDescGZIP(), []int{7} 630} 631 632func (x *Leave) GetInfo() *ClientInfo { 633 if x != nil { 634 return x.Info 635 } 636 return nil 637} 638 639type Unsubscribe struct { 640 state protoimpl.MessageState 641 sizeCache protoimpl.SizeCache 642 unknownFields protoimpl.UnknownFields 643} 644 645func (x *Unsubscribe) Reset() { 646 *x = Unsubscribe{} 647 if protoimpl.UnsafeEnabled { 648 mi := &file_client_proto_msgTypes[8] 649 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 650 ms.StoreMessageInfo(mi) 651 } 652} 653 654func (x *Unsubscribe) String() string { 655 return protoimpl.X.MessageStringOf(x) 656} 657 658func (*Unsubscribe) ProtoMessage() {} 659 660func (x *Unsubscribe) ProtoReflect() protoreflect.Message { 661 mi := &file_client_proto_msgTypes[8] 662 if protoimpl.UnsafeEnabled && x != nil { 663 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 664 if ms.LoadMessageInfo() == nil { 665 ms.StoreMessageInfo(mi) 666 } 667 return ms 668 } 669 return mi.MessageOf(x) 670} 671 672// Deprecated: Use Unsubscribe.ProtoReflect.Descriptor instead. 673func (*Unsubscribe) Descriptor() ([]byte, []int) { 674 return file_client_proto_rawDescGZIP(), []int{8} 675} 676 677type Subscribe struct { 678 state protoimpl.MessageState 679 sizeCache protoimpl.SizeCache 680 unknownFields protoimpl.UnknownFields 681 682 Recoverable bool `protobuf:"varint,1,opt,name=recoverable,proto3" json:"recoverable,omitempty"` 683 // 2-3 skipped here for backwards compatibility. 684 Epoch string `protobuf:"bytes,4,opt,name=epoch,proto3" json:"epoch,omitempty"` 685 Offset uint64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"` 686 Positioned bool `protobuf:"varint,6,opt,name=positioned,proto3" json:"positioned,omitempty"` 687 Data Raw `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"` 688} 689 690func (x *Subscribe) Reset() { 691 *x = Subscribe{} 692 if protoimpl.UnsafeEnabled { 693 mi := &file_client_proto_msgTypes[9] 694 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 695 ms.StoreMessageInfo(mi) 696 } 697} 698 699func (x *Subscribe) String() string { 700 return protoimpl.X.MessageStringOf(x) 701} 702 703func (*Subscribe) ProtoMessage() {} 704 705func (x *Subscribe) ProtoReflect() protoreflect.Message { 706 mi := &file_client_proto_msgTypes[9] 707 if protoimpl.UnsafeEnabled && x != nil { 708 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 709 if ms.LoadMessageInfo() == nil { 710 ms.StoreMessageInfo(mi) 711 } 712 return ms 713 } 714 return mi.MessageOf(x) 715} 716 717// Deprecated: Use Subscribe.ProtoReflect.Descriptor instead. 718func (*Subscribe) Descriptor() ([]byte, []int) { 719 return file_client_proto_rawDescGZIP(), []int{9} 720} 721 722func (x *Subscribe) GetRecoverable() bool { 723 if x != nil { 724 return x.Recoverable 725 } 726 return false 727} 728 729func (x *Subscribe) GetEpoch() string { 730 if x != nil { 731 return x.Epoch 732 } 733 return "" 734} 735 736func (x *Subscribe) GetOffset() uint64 { 737 if x != nil { 738 return x.Offset 739 } 740 return 0 741} 742 743func (x *Subscribe) GetPositioned() bool { 744 if x != nil { 745 return x.Positioned 746 } 747 return false 748} 749 750func (x *Subscribe) GetData() []byte { 751 if x != nil { 752 return x.Data 753 } 754 return nil 755} 756 757type Message struct { 758 state protoimpl.MessageState 759 sizeCache protoimpl.SizeCache 760 unknownFields protoimpl.UnknownFields 761 762 Data Raw `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` 763} 764 765func (x *Message) Reset() { 766 *x = Message{} 767 if protoimpl.UnsafeEnabled { 768 mi := &file_client_proto_msgTypes[10] 769 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 770 ms.StoreMessageInfo(mi) 771 } 772} 773 774func (x *Message) String() string { 775 return protoimpl.X.MessageStringOf(x) 776} 777 778func (*Message) ProtoMessage() {} 779 780func (x *Message) ProtoReflect() protoreflect.Message { 781 mi := &file_client_proto_msgTypes[10] 782 if protoimpl.UnsafeEnabled && x != nil { 783 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 784 if ms.LoadMessageInfo() == nil { 785 ms.StoreMessageInfo(mi) 786 } 787 return ms 788 } 789 return mi.MessageOf(x) 790} 791 792// Deprecated: Use Message.ProtoReflect.Descriptor instead. 793func (*Message) Descriptor() ([]byte, []int) { 794 return file_client_proto_rawDescGZIP(), []int{10} 795} 796 797func (x *Message) GetData() []byte { 798 if x != nil { 799 return x.Data 800 } 801 return nil 802} 803 804type Connect struct { 805 state protoimpl.MessageState 806 sizeCache protoimpl.SizeCache 807 unknownFields protoimpl.UnknownFields 808 809 Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` 810 Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` 811 Data Raw `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` 812 Subs map[string]*SubscribeResult `protobuf:"bytes,4,rep,name=subs,proto3" json:"subs,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 813 Expires bool `protobuf:"varint,5,opt,name=expires,proto3" json:"expires,omitempty"` 814 Ttl uint32 `protobuf:"varint,6,opt,name=ttl,proto3" json:"ttl,omitempty"` 815} 816 817func (x *Connect) Reset() { 818 *x = Connect{} 819 if protoimpl.UnsafeEnabled { 820 mi := &file_client_proto_msgTypes[11] 821 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 822 ms.StoreMessageInfo(mi) 823 } 824} 825 826func (x *Connect) String() string { 827 return protoimpl.X.MessageStringOf(x) 828} 829 830func (*Connect) ProtoMessage() {} 831 832func (x *Connect) ProtoReflect() protoreflect.Message { 833 mi := &file_client_proto_msgTypes[11] 834 if protoimpl.UnsafeEnabled && x != nil { 835 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 836 if ms.LoadMessageInfo() == nil { 837 ms.StoreMessageInfo(mi) 838 } 839 return ms 840 } 841 return mi.MessageOf(x) 842} 843 844// Deprecated: Use Connect.ProtoReflect.Descriptor instead. 845func (*Connect) Descriptor() ([]byte, []int) { 846 return file_client_proto_rawDescGZIP(), []int{11} 847} 848 849func (x *Connect) GetClient() string { 850 if x != nil { 851 return x.Client 852 } 853 return "" 854} 855 856func (x *Connect) GetVersion() string { 857 if x != nil { 858 return x.Version 859 } 860 return "" 861} 862 863func (x *Connect) GetData() []byte { 864 if x != nil { 865 return x.Data 866 } 867 return nil 868} 869 870func (x *Connect) GetSubs() map[string]*SubscribeResult { 871 if x != nil { 872 return x.Subs 873 } 874 return nil 875} 876 877func (x *Connect) GetExpires() bool { 878 if x != nil { 879 return x.Expires 880 } 881 return false 882} 883 884func (x *Connect) GetTtl() uint32 { 885 if x != nil { 886 return x.Ttl 887 } 888 return 0 889} 890 891type Disconnect struct { 892 state protoimpl.MessageState 893 sizeCache protoimpl.SizeCache 894 unknownFields protoimpl.UnknownFields 895 896 Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` 897 Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` 898 Reconnect bool `protobuf:"varint,3,opt,name=reconnect,proto3" json:"reconnect,omitempty"` 899} 900 901func (x *Disconnect) Reset() { 902 *x = Disconnect{} 903 if protoimpl.UnsafeEnabled { 904 mi := &file_client_proto_msgTypes[12] 905 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 906 ms.StoreMessageInfo(mi) 907 } 908} 909 910func (x *Disconnect) String() string { 911 return protoimpl.X.MessageStringOf(x) 912} 913 914func (*Disconnect) ProtoMessage() {} 915 916func (x *Disconnect) ProtoReflect() protoreflect.Message { 917 mi := &file_client_proto_msgTypes[12] 918 if protoimpl.UnsafeEnabled && x != nil { 919 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 920 if ms.LoadMessageInfo() == nil { 921 ms.StoreMessageInfo(mi) 922 } 923 return ms 924 } 925 return mi.MessageOf(x) 926} 927 928// Deprecated: Use Disconnect.ProtoReflect.Descriptor instead. 929func (*Disconnect) Descriptor() ([]byte, []int) { 930 return file_client_proto_rawDescGZIP(), []int{12} 931} 932 933func (x *Disconnect) GetCode() uint32 { 934 if x != nil { 935 return x.Code 936 } 937 return 0 938} 939 940func (x *Disconnect) GetReason() string { 941 if x != nil { 942 return x.Reason 943 } 944 return "" 945} 946 947func (x *Disconnect) GetReconnect() bool { 948 if x != nil { 949 return x.Reconnect 950 } 951 return false 952} 953 954type Refresh struct { 955 state protoimpl.MessageState 956 sizeCache protoimpl.SizeCache 957 unknownFields protoimpl.UnknownFields 958 959 Expires bool `protobuf:"varint,1,opt,name=expires,proto3" json:"expires,omitempty"` 960 Ttl uint32 `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"` 961} 962 963func (x *Refresh) Reset() { 964 *x = Refresh{} 965 if protoimpl.UnsafeEnabled { 966 mi := &file_client_proto_msgTypes[13] 967 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 968 ms.StoreMessageInfo(mi) 969 } 970} 971 972func (x *Refresh) String() string { 973 return protoimpl.X.MessageStringOf(x) 974} 975 976func (*Refresh) ProtoMessage() {} 977 978func (x *Refresh) ProtoReflect() protoreflect.Message { 979 mi := &file_client_proto_msgTypes[13] 980 if protoimpl.UnsafeEnabled && x != nil { 981 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 982 if ms.LoadMessageInfo() == nil { 983 ms.StoreMessageInfo(mi) 984 } 985 return ms 986 } 987 return mi.MessageOf(x) 988} 989 990// Deprecated: Use Refresh.ProtoReflect.Descriptor instead. 991func (*Refresh) Descriptor() ([]byte, []int) { 992 return file_client_proto_rawDescGZIP(), []int{13} 993} 994 995func (x *Refresh) GetExpires() bool { 996 if x != nil { 997 return x.Expires 998 } 999 return false 1000} 1001 1002func (x *Refresh) GetTtl() uint32 { 1003 if x != nil { 1004 return x.Ttl 1005 } 1006 return 0 1007} 1008 1009type ConnectRequest struct { 1010 state protoimpl.MessageState 1011 sizeCache protoimpl.SizeCache 1012 unknownFields protoimpl.UnknownFields 1013 1014 Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` 1015 Data Raw `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` 1016 Subs map[string]*SubscribeRequest `protobuf:"bytes,3,rep,name=subs,proto3" json:"subs,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 1017 Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` 1018 Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"` 1019} 1020 1021func (x *ConnectRequest) Reset() { 1022 *x = ConnectRequest{} 1023 if protoimpl.UnsafeEnabled { 1024 mi := &file_client_proto_msgTypes[14] 1025 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1026 ms.StoreMessageInfo(mi) 1027 } 1028} 1029 1030func (x *ConnectRequest) String() string { 1031 return protoimpl.X.MessageStringOf(x) 1032} 1033 1034func (*ConnectRequest) ProtoMessage() {} 1035 1036func (x *ConnectRequest) ProtoReflect() protoreflect.Message { 1037 mi := &file_client_proto_msgTypes[14] 1038 if protoimpl.UnsafeEnabled && x != nil { 1039 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1040 if ms.LoadMessageInfo() == nil { 1041 ms.StoreMessageInfo(mi) 1042 } 1043 return ms 1044 } 1045 return mi.MessageOf(x) 1046} 1047 1048// Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead. 1049func (*ConnectRequest) Descriptor() ([]byte, []int) { 1050 return file_client_proto_rawDescGZIP(), []int{14} 1051} 1052 1053func (x *ConnectRequest) GetToken() string { 1054 if x != nil { 1055 return x.Token 1056 } 1057 return "" 1058} 1059 1060func (x *ConnectRequest) GetData() []byte { 1061 if x != nil { 1062 return x.Data 1063 } 1064 return nil 1065} 1066 1067func (x *ConnectRequest) GetSubs() map[string]*SubscribeRequest { 1068 if x != nil { 1069 return x.Subs 1070 } 1071 return nil 1072} 1073 1074func (x *ConnectRequest) GetName() string { 1075 if x != nil { 1076 return x.Name 1077 } 1078 return "" 1079} 1080 1081func (x *ConnectRequest) GetVersion() string { 1082 if x != nil { 1083 return x.Version 1084 } 1085 return "" 1086} 1087 1088type ConnectResult struct { 1089 state protoimpl.MessageState 1090 sizeCache protoimpl.SizeCache 1091 unknownFields protoimpl.UnknownFields 1092 1093 Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` 1094 Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` 1095 Expires bool `protobuf:"varint,3,opt,name=expires,proto3" json:"expires,omitempty"` 1096 Ttl uint32 `protobuf:"varint,4,opt,name=ttl,proto3" json:"ttl,omitempty"` 1097 Data Raw `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"` 1098 Subs map[string]*SubscribeResult `protobuf:"bytes,6,rep,name=subs,proto3" json:"subs,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 1099} 1100 1101func (x *ConnectResult) Reset() { 1102 *x = ConnectResult{} 1103 if protoimpl.UnsafeEnabled { 1104 mi := &file_client_proto_msgTypes[15] 1105 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1106 ms.StoreMessageInfo(mi) 1107 } 1108} 1109 1110func (x *ConnectResult) String() string { 1111 return protoimpl.X.MessageStringOf(x) 1112} 1113 1114func (*ConnectResult) ProtoMessage() {} 1115 1116func (x *ConnectResult) ProtoReflect() protoreflect.Message { 1117 mi := &file_client_proto_msgTypes[15] 1118 if protoimpl.UnsafeEnabled && x != nil { 1119 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1120 if ms.LoadMessageInfo() == nil { 1121 ms.StoreMessageInfo(mi) 1122 } 1123 return ms 1124 } 1125 return mi.MessageOf(x) 1126} 1127 1128// Deprecated: Use ConnectResult.ProtoReflect.Descriptor instead. 1129func (*ConnectResult) Descriptor() ([]byte, []int) { 1130 return file_client_proto_rawDescGZIP(), []int{15} 1131} 1132 1133func (x *ConnectResult) GetClient() string { 1134 if x != nil { 1135 return x.Client 1136 } 1137 return "" 1138} 1139 1140func (x *ConnectResult) GetVersion() string { 1141 if x != nil { 1142 return x.Version 1143 } 1144 return "" 1145} 1146 1147func (x *ConnectResult) GetExpires() bool { 1148 if x != nil { 1149 return x.Expires 1150 } 1151 return false 1152} 1153 1154func (x *ConnectResult) GetTtl() uint32 { 1155 if x != nil { 1156 return x.Ttl 1157 } 1158 return 0 1159} 1160 1161func (x *ConnectResult) GetData() []byte { 1162 if x != nil { 1163 return x.Data 1164 } 1165 return nil 1166} 1167 1168func (x *ConnectResult) GetSubs() map[string]*SubscribeResult { 1169 if x != nil { 1170 return x.Subs 1171 } 1172 return nil 1173} 1174 1175type RefreshRequest struct { 1176 state protoimpl.MessageState 1177 sizeCache protoimpl.SizeCache 1178 unknownFields protoimpl.UnknownFields 1179 1180 Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` 1181} 1182 1183func (x *RefreshRequest) Reset() { 1184 *x = RefreshRequest{} 1185 if protoimpl.UnsafeEnabled { 1186 mi := &file_client_proto_msgTypes[16] 1187 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1188 ms.StoreMessageInfo(mi) 1189 } 1190} 1191 1192func (x *RefreshRequest) String() string { 1193 return protoimpl.X.MessageStringOf(x) 1194} 1195 1196func (*RefreshRequest) ProtoMessage() {} 1197 1198func (x *RefreshRequest) ProtoReflect() protoreflect.Message { 1199 mi := &file_client_proto_msgTypes[16] 1200 if protoimpl.UnsafeEnabled && x != nil { 1201 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1202 if ms.LoadMessageInfo() == nil { 1203 ms.StoreMessageInfo(mi) 1204 } 1205 return ms 1206 } 1207 return mi.MessageOf(x) 1208} 1209 1210// Deprecated: Use RefreshRequest.ProtoReflect.Descriptor instead. 1211func (*RefreshRequest) Descriptor() ([]byte, []int) { 1212 return file_client_proto_rawDescGZIP(), []int{16} 1213} 1214 1215func (x *RefreshRequest) GetToken() string { 1216 if x != nil { 1217 return x.Token 1218 } 1219 return "" 1220} 1221 1222type RefreshResult struct { 1223 state protoimpl.MessageState 1224 sizeCache protoimpl.SizeCache 1225 unknownFields protoimpl.UnknownFields 1226 1227 Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` 1228 Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` 1229 Expires bool `protobuf:"varint,3,opt,name=expires,proto3" json:"expires,omitempty"` 1230 Ttl uint32 `protobuf:"varint,4,opt,name=ttl,proto3" json:"ttl,omitempty"` 1231} 1232 1233func (x *RefreshResult) Reset() { 1234 *x = RefreshResult{} 1235 if protoimpl.UnsafeEnabled { 1236 mi := &file_client_proto_msgTypes[17] 1237 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1238 ms.StoreMessageInfo(mi) 1239 } 1240} 1241 1242func (x *RefreshResult) String() string { 1243 return protoimpl.X.MessageStringOf(x) 1244} 1245 1246func (*RefreshResult) ProtoMessage() {} 1247 1248func (x *RefreshResult) ProtoReflect() protoreflect.Message { 1249 mi := &file_client_proto_msgTypes[17] 1250 if protoimpl.UnsafeEnabled && x != nil { 1251 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1252 if ms.LoadMessageInfo() == nil { 1253 ms.StoreMessageInfo(mi) 1254 } 1255 return ms 1256 } 1257 return mi.MessageOf(x) 1258} 1259 1260// Deprecated: Use RefreshResult.ProtoReflect.Descriptor instead. 1261func (*RefreshResult) Descriptor() ([]byte, []int) { 1262 return file_client_proto_rawDescGZIP(), []int{17} 1263} 1264 1265func (x *RefreshResult) GetClient() string { 1266 if x != nil { 1267 return x.Client 1268 } 1269 return "" 1270} 1271 1272func (x *RefreshResult) GetVersion() string { 1273 if x != nil { 1274 return x.Version 1275 } 1276 return "" 1277} 1278 1279func (x *RefreshResult) GetExpires() bool { 1280 if x != nil { 1281 return x.Expires 1282 } 1283 return false 1284} 1285 1286func (x *RefreshResult) GetTtl() uint32 { 1287 if x != nil { 1288 return x.Ttl 1289 } 1290 return 0 1291} 1292 1293type SubscribeRequest struct { 1294 state protoimpl.MessageState 1295 sizeCache protoimpl.SizeCache 1296 unknownFields protoimpl.UnknownFields 1297 1298 Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` 1299 Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"` 1300 Recover bool `protobuf:"varint,3,opt,name=recover,proto3" json:"recover,omitempty"` 1301 // 4-5 skipped here for backwards compatibility. 1302 Epoch string `protobuf:"bytes,6,opt,name=epoch,proto3" json:"epoch,omitempty"` 1303 Offset uint64 `protobuf:"varint,7,opt,name=offset,proto3" json:"offset,omitempty"` 1304} 1305 1306func (x *SubscribeRequest) Reset() { 1307 *x = SubscribeRequest{} 1308 if protoimpl.UnsafeEnabled { 1309 mi := &file_client_proto_msgTypes[18] 1310 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1311 ms.StoreMessageInfo(mi) 1312 } 1313} 1314 1315func (x *SubscribeRequest) String() string { 1316 return protoimpl.X.MessageStringOf(x) 1317} 1318 1319func (*SubscribeRequest) ProtoMessage() {} 1320 1321func (x *SubscribeRequest) ProtoReflect() protoreflect.Message { 1322 mi := &file_client_proto_msgTypes[18] 1323 if protoimpl.UnsafeEnabled && x != nil { 1324 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1325 if ms.LoadMessageInfo() == nil { 1326 ms.StoreMessageInfo(mi) 1327 } 1328 return ms 1329 } 1330 return mi.MessageOf(x) 1331} 1332 1333// Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead. 1334func (*SubscribeRequest) Descriptor() ([]byte, []int) { 1335 return file_client_proto_rawDescGZIP(), []int{18} 1336} 1337 1338func (x *SubscribeRequest) GetChannel() string { 1339 if x != nil { 1340 return x.Channel 1341 } 1342 return "" 1343} 1344 1345func (x *SubscribeRequest) GetToken() string { 1346 if x != nil { 1347 return x.Token 1348 } 1349 return "" 1350} 1351 1352func (x *SubscribeRequest) GetRecover() bool { 1353 if x != nil { 1354 return x.Recover 1355 } 1356 return false 1357} 1358 1359func (x *SubscribeRequest) GetEpoch() string { 1360 if x != nil { 1361 return x.Epoch 1362 } 1363 return "" 1364} 1365 1366func (x *SubscribeRequest) GetOffset() uint64 { 1367 if x != nil { 1368 return x.Offset 1369 } 1370 return 0 1371} 1372 1373type SubscribeResult struct { 1374 state protoimpl.MessageState 1375 sizeCache protoimpl.SizeCache 1376 unknownFields protoimpl.UnknownFields 1377 1378 Expires bool `protobuf:"varint,1,opt,name=expires,proto3" json:"expires,omitempty"` 1379 Ttl uint32 `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"` 1380 Recoverable bool `protobuf:"varint,3,opt,name=recoverable,proto3" json:"recoverable,omitempty"` 1381 // 4-5 skipped here for backwards compatibility. 1382 Epoch string `protobuf:"bytes,6,opt,name=epoch,proto3" json:"epoch,omitempty"` 1383 Publications []*Publication `protobuf:"bytes,7,rep,name=publications,proto3" json:"publications,omitempty"` 1384 Recovered bool `protobuf:"varint,8,opt,name=recovered,proto3" json:"recovered,omitempty"` 1385 Offset uint64 `protobuf:"varint,9,opt,name=offset,proto3" json:"offset,omitempty"` 1386 Positioned bool `protobuf:"varint,10,opt,name=positioned,proto3" json:"positioned,omitempty"` 1387 Data Raw `protobuf:"bytes,11,opt,name=data,proto3" json:"data,omitempty"` 1388} 1389 1390func (x *SubscribeResult) Reset() { 1391 *x = SubscribeResult{} 1392 if protoimpl.UnsafeEnabled { 1393 mi := &file_client_proto_msgTypes[19] 1394 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1395 ms.StoreMessageInfo(mi) 1396 } 1397} 1398 1399func (x *SubscribeResult) String() string { 1400 return protoimpl.X.MessageStringOf(x) 1401} 1402 1403func (*SubscribeResult) ProtoMessage() {} 1404 1405func (x *SubscribeResult) ProtoReflect() protoreflect.Message { 1406 mi := &file_client_proto_msgTypes[19] 1407 if protoimpl.UnsafeEnabled && x != nil { 1408 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1409 if ms.LoadMessageInfo() == nil { 1410 ms.StoreMessageInfo(mi) 1411 } 1412 return ms 1413 } 1414 return mi.MessageOf(x) 1415} 1416 1417// Deprecated: Use SubscribeResult.ProtoReflect.Descriptor instead. 1418func (*SubscribeResult) Descriptor() ([]byte, []int) { 1419 return file_client_proto_rawDescGZIP(), []int{19} 1420} 1421 1422func (x *SubscribeResult) GetExpires() bool { 1423 if x != nil { 1424 return x.Expires 1425 } 1426 return false 1427} 1428 1429func (x *SubscribeResult) GetTtl() uint32 { 1430 if x != nil { 1431 return x.Ttl 1432 } 1433 return 0 1434} 1435 1436func (x *SubscribeResult) GetRecoverable() bool { 1437 if x != nil { 1438 return x.Recoverable 1439 } 1440 return false 1441} 1442 1443func (x *SubscribeResult) GetEpoch() string { 1444 if x != nil { 1445 return x.Epoch 1446 } 1447 return "" 1448} 1449 1450func (x *SubscribeResult) GetPublications() []*Publication { 1451 if x != nil { 1452 return x.Publications 1453 } 1454 return nil 1455} 1456 1457func (x *SubscribeResult) GetRecovered() bool { 1458 if x != nil { 1459 return x.Recovered 1460 } 1461 return false 1462} 1463 1464func (x *SubscribeResult) GetOffset() uint64 { 1465 if x != nil { 1466 return x.Offset 1467 } 1468 return 0 1469} 1470 1471func (x *SubscribeResult) GetPositioned() bool { 1472 if x != nil { 1473 return x.Positioned 1474 } 1475 return false 1476} 1477 1478func (x *SubscribeResult) GetData() []byte { 1479 if x != nil { 1480 return x.Data 1481 } 1482 return nil 1483} 1484 1485type SubRefreshRequest struct { 1486 state protoimpl.MessageState 1487 sizeCache protoimpl.SizeCache 1488 unknownFields protoimpl.UnknownFields 1489 1490 Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` 1491 Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"` 1492} 1493 1494func (x *SubRefreshRequest) Reset() { 1495 *x = SubRefreshRequest{} 1496 if protoimpl.UnsafeEnabled { 1497 mi := &file_client_proto_msgTypes[20] 1498 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1499 ms.StoreMessageInfo(mi) 1500 } 1501} 1502 1503func (x *SubRefreshRequest) String() string { 1504 return protoimpl.X.MessageStringOf(x) 1505} 1506 1507func (*SubRefreshRequest) ProtoMessage() {} 1508 1509func (x *SubRefreshRequest) ProtoReflect() protoreflect.Message { 1510 mi := &file_client_proto_msgTypes[20] 1511 if protoimpl.UnsafeEnabled && x != nil { 1512 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1513 if ms.LoadMessageInfo() == nil { 1514 ms.StoreMessageInfo(mi) 1515 } 1516 return ms 1517 } 1518 return mi.MessageOf(x) 1519} 1520 1521// Deprecated: Use SubRefreshRequest.ProtoReflect.Descriptor instead. 1522func (*SubRefreshRequest) Descriptor() ([]byte, []int) { 1523 return file_client_proto_rawDescGZIP(), []int{20} 1524} 1525 1526func (x *SubRefreshRequest) GetChannel() string { 1527 if x != nil { 1528 return x.Channel 1529 } 1530 return "" 1531} 1532 1533func (x *SubRefreshRequest) GetToken() string { 1534 if x != nil { 1535 return x.Token 1536 } 1537 return "" 1538} 1539 1540type SubRefreshResult struct { 1541 state protoimpl.MessageState 1542 sizeCache protoimpl.SizeCache 1543 unknownFields protoimpl.UnknownFields 1544 1545 Expires bool `protobuf:"varint,1,opt,name=expires,proto3" json:"expires,omitempty"` 1546 Ttl uint32 `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"` 1547} 1548 1549func (x *SubRefreshResult) Reset() { 1550 *x = SubRefreshResult{} 1551 if protoimpl.UnsafeEnabled { 1552 mi := &file_client_proto_msgTypes[21] 1553 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1554 ms.StoreMessageInfo(mi) 1555 } 1556} 1557 1558func (x *SubRefreshResult) String() string { 1559 return protoimpl.X.MessageStringOf(x) 1560} 1561 1562func (*SubRefreshResult) ProtoMessage() {} 1563 1564func (x *SubRefreshResult) ProtoReflect() protoreflect.Message { 1565 mi := &file_client_proto_msgTypes[21] 1566 if protoimpl.UnsafeEnabled && x != nil { 1567 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1568 if ms.LoadMessageInfo() == nil { 1569 ms.StoreMessageInfo(mi) 1570 } 1571 return ms 1572 } 1573 return mi.MessageOf(x) 1574} 1575 1576// Deprecated: Use SubRefreshResult.ProtoReflect.Descriptor instead. 1577func (*SubRefreshResult) Descriptor() ([]byte, []int) { 1578 return file_client_proto_rawDescGZIP(), []int{21} 1579} 1580 1581func (x *SubRefreshResult) GetExpires() bool { 1582 if x != nil { 1583 return x.Expires 1584 } 1585 return false 1586} 1587 1588func (x *SubRefreshResult) GetTtl() uint32 { 1589 if x != nil { 1590 return x.Ttl 1591 } 1592 return 0 1593} 1594 1595type UnsubscribeRequest struct { 1596 state protoimpl.MessageState 1597 sizeCache protoimpl.SizeCache 1598 unknownFields protoimpl.UnknownFields 1599 1600 Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` 1601} 1602 1603func (x *UnsubscribeRequest) Reset() { 1604 *x = UnsubscribeRequest{} 1605 if protoimpl.UnsafeEnabled { 1606 mi := &file_client_proto_msgTypes[22] 1607 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1608 ms.StoreMessageInfo(mi) 1609 } 1610} 1611 1612func (x *UnsubscribeRequest) String() string { 1613 return protoimpl.X.MessageStringOf(x) 1614} 1615 1616func (*UnsubscribeRequest) ProtoMessage() {} 1617 1618func (x *UnsubscribeRequest) ProtoReflect() protoreflect.Message { 1619 mi := &file_client_proto_msgTypes[22] 1620 if protoimpl.UnsafeEnabled && x != nil { 1621 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1622 if ms.LoadMessageInfo() == nil { 1623 ms.StoreMessageInfo(mi) 1624 } 1625 return ms 1626 } 1627 return mi.MessageOf(x) 1628} 1629 1630// Deprecated: Use UnsubscribeRequest.ProtoReflect.Descriptor instead. 1631func (*UnsubscribeRequest) Descriptor() ([]byte, []int) { 1632 return file_client_proto_rawDescGZIP(), []int{22} 1633} 1634 1635func (x *UnsubscribeRequest) GetChannel() string { 1636 if x != nil { 1637 return x.Channel 1638 } 1639 return "" 1640} 1641 1642type UnsubscribeResult struct { 1643 state protoimpl.MessageState 1644 sizeCache protoimpl.SizeCache 1645 unknownFields protoimpl.UnknownFields 1646} 1647 1648func (x *UnsubscribeResult) Reset() { 1649 *x = UnsubscribeResult{} 1650 if protoimpl.UnsafeEnabled { 1651 mi := &file_client_proto_msgTypes[23] 1652 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1653 ms.StoreMessageInfo(mi) 1654 } 1655} 1656 1657func (x *UnsubscribeResult) String() string { 1658 return protoimpl.X.MessageStringOf(x) 1659} 1660 1661func (*UnsubscribeResult) ProtoMessage() {} 1662 1663func (x *UnsubscribeResult) ProtoReflect() protoreflect.Message { 1664 mi := &file_client_proto_msgTypes[23] 1665 if protoimpl.UnsafeEnabled && x != nil { 1666 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1667 if ms.LoadMessageInfo() == nil { 1668 ms.StoreMessageInfo(mi) 1669 } 1670 return ms 1671 } 1672 return mi.MessageOf(x) 1673} 1674 1675// Deprecated: Use UnsubscribeResult.ProtoReflect.Descriptor instead. 1676func (*UnsubscribeResult) Descriptor() ([]byte, []int) { 1677 return file_client_proto_rawDescGZIP(), []int{23} 1678} 1679 1680type PublishRequest struct { 1681 state protoimpl.MessageState 1682 sizeCache protoimpl.SizeCache 1683 unknownFields protoimpl.UnknownFields 1684 1685 Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` 1686 Data Raw `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` 1687} 1688 1689func (x *PublishRequest) Reset() { 1690 *x = PublishRequest{} 1691 if protoimpl.UnsafeEnabled { 1692 mi := &file_client_proto_msgTypes[24] 1693 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1694 ms.StoreMessageInfo(mi) 1695 } 1696} 1697 1698func (x *PublishRequest) String() string { 1699 return protoimpl.X.MessageStringOf(x) 1700} 1701 1702func (*PublishRequest) ProtoMessage() {} 1703 1704func (x *PublishRequest) ProtoReflect() protoreflect.Message { 1705 mi := &file_client_proto_msgTypes[24] 1706 if protoimpl.UnsafeEnabled && x != nil { 1707 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1708 if ms.LoadMessageInfo() == nil { 1709 ms.StoreMessageInfo(mi) 1710 } 1711 return ms 1712 } 1713 return mi.MessageOf(x) 1714} 1715 1716// Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead. 1717func (*PublishRequest) Descriptor() ([]byte, []int) { 1718 return file_client_proto_rawDescGZIP(), []int{24} 1719} 1720 1721func (x *PublishRequest) GetChannel() string { 1722 if x != nil { 1723 return x.Channel 1724 } 1725 return "" 1726} 1727 1728func (x *PublishRequest) GetData() []byte { 1729 if x != nil { 1730 return x.Data 1731 } 1732 return nil 1733} 1734 1735type PublishResult struct { 1736 state protoimpl.MessageState 1737 sizeCache protoimpl.SizeCache 1738 unknownFields protoimpl.UnknownFields 1739} 1740 1741func (x *PublishResult) Reset() { 1742 *x = PublishResult{} 1743 if protoimpl.UnsafeEnabled { 1744 mi := &file_client_proto_msgTypes[25] 1745 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1746 ms.StoreMessageInfo(mi) 1747 } 1748} 1749 1750func (x *PublishResult) String() string { 1751 return protoimpl.X.MessageStringOf(x) 1752} 1753 1754func (*PublishResult) ProtoMessage() {} 1755 1756func (x *PublishResult) ProtoReflect() protoreflect.Message { 1757 mi := &file_client_proto_msgTypes[25] 1758 if protoimpl.UnsafeEnabled && x != nil { 1759 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1760 if ms.LoadMessageInfo() == nil { 1761 ms.StoreMessageInfo(mi) 1762 } 1763 return ms 1764 } 1765 return mi.MessageOf(x) 1766} 1767 1768// Deprecated: Use PublishResult.ProtoReflect.Descriptor instead. 1769func (*PublishResult) Descriptor() ([]byte, []int) { 1770 return file_client_proto_rawDescGZIP(), []int{25} 1771} 1772 1773type PresenceRequest struct { 1774 state protoimpl.MessageState 1775 sizeCache protoimpl.SizeCache 1776 unknownFields protoimpl.UnknownFields 1777 1778 Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` 1779} 1780 1781func (x *PresenceRequest) Reset() { 1782 *x = PresenceRequest{} 1783 if protoimpl.UnsafeEnabled { 1784 mi := &file_client_proto_msgTypes[26] 1785 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1786 ms.StoreMessageInfo(mi) 1787 } 1788} 1789 1790func (x *PresenceRequest) String() string { 1791 return protoimpl.X.MessageStringOf(x) 1792} 1793 1794func (*PresenceRequest) ProtoMessage() {} 1795 1796func (x *PresenceRequest) ProtoReflect() protoreflect.Message { 1797 mi := &file_client_proto_msgTypes[26] 1798 if protoimpl.UnsafeEnabled && x != nil { 1799 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1800 if ms.LoadMessageInfo() == nil { 1801 ms.StoreMessageInfo(mi) 1802 } 1803 return ms 1804 } 1805 return mi.MessageOf(x) 1806} 1807 1808// Deprecated: Use PresenceRequest.ProtoReflect.Descriptor instead. 1809func (*PresenceRequest) Descriptor() ([]byte, []int) { 1810 return file_client_proto_rawDescGZIP(), []int{26} 1811} 1812 1813func (x *PresenceRequest) GetChannel() string { 1814 if x != nil { 1815 return x.Channel 1816 } 1817 return "" 1818} 1819 1820type PresenceResult struct { 1821 state protoimpl.MessageState 1822 sizeCache protoimpl.SizeCache 1823 unknownFields protoimpl.UnknownFields 1824 1825 Presence map[string]*ClientInfo `protobuf:"bytes,1,rep,name=presence,proto3" json:"presence" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 1826} 1827 1828func (x *PresenceResult) Reset() { 1829 *x = PresenceResult{} 1830 if protoimpl.UnsafeEnabled { 1831 mi := &file_client_proto_msgTypes[27] 1832 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1833 ms.StoreMessageInfo(mi) 1834 } 1835} 1836 1837func (x *PresenceResult) String() string { 1838 return protoimpl.X.MessageStringOf(x) 1839} 1840 1841func (*PresenceResult) ProtoMessage() {} 1842 1843func (x *PresenceResult) ProtoReflect() protoreflect.Message { 1844 mi := &file_client_proto_msgTypes[27] 1845 if protoimpl.UnsafeEnabled && x != nil { 1846 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1847 if ms.LoadMessageInfo() == nil { 1848 ms.StoreMessageInfo(mi) 1849 } 1850 return ms 1851 } 1852 return mi.MessageOf(x) 1853} 1854 1855// Deprecated: Use PresenceResult.ProtoReflect.Descriptor instead. 1856func (*PresenceResult) Descriptor() ([]byte, []int) { 1857 return file_client_proto_rawDescGZIP(), []int{27} 1858} 1859 1860func (x *PresenceResult) GetPresence() map[string]*ClientInfo { 1861 if x != nil { 1862 return x.Presence 1863 } 1864 return nil 1865} 1866 1867type PresenceStatsRequest struct { 1868 state protoimpl.MessageState 1869 sizeCache protoimpl.SizeCache 1870 unknownFields protoimpl.UnknownFields 1871 1872 Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` 1873} 1874 1875func (x *PresenceStatsRequest) Reset() { 1876 *x = PresenceStatsRequest{} 1877 if protoimpl.UnsafeEnabled { 1878 mi := &file_client_proto_msgTypes[28] 1879 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1880 ms.StoreMessageInfo(mi) 1881 } 1882} 1883 1884func (x *PresenceStatsRequest) String() string { 1885 return protoimpl.X.MessageStringOf(x) 1886} 1887 1888func (*PresenceStatsRequest) ProtoMessage() {} 1889 1890func (x *PresenceStatsRequest) ProtoReflect() protoreflect.Message { 1891 mi := &file_client_proto_msgTypes[28] 1892 if protoimpl.UnsafeEnabled && x != nil { 1893 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1894 if ms.LoadMessageInfo() == nil { 1895 ms.StoreMessageInfo(mi) 1896 } 1897 return ms 1898 } 1899 return mi.MessageOf(x) 1900} 1901 1902// Deprecated: Use PresenceStatsRequest.ProtoReflect.Descriptor instead. 1903func (*PresenceStatsRequest) Descriptor() ([]byte, []int) { 1904 return file_client_proto_rawDescGZIP(), []int{28} 1905} 1906 1907func (x *PresenceStatsRequest) GetChannel() string { 1908 if x != nil { 1909 return x.Channel 1910 } 1911 return "" 1912} 1913 1914type PresenceStatsResult struct { 1915 state protoimpl.MessageState 1916 sizeCache protoimpl.SizeCache 1917 unknownFields protoimpl.UnknownFields 1918 1919 NumClients uint32 `protobuf:"varint,1,opt,name=num_clients,json=numClients,proto3" json:"num_clients"` 1920 NumUsers uint32 `protobuf:"varint,2,opt,name=num_users,json=numUsers,proto3" json:"num_users"` 1921} 1922 1923func (x *PresenceStatsResult) Reset() { 1924 *x = PresenceStatsResult{} 1925 if protoimpl.UnsafeEnabled { 1926 mi := &file_client_proto_msgTypes[29] 1927 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1928 ms.StoreMessageInfo(mi) 1929 } 1930} 1931 1932func (x *PresenceStatsResult) String() string { 1933 return protoimpl.X.MessageStringOf(x) 1934} 1935 1936func (*PresenceStatsResult) ProtoMessage() {} 1937 1938func (x *PresenceStatsResult) ProtoReflect() protoreflect.Message { 1939 mi := &file_client_proto_msgTypes[29] 1940 if protoimpl.UnsafeEnabled && x != nil { 1941 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1942 if ms.LoadMessageInfo() == nil { 1943 ms.StoreMessageInfo(mi) 1944 } 1945 return ms 1946 } 1947 return mi.MessageOf(x) 1948} 1949 1950// Deprecated: Use PresenceStatsResult.ProtoReflect.Descriptor instead. 1951func (*PresenceStatsResult) Descriptor() ([]byte, []int) { 1952 return file_client_proto_rawDescGZIP(), []int{29} 1953} 1954 1955func (x *PresenceStatsResult) GetNumClients() uint32 { 1956 if x != nil { 1957 return x.NumClients 1958 } 1959 return 0 1960} 1961 1962func (x *PresenceStatsResult) GetNumUsers() uint32 { 1963 if x != nil { 1964 return x.NumUsers 1965 } 1966 return 0 1967} 1968 1969type StreamPosition struct { 1970 state protoimpl.MessageState 1971 sizeCache protoimpl.SizeCache 1972 unknownFields protoimpl.UnknownFields 1973 1974 Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` 1975 Epoch string `protobuf:"bytes,2,opt,name=epoch,proto3" json:"epoch,omitempty"` 1976} 1977 1978func (x *StreamPosition) Reset() { 1979 *x = StreamPosition{} 1980 if protoimpl.UnsafeEnabled { 1981 mi := &file_client_proto_msgTypes[30] 1982 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1983 ms.StoreMessageInfo(mi) 1984 } 1985} 1986 1987func (x *StreamPosition) String() string { 1988 return protoimpl.X.MessageStringOf(x) 1989} 1990 1991func (*StreamPosition) ProtoMessage() {} 1992 1993func (x *StreamPosition) ProtoReflect() protoreflect.Message { 1994 mi := &file_client_proto_msgTypes[30] 1995 if protoimpl.UnsafeEnabled && x != nil { 1996 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1997 if ms.LoadMessageInfo() == nil { 1998 ms.StoreMessageInfo(mi) 1999 } 2000 return ms 2001 } 2002 return mi.MessageOf(x) 2003} 2004 2005// Deprecated: Use StreamPosition.ProtoReflect.Descriptor instead. 2006func (*StreamPosition) Descriptor() ([]byte, []int) { 2007 return file_client_proto_rawDescGZIP(), []int{30} 2008} 2009 2010func (x *StreamPosition) GetOffset() uint64 { 2011 if x != nil { 2012 return x.Offset 2013 } 2014 return 0 2015} 2016 2017func (x *StreamPosition) GetEpoch() string { 2018 if x != nil { 2019 return x.Epoch 2020 } 2021 return "" 2022} 2023 2024type HistoryRequest struct { 2025 state protoimpl.MessageState 2026 sizeCache protoimpl.SizeCache 2027 unknownFields protoimpl.UnknownFields 2028 2029 Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` 2030 // 2-6 skipped here for backwards compatibility. 2031 Limit int32 `protobuf:"varint,7,opt,name=limit,proto3" json:"limit,omitempty"` 2032 Since *StreamPosition `protobuf:"bytes,8,opt,name=since,proto3" json:"since,omitempty"` 2033 Reverse bool `protobuf:"varint,9,opt,name=reverse,proto3" json:"reverse,omitempty"` 2034} 2035 2036func (x *HistoryRequest) Reset() { 2037 *x = HistoryRequest{} 2038 if protoimpl.UnsafeEnabled { 2039 mi := &file_client_proto_msgTypes[31] 2040 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 2041 ms.StoreMessageInfo(mi) 2042 } 2043} 2044 2045func (x *HistoryRequest) String() string { 2046 return protoimpl.X.MessageStringOf(x) 2047} 2048 2049func (*HistoryRequest) ProtoMessage() {} 2050 2051func (x *HistoryRequest) ProtoReflect() protoreflect.Message { 2052 mi := &file_client_proto_msgTypes[31] 2053 if protoimpl.UnsafeEnabled && x != nil { 2054 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 2055 if ms.LoadMessageInfo() == nil { 2056 ms.StoreMessageInfo(mi) 2057 } 2058 return ms 2059 } 2060 return mi.MessageOf(x) 2061} 2062 2063// Deprecated: Use HistoryRequest.ProtoReflect.Descriptor instead. 2064func (*HistoryRequest) Descriptor() ([]byte, []int) { 2065 return file_client_proto_rawDescGZIP(), []int{31} 2066} 2067 2068func (x *HistoryRequest) GetChannel() string { 2069 if x != nil { 2070 return x.Channel 2071 } 2072 return "" 2073} 2074 2075func (x *HistoryRequest) GetLimit() int32 { 2076 if x != nil { 2077 return x.Limit 2078 } 2079 return 0 2080} 2081 2082func (x *HistoryRequest) GetSince() *StreamPosition { 2083 if x != nil { 2084 return x.Since 2085 } 2086 return nil 2087} 2088 2089func (x *HistoryRequest) GetReverse() bool { 2090 if x != nil { 2091 return x.Reverse 2092 } 2093 return false 2094} 2095 2096type HistoryResult struct { 2097 state protoimpl.MessageState 2098 sizeCache protoimpl.SizeCache 2099 unknownFields protoimpl.UnknownFields 2100 2101 Publications []*Publication `protobuf:"bytes,1,rep,name=publications,proto3" json:"publications"` 2102 Epoch string `protobuf:"bytes,2,opt,name=epoch,proto3" json:"epoch"` 2103 Offset uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset"` 2104} 2105 2106func (x *HistoryResult) Reset() { 2107 *x = HistoryResult{} 2108 if protoimpl.UnsafeEnabled { 2109 mi := &file_client_proto_msgTypes[32] 2110 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 2111 ms.StoreMessageInfo(mi) 2112 } 2113} 2114 2115func (x *HistoryResult) String() string { 2116 return protoimpl.X.MessageStringOf(x) 2117} 2118 2119func (*HistoryResult) ProtoMessage() {} 2120 2121func (x *HistoryResult) ProtoReflect() protoreflect.Message { 2122 mi := &file_client_proto_msgTypes[32] 2123 if protoimpl.UnsafeEnabled && x != nil { 2124 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 2125 if ms.LoadMessageInfo() == nil { 2126 ms.StoreMessageInfo(mi) 2127 } 2128 return ms 2129 } 2130 return mi.MessageOf(x) 2131} 2132 2133// Deprecated: Use HistoryResult.ProtoReflect.Descriptor instead. 2134func (*HistoryResult) Descriptor() ([]byte, []int) { 2135 return file_client_proto_rawDescGZIP(), []int{32} 2136} 2137 2138func (x *HistoryResult) GetPublications() []*Publication { 2139 if x != nil { 2140 return x.Publications 2141 } 2142 return nil 2143} 2144 2145func (x *HistoryResult) GetEpoch() string { 2146 if x != nil { 2147 return x.Epoch 2148 } 2149 return "" 2150} 2151 2152func (x *HistoryResult) GetOffset() uint64 { 2153 if x != nil { 2154 return x.Offset 2155 } 2156 return 0 2157} 2158 2159type PingRequest struct { 2160 state protoimpl.MessageState 2161 sizeCache protoimpl.SizeCache 2162 unknownFields protoimpl.UnknownFields 2163} 2164 2165func (x *PingRequest) Reset() { 2166 *x = PingRequest{} 2167 if protoimpl.UnsafeEnabled { 2168 mi := &file_client_proto_msgTypes[33] 2169 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 2170 ms.StoreMessageInfo(mi) 2171 } 2172} 2173 2174func (x *PingRequest) String() string { 2175 return protoimpl.X.MessageStringOf(x) 2176} 2177 2178func (*PingRequest) ProtoMessage() {} 2179 2180func (x *PingRequest) ProtoReflect() protoreflect.Message { 2181 mi := &file_client_proto_msgTypes[33] 2182 if protoimpl.UnsafeEnabled && x != nil { 2183 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 2184 if ms.LoadMessageInfo() == nil { 2185 ms.StoreMessageInfo(mi) 2186 } 2187 return ms 2188 } 2189 return mi.MessageOf(x) 2190} 2191 2192// Deprecated: Use PingRequest.ProtoReflect.Descriptor instead. 2193func (*PingRequest) Descriptor() ([]byte, []int) { 2194 return file_client_proto_rawDescGZIP(), []int{33} 2195} 2196 2197type PingResult struct { 2198 state protoimpl.MessageState 2199 sizeCache protoimpl.SizeCache 2200 unknownFields protoimpl.UnknownFields 2201} 2202 2203func (x *PingResult) Reset() { 2204 *x = PingResult{} 2205 if protoimpl.UnsafeEnabled { 2206 mi := &file_client_proto_msgTypes[34] 2207 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 2208 ms.StoreMessageInfo(mi) 2209 } 2210} 2211 2212func (x *PingResult) String() string { 2213 return protoimpl.X.MessageStringOf(x) 2214} 2215 2216func (*PingResult) ProtoMessage() {} 2217 2218func (x *PingResult) ProtoReflect() protoreflect.Message { 2219 mi := &file_client_proto_msgTypes[34] 2220 if protoimpl.UnsafeEnabled && x != nil { 2221 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 2222 if ms.LoadMessageInfo() == nil { 2223 ms.StoreMessageInfo(mi) 2224 } 2225 return ms 2226 } 2227 return mi.MessageOf(x) 2228} 2229 2230// Deprecated: Use PingResult.ProtoReflect.Descriptor instead. 2231func (*PingResult) Descriptor() ([]byte, []int) { 2232 return file_client_proto_rawDescGZIP(), []int{34} 2233} 2234 2235type RPCRequest struct { 2236 state protoimpl.MessageState 2237 sizeCache protoimpl.SizeCache 2238 unknownFields protoimpl.UnknownFields 2239 2240 Data Raw `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` 2241 Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"` 2242} 2243 2244func (x *RPCRequest) Reset() { 2245 *x = RPCRequest{} 2246 if protoimpl.UnsafeEnabled { 2247 mi := &file_client_proto_msgTypes[35] 2248 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 2249 ms.StoreMessageInfo(mi) 2250 } 2251} 2252 2253func (x *RPCRequest) String() string { 2254 return protoimpl.X.MessageStringOf(x) 2255} 2256 2257func (*RPCRequest) ProtoMessage() {} 2258 2259func (x *RPCRequest) ProtoReflect() protoreflect.Message { 2260 mi := &file_client_proto_msgTypes[35] 2261 if protoimpl.UnsafeEnabled && x != nil { 2262 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 2263 if ms.LoadMessageInfo() == nil { 2264 ms.StoreMessageInfo(mi) 2265 } 2266 return ms 2267 } 2268 return mi.MessageOf(x) 2269} 2270 2271// Deprecated: Use RPCRequest.ProtoReflect.Descriptor instead. 2272func (*RPCRequest) Descriptor() ([]byte, []int) { 2273 return file_client_proto_rawDescGZIP(), []int{35} 2274} 2275 2276func (x *RPCRequest) GetData() []byte { 2277 if x != nil { 2278 return x.Data 2279 } 2280 return nil 2281} 2282 2283func (x *RPCRequest) GetMethod() string { 2284 if x != nil { 2285 return x.Method 2286 } 2287 return "" 2288} 2289 2290type RPCResult struct { 2291 state protoimpl.MessageState 2292 sizeCache protoimpl.SizeCache 2293 unknownFields protoimpl.UnknownFields 2294 2295 Data Raw `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` 2296} 2297 2298func (x *RPCResult) Reset() { 2299 *x = RPCResult{} 2300 if protoimpl.UnsafeEnabled { 2301 mi := &file_client_proto_msgTypes[36] 2302 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 2303 ms.StoreMessageInfo(mi) 2304 } 2305} 2306 2307func (x *RPCResult) String() string { 2308 return protoimpl.X.MessageStringOf(x) 2309} 2310 2311func (*RPCResult) ProtoMessage() {} 2312 2313func (x *RPCResult) ProtoReflect() protoreflect.Message { 2314 mi := &file_client_proto_msgTypes[36] 2315 if protoimpl.UnsafeEnabled && x != nil { 2316 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 2317 if ms.LoadMessageInfo() == nil { 2318 ms.StoreMessageInfo(mi) 2319 } 2320 return ms 2321 } 2322 return mi.MessageOf(x) 2323} 2324 2325// Deprecated: Use RPCResult.ProtoReflect.Descriptor instead. 2326func (*RPCResult) Descriptor() ([]byte, []int) { 2327 return file_client_proto_rawDescGZIP(), []int{36} 2328} 2329 2330func (x *RPCResult) GetData() []byte { 2331 if x != nil { 2332 return x.Data 2333 } 2334 return nil 2335} 2336 2337type SendRequest struct { 2338 state protoimpl.MessageState 2339 sizeCache protoimpl.SizeCache 2340 unknownFields protoimpl.UnknownFields 2341 2342 Data Raw `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` 2343} 2344 2345func (x *SendRequest) Reset() { 2346 *x = SendRequest{} 2347 if protoimpl.UnsafeEnabled { 2348 mi := &file_client_proto_msgTypes[37] 2349 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 2350 ms.StoreMessageInfo(mi) 2351 } 2352} 2353 2354func (x *SendRequest) String() string { 2355 return protoimpl.X.MessageStringOf(x) 2356} 2357 2358func (*SendRequest) ProtoMessage() {} 2359 2360func (x *SendRequest) ProtoReflect() protoreflect.Message { 2361 mi := &file_client_proto_msgTypes[37] 2362 if protoimpl.UnsafeEnabled && x != nil { 2363 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 2364 if ms.LoadMessageInfo() == nil { 2365 ms.StoreMessageInfo(mi) 2366 } 2367 return ms 2368 } 2369 return mi.MessageOf(x) 2370} 2371 2372// Deprecated: Use SendRequest.ProtoReflect.Descriptor instead. 2373func (*SendRequest) Descriptor() ([]byte, []int) { 2374 return file_client_proto_rawDescGZIP(), []int{37} 2375} 2376 2377func (x *SendRequest) GetData() []byte { 2378 if x != nil { 2379 return x.Data 2380 } 2381 return nil 2382} 2383 2384var File_client_proto protoreflect.FileDescriptor 2385 2386var file_client_proto_rawDesc = []byte{ 2387 0x0a, 0x0c, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1f, 2388 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x61, 0x6c, 0x2e, 0x63, 0x65, 0x6e, 0x74, 2389 0x72, 0x69, 0x66, 0x75, 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x22, 2390 0x35, 0x0a, 0x05, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 2391 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x18, 0x0a, 0x07, 2392 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 2393 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x22, 0xb1, 0x02, 0x0a, 0x07, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 2394 0x6e, 0x64, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x02, 2395 0x69, 0x64, 0x12, 0x4b, 0x0a, 0x06, 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x18, 0x02, 0x20, 0x01, 2396 0x28, 0x0e, 0x32, 0x33, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x61, 0x6c, 2397 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 2398 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x2e, 0x4d, 0x65, 0x74, 2399 0x68, 0x6f, 0x64, 0x54, 0x79, 0x70, 0x65, 0x52, 0x06, 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x12, 2400 0x16, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 2401 0x06, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x73, 0x22, 0xb0, 0x01, 0x0a, 0x0a, 0x4d, 0x65, 0x74, 0x68, 2402 0x6f, 0x64, 0x54, 0x79, 0x70, 0x65, 0x12, 0x0b, 0x0a, 0x07, 0x43, 0x4f, 0x4e, 0x4e, 0x45, 0x43, 2403 0x54, 0x10, 0x00, 0x12, 0x0d, 0x0a, 0x09, 0x53, 0x55, 0x42, 0x53, 0x43, 0x52, 0x49, 0x42, 0x45, 2404 0x10, 0x01, 0x12, 0x0f, 0x0a, 0x0b, 0x55, 0x4e, 0x53, 0x55, 0x42, 0x53, 0x43, 0x52, 0x49, 0x42, 2405 0x45, 0x10, 0x02, 0x12, 0x0b, 0x0a, 0x07, 0x50, 0x55, 0x42, 0x4c, 0x49, 0x53, 0x48, 0x10, 0x03, 2406 0x12, 0x0c, 0x0a, 0x08, 0x50, 0x52, 0x45, 0x53, 0x45, 0x4e, 0x43, 0x45, 0x10, 0x04, 0x12, 0x12, 2407 0x0a, 0x0e, 0x50, 0x52, 0x45, 0x53, 0x45, 0x4e, 0x43, 0x45, 0x5f, 0x53, 0x54, 0x41, 0x54, 0x53, 2408 0x10, 0x05, 0x12, 0x0b, 0x0a, 0x07, 0x48, 0x49, 0x53, 0x54, 0x4f, 0x52, 0x59, 0x10, 0x06, 0x12, 2409 0x08, 0x0a, 0x04, 0x50, 0x49, 0x4e, 0x47, 0x10, 0x07, 0x12, 0x08, 0x0a, 0x04, 0x53, 0x45, 0x4e, 2410 0x44, 0x10, 0x08, 0x12, 0x07, 0x0a, 0x03, 0x52, 0x50, 0x43, 0x10, 0x09, 0x12, 0x0b, 0x0a, 0x07, 2411 0x52, 0x45, 0x46, 0x52, 0x45, 0x53, 0x48, 0x10, 0x0a, 0x12, 0x0f, 0x0a, 0x0b, 0x53, 0x55, 0x42, 2412 0x5f, 0x52, 0x45, 0x46, 0x52, 0x45, 0x53, 0x48, 0x10, 0x0b, 0x22, 0x6d, 0x0a, 0x05, 0x52, 0x65, 2413 0x70, 0x6c, 0x79, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 2414 0x02, 0x69, 0x64, 0x12, 0x3c, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x02, 0x20, 0x01, 2415 0x28, 0x0b, 0x32, 0x26, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x61, 0x6c, 2416 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 2417 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 2418 0x72, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 2419 0x0c, 0x52, 0x06, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x22, 0x82, 0x02, 0x0a, 0x04, 0x50, 0x75, 2420 0x73, 0x68, 0x12, 0x42, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 2421 0x32, 0x2e, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x61, 0x6c, 0x2e, 0x63, 2422 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 2423 0x6f, 0x6c, 0x2e, 0x50, 0x75, 0x73, 0x68, 0x2e, 0x50, 0x75, 0x73, 0x68, 0x54, 0x79, 0x70, 0x65, 2424 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 2425 0x6c, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 2426 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 2427 0x64, 0x61, 0x74, 0x61, 0x22, 0x87, 0x01, 0x0a, 0x08, 0x50, 0x75, 0x73, 0x68, 0x54, 0x79, 0x70, 2428 0x65, 0x12, 0x0f, 0x0a, 0x0b, 0x50, 0x55, 0x42, 0x4c, 0x49, 0x43, 0x41, 0x54, 0x49, 0x4f, 0x4e, 2429 0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 0x4a, 0x4f, 0x49, 0x4e, 0x10, 0x01, 0x12, 0x09, 0x0a, 0x05, 2430 0x4c, 0x45, 0x41, 0x56, 0x45, 0x10, 0x02, 0x12, 0x0f, 0x0a, 0x0b, 0x55, 0x4e, 0x53, 0x55, 0x42, 2431 0x53, 0x43, 0x52, 0x49, 0x42, 0x45, 0x10, 0x03, 0x12, 0x0b, 0x0a, 0x07, 0x4d, 0x45, 0x53, 0x53, 2432 0x41, 0x47, 0x45, 0x10, 0x04, 0x12, 0x0d, 0x0a, 0x09, 0x53, 0x55, 0x42, 0x53, 0x43, 0x52, 0x49, 2433 0x42, 0x45, 0x10, 0x05, 0x12, 0x0b, 0x0a, 0x07, 0x43, 0x4f, 0x4e, 0x4e, 0x45, 0x43, 0x54, 0x10, 2434 0x06, 0x12, 0x0e, 0x0a, 0x0a, 0x44, 0x49, 0x53, 0x43, 0x4f, 0x4e, 0x4e, 0x45, 0x43, 0x54, 0x10, 2435 0x07, 0x12, 0x0b, 0x0a, 0x07, 0x52, 0x45, 0x46, 0x52, 0x45, 0x53, 0x48, 0x10, 0x08, 0x22, 0x72, 2436 0x0a, 0x0a, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x12, 0x0a, 0x04, 2437 0x75, 0x73, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x75, 0x73, 0x65, 0x72, 2438 0x12, 0x16, 0x0a, 0x06, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 2439 0x52, 0x06, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x63, 0x6f, 0x6e, 0x6e, 2440 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x08, 0x63, 0x6f, 0x6e, 2441 0x6e, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x1b, 0x0a, 0x09, 0x63, 0x68, 0x61, 0x6e, 0x5f, 0x69, 0x6e, 2442 0x66, 0x6f, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x08, 0x63, 0x68, 0x61, 0x6e, 0x49, 0x6e, 2443 0x66, 0x6f, 0x22, 0x7a, 0x0a, 0x0b, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 2444 0x6e, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0c, 0x52, 2445 0x04, 0x64, 0x61, 0x74, 0x61, 0x12, 0x3f, 0x0a, 0x04, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x05, 0x20, 2446 0x01, 0x28, 0x0b, 0x32, 0x2b, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x61, 2447 0x6c, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 2448 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x49, 0x6e, 0x66, 0x6f, 2449 0x52, 0x04, 0x69, 0x6e, 0x66, 0x6f, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 2450 0x18, 0x06, 0x20, 0x01, 0x28, 0x04, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x22, 0x47, 2451 0x0a, 0x04, 0x4a, 0x6f, 0x69, 0x6e, 0x12, 0x3f, 0x0a, 0x04, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x01, 2452 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2b, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 2453 0x61, 0x6c, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x65, 0x2e, 0x70, 0x72, 2454 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x49, 0x6e, 0x66, 2455 0x6f, 0x52, 0x04, 0x69, 0x6e, 0x66, 0x6f, 0x22, 0x48, 0x0a, 0x05, 0x4c, 0x65, 0x61, 0x76, 0x65, 2456 0x12, 0x3f, 0x0a, 0x04, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2b, 2457 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x61, 0x6c, 0x2e, 0x63, 0x65, 0x6e, 2458 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 2459 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x04, 0x69, 0x6e, 0x66, 2460 0x6f, 0x22, 0x0d, 0x0a, 0x0b, 0x55, 0x6e, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 2461 0x22, 0x8f, 0x01, 0x0a, 0x09, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x12, 0x20, 2462 0x0a, 0x0b, 0x72, 0x65, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x61, 0x62, 0x6c, 0x65, 0x18, 0x01, 0x20, 2463 0x01, 0x28, 0x08, 0x52, 0x0b, 0x72, 0x65, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x61, 0x62, 0x6c, 0x65, 2464 0x12, 0x14, 0x0a, 0x05, 0x65, 0x70, 0x6f, 0x63, 0x68, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 2465 0x05, 0x65, 0x70, 0x6f, 0x63, 0x68, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 2466 0x18, 0x05, 0x20, 0x01, 0x28, 0x04, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x12, 0x1e, 2467 0x0a, 0x0a, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x65, 0x64, 0x18, 0x06, 0x20, 0x01, 2468 0x28, 0x08, 0x52, 0x0a, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x65, 0x64, 0x12, 0x12, 2469 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 2470 0x74, 0x61, 0x22, 0x1d, 0x0a, 0x07, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x12, 0x0a, 2471 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 2472 0x61, 0x22, 0xae, 0x02, 0x0a, 0x07, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x12, 0x16, 0x0a, 2473 0x06, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x63, 2474 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 2475 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 2476 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 2477 0x61, 0x74, 0x61, 0x12, 0x46, 0x0a, 0x04, 0x73, 0x75, 0x62, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 2478 0x0b, 0x32, 0x32, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x61, 0x6c, 0x2e, 2479 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 2480 0x63, 0x6f, 0x6c, 0x2e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x2e, 0x53, 0x75, 0x62, 0x73, 2481 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x04, 0x73, 0x75, 0x62, 0x73, 0x12, 0x18, 0x0a, 0x07, 0x65, 2482 0x78, 0x70, 0x69, 0x72, 0x65, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x78, 2483 0x70, 0x69, 0x72, 0x65, 0x73, 0x12, 0x10, 0x0a, 0x03, 0x74, 0x74, 0x6c, 0x18, 0x06, 0x20, 0x01, 2484 0x28, 0x0d, 0x52, 0x03, 0x74, 0x74, 0x6c, 0x1a, 0x69, 0x0a, 0x09, 0x53, 0x75, 0x62, 0x73, 0x45, 2485 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 2486 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x46, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 2487 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x30, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 2488 0x67, 0x61, 0x6c, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x65, 0x2e, 0x70, 2489 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 2490 0x65, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 2491 0x38, 0x01, 0x22, 0x56, 0x0a, 0x0a, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 2492 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x04, 2493 0x63, 0x6f, 0x64, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x65, 0x61, 0x73, 0x6f, 0x6e, 0x18, 0x02, 2494 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x72, 0x65, 0x61, 0x73, 0x6f, 0x6e, 0x12, 0x1c, 0x0a, 0x09, 2495 0x72, 0x65, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, 2496 0x09, 0x72, 0x65, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x22, 0x35, 0x0a, 0x07, 0x52, 0x65, 2497 0x66, 0x72, 0x65, 0x73, 0x68, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x73, 2498 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x73, 0x12, 2499 0x10, 0x0a, 0x03, 0x74, 0x74, 0x6c, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x03, 0x74, 0x74, 2500 0x6c, 0x22, 0xa3, 0x02, 0x0a, 0x0e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x52, 0x65, 0x71, 2501 0x75, 0x65, 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x01, 0x20, 2502 0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 2503 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x12, 0x4d, 2504 0x0a, 0x04, 0x73, 0x75, 0x62, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x39, 0x2e, 0x63, 2505 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x61, 0x6c, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 2506 0x69, 0x66, 0x75, 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x43, 2507 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x53, 0x75, 2508 0x62, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x04, 0x73, 0x75, 0x62, 0x73, 0x12, 0x12, 0x0a, 2509 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 2510 0x65, 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x05, 0x20, 0x01, 2511 0x28, 0x09, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x1a, 0x6a, 0x0a, 0x09, 0x53, 2512 0x75, 0x62, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 2513 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x47, 0x0a, 0x05, 0x76, 0x61, 2514 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x31, 0x2e, 0x63, 0x65, 0x6e, 0x74, 2515 0x72, 0x69, 0x66, 0x75, 0x67, 0x61, 0x6c, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 2516 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x53, 0x75, 0x62, 0x73, 2517 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x52, 0x05, 0x76, 0x61, 2518 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0xba, 0x02, 0x0a, 0x0d, 0x43, 0x6f, 0x6e, 0x6e, 2519 0x65, 0x63, 0x74, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x63, 0x6c, 0x69, 2520 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x63, 0x6c, 0x69, 0x65, 0x6e, 2521 0x74, 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 2522 0x28, 0x09, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x18, 0x0a, 0x07, 0x65, 2523 0x78, 0x70, 0x69, 0x72, 0x65, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x78, 2524 0x70, 0x69, 0x72, 0x65, 0x73, 0x12, 0x10, 0x0a, 0x03, 0x74, 0x74, 0x6c, 0x18, 0x04, 0x20, 0x01, 2525 0x28, 0x0d, 0x52, 0x03, 0x74, 0x74, 0x6c, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 2526 0x05, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x12, 0x4c, 0x0a, 0x04, 0x73, 2527 0x75, 0x62, 0x73, 0x18, 0x06, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x38, 0x2e, 0x63, 0x65, 0x6e, 0x74, 2528 0x72, 0x69, 0x66, 0x75, 0x67, 0x61, 0x6c, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 2529 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x43, 0x6f, 0x6e, 0x6e, 2530 0x65, 0x63, 0x74, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x45, 0x6e, 2531 0x74, 0x72, 0x79, 0x52, 0x04, 0x73, 0x75, 0x62, 0x73, 0x1a, 0x69, 0x0a, 0x09, 0x53, 0x75, 0x62, 2532 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 2533 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x46, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 2534 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x30, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 2535 0x66, 0x75, 0x67, 0x61, 0x6c, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x65, 2536 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 2537 0x69, 0x62, 0x65, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 2538 0x3a, 0x02, 0x38, 0x01, 0x22, 0x26, 0x0a, 0x0e, 0x52, 0x65, 0x66, 0x72, 0x65, 0x73, 0x68, 0x52, 2539 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 2540 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x6d, 0x0a, 0x0d, 2541 0x52, 0x65, 0x66, 0x72, 0x65, 0x73, 0x68, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x16, 0x0a, 2542 0x06, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x63, 2543 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 2544 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 2545 0x18, 0x0a, 0x07, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 2546 0x52, 0x07, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x73, 0x12, 0x10, 0x0a, 0x03, 0x74, 0x74, 0x6c, 2547 0x18, 0x04, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x03, 0x74, 0x74, 0x6c, 0x22, 0x8a, 0x01, 0x0a, 0x10, 2548 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 2549 0x12, 0x18, 0x0a, 0x07, 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28, 2550 0x09, 0x52, 0x07, 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 2551 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 2552 0x12, 0x18, 0x0a, 0x07, 0x72, 0x65, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 2553 0x08, 0x52, 0x07, 0x72, 0x65, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x12, 0x14, 0x0a, 0x05, 0x65, 0x70, 2554 0x6f, 0x63, 0x68, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65, 0x70, 0x6f, 0x63, 0x68, 2555 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x07, 0x20, 0x01, 0x28, 0x04, 2556 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x22, 0xb1, 0x02, 0x0a, 0x0f, 0x53, 0x75, 0x62, 2557 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x18, 0x0a, 0x07, 2558 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 2559 0x78, 0x70, 0x69, 0x72, 0x65, 0x73, 0x12, 0x10, 0x0a, 0x03, 0x74, 0x74, 0x6c, 0x18, 0x02, 0x20, 2560 0x01, 0x28, 0x0d, 0x52, 0x03, 0x74, 0x74, 0x6c, 0x12, 0x20, 0x0a, 0x0b, 0x72, 0x65, 0x63, 0x6f, 2561 0x76, 0x65, 0x72, 0x61, 0x62, 0x6c, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0b, 0x72, 2562 0x65, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x65, 0x70, 2563 0x6f, 0x63, 0x68, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65, 0x70, 0x6f, 0x63, 0x68, 2564 0x12, 0x50, 0x0a, 0x0c, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 2565 0x18, 0x07, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 2566 0x75, 0x67, 0x61, 0x6c, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x65, 0x2e, 2567 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x63, 0x61, 2568 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0c, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 2569 0x6e, 0x73, 0x12, 0x1c, 0x0a, 0x09, 0x72, 0x65, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x65, 0x64, 0x18, 2570 0x08, 0x20, 0x01, 0x28, 0x08, 0x52, 0x09, 0x72, 0x65, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x65, 0x64, 2571 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x09, 0x20, 0x01, 0x28, 0x04, 2572 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x12, 0x1e, 0x0a, 0x0a, 0x70, 0x6f, 0x73, 0x69, 2573 0x74, 0x69, 0x6f, 0x6e, 0x65, 0x64, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0a, 0x70, 0x6f, 2574 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x65, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 2575 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x22, 0x43, 0x0a, 0x11, 2576 0x53, 0x75, 0x62, 0x52, 0x65, 0x66, 0x72, 0x65, 0x73, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 2577 0x74, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x18, 0x01, 0x20, 0x01, 2578 0x28, 0x09, 0x52, 0x07, 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x12, 0x14, 0x0a, 0x05, 0x74, 2579 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 0x6f, 0x6b, 0x65, 2580 0x6e, 0x22, 0x3e, 0x0a, 0x10, 0x53, 0x75, 0x62, 0x52, 0x65, 0x66, 0x72, 0x65, 0x73, 0x68, 0x52, 2581 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x73, 2582 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x73, 0x12, 2583 0x10, 0x0a, 0x03, 0x74, 0x74, 0x6c, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x03, 0x74, 0x74, 2584 0x6c, 0x22, 0x2e, 0x0a, 0x12, 0x55, 0x6e, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 2585 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x68, 0x61, 0x6e, 0x6e, 2586 0x65, 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 2587 0x6c, 0x22, 0x13, 0x0a, 0x11, 0x55, 0x6e, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 2588 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x22, 0x3e, 0x0a, 0x0e, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 2589 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x68, 0x61, 0x6e, 2590 0x6e, 0x65, 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x68, 0x61, 0x6e, 0x6e, 2591 0x65, 0x6c, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 2592 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x22, 0x0f, 0x0a, 0x0d, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 2593 0x68, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x22, 0x2b, 0x0a, 0x0f, 0x50, 0x72, 0x65, 0x73, 0x65, 2594 0x6e, 0x63, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x68, 2595 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x68, 0x61, 2596 0x6e, 0x6e, 0x65, 0x6c, 0x22, 0xd5, 0x01, 0x0a, 0x0e, 0x50, 0x72, 0x65, 0x73, 0x65, 0x6e, 0x63, 2597 0x65, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x59, 0x0a, 0x08, 0x70, 0x72, 0x65, 0x73, 0x65, 2598 0x6e, 0x63, 0x65, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x3d, 0x2e, 0x63, 0x65, 0x6e, 0x74, 2599 0x72, 0x69, 0x66, 0x75, 0x67, 0x61, 0x6c, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 2600 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x50, 0x72, 0x65, 0x73, 2601 0x65, 0x6e, 0x63, 0x65, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x2e, 0x50, 0x72, 0x65, 0x73, 0x65, 2602 0x6e, 0x63, 0x65, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x08, 0x70, 0x72, 0x65, 0x73, 0x65, 0x6e, 2603 0x63, 0x65, 0x1a, 0x68, 0x0a, 0x0d, 0x50, 0x72, 0x65, 0x73, 0x65, 0x6e, 0x63, 0x65, 0x45, 0x6e, 2604 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 2605 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x41, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 2606 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2b, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 2607 0x61, 0x6c, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x65, 0x2e, 0x70, 0x72, 2608 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x49, 0x6e, 0x66, 2609 0x6f, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x30, 0x0a, 0x14, 2610 0x50, 0x72, 0x65, 0x73, 0x65, 0x6e, 0x63, 0x65, 0x53, 0x74, 0x61, 0x74, 0x73, 0x52, 0x65, 0x71, 2611 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x18, 2612 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x22, 0x53, 2613 0x0a, 0x13, 0x50, 0x72, 0x65, 0x73, 0x65, 0x6e, 0x63, 0x65, 0x53, 0x74, 0x61, 0x74, 0x73, 0x52, 2614 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x1f, 0x0a, 0x0b, 0x6e, 0x75, 0x6d, 0x5f, 0x63, 0x6c, 0x69, 2615 0x65, 0x6e, 0x74, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0a, 0x6e, 0x75, 0x6d, 0x43, 2616 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x6e, 0x75, 0x6d, 0x5f, 0x75, 0x73, 2617 0x65, 0x72, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x08, 0x6e, 0x75, 0x6d, 0x55, 0x73, 2618 0x65, 0x72, 0x73, 0x22, 0x3e, 0x0a, 0x0e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x50, 0x6f, 0x73, 2619 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 2620 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x12, 0x14, 0x0a, 2621 0x05, 0x65, 0x70, 0x6f, 0x63, 0x68, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65, 0x70, 2622 0x6f, 0x63, 0x68, 0x22, 0xa1, 0x01, 0x0a, 0x0e, 0x48, 0x69, 0x73, 0x74, 0x6f, 0x72, 0x79, 0x52, 2623 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 2624 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 2625 0x12, 0x14, 0x0a, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x07, 0x20, 0x01, 0x28, 0x05, 0x52, 2626 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x12, 0x45, 0x0a, 0x05, 0x73, 0x69, 0x6e, 0x63, 0x65, 0x18, 2627 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 2628 0x67, 0x61, 0x6c, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x65, 0x2e, 0x70, 2629 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 0x6c, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x50, 0x6f, 2630 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x05, 0x73, 0x69, 0x6e, 0x63, 0x65, 0x12, 0x18, 0x0a, 2631 0x07, 0x72, 0x65, 0x76, 0x65, 0x72, 0x73, 0x65, 0x18, 0x09, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 2632 0x72, 0x65, 0x76, 0x65, 0x72, 0x73, 0x65, 0x22, 0x8f, 0x01, 0x0a, 0x0d, 0x48, 0x69, 0x73, 0x74, 2633 0x6f, 0x72, 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x50, 0x0a, 0x0c, 0x70, 0x75, 0x62, 2634 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 2635 0x2c, 0x2e, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x61, 0x6c, 0x2e, 0x63, 0x65, 2636 0x6e, 0x74, 0x72, 0x69, 0x66, 0x75, 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x63, 0x6f, 2637 0x6c, 0x2e, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0c, 0x70, 2638 0x75, 0x62, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x65, 2639 0x70, 0x6f, 0x63, 0x68, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65, 0x70, 0x6f, 0x63, 2640 0x68, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 2641 0x04, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x22, 0x0d, 0x0a, 0x0b, 0x50, 0x69, 0x6e, 2642 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x22, 0x0c, 0x0a, 0x0a, 0x50, 0x69, 0x6e, 0x67, 2643 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x22, 0x38, 0x0a, 0x0a, 0x52, 0x50, 0x43, 0x52, 0x65, 0x71, 2644 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 2645 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x12, 0x16, 0x0a, 0x06, 0x6d, 0x65, 0x74, 0x68, 2646 0x6f, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 2647 0x22, 0x1f, 0x0a, 0x09, 0x52, 0x50, 0x43, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x12, 0x12, 0x0a, 2648 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 2649 0x61, 0x22, 0x21, 0x0a, 0x0b, 0x53, 0x65, 0x6e, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 2650 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 2651 0x64, 0x61, 0x74, 0x61, 0x42, 0x0d, 0x5a, 0x0b, 0x2e, 0x2f, 0x3b, 0x70, 0x72, 0x6f, 0x74, 0x6f, 2652 0x63, 0x6f, 0x6c, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 2653} 2654 2655var ( 2656 file_client_proto_rawDescOnce sync.Once 2657 file_client_proto_rawDescData = file_client_proto_rawDesc 2658) 2659 2660func file_client_proto_rawDescGZIP() []byte { 2661 file_client_proto_rawDescOnce.Do(func() { 2662 file_client_proto_rawDescData = protoimpl.X.CompressGZIP(file_client_proto_rawDescData) 2663 }) 2664 return file_client_proto_rawDescData 2665} 2666 2667var file_client_proto_enumTypes = make([]protoimpl.EnumInfo, 2) 2668var file_client_proto_msgTypes = make([]protoimpl.MessageInfo, 42) 2669var file_client_proto_goTypes = []interface{}{ 2670 (Command_MethodType)(0), // 0: centrifugal.centrifuge.protocol.Command.MethodType 2671 (Push_PushType)(0), // 1: centrifugal.centrifuge.protocol.Push.PushType 2672 (*Error)(nil), // 2: centrifugal.centrifuge.protocol.Error 2673 (*Command)(nil), // 3: centrifugal.centrifuge.protocol.Command 2674 (*Reply)(nil), // 4: centrifugal.centrifuge.protocol.Reply 2675 (*Push)(nil), // 5: centrifugal.centrifuge.protocol.Push 2676 (*ClientInfo)(nil), // 6: centrifugal.centrifuge.protocol.ClientInfo 2677 (*Publication)(nil), // 7: centrifugal.centrifuge.protocol.Publication 2678 (*Join)(nil), // 8: centrifugal.centrifuge.protocol.Join 2679 (*Leave)(nil), // 9: centrifugal.centrifuge.protocol.Leave 2680 (*Unsubscribe)(nil), // 10: centrifugal.centrifuge.protocol.Unsubscribe 2681 (*Subscribe)(nil), // 11: centrifugal.centrifuge.protocol.Subscribe 2682 (*Message)(nil), // 12: centrifugal.centrifuge.protocol.Message 2683 (*Connect)(nil), // 13: centrifugal.centrifuge.protocol.Connect 2684 (*Disconnect)(nil), // 14: centrifugal.centrifuge.protocol.Disconnect 2685 (*Refresh)(nil), // 15: centrifugal.centrifuge.protocol.Refresh 2686 (*ConnectRequest)(nil), // 16: centrifugal.centrifuge.protocol.ConnectRequest 2687 (*ConnectResult)(nil), // 17: centrifugal.centrifuge.protocol.ConnectResult 2688 (*RefreshRequest)(nil), // 18: centrifugal.centrifuge.protocol.RefreshRequest 2689 (*RefreshResult)(nil), // 19: centrifugal.centrifuge.protocol.RefreshResult 2690 (*SubscribeRequest)(nil), // 20: centrifugal.centrifuge.protocol.SubscribeRequest 2691 (*SubscribeResult)(nil), // 21: centrifugal.centrifuge.protocol.SubscribeResult 2692 (*SubRefreshRequest)(nil), // 22: centrifugal.centrifuge.protocol.SubRefreshRequest 2693 (*SubRefreshResult)(nil), // 23: centrifugal.centrifuge.protocol.SubRefreshResult 2694 (*UnsubscribeRequest)(nil), // 24: centrifugal.centrifuge.protocol.UnsubscribeRequest 2695 (*UnsubscribeResult)(nil), // 25: centrifugal.centrifuge.protocol.UnsubscribeResult 2696 (*PublishRequest)(nil), // 26: centrifugal.centrifuge.protocol.PublishRequest 2697 (*PublishResult)(nil), // 27: centrifugal.centrifuge.protocol.PublishResult 2698 (*PresenceRequest)(nil), // 28: centrifugal.centrifuge.protocol.PresenceRequest 2699 (*PresenceResult)(nil), // 29: centrifugal.centrifuge.protocol.PresenceResult 2700 (*PresenceStatsRequest)(nil), // 30: centrifugal.centrifuge.protocol.PresenceStatsRequest 2701 (*PresenceStatsResult)(nil), // 31: centrifugal.centrifuge.protocol.PresenceStatsResult 2702 (*StreamPosition)(nil), // 32: centrifugal.centrifuge.protocol.StreamPosition 2703 (*HistoryRequest)(nil), // 33: centrifugal.centrifuge.protocol.HistoryRequest 2704 (*HistoryResult)(nil), // 34: centrifugal.centrifuge.protocol.HistoryResult 2705 (*PingRequest)(nil), // 35: centrifugal.centrifuge.protocol.PingRequest 2706 (*PingResult)(nil), // 36: centrifugal.centrifuge.protocol.PingResult 2707 (*RPCRequest)(nil), // 37: centrifugal.centrifuge.protocol.RPCRequest 2708 (*RPCResult)(nil), // 38: centrifugal.centrifuge.protocol.RPCResult 2709 (*SendRequest)(nil), // 39: centrifugal.centrifuge.protocol.SendRequest 2710 nil, // 40: centrifugal.centrifuge.protocol.Connect.SubsEntry 2711 nil, // 41: centrifugal.centrifuge.protocol.ConnectRequest.SubsEntry 2712 nil, // 42: centrifugal.centrifuge.protocol.ConnectResult.SubsEntry 2713 nil, // 43: centrifugal.centrifuge.protocol.PresenceResult.PresenceEntry 2714} 2715var file_client_proto_depIdxs = []int32{ 2716 0, // 0: centrifugal.centrifuge.protocol.Command.method:type_name -> centrifugal.centrifuge.protocol.Command.MethodType 2717 2, // 1: centrifugal.centrifuge.protocol.Reply.error:type_name -> centrifugal.centrifuge.protocol.Error 2718 1, // 2: centrifugal.centrifuge.protocol.Push.type:type_name -> centrifugal.centrifuge.protocol.Push.PushType 2719 6, // 3: centrifugal.centrifuge.protocol.Publication.info:type_name -> centrifugal.centrifuge.protocol.ClientInfo 2720 6, // 4: centrifugal.centrifuge.protocol.Join.info:type_name -> centrifugal.centrifuge.protocol.ClientInfo 2721 6, // 5: centrifugal.centrifuge.protocol.Leave.info:type_name -> centrifugal.centrifuge.protocol.ClientInfo 2722 40, // 6: centrifugal.centrifuge.protocol.Connect.subs:type_name -> centrifugal.centrifuge.protocol.Connect.SubsEntry 2723 41, // 7: centrifugal.centrifuge.protocol.ConnectRequest.subs:type_name -> centrifugal.centrifuge.protocol.ConnectRequest.SubsEntry 2724 42, // 8: centrifugal.centrifuge.protocol.ConnectResult.subs:type_name -> centrifugal.centrifuge.protocol.ConnectResult.SubsEntry 2725 7, // 9: centrifugal.centrifuge.protocol.SubscribeResult.publications:type_name -> centrifugal.centrifuge.protocol.Publication 2726 43, // 10: centrifugal.centrifuge.protocol.PresenceResult.presence:type_name -> centrifugal.centrifuge.protocol.PresenceResult.PresenceEntry 2727 32, // 11: centrifugal.centrifuge.protocol.HistoryRequest.since:type_name -> centrifugal.centrifuge.protocol.StreamPosition 2728 7, // 12: centrifugal.centrifuge.protocol.HistoryResult.publications:type_name -> centrifugal.centrifuge.protocol.Publication 2729 21, // 13: centrifugal.centrifuge.protocol.Connect.SubsEntry.value:type_name -> centrifugal.centrifuge.protocol.SubscribeResult 2730 20, // 14: centrifugal.centrifuge.protocol.ConnectRequest.SubsEntry.value:type_name -> centrifugal.centrifuge.protocol.SubscribeRequest 2731 21, // 15: centrifugal.centrifuge.protocol.ConnectResult.SubsEntry.value:type_name -> centrifugal.centrifuge.protocol.SubscribeResult 2732 6, // 16: centrifugal.centrifuge.protocol.PresenceResult.PresenceEntry.value:type_name -> centrifugal.centrifuge.protocol.ClientInfo 2733 17, // [17:17] is the sub-list for method output_type 2734 17, // [17:17] is the sub-list for method input_type 2735 17, // [17:17] is the sub-list for extension type_name 2736 17, // [17:17] is the sub-list for extension extendee 2737 0, // [0:17] is the sub-list for field type_name 2738} 2739 2740func init() { file_client_proto_init() } 2741func file_client_proto_init() { 2742 if File_client_proto != nil { 2743 return 2744 } 2745 if !protoimpl.UnsafeEnabled { 2746 file_client_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 2747 switch v := v.(*Error); i { 2748 case 0: 2749 return &v.state 2750 case 1: 2751 return &v.sizeCache 2752 case 2: 2753 return &v.unknownFields 2754 default: 2755 return nil 2756 } 2757 } 2758 file_client_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 2759 switch v := v.(*Command); i { 2760 case 0: 2761 return &v.state 2762 case 1: 2763 return &v.sizeCache 2764 case 2: 2765 return &v.unknownFields 2766 default: 2767 return nil 2768 } 2769 } 2770 file_client_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 2771 switch v := v.(*Reply); i { 2772 case 0: 2773 return &v.state 2774 case 1: 2775 return &v.sizeCache 2776 case 2: 2777 return &v.unknownFields 2778 default: 2779 return nil 2780 } 2781 } 2782 file_client_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 2783 switch v := v.(*Push); i { 2784 case 0: 2785 return &v.state 2786 case 1: 2787 return &v.sizeCache 2788 case 2: 2789 return &v.unknownFields 2790 default: 2791 return nil 2792 } 2793 } 2794 file_client_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 2795 switch v := v.(*ClientInfo); i { 2796 case 0: 2797 return &v.state 2798 case 1: 2799 return &v.sizeCache 2800 case 2: 2801 return &v.unknownFields 2802 default: 2803 return nil 2804 } 2805 } 2806 file_client_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 2807 switch v := v.(*Publication); i { 2808 case 0: 2809 return &v.state 2810 case 1: 2811 return &v.sizeCache 2812 case 2: 2813 return &v.unknownFields 2814 default: 2815 return nil 2816 } 2817 } 2818 file_client_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 2819 switch v := v.(*Join); i { 2820 case 0: 2821 return &v.state 2822 case 1: 2823 return &v.sizeCache 2824 case 2: 2825 return &v.unknownFields 2826 default: 2827 return nil 2828 } 2829 } 2830 file_client_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { 2831 switch v := v.(*Leave); i { 2832 case 0: 2833 return &v.state 2834 case 1: 2835 return &v.sizeCache 2836 case 2: 2837 return &v.unknownFields 2838 default: 2839 return nil 2840 } 2841 } 2842 file_client_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { 2843 switch v := v.(*Unsubscribe); i { 2844 case 0: 2845 return &v.state 2846 case 1: 2847 return &v.sizeCache 2848 case 2: 2849 return &v.unknownFields 2850 default: 2851 return nil 2852 } 2853 } 2854 file_client_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { 2855 switch v := v.(*Subscribe); i { 2856 case 0: 2857 return &v.state 2858 case 1: 2859 return &v.sizeCache 2860 case 2: 2861 return &v.unknownFields 2862 default: 2863 return nil 2864 } 2865 } 2866 file_client_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { 2867 switch v := v.(*Message); i { 2868 case 0: 2869 return &v.state 2870 case 1: 2871 return &v.sizeCache 2872 case 2: 2873 return &v.unknownFields 2874 default: 2875 return nil 2876 } 2877 } 2878 file_client_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { 2879 switch v := v.(*Connect); i { 2880 case 0: 2881 return &v.state 2882 case 1: 2883 return &v.sizeCache 2884 case 2: 2885 return &v.unknownFields 2886 default: 2887 return nil 2888 } 2889 } 2890 file_client_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { 2891 switch v := v.(*Disconnect); i { 2892 case 0: 2893 return &v.state 2894 case 1: 2895 return &v.sizeCache 2896 case 2: 2897 return &v.unknownFields 2898 default: 2899 return nil 2900 } 2901 } 2902 file_client_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { 2903 switch v := v.(*Refresh); i { 2904 case 0: 2905 return &v.state 2906 case 1: 2907 return &v.sizeCache 2908 case 2: 2909 return &v.unknownFields 2910 default: 2911 return nil 2912 } 2913 } 2914 file_client_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { 2915 switch v := v.(*ConnectRequest); i { 2916 case 0: 2917 return &v.state 2918 case 1: 2919 return &v.sizeCache 2920 case 2: 2921 return &v.unknownFields 2922 default: 2923 return nil 2924 } 2925 } 2926 file_client_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} { 2927 switch v := v.(*ConnectResult); i { 2928 case 0: 2929 return &v.state 2930 case 1: 2931 return &v.sizeCache 2932 case 2: 2933 return &v.unknownFields 2934 default: 2935 return nil 2936 } 2937 } 2938 file_client_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} { 2939 switch v := v.(*RefreshRequest); i { 2940 case 0: 2941 return &v.state 2942 case 1: 2943 return &v.sizeCache 2944 case 2: 2945 return &v.unknownFields 2946 default: 2947 return nil 2948 } 2949 } 2950 file_client_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} { 2951 switch v := v.(*RefreshResult); i { 2952 case 0: 2953 return &v.state 2954 case 1: 2955 return &v.sizeCache 2956 case 2: 2957 return &v.unknownFields 2958 default: 2959 return nil 2960 } 2961 } 2962 file_client_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} { 2963 switch v := v.(*SubscribeRequest); i { 2964 case 0: 2965 return &v.state 2966 case 1: 2967 return &v.sizeCache 2968 case 2: 2969 return &v.unknownFields 2970 default: 2971 return nil 2972 } 2973 } 2974 file_client_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} { 2975 switch v := v.(*SubscribeResult); i { 2976 case 0: 2977 return &v.state 2978 case 1: 2979 return &v.sizeCache 2980 case 2: 2981 return &v.unknownFields 2982 default: 2983 return nil 2984 } 2985 } 2986 file_client_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} { 2987 switch v := v.(*SubRefreshRequest); i { 2988 case 0: 2989 return &v.state 2990 case 1: 2991 return &v.sizeCache 2992 case 2: 2993 return &v.unknownFields 2994 default: 2995 return nil 2996 } 2997 } 2998 file_client_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} { 2999 switch v := v.(*SubRefreshResult); i { 3000 case 0: 3001 return &v.state 3002 case 1: 3003 return &v.sizeCache 3004 case 2: 3005 return &v.unknownFields 3006 default: 3007 return nil 3008 } 3009 } 3010 file_client_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} { 3011 switch v := v.(*UnsubscribeRequest); i { 3012 case 0: 3013 return &v.state 3014 case 1: 3015 return &v.sizeCache 3016 case 2: 3017 return &v.unknownFields 3018 default: 3019 return nil 3020 } 3021 } 3022 file_client_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} { 3023 switch v := v.(*UnsubscribeResult); i { 3024 case 0: 3025 return &v.state 3026 case 1: 3027 return &v.sizeCache 3028 case 2: 3029 return &v.unknownFields 3030 default: 3031 return nil 3032 } 3033 } 3034 file_client_proto_msgTypes[24].Exporter = func(v interface{}, i int) interface{} { 3035 switch v := v.(*PublishRequest); i { 3036 case 0: 3037 return &v.state 3038 case 1: 3039 return &v.sizeCache 3040 case 2: 3041 return &v.unknownFields 3042 default: 3043 return nil 3044 } 3045 } 3046 file_client_proto_msgTypes[25].Exporter = func(v interface{}, i int) interface{} { 3047 switch v := v.(*PublishResult); i { 3048 case 0: 3049 return &v.state 3050 case 1: 3051 return &v.sizeCache 3052 case 2: 3053 return &v.unknownFields 3054 default: 3055 return nil 3056 } 3057 } 3058 file_client_proto_msgTypes[26].Exporter = func(v interface{}, i int) interface{} { 3059 switch v := v.(*PresenceRequest); i { 3060 case 0: 3061 return &v.state 3062 case 1: 3063 return &v.sizeCache 3064 case 2: 3065 return &v.unknownFields 3066 default: 3067 return nil 3068 } 3069 } 3070 file_client_proto_msgTypes[27].Exporter = func(v interface{}, i int) interface{} { 3071 switch v := v.(*PresenceResult); i { 3072 case 0: 3073 return &v.state 3074 case 1: 3075 return &v.sizeCache 3076 case 2: 3077 return &v.unknownFields 3078 default: 3079 return nil 3080 } 3081 } 3082 file_client_proto_msgTypes[28].Exporter = func(v interface{}, i int) interface{} { 3083 switch v := v.(*PresenceStatsRequest); i { 3084 case 0: 3085 return &v.state 3086 case 1: 3087 return &v.sizeCache 3088 case 2: 3089 return &v.unknownFields 3090 default: 3091 return nil 3092 } 3093 } 3094 file_client_proto_msgTypes[29].Exporter = func(v interface{}, i int) interface{} { 3095 switch v := v.(*PresenceStatsResult); i { 3096 case 0: 3097 return &v.state 3098 case 1: 3099 return &v.sizeCache 3100 case 2: 3101 return &v.unknownFields 3102 default: 3103 return nil 3104 } 3105 } 3106 file_client_proto_msgTypes[30].Exporter = func(v interface{}, i int) interface{} { 3107 switch v := v.(*StreamPosition); i { 3108 case 0: 3109 return &v.state 3110 case 1: 3111 return &v.sizeCache 3112 case 2: 3113 return &v.unknownFields 3114 default: 3115 return nil 3116 } 3117 } 3118 file_client_proto_msgTypes[31].Exporter = func(v interface{}, i int) interface{} { 3119 switch v := v.(*HistoryRequest); i { 3120 case 0: 3121 return &v.state 3122 case 1: 3123 return &v.sizeCache 3124 case 2: 3125 return &v.unknownFields 3126 default: 3127 return nil 3128 } 3129 } 3130 file_client_proto_msgTypes[32].Exporter = func(v interface{}, i int) interface{} { 3131 switch v := v.(*HistoryResult); i { 3132 case 0: 3133 return &v.state 3134 case 1: 3135 return &v.sizeCache 3136 case 2: 3137 return &v.unknownFields 3138 default: 3139 return nil 3140 } 3141 } 3142 file_client_proto_msgTypes[33].Exporter = func(v interface{}, i int) interface{} { 3143 switch v := v.(*PingRequest); i { 3144 case 0: 3145 return &v.state 3146 case 1: 3147 return &v.sizeCache 3148 case 2: 3149 return &v.unknownFields 3150 default: 3151 return nil 3152 } 3153 } 3154 file_client_proto_msgTypes[34].Exporter = func(v interface{}, i int) interface{} { 3155 switch v := v.(*PingResult); i { 3156 case 0: 3157 return &v.state 3158 case 1: 3159 return &v.sizeCache 3160 case 2: 3161 return &v.unknownFields 3162 default: 3163 return nil 3164 } 3165 } 3166 file_client_proto_msgTypes[35].Exporter = func(v interface{}, i int) interface{} { 3167 switch v := v.(*RPCRequest); i { 3168 case 0: 3169 return &v.state 3170 case 1: 3171 return &v.sizeCache 3172 case 2: 3173 return &v.unknownFields 3174 default: 3175 return nil 3176 } 3177 } 3178 file_client_proto_msgTypes[36].Exporter = func(v interface{}, i int) interface{} { 3179 switch v := v.(*RPCResult); i { 3180 case 0: 3181 return &v.state 3182 case 1: 3183 return &v.sizeCache 3184 case 2: 3185 return &v.unknownFields 3186 default: 3187 return nil 3188 } 3189 } 3190 file_client_proto_msgTypes[37].Exporter = func(v interface{}, i int) interface{} { 3191 switch v := v.(*SendRequest); i { 3192 case 0: 3193 return &v.state 3194 case 1: 3195 return &v.sizeCache 3196 case 2: 3197 return &v.unknownFields 3198 default: 3199 return nil 3200 } 3201 } 3202 } 3203 type x struct{} 3204 out := protoimpl.TypeBuilder{ 3205 File: protoimpl.DescBuilder{ 3206 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 3207 RawDescriptor: file_client_proto_rawDesc, 3208 NumEnums: 2, 3209 NumMessages: 42, 3210 NumExtensions: 0, 3211 NumServices: 0, 3212 }, 3213 GoTypes: file_client_proto_goTypes, 3214 DependencyIndexes: file_client_proto_depIdxs, 3215 EnumInfos: file_client_proto_enumTypes, 3216 MessageInfos: file_client_proto_msgTypes, 3217 }.Build() 3218 File_client_proto = out.File 3219 file_client_proto_rawDesc = nil 3220 file_client_proto_goTypes = nil 3221 file_client_proto_depIdxs = nil 3222} 3223