1// Copyright (c) 2015, Google Inc. 2// 3// Licensed under the Apache License, Version 2.0 (the "License"); 4// you may not use this file except in compliance with the License. 5// You may obtain a copy of the License at 6// 7// http://www.apache.org/licenses/LICENSE-2.0 8// 9// Unless required by applicable law or agreed to in writing, software 10// distributed under the License is distributed on an "AS IS" BASIS, 11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12// See the License for the specific language governing permissions and 13// limitations under the License. 14 15// Code generated by protoc-gen-go. DO NOT EDIT. 16// versions: 17// protoc-gen-go v1.25.0 18// protoc v3.13.0 19// source: google/pubsub/v1beta2/pubsub.proto 20 21package pubsub 22 23import ( 24 context "context" 25 reflect "reflect" 26 sync "sync" 27 28 proto "github.com/golang/protobuf/proto" 29 grpc "google.golang.org/grpc" 30 codes "google.golang.org/grpc/codes" 31 status "google.golang.org/grpc/status" 32 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 33 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 34 emptypb "google.golang.org/protobuf/types/known/emptypb" 35) 36 37const ( 38 // Verify that this generated code is sufficiently up-to-date. 39 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 40 // Verify that runtime/protoimpl is sufficiently up-to-date. 41 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 42) 43 44// This is a compile-time assertion that a sufficiently up-to-date version 45// of the legacy proto package is being used. 46const _ = proto.ProtoPackageIsVersion4 47 48// A topic resource. 49type Topic struct { 50 state protoimpl.MessageState 51 sizeCache protoimpl.SizeCache 52 unknownFields protoimpl.UnknownFields 53 54 // Name of the topic. 55 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 56} 57 58func (x *Topic) Reset() { 59 *x = Topic{} 60 if protoimpl.UnsafeEnabled { 61 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[0] 62 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 63 ms.StoreMessageInfo(mi) 64 } 65} 66 67func (x *Topic) String() string { 68 return protoimpl.X.MessageStringOf(x) 69} 70 71func (*Topic) ProtoMessage() {} 72 73func (x *Topic) ProtoReflect() protoreflect.Message { 74 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[0] 75 if protoimpl.UnsafeEnabled && x != nil { 76 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 77 if ms.LoadMessageInfo() == nil { 78 ms.StoreMessageInfo(mi) 79 } 80 return ms 81 } 82 return mi.MessageOf(x) 83} 84 85// Deprecated: Use Topic.ProtoReflect.Descriptor instead. 86func (*Topic) Descriptor() ([]byte, []int) { 87 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{0} 88} 89 90func (x *Topic) GetName() string { 91 if x != nil { 92 return x.Name 93 } 94 return "" 95} 96 97// A message data and its attributes. 98type PubsubMessage struct { 99 state protoimpl.MessageState 100 sizeCache protoimpl.SizeCache 101 unknownFields protoimpl.UnknownFields 102 103 // The message payload. For JSON requests, the value of this field must be 104 // base64-encoded. 105 Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` 106 // Optional attributes for this message. 107 Attributes map[string]string `protobuf:"bytes,2,rep,name=attributes,proto3" json:"attributes,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 108 // ID of this message assigned by the server at publication time. Guaranteed 109 // to be unique within the topic. This value may be read by a subscriber 110 // that receives a PubsubMessage via a Pull call or a push delivery. It must 111 // not be populated by a publisher in a Publish call. 112 MessageId string `protobuf:"bytes,3,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` 113} 114 115func (x *PubsubMessage) Reset() { 116 *x = PubsubMessage{} 117 if protoimpl.UnsafeEnabled { 118 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[1] 119 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 120 ms.StoreMessageInfo(mi) 121 } 122} 123 124func (x *PubsubMessage) String() string { 125 return protoimpl.X.MessageStringOf(x) 126} 127 128func (*PubsubMessage) ProtoMessage() {} 129 130func (x *PubsubMessage) ProtoReflect() protoreflect.Message { 131 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[1] 132 if protoimpl.UnsafeEnabled && x != nil { 133 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 134 if ms.LoadMessageInfo() == nil { 135 ms.StoreMessageInfo(mi) 136 } 137 return ms 138 } 139 return mi.MessageOf(x) 140} 141 142// Deprecated: Use PubsubMessage.ProtoReflect.Descriptor instead. 143func (*PubsubMessage) Descriptor() ([]byte, []int) { 144 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{1} 145} 146 147func (x *PubsubMessage) GetData() []byte { 148 if x != nil { 149 return x.Data 150 } 151 return nil 152} 153 154func (x *PubsubMessage) GetAttributes() map[string]string { 155 if x != nil { 156 return x.Attributes 157 } 158 return nil 159} 160 161func (x *PubsubMessage) GetMessageId() string { 162 if x != nil { 163 return x.MessageId 164 } 165 return "" 166} 167 168// Request for the GetTopic method. 169type GetTopicRequest struct { 170 state protoimpl.MessageState 171 sizeCache protoimpl.SizeCache 172 unknownFields protoimpl.UnknownFields 173 174 // The name of the topic to get. 175 Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` 176} 177 178func (x *GetTopicRequest) Reset() { 179 *x = GetTopicRequest{} 180 if protoimpl.UnsafeEnabled { 181 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[2] 182 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 183 ms.StoreMessageInfo(mi) 184 } 185} 186 187func (x *GetTopicRequest) String() string { 188 return protoimpl.X.MessageStringOf(x) 189} 190 191func (*GetTopicRequest) ProtoMessage() {} 192 193func (x *GetTopicRequest) ProtoReflect() protoreflect.Message { 194 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[2] 195 if protoimpl.UnsafeEnabled && x != nil { 196 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 197 if ms.LoadMessageInfo() == nil { 198 ms.StoreMessageInfo(mi) 199 } 200 return ms 201 } 202 return mi.MessageOf(x) 203} 204 205// Deprecated: Use GetTopicRequest.ProtoReflect.Descriptor instead. 206func (*GetTopicRequest) Descriptor() ([]byte, []int) { 207 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{2} 208} 209 210func (x *GetTopicRequest) GetTopic() string { 211 if x != nil { 212 return x.Topic 213 } 214 return "" 215} 216 217// Request for the Publish method. 218type PublishRequest struct { 219 state protoimpl.MessageState 220 sizeCache protoimpl.SizeCache 221 unknownFields protoimpl.UnknownFields 222 223 // The messages in the request will be published on this topic. 224 Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` 225 // The messages to publish. 226 Messages []*PubsubMessage `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"` 227} 228 229func (x *PublishRequest) Reset() { 230 *x = PublishRequest{} 231 if protoimpl.UnsafeEnabled { 232 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[3] 233 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 234 ms.StoreMessageInfo(mi) 235 } 236} 237 238func (x *PublishRequest) String() string { 239 return protoimpl.X.MessageStringOf(x) 240} 241 242func (*PublishRequest) ProtoMessage() {} 243 244func (x *PublishRequest) ProtoReflect() protoreflect.Message { 245 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[3] 246 if protoimpl.UnsafeEnabled && x != nil { 247 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 248 if ms.LoadMessageInfo() == nil { 249 ms.StoreMessageInfo(mi) 250 } 251 return ms 252 } 253 return mi.MessageOf(x) 254} 255 256// Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead. 257func (*PublishRequest) Descriptor() ([]byte, []int) { 258 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{3} 259} 260 261func (x *PublishRequest) GetTopic() string { 262 if x != nil { 263 return x.Topic 264 } 265 return "" 266} 267 268func (x *PublishRequest) GetMessages() []*PubsubMessage { 269 if x != nil { 270 return x.Messages 271 } 272 return nil 273} 274 275// Response for the Publish method. 276type PublishResponse struct { 277 state protoimpl.MessageState 278 sizeCache protoimpl.SizeCache 279 unknownFields protoimpl.UnknownFields 280 281 // The server-assigned ID of each published message, in the same order as 282 // the messages in the request. IDs are guaranteed to be unique within 283 // the topic. 284 MessageIds []string `protobuf:"bytes,1,rep,name=message_ids,json=messageIds,proto3" json:"message_ids,omitempty"` 285} 286 287func (x *PublishResponse) Reset() { 288 *x = PublishResponse{} 289 if protoimpl.UnsafeEnabled { 290 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[4] 291 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 292 ms.StoreMessageInfo(mi) 293 } 294} 295 296func (x *PublishResponse) String() string { 297 return protoimpl.X.MessageStringOf(x) 298} 299 300func (*PublishResponse) ProtoMessage() {} 301 302func (x *PublishResponse) ProtoReflect() protoreflect.Message { 303 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[4] 304 if protoimpl.UnsafeEnabled && x != nil { 305 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 306 if ms.LoadMessageInfo() == nil { 307 ms.StoreMessageInfo(mi) 308 } 309 return ms 310 } 311 return mi.MessageOf(x) 312} 313 314// Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead. 315func (*PublishResponse) Descriptor() ([]byte, []int) { 316 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{4} 317} 318 319func (x *PublishResponse) GetMessageIds() []string { 320 if x != nil { 321 return x.MessageIds 322 } 323 return nil 324} 325 326// Request for the ListTopics method. 327type ListTopicsRequest struct { 328 state protoimpl.MessageState 329 sizeCache protoimpl.SizeCache 330 unknownFields protoimpl.UnknownFields 331 332 // The name of the cloud project that topics belong to. 333 Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` 334 // Maximum number of topics to return. 335 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 336 // The value returned by the last ListTopicsResponse; indicates that this is 337 // a continuation of a prior ListTopics call, and that the system should 338 // return the next page of data. 339 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 340} 341 342func (x *ListTopicsRequest) Reset() { 343 *x = ListTopicsRequest{} 344 if protoimpl.UnsafeEnabled { 345 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[5] 346 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 347 ms.StoreMessageInfo(mi) 348 } 349} 350 351func (x *ListTopicsRequest) String() string { 352 return protoimpl.X.MessageStringOf(x) 353} 354 355func (*ListTopicsRequest) ProtoMessage() {} 356 357func (x *ListTopicsRequest) ProtoReflect() protoreflect.Message { 358 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[5] 359 if protoimpl.UnsafeEnabled && x != nil { 360 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 361 if ms.LoadMessageInfo() == nil { 362 ms.StoreMessageInfo(mi) 363 } 364 return ms 365 } 366 return mi.MessageOf(x) 367} 368 369// Deprecated: Use ListTopicsRequest.ProtoReflect.Descriptor instead. 370func (*ListTopicsRequest) Descriptor() ([]byte, []int) { 371 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{5} 372} 373 374func (x *ListTopicsRequest) GetProject() string { 375 if x != nil { 376 return x.Project 377 } 378 return "" 379} 380 381func (x *ListTopicsRequest) GetPageSize() int32 { 382 if x != nil { 383 return x.PageSize 384 } 385 return 0 386} 387 388func (x *ListTopicsRequest) GetPageToken() string { 389 if x != nil { 390 return x.PageToken 391 } 392 return "" 393} 394 395// Response for the ListTopics method. 396type ListTopicsResponse struct { 397 state protoimpl.MessageState 398 sizeCache protoimpl.SizeCache 399 unknownFields protoimpl.UnknownFields 400 401 // The resulting topics. 402 Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"` 403 // If not empty, indicates that there may be more topics that match the 404 // request; this value should be passed in a new ListTopicsRequest. 405 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 406} 407 408func (x *ListTopicsResponse) Reset() { 409 *x = ListTopicsResponse{} 410 if protoimpl.UnsafeEnabled { 411 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[6] 412 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 413 ms.StoreMessageInfo(mi) 414 } 415} 416 417func (x *ListTopicsResponse) String() string { 418 return protoimpl.X.MessageStringOf(x) 419} 420 421func (*ListTopicsResponse) ProtoMessage() {} 422 423func (x *ListTopicsResponse) ProtoReflect() protoreflect.Message { 424 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[6] 425 if protoimpl.UnsafeEnabled && x != nil { 426 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 427 if ms.LoadMessageInfo() == nil { 428 ms.StoreMessageInfo(mi) 429 } 430 return ms 431 } 432 return mi.MessageOf(x) 433} 434 435// Deprecated: Use ListTopicsResponse.ProtoReflect.Descriptor instead. 436func (*ListTopicsResponse) Descriptor() ([]byte, []int) { 437 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{6} 438} 439 440func (x *ListTopicsResponse) GetTopics() []*Topic { 441 if x != nil { 442 return x.Topics 443 } 444 return nil 445} 446 447func (x *ListTopicsResponse) GetNextPageToken() string { 448 if x != nil { 449 return x.NextPageToken 450 } 451 return "" 452} 453 454// Request for the ListTopicSubscriptions method. 455type ListTopicSubscriptionsRequest struct { 456 state protoimpl.MessageState 457 sizeCache protoimpl.SizeCache 458 unknownFields protoimpl.UnknownFields 459 460 // The name of the topic that subscriptions are attached to. 461 Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` 462 // Maximum number of subscription names to return. 463 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 464 // The value returned by the last ListTopicSubscriptionsResponse; indicates 465 // that this is a continuation of a prior ListTopicSubscriptions call, and 466 // that the system should return the next page of data. 467 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 468} 469 470func (x *ListTopicSubscriptionsRequest) Reset() { 471 *x = ListTopicSubscriptionsRequest{} 472 if protoimpl.UnsafeEnabled { 473 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[7] 474 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 475 ms.StoreMessageInfo(mi) 476 } 477} 478 479func (x *ListTopicSubscriptionsRequest) String() string { 480 return protoimpl.X.MessageStringOf(x) 481} 482 483func (*ListTopicSubscriptionsRequest) ProtoMessage() {} 484 485func (x *ListTopicSubscriptionsRequest) ProtoReflect() protoreflect.Message { 486 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[7] 487 if protoimpl.UnsafeEnabled && x != nil { 488 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 489 if ms.LoadMessageInfo() == nil { 490 ms.StoreMessageInfo(mi) 491 } 492 return ms 493 } 494 return mi.MessageOf(x) 495} 496 497// Deprecated: Use ListTopicSubscriptionsRequest.ProtoReflect.Descriptor instead. 498func (*ListTopicSubscriptionsRequest) Descriptor() ([]byte, []int) { 499 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{7} 500} 501 502func (x *ListTopicSubscriptionsRequest) GetTopic() string { 503 if x != nil { 504 return x.Topic 505 } 506 return "" 507} 508 509func (x *ListTopicSubscriptionsRequest) GetPageSize() int32 { 510 if x != nil { 511 return x.PageSize 512 } 513 return 0 514} 515 516func (x *ListTopicSubscriptionsRequest) GetPageToken() string { 517 if x != nil { 518 return x.PageToken 519 } 520 return "" 521} 522 523// Response for the ListTopicSubscriptions method. 524type ListTopicSubscriptionsResponse struct { 525 state protoimpl.MessageState 526 sizeCache protoimpl.SizeCache 527 unknownFields protoimpl.UnknownFields 528 529 // The names of the subscriptions that match the request. 530 Subscriptions []string `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` 531 // If not empty, indicates that there may be more subscriptions that match 532 // the request; this value should be passed in a new 533 // ListTopicSubscriptionsRequest to get more subscriptions. 534 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 535} 536 537func (x *ListTopicSubscriptionsResponse) Reset() { 538 *x = ListTopicSubscriptionsResponse{} 539 if protoimpl.UnsafeEnabled { 540 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[8] 541 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 542 ms.StoreMessageInfo(mi) 543 } 544} 545 546func (x *ListTopicSubscriptionsResponse) String() string { 547 return protoimpl.X.MessageStringOf(x) 548} 549 550func (*ListTopicSubscriptionsResponse) ProtoMessage() {} 551 552func (x *ListTopicSubscriptionsResponse) ProtoReflect() protoreflect.Message { 553 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[8] 554 if protoimpl.UnsafeEnabled && x != nil { 555 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 556 if ms.LoadMessageInfo() == nil { 557 ms.StoreMessageInfo(mi) 558 } 559 return ms 560 } 561 return mi.MessageOf(x) 562} 563 564// Deprecated: Use ListTopicSubscriptionsResponse.ProtoReflect.Descriptor instead. 565func (*ListTopicSubscriptionsResponse) Descriptor() ([]byte, []int) { 566 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{8} 567} 568 569func (x *ListTopicSubscriptionsResponse) GetSubscriptions() []string { 570 if x != nil { 571 return x.Subscriptions 572 } 573 return nil 574} 575 576func (x *ListTopicSubscriptionsResponse) GetNextPageToken() string { 577 if x != nil { 578 return x.NextPageToken 579 } 580 return "" 581} 582 583// Request for the DeleteTopic method. 584type DeleteTopicRequest struct { 585 state protoimpl.MessageState 586 sizeCache protoimpl.SizeCache 587 unknownFields protoimpl.UnknownFields 588 589 // Name of the topic to delete. 590 Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` 591} 592 593func (x *DeleteTopicRequest) Reset() { 594 *x = DeleteTopicRequest{} 595 if protoimpl.UnsafeEnabled { 596 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[9] 597 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 598 ms.StoreMessageInfo(mi) 599 } 600} 601 602func (x *DeleteTopicRequest) String() string { 603 return protoimpl.X.MessageStringOf(x) 604} 605 606func (*DeleteTopicRequest) ProtoMessage() {} 607 608func (x *DeleteTopicRequest) ProtoReflect() protoreflect.Message { 609 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[9] 610 if protoimpl.UnsafeEnabled && x != nil { 611 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 612 if ms.LoadMessageInfo() == nil { 613 ms.StoreMessageInfo(mi) 614 } 615 return ms 616 } 617 return mi.MessageOf(x) 618} 619 620// Deprecated: Use DeleteTopicRequest.ProtoReflect.Descriptor instead. 621func (*DeleteTopicRequest) Descriptor() ([]byte, []int) { 622 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{9} 623} 624 625func (x *DeleteTopicRequest) GetTopic() string { 626 if x != nil { 627 return x.Topic 628 } 629 return "" 630} 631 632// A subscription resource. 633type Subscription struct { 634 state protoimpl.MessageState 635 sizeCache protoimpl.SizeCache 636 unknownFields protoimpl.UnknownFields 637 638 // Name of the subscription. 639 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 640 // The name of the topic from which this subscription is receiving messages. 641 // This will be present if and only if the subscription has not been detached 642 // from its topic. 643 Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` 644 // If push delivery is used with this subscription, this field is 645 // used to configure it. An empty pushConfig signifies that the subscriber 646 // will pull and ack messages using API methods. 647 PushConfig *PushConfig `protobuf:"bytes,4,opt,name=push_config,json=pushConfig,proto3" json:"push_config,omitempty"` 648 // This value is the maximum time after a subscriber receives a message 649 // before the subscriber should acknowledge the message. After message 650 // delivery but before the ack deadline expires and before the message is 651 // acknowledged, it is an outstanding message and will not be delivered 652 // again during that time (on a best-effort basis). 653 // 654 // For pull delivery this value 655 // is used as the initial value for the ack deadline. It may be overridden 656 // for a specific message by calling ModifyAckDeadline. 657 // 658 // For push delivery, this value is also used to set the request timeout for 659 // the call to the push endpoint. 660 // 661 // If the subscriber never acknowledges the message, the Pub/Sub 662 // system will eventually redeliver the message. 663 AckDeadlineSeconds int32 `protobuf:"varint,5,opt,name=ack_deadline_seconds,json=ackDeadlineSeconds,proto3" json:"ack_deadline_seconds,omitempty"` 664} 665 666func (x *Subscription) Reset() { 667 *x = Subscription{} 668 if protoimpl.UnsafeEnabled { 669 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[10] 670 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 671 ms.StoreMessageInfo(mi) 672 } 673} 674 675func (x *Subscription) String() string { 676 return protoimpl.X.MessageStringOf(x) 677} 678 679func (*Subscription) ProtoMessage() {} 680 681func (x *Subscription) ProtoReflect() protoreflect.Message { 682 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[10] 683 if protoimpl.UnsafeEnabled && x != nil { 684 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 685 if ms.LoadMessageInfo() == nil { 686 ms.StoreMessageInfo(mi) 687 } 688 return ms 689 } 690 return mi.MessageOf(x) 691} 692 693// Deprecated: Use Subscription.ProtoReflect.Descriptor instead. 694func (*Subscription) Descriptor() ([]byte, []int) { 695 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{10} 696} 697 698func (x *Subscription) GetName() string { 699 if x != nil { 700 return x.Name 701 } 702 return "" 703} 704 705func (x *Subscription) GetTopic() string { 706 if x != nil { 707 return x.Topic 708 } 709 return "" 710} 711 712func (x *Subscription) GetPushConfig() *PushConfig { 713 if x != nil { 714 return x.PushConfig 715 } 716 return nil 717} 718 719func (x *Subscription) GetAckDeadlineSeconds() int32 { 720 if x != nil { 721 return x.AckDeadlineSeconds 722 } 723 return 0 724} 725 726// Configuration for a push delivery endpoint. 727type PushConfig struct { 728 state protoimpl.MessageState 729 sizeCache protoimpl.SizeCache 730 unknownFields protoimpl.UnknownFields 731 732 // A URL locating the endpoint to which messages should be pushed. 733 // For example, a Webhook endpoint might use "https://example.com/push". 734 PushEndpoint string `protobuf:"bytes,1,opt,name=push_endpoint,json=pushEndpoint,proto3" json:"push_endpoint,omitempty"` 735 // Endpoint configuration attributes. 736 // 737 // Every endpoint has a set of API supported attributes that can be used to 738 // control different aspects of the message delivery. 739 // 740 // The currently supported attribute is `x-goog-version`, which you can 741 // use to change the format of the push message. This attribute 742 // indicates the version of the data expected by the endpoint. This 743 // controls the shape of the envelope (i.e. its fields and metadata). 744 // The endpoint version is based on the version of the Pub/Sub 745 // API. 746 // 747 // If not present during the CreateSubscription call, it will default to 748 // the version of the API used to make such call. If not present during a 749 // ModifyPushConfig call, its value will not be changed. GetSubscription 750 // calls will always return a valid version, even if the subscription was 751 // created without this attribute. 752 // 753 // The possible values for this attribute are: 754 // 755 // * `v1beta1`: uses the push format defined in the v1beta1 Pub/Sub API. 756 // * `v1beta2`: uses the push format defined in the v1beta2 Pub/Sub API. 757 // 758 Attributes map[string]string `protobuf:"bytes,2,rep,name=attributes,proto3" json:"attributes,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 759} 760 761func (x *PushConfig) Reset() { 762 *x = PushConfig{} 763 if protoimpl.UnsafeEnabled { 764 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[11] 765 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 766 ms.StoreMessageInfo(mi) 767 } 768} 769 770func (x *PushConfig) String() string { 771 return protoimpl.X.MessageStringOf(x) 772} 773 774func (*PushConfig) ProtoMessage() {} 775 776func (x *PushConfig) ProtoReflect() protoreflect.Message { 777 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[11] 778 if protoimpl.UnsafeEnabled && x != nil { 779 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 780 if ms.LoadMessageInfo() == nil { 781 ms.StoreMessageInfo(mi) 782 } 783 return ms 784 } 785 return mi.MessageOf(x) 786} 787 788// Deprecated: Use PushConfig.ProtoReflect.Descriptor instead. 789func (*PushConfig) Descriptor() ([]byte, []int) { 790 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{11} 791} 792 793func (x *PushConfig) GetPushEndpoint() string { 794 if x != nil { 795 return x.PushEndpoint 796 } 797 return "" 798} 799 800func (x *PushConfig) GetAttributes() map[string]string { 801 if x != nil { 802 return x.Attributes 803 } 804 return nil 805} 806 807// A message and its corresponding acknowledgment ID. 808type ReceivedMessage struct { 809 state protoimpl.MessageState 810 sizeCache protoimpl.SizeCache 811 unknownFields protoimpl.UnknownFields 812 813 // This ID can be used to acknowledge the received message. 814 AckId string `protobuf:"bytes,1,opt,name=ack_id,json=ackId,proto3" json:"ack_id,omitempty"` 815 // The message. 816 Message *PubsubMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` 817} 818 819func (x *ReceivedMessage) Reset() { 820 *x = ReceivedMessage{} 821 if protoimpl.UnsafeEnabled { 822 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[12] 823 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 824 ms.StoreMessageInfo(mi) 825 } 826} 827 828func (x *ReceivedMessage) String() string { 829 return protoimpl.X.MessageStringOf(x) 830} 831 832func (*ReceivedMessage) ProtoMessage() {} 833 834func (x *ReceivedMessage) ProtoReflect() protoreflect.Message { 835 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[12] 836 if protoimpl.UnsafeEnabled && x != nil { 837 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 838 if ms.LoadMessageInfo() == nil { 839 ms.StoreMessageInfo(mi) 840 } 841 return ms 842 } 843 return mi.MessageOf(x) 844} 845 846// Deprecated: Use ReceivedMessage.ProtoReflect.Descriptor instead. 847func (*ReceivedMessage) Descriptor() ([]byte, []int) { 848 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{12} 849} 850 851func (x *ReceivedMessage) GetAckId() string { 852 if x != nil { 853 return x.AckId 854 } 855 return "" 856} 857 858func (x *ReceivedMessage) GetMessage() *PubsubMessage { 859 if x != nil { 860 return x.Message 861 } 862 return nil 863} 864 865// Request for the GetSubscription method. 866type GetSubscriptionRequest struct { 867 state protoimpl.MessageState 868 sizeCache protoimpl.SizeCache 869 unknownFields protoimpl.UnknownFields 870 871 // The name of the subscription to get. 872 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 873} 874 875func (x *GetSubscriptionRequest) Reset() { 876 *x = GetSubscriptionRequest{} 877 if protoimpl.UnsafeEnabled { 878 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[13] 879 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 880 ms.StoreMessageInfo(mi) 881 } 882} 883 884func (x *GetSubscriptionRequest) String() string { 885 return protoimpl.X.MessageStringOf(x) 886} 887 888func (*GetSubscriptionRequest) ProtoMessage() {} 889 890func (x *GetSubscriptionRequest) ProtoReflect() protoreflect.Message { 891 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[13] 892 if protoimpl.UnsafeEnabled && x != nil { 893 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 894 if ms.LoadMessageInfo() == nil { 895 ms.StoreMessageInfo(mi) 896 } 897 return ms 898 } 899 return mi.MessageOf(x) 900} 901 902// Deprecated: Use GetSubscriptionRequest.ProtoReflect.Descriptor instead. 903func (*GetSubscriptionRequest) Descriptor() ([]byte, []int) { 904 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{13} 905} 906 907func (x *GetSubscriptionRequest) GetSubscription() string { 908 if x != nil { 909 return x.Subscription 910 } 911 return "" 912} 913 914// Request for the ListSubscriptions method. 915type ListSubscriptionsRequest struct { 916 state protoimpl.MessageState 917 sizeCache protoimpl.SizeCache 918 unknownFields protoimpl.UnknownFields 919 920 // The name of the cloud project that subscriptions belong to. 921 Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` 922 // Maximum number of subscriptions to return. 923 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 924 // The value returned by the last ListSubscriptionsResponse; indicates that 925 // this is a continuation of a prior ListSubscriptions call, and that the 926 // system should return the next page of data. 927 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 928} 929 930func (x *ListSubscriptionsRequest) Reset() { 931 *x = ListSubscriptionsRequest{} 932 if protoimpl.UnsafeEnabled { 933 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[14] 934 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 935 ms.StoreMessageInfo(mi) 936 } 937} 938 939func (x *ListSubscriptionsRequest) String() string { 940 return protoimpl.X.MessageStringOf(x) 941} 942 943func (*ListSubscriptionsRequest) ProtoMessage() {} 944 945func (x *ListSubscriptionsRequest) ProtoReflect() protoreflect.Message { 946 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[14] 947 if protoimpl.UnsafeEnabled && x != nil { 948 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 949 if ms.LoadMessageInfo() == nil { 950 ms.StoreMessageInfo(mi) 951 } 952 return ms 953 } 954 return mi.MessageOf(x) 955} 956 957// Deprecated: Use ListSubscriptionsRequest.ProtoReflect.Descriptor instead. 958func (*ListSubscriptionsRequest) Descriptor() ([]byte, []int) { 959 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{14} 960} 961 962func (x *ListSubscriptionsRequest) GetProject() string { 963 if x != nil { 964 return x.Project 965 } 966 return "" 967} 968 969func (x *ListSubscriptionsRequest) GetPageSize() int32 { 970 if x != nil { 971 return x.PageSize 972 } 973 return 0 974} 975 976func (x *ListSubscriptionsRequest) GetPageToken() string { 977 if x != nil { 978 return x.PageToken 979 } 980 return "" 981} 982 983// Response for the ListSubscriptions method. 984type ListSubscriptionsResponse struct { 985 state protoimpl.MessageState 986 sizeCache protoimpl.SizeCache 987 unknownFields protoimpl.UnknownFields 988 989 // The subscriptions that match the request. 990 Subscriptions []*Subscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` 991 // If not empty, indicates that there may be more subscriptions that match 992 // the request; this value should be passed in a new ListSubscriptionsRequest 993 // to get more subscriptions. 994 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 995} 996 997func (x *ListSubscriptionsResponse) Reset() { 998 *x = ListSubscriptionsResponse{} 999 if protoimpl.UnsafeEnabled { 1000 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[15] 1001 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1002 ms.StoreMessageInfo(mi) 1003 } 1004} 1005 1006func (x *ListSubscriptionsResponse) String() string { 1007 return protoimpl.X.MessageStringOf(x) 1008} 1009 1010func (*ListSubscriptionsResponse) ProtoMessage() {} 1011 1012func (x *ListSubscriptionsResponse) ProtoReflect() protoreflect.Message { 1013 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[15] 1014 if protoimpl.UnsafeEnabled && x != nil { 1015 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1016 if ms.LoadMessageInfo() == nil { 1017 ms.StoreMessageInfo(mi) 1018 } 1019 return ms 1020 } 1021 return mi.MessageOf(x) 1022} 1023 1024// Deprecated: Use ListSubscriptionsResponse.ProtoReflect.Descriptor instead. 1025func (*ListSubscriptionsResponse) Descriptor() ([]byte, []int) { 1026 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{15} 1027} 1028 1029func (x *ListSubscriptionsResponse) GetSubscriptions() []*Subscription { 1030 if x != nil { 1031 return x.Subscriptions 1032 } 1033 return nil 1034} 1035 1036func (x *ListSubscriptionsResponse) GetNextPageToken() string { 1037 if x != nil { 1038 return x.NextPageToken 1039 } 1040 return "" 1041} 1042 1043// Request for the DeleteSubscription method. 1044type DeleteSubscriptionRequest struct { 1045 state protoimpl.MessageState 1046 sizeCache protoimpl.SizeCache 1047 unknownFields protoimpl.UnknownFields 1048 1049 // The subscription to delete. 1050 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 1051} 1052 1053func (x *DeleteSubscriptionRequest) Reset() { 1054 *x = DeleteSubscriptionRequest{} 1055 if protoimpl.UnsafeEnabled { 1056 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[16] 1057 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1058 ms.StoreMessageInfo(mi) 1059 } 1060} 1061 1062func (x *DeleteSubscriptionRequest) String() string { 1063 return protoimpl.X.MessageStringOf(x) 1064} 1065 1066func (*DeleteSubscriptionRequest) ProtoMessage() {} 1067 1068func (x *DeleteSubscriptionRequest) ProtoReflect() protoreflect.Message { 1069 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[16] 1070 if protoimpl.UnsafeEnabled && x != nil { 1071 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1072 if ms.LoadMessageInfo() == nil { 1073 ms.StoreMessageInfo(mi) 1074 } 1075 return ms 1076 } 1077 return mi.MessageOf(x) 1078} 1079 1080// Deprecated: Use DeleteSubscriptionRequest.ProtoReflect.Descriptor instead. 1081func (*DeleteSubscriptionRequest) Descriptor() ([]byte, []int) { 1082 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{16} 1083} 1084 1085func (x *DeleteSubscriptionRequest) GetSubscription() string { 1086 if x != nil { 1087 return x.Subscription 1088 } 1089 return "" 1090} 1091 1092// Request for the ModifyPushConfig method. 1093type ModifyPushConfigRequest struct { 1094 state protoimpl.MessageState 1095 sizeCache protoimpl.SizeCache 1096 unknownFields protoimpl.UnknownFields 1097 1098 // The name of the subscription. 1099 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 1100 // The push configuration for future deliveries. 1101 // 1102 // An empty pushConfig indicates that the Pub/Sub system should 1103 // stop pushing messages from the given subscription and allow 1104 // messages to be pulled and acknowledged - effectively pausing 1105 // the subscription if Pull is not called. 1106 PushConfig *PushConfig `protobuf:"bytes,2,opt,name=push_config,json=pushConfig,proto3" json:"push_config,omitempty"` 1107} 1108 1109func (x *ModifyPushConfigRequest) Reset() { 1110 *x = ModifyPushConfigRequest{} 1111 if protoimpl.UnsafeEnabled { 1112 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[17] 1113 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1114 ms.StoreMessageInfo(mi) 1115 } 1116} 1117 1118func (x *ModifyPushConfigRequest) String() string { 1119 return protoimpl.X.MessageStringOf(x) 1120} 1121 1122func (*ModifyPushConfigRequest) ProtoMessage() {} 1123 1124func (x *ModifyPushConfigRequest) ProtoReflect() protoreflect.Message { 1125 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[17] 1126 if protoimpl.UnsafeEnabled && x != nil { 1127 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1128 if ms.LoadMessageInfo() == nil { 1129 ms.StoreMessageInfo(mi) 1130 } 1131 return ms 1132 } 1133 return mi.MessageOf(x) 1134} 1135 1136// Deprecated: Use ModifyPushConfigRequest.ProtoReflect.Descriptor instead. 1137func (*ModifyPushConfigRequest) Descriptor() ([]byte, []int) { 1138 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{17} 1139} 1140 1141func (x *ModifyPushConfigRequest) GetSubscription() string { 1142 if x != nil { 1143 return x.Subscription 1144 } 1145 return "" 1146} 1147 1148func (x *ModifyPushConfigRequest) GetPushConfig() *PushConfig { 1149 if x != nil { 1150 return x.PushConfig 1151 } 1152 return nil 1153} 1154 1155// Request for the Pull method. 1156type PullRequest struct { 1157 state protoimpl.MessageState 1158 sizeCache protoimpl.SizeCache 1159 unknownFields protoimpl.UnknownFields 1160 1161 // The subscription from which messages should be pulled. 1162 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 1163 // If this is specified as true the system will respond immediately even if 1164 // it is not able to return a message in the Pull response. Otherwise the 1165 // system is allowed to wait until at least one message is available rather 1166 // than returning no messages. The client may cancel the request if it does 1167 // not wish to wait any longer for the response. 1168 ReturnImmediately bool `protobuf:"varint,2,opt,name=return_immediately,json=returnImmediately,proto3" json:"return_immediately,omitempty"` 1169 // The maximum number of messages returned for this request. The Pub/Sub 1170 // system may return fewer than the number specified. 1171 MaxMessages int32 `protobuf:"varint,3,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"` 1172} 1173 1174func (x *PullRequest) Reset() { 1175 *x = PullRequest{} 1176 if protoimpl.UnsafeEnabled { 1177 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[18] 1178 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1179 ms.StoreMessageInfo(mi) 1180 } 1181} 1182 1183func (x *PullRequest) String() string { 1184 return protoimpl.X.MessageStringOf(x) 1185} 1186 1187func (*PullRequest) ProtoMessage() {} 1188 1189func (x *PullRequest) ProtoReflect() protoreflect.Message { 1190 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[18] 1191 if protoimpl.UnsafeEnabled && x != nil { 1192 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1193 if ms.LoadMessageInfo() == nil { 1194 ms.StoreMessageInfo(mi) 1195 } 1196 return ms 1197 } 1198 return mi.MessageOf(x) 1199} 1200 1201// Deprecated: Use PullRequest.ProtoReflect.Descriptor instead. 1202func (*PullRequest) Descriptor() ([]byte, []int) { 1203 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{18} 1204} 1205 1206func (x *PullRequest) GetSubscription() string { 1207 if x != nil { 1208 return x.Subscription 1209 } 1210 return "" 1211} 1212 1213func (x *PullRequest) GetReturnImmediately() bool { 1214 if x != nil { 1215 return x.ReturnImmediately 1216 } 1217 return false 1218} 1219 1220func (x *PullRequest) GetMaxMessages() int32 { 1221 if x != nil { 1222 return x.MaxMessages 1223 } 1224 return 0 1225} 1226 1227// Response for the Pull method. 1228type PullResponse struct { 1229 state protoimpl.MessageState 1230 sizeCache protoimpl.SizeCache 1231 unknownFields protoimpl.UnknownFields 1232 1233 // Received Pub/Sub messages. The Pub/Sub system will return zero messages if 1234 // there are no more available in the backlog. The Pub/Sub system may return 1235 // fewer than the maxMessages requested even if there are more messages 1236 // available in the backlog. 1237 ReceivedMessages []*ReceivedMessage `protobuf:"bytes,1,rep,name=received_messages,json=receivedMessages,proto3" json:"received_messages,omitempty"` 1238} 1239 1240func (x *PullResponse) Reset() { 1241 *x = PullResponse{} 1242 if protoimpl.UnsafeEnabled { 1243 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[19] 1244 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1245 ms.StoreMessageInfo(mi) 1246 } 1247} 1248 1249func (x *PullResponse) String() string { 1250 return protoimpl.X.MessageStringOf(x) 1251} 1252 1253func (*PullResponse) ProtoMessage() {} 1254 1255func (x *PullResponse) ProtoReflect() protoreflect.Message { 1256 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[19] 1257 if protoimpl.UnsafeEnabled && x != nil { 1258 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1259 if ms.LoadMessageInfo() == nil { 1260 ms.StoreMessageInfo(mi) 1261 } 1262 return ms 1263 } 1264 return mi.MessageOf(x) 1265} 1266 1267// Deprecated: Use PullResponse.ProtoReflect.Descriptor instead. 1268func (*PullResponse) Descriptor() ([]byte, []int) { 1269 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{19} 1270} 1271 1272func (x *PullResponse) GetReceivedMessages() []*ReceivedMessage { 1273 if x != nil { 1274 return x.ReceivedMessages 1275 } 1276 return nil 1277} 1278 1279// Request for the ModifyAckDeadline method. 1280type ModifyAckDeadlineRequest struct { 1281 state protoimpl.MessageState 1282 sizeCache protoimpl.SizeCache 1283 unknownFields protoimpl.UnknownFields 1284 1285 // The name of the subscription. 1286 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 1287 // The acknowledgment ID. 1288 AckId string `protobuf:"bytes,2,opt,name=ack_id,json=ackId,proto3" json:"ack_id,omitempty"` 1289 // The new ack deadline with respect to the time this request was sent to the 1290 // Pub/Sub system. Must be >= 0. For example, if the value is 10, the new ack 1291 // deadline will expire 10 seconds after the ModifyAckDeadline call was made. 1292 // Specifying zero may immediately make the message available for another pull 1293 // request. 1294 AckDeadlineSeconds int32 `protobuf:"varint,3,opt,name=ack_deadline_seconds,json=ackDeadlineSeconds,proto3" json:"ack_deadline_seconds,omitempty"` 1295} 1296 1297func (x *ModifyAckDeadlineRequest) Reset() { 1298 *x = ModifyAckDeadlineRequest{} 1299 if protoimpl.UnsafeEnabled { 1300 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[20] 1301 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1302 ms.StoreMessageInfo(mi) 1303 } 1304} 1305 1306func (x *ModifyAckDeadlineRequest) String() string { 1307 return protoimpl.X.MessageStringOf(x) 1308} 1309 1310func (*ModifyAckDeadlineRequest) ProtoMessage() {} 1311 1312func (x *ModifyAckDeadlineRequest) ProtoReflect() protoreflect.Message { 1313 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[20] 1314 if protoimpl.UnsafeEnabled && x != nil { 1315 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1316 if ms.LoadMessageInfo() == nil { 1317 ms.StoreMessageInfo(mi) 1318 } 1319 return ms 1320 } 1321 return mi.MessageOf(x) 1322} 1323 1324// Deprecated: Use ModifyAckDeadlineRequest.ProtoReflect.Descriptor instead. 1325func (*ModifyAckDeadlineRequest) Descriptor() ([]byte, []int) { 1326 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{20} 1327} 1328 1329func (x *ModifyAckDeadlineRequest) GetSubscription() string { 1330 if x != nil { 1331 return x.Subscription 1332 } 1333 return "" 1334} 1335 1336func (x *ModifyAckDeadlineRequest) GetAckId() string { 1337 if x != nil { 1338 return x.AckId 1339 } 1340 return "" 1341} 1342 1343func (x *ModifyAckDeadlineRequest) GetAckDeadlineSeconds() int32 { 1344 if x != nil { 1345 return x.AckDeadlineSeconds 1346 } 1347 return 0 1348} 1349 1350// Request for the Acknowledge method. 1351type AcknowledgeRequest struct { 1352 state protoimpl.MessageState 1353 sizeCache protoimpl.SizeCache 1354 unknownFields protoimpl.UnknownFields 1355 1356 // The subscription whose message is being acknowledged. 1357 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 1358 // The acknowledgment ID for the messages being acknowledged that was returned 1359 // by the Pub/Sub system in the Pull response. Must not be empty. 1360 AckIds []string `protobuf:"bytes,2,rep,name=ack_ids,json=ackIds,proto3" json:"ack_ids,omitempty"` 1361} 1362 1363func (x *AcknowledgeRequest) Reset() { 1364 *x = AcknowledgeRequest{} 1365 if protoimpl.UnsafeEnabled { 1366 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[21] 1367 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1368 ms.StoreMessageInfo(mi) 1369 } 1370} 1371 1372func (x *AcknowledgeRequest) String() string { 1373 return protoimpl.X.MessageStringOf(x) 1374} 1375 1376func (*AcknowledgeRequest) ProtoMessage() {} 1377 1378func (x *AcknowledgeRequest) ProtoReflect() protoreflect.Message { 1379 mi := &file_google_pubsub_v1beta2_pubsub_proto_msgTypes[21] 1380 if protoimpl.UnsafeEnabled && x != nil { 1381 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1382 if ms.LoadMessageInfo() == nil { 1383 ms.StoreMessageInfo(mi) 1384 } 1385 return ms 1386 } 1387 return mi.MessageOf(x) 1388} 1389 1390// Deprecated: Use AcknowledgeRequest.ProtoReflect.Descriptor instead. 1391func (*AcknowledgeRequest) Descriptor() ([]byte, []int) { 1392 return file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP(), []int{21} 1393} 1394 1395func (x *AcknowledgeRequest) GetSubscription() string { 1396 if x != nil { 1397 return x.Subscription 1398 } 1399 return "" 1400} 1401 1402func (x *AcknowledgeRequest) GetAckIds() []string { 1403 if x != nil { 1404 return x.AckIds 1405 } 1406 return nil 1407} 1408 1409var File_google_pubsub_v1beta2_pubsub_proto protoreflect.FileDescriptor 1410 1411var file_google_pubsub_v1beta2_pubsub_proto_rawDesc = []byte{ 1412 0x0a, 0x22, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2f, 1413 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x70, 1414 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x15, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 1415 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 1416 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 1417 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x1b, 0x0a, 0x05, 0x54, 0x6f, 0x70, 0x69, 1418 0x63, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 1419 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0xd7, 0x01, 0x0a, 0x0d, 0x50, 0x75, 0x62, 0x73, 0x75, 0x62, 1420 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 1421 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x12, 0x54, 0x0a, 0x0a, 0x61, 1422 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 1423 0x34, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 1424 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x50, 0x75, 0x62, 0x73, 0x75, 0x62, 0x4d, 0x65, 1425 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x41, 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x73, 1426 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x0a, 0x61, 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 1427 0x73, 0x12, 0x1d, 0x0a, 0x0a, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x69, 0x64, 0x18, 1428 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x49, 0x64, 1429 0x1a, 0x3d, 0x0a, 0x0f, 0x41, 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x73, 0x45, 0x6e, 1430 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 1431 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 1432 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 1433 0x27, 0x0a, 0x0f, 0x47, 0x65, 0x74, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x52, 0x65, 0x71, 0x75, 0x65, 1434 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, 1435 0x09, 0x52, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x22, 0x68, 0x0a, 0x0e, 0x50, 0x75, 0x62, 0x6c, 1436 0x69, 0x73, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 1437 0x70, 0x69, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 1438 0x12, 0x40, 0x0a, 0x08, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x73, 0x18, 0x02, 0x20, 0x03, 1439 0x28, 0x0b, 0x32, 0x24, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 1440 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x50, 0x75, 0x62, 0x73, 0x75, 1441 0x62, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x08, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 1442 0x65, 0x73, 0x22, 0x32, 0x0a, 0x0f, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x52, 0x65, 0x73, 1443 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 1444 0x5f, 0x69, 0x64, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0a, 0x6d, 0x65, 0x73, 0x73, 1445 0x61, 0x67, 0x65, 0x49, 0x64, 0x73, 0x22, 0x69, 0x0a, 0x11, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x6f, 1446 0x70, 0x69, 0x63, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x70, 1447 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x70, 0x72, 1448 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69, 1449 0x7a, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 1450 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 1451 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 1452 0x6e, 0x22, 0x72, 0x0a, 0x12, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x73, 0x52, 1453 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x34, 0x0a, 0x06, 0x74, 0x6f, 0x70, 0x69, 0x63, 1454 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 1455 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 1456 0x54, 0x6f, 0x70, 0x69, 0x63, 0x52, 0x06, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x73, 0x12, 0x26, 0x0a, 1457 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 1458 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 0x67, 0x65, 1459 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x71, 0x0a, 0x1d, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x6f, 0x70, 1460 0x69, 0x63, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 1461 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x18, 1462 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x1b, 0x0a, 0x09, 1463 0x70, 0x61, 0x67, 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 1464 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 1465 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 1466 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x6e, 0x0a, 0x1e, 0x4c, 0x69, 0x73, 0x74, 1467 0x54, 0x6f, 0x70, 0x69, 0x63, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 1468 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x24, 0x0a, 0x0d, 0x73, 0x75, 1469 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 1470 0x09, 0x52, 0x0d, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 1471 0x12, 0x26, 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 1472 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 1473 0x61, 0x67, 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x2a, 0x0a, 0x12, 0x44, 0x65, 0x6c, 0x65, 1474 0x74, 0x65, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x14, 1475 0x0a, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 1476 0x6f, 0x70, 0x69, 0x63, 0x22, 0xae, 0x01, 0x0a, 0x0c, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 1477 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 1478 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x70, 1479 0x69, 0x63, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x12, 1480 0x42, 0x0a, 0x0b, 0x70, 0x75, 0x73, 0x68, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x04, 1481 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 1482 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x50, 0x75, 0x73, 1483 0x68, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x0a, 0x70, 0x75, 0x73, 0x68, 0x43, 0x6f, 0x6e, 1484 0x66, 0x69, 0x67, 0x12, 0x30, 0x0a, 0x14, 0x61, 0x63, 0x6b, 0x5f, 0x64, 0x65, 0x61, 0x64, 0x6c, 1485 0x69, 0x6e, 0x65, 0x5f, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 1486 0x05, 0x52, 0x12, 0x61, 0x63, 0x6b, 0x44, 0x65, 0x61, 0x64, 0x6c, 0x69, 0x6e, 0x65, 0x53, 0x65, 1487 0x63, 0x6f, 0x6e, 0x64, 0x73, 0x22, 0xc3, 0x01, 0x0a, 0x0a, 0x50, 0x75, 0x73, 0x68, 0x43, 0x6f, 1488 0x6e, 0x66, 0x69, 0x67, 0x12, 0x23, 0x0a, 0x0d, 0x70, 0x75, 0x73, 0x68, 0x5f, 0x65, 0x6e, 0x64, 1489 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x70, 0x75, 0x73, 1490 0x68, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x12, 0x51, 0x0a, 0x0a, 0x61, 0x74, 0x74, 1491 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x31, 0x2e, 1492 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 1493 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x50, 0x75, 0x73, 0x68, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 1494 0x2e, 0x41, 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 1495 0x52, 0x0a, 0x61, 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x73, 0x1a, 0x3d, 0x0a, 0x0f, 1496 0x41, 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 1497 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 1498 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 1499 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x68, 0x0a, 0x0f, 0x52, 1500 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x64, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x15, 1501 0x0a, 0x06, 0x61, 0x63, 0x6b, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 1502 0x61, 0x63, 0x6b, 0x49, 0x64, 0x12, 0x3e, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 1503 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x24, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 1504 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x50, 1505 0x75, 0x62, 0x73, 0x75, 0x62, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x07, 0x6d, 0x65, 1506 0x73, 0x73, 0x61, 0x67, 0x65, 0x22, 0x3c, 0x0a, 0x16, 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, 0x73, 1507 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 1508 0x22, 0x0a, 0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 1509 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 1510 0x69, 0x6f, 0x6e, 0x22, 0x70, 0x0a, 0x18, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x75, 0x62, 0x73, 0x63, 1511 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 1512 0x18, 0x0a, 0x07, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 1513 0x52, 0x07, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x61, 0x67, 1514 0x65, 0x5f, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x70, 0x61, 1515 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 1516 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 1517 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x8e, 0x01, 0x0a, 0x19, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x75, 1518 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 1519 0x6e, 0x73, 0x65, 0x12, 0x49, 0x0a, 0x0d, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 1520 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x23, 0x2e, 0x67, 0x6f, 0x6f, 1521 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 1522 0x61, 0x32, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 1523 0x0d, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x26, 1524 0x0a, 0x0f, 0x6e, 0x65, 0x78, 0x74, 0x5f, 0x70, 0x61, 0x67, 0x65, 0x5f, 0x74, 0x6f, 0x6b, 0x65, 1525 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6e, 0x65, 0x78, 0x74, 0x50, 0x61, 0x67, 1526 0x65, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x3f, 0x0a, 0x19, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 1527 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 1528 0x65, 0x73, 0x74, 0x12, 0x22, 0x0a, 0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 1529 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, 1530 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x81, 0x01, 0x0a, 0x17, 0x4d, 0x6f, 0x64, 0x69, 1531 0x66, 0x79, 0x50, 0x75, 0x73, 0x68, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, 0x71, 0x75, 1532 0x65, 0x73, 0x74, 0x12, 0x22, 0x0a, 0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 1533 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, 1534 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x42, 0x0a, 0x0b, 0x70, 0x75, 0x73, 0x68, 0x5f, 1535 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, 1536 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 1537 0x65, 0x74, 0x61, 0x32, 0x2e, 0x50, 0x75, 0x73, 0x68, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 1538 0x0a, 0x70, 0x75, 0x73, 0x68, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x22, 0x83, 0x01, 0x0a, 0x0b, 1539 0x50, 0x75, 0x6c, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x22, 0x0a, 0x0c, 0x73, 1540 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 1541 0x09, 0x52, 0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 1542 0x2d, 0x0a, 0x12, 0x72, 0x65, 0x74, 0x75, 0x72, 0x6e, 0x5f, 0x69, 0x6d, 0x6d, 0x65, 0x64, 0x69, 1543 0x61, 0x74, 0x65, 0x6c, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x11, 0x72, 0x65, 0x74, 1544 0x75, 0x72, 0x6e, 0x49, 0x6d, 0x6d, 0x65, 0x64, 0x69, 0x61, 0x74, 0x65, 0x6c, 0x79, 0x12, 0x21, 1545 0x0a, 0x0c, 0x6d, 0x61, 0x78, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x73, 0x18, 0x03, 1546 0x20, 0x01, 0x28, 0x05, 0x52, 0x0b, 0x6d, 0x61, 0x78, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 1547 0x73, 0x22, 0x63, 0x0a, 0x0c, 0x50, 0x75, 0x6c, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 1548 0x65, 0x12, 0x53, 0x0a, 0x11, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x64, 0x5f, 0x6d, 0x65, 1549 0x73, 0x73, 0x61, 0x67, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x26, 0x2e, 0x67, 1550 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 1551 0x65, 0x74, 0x61, 0x32, 0x2e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x64, 0x4d, 0x65, 0x73, 1552 0x73, 0x61, 0x67, 0x65, 0x52, 0x10, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x64, 0x4d, 0x65, 1553 0x73, 0x73, 0x61, 0x67, 0x65, 0x73, 0x22, 0x87, 0x01, 0x0a, 0x18, 0x4d, 0x6f, 0x64, 0x69, 0x66, 1554 0x79, 0x41, 0x63, 0x6b, 0x44, 0x65, 0x61, 0x64, 0x6c, 0x69, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x75, 1555 0x65, 0x73, 0x74, 0x12, 0x22, 0x0a, 0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 1556 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, 1557 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x15, 0x0a, 0x06, 0x61, 0x63, 0x6b, 0x5f, 0x69, 1558 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x61, 0x63, 0x6b, 0x49, 0x64, 0x12, 0x30, 1559 0x0a, 0x14, 0x61, 0x63, 0x6b, 0x5f, 0x64, 0x65, 0x61, 0x64, 0x6c, 0x69, 0x6e, 0x65, 0x5f, 0x73, 1560 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x12, 0x61, 0x63, 1561 0x6b, 0x44, 0x65, 0x61, 0x64, 0x6c, 0x69, 0x6e, 0x65, 0x53, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x73, 1562 0x22, 0x51, 0x0a, 0x12, 0x41, 0x63, 0x6b, 0x6e, 0x6f, 0x77, 0x6c, 0x65, 0x64, 0x67, 0x65, 0x52, 1563 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x22, 0x0a, 0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 1564 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x73, 0x75, 1565 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x17, 0x0a, 0x07, 0x61, 0x63, 1566 0x6b, 0x5f, 0x69, 0x64, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x06, 0x61, 0x63, 0x6b, 1567 0x49, 0x64, 0x73, 0x32, 0x88, 0x06, 0x0a, 0x0a, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 1568 0x65, 0x72, 0x12, 0x5e, 0x0a, 0x12, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x53, 0x75, 0x62, 0x73, 1569 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x23, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 1570 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 1571 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x1a, 0x23, 0x2e, 1572 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 1573 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 1574 0x6f, 0x6e, 0x12, 0x65, 0x0a, 0x0f, 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 1575 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 1576 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x47, 0x65, 1577 0x74, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 1578 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 1579 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x53, 0x75, 0x62, 1580 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x76, 0x0a, 0x11, 0x4c, 0x69, 0x73, 1581 0x74, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x2f, 1582 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 1583 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x75, 0x62, 0x73, 0x63, 1584 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 1585 0x30, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 1586 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x75, 0x62, 0x73, 1587 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 1588 0x65, 0x12, 0x5e, 0x0a, 0x12, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x75, 0x62, 0x73, 0x63, 1589 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x30, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 1590 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 1591 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 1592 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 1593 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 1594 0x79, 0x12, 0x5c, 0x0a, 0x11, 0x4d, 0x6f, 0x64, 0x69, 0x66, 0x79, 0x41, 0x63, 0x6b, 0x44, 0x65, 1595 0x61, 0x64, 0x6c, 0x69, 0x6e, 0x65, 0x12, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 1596 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x4d, 1597 0x6f, 0x64, 0x69, 0x66, 0x79, 0x41, 0x63, 0x6b, 0x44, 0x65, 0x61, 0x64, 0x6c, 0x69, 0x6e, 0x65, 1598 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 1599 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x12, 1600 0x50, 0x0a, 0x0b, 0x41, 0x63, 0x6b, 0x6e, 0x6f, 0x77, 0x6c, 0x65, 0x64, 0x67, 0x65, 0x12, 0x29, 1601 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 1602 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x41, 0x63, 0x6b, 0x6e, 0x6f, 0x77, 0x6c, 0x65, 0x64, 1603 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 1604 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 1605 0x79, 0x12, 0x4f, 0x0a, 0x04, 0x50, 0x75, 0x6c, 0x6c, 0x12, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 1606 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 1607 0x32, 0x2e, 0x50, 0x75, 0x6c, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 1608 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 1609 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x50, 0x75, 0x6c, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 1610 0x73, 0x65, 0x12, 0x5a, 0x0a, 0x10, 0x4d, 0x6f, 0x64, 0x69, 0x66, 0x79, 0x50, 0x75, 0x73, 0x68, 1611 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x2e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 1612 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x4d, 1613 0x6f, 0x64, 0x69, 0x66, 0x79, 0x50, 0x75, 0x73, 0x68, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 1614 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 1615 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x32, 0xbf, 1616 0x04, 0x0a, 0x09, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x65, 0x72, 0x12, 0x49, 0x0a, 0x0b, 1617 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x1c, 0x2e, 0x67, 0x6f, 1618 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 1619 0x74, 0x61, 0x32, 0x2e, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x1a, 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 1620 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 1621 0x32, 0x2e, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x58, 0x0a, 0x07, 0x50, 0x75, 0x62, 0x6c, 0x69, 1622 0x73, 0x68, 0x12, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 1623 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x50, 0x75, 0x62, 0x6c, 0x69, 1624 0x73, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x26, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 1625 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 1626 0x32, 0x2e, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 1627 0x65, 0x12, 0x50, 0x0a, 0x08, 0x47, 0x65, 0x74, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x26, 0x2e, 1628 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 1629 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x47, 0x65, 0x74, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x52, 0x65, 1630 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 1631 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x54, 0x6f, 1632 0x70, 0x69, 0x63, 0x12, 0x61, 0x0a, 0x0a, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x6f, 0x70, 0x69, 0x63, 1633 0x73, 0x12, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 1634 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x6f, 1635 0x70, 0x69, 0x63, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x29, 0x2e, 0x67, 0x6f, 1636 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 1637 0x74, 0x61, 0x32, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x73, 0x52, 0x65, 1638 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x85, 0x01, 0x0a, 0x16, 0x4c, 0x69, 0x73, 0x74, 0x54, 1639 0x6f, 0x70, 0x69, 0x63, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 1640 0x73, 0x12, 0x34, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 1641 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x54, 0x6f, 1642 0x70, 0x69, 0x63, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 1643 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 1644 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 1645 0x4c, 0x69, 0x73, 0x74, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 1646 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x50, 1647 0x0a, 0x0b, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x29, 0x2e, 1648 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 1649 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x54, 0x6f, 0x70, 0x69, 1650 0x63, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 1651 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 1652 0x42, 0x67, 0x0a, 0x19, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 1653 0x75, 0x62, 0x73, 0x75, 0x62, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x42, 0x0b, 0x50, 1654 0x75, 0x62, 0x73, 0x75, 0x62, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x3b, 0x67, 0x6f, 1655 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 1656 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 1657 0x70, 0x69, 0x73, 0x2f, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 1658 0x61, 0x32, 0x3b, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 1659 0x33, 1660} 1661 1662var ( 1663 file_google_pubsub_v1beta2_pubsub_proto_rawDescOnce sync.Once 1664 file_google_pubsub_v1beta2_pubsub_proto_rawDescData = file_google_pubsub_v1beta2_pubsub_proto_rawDesc 1665) 1666 1667func file_google_pubsub_v1beta2_pubsub_proto_rawDescGZIP() []byte { 1668 file_google_pubsub_v1beta2_pubsub_proto_rawDescOnce.Do(func() { 1669 file_google_pubsub_v1beta2_pubsub_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_pubsub_v1beta2_pubsub_proto_rawDescData) 1670 }) 1671 return file_google_pubsub_v1beta2_pubsub_proto_rawDescData 1672} 1673 1674var file_google_pubsub_v1beta2_pubsub_proto_msgTypes = make([]protoimpl.MessageInfo, 24) 1675var file_google_pubsub_v1beta2_pubsub_proto_goTypes = []interface{}{ 1676 (*Topic)(nil), // 0: google.pubsub.v1beta2.Topic 1677 (*PubsubMessage)(nil), // 1: google.pubsub.v1beta2.PubsubMessage 1678 (*GetTopicRequest)(nil), // 2: google.pubsub.v1beta2.GetTopicRequest 1679 (*PublishRequest)(nil), // 3: google.pubsub.v1beta2.PublishRequest 1680 (*PublishResponse)(nil), // 4: google.pubsub.v1beta2.PublishResponse 1681 (*ListTopicsRequest)(nil), // 5: google.pubsub.v1beta2.ListTopicsRequest 1682 (*ListTopicsResponse)(nil), // 6: google.pubsub.v1beta2.ListTopicsResponse 1683 (*ListTopicSubscriptionsRequest)(nil), // 7: google.pubsub.v1beta2.ListTopicSubscriptionsRequest 1684 (*ListTopicSubscriptionsResponse)(nil), // 8: google.pubsub.v1beta2.ListTopicSubscriptionsResponse 1685 (*DeleteTopicRequest)(nil), // 9: google.pubsub.v1beta2.DeleteTopicRequest 1686 (*Subscription)(nil), // 10: google.pubsub.v1beta2.Subscription 1687 (*PushConfig)(nil), // 11: google.pubsub.v1beta2.PushConfig 1688 (*ReceivedMessage)(nil), // 12: google.pubsub.v1beta2.ReceivedMessage 1689 (*GetSubscriptionRequest)(nil), // 13: google.pubsub.v1beta2.GetSubscriptionRequest 1690 (*ListSubscriptionsRequest)(nil), // 14: google.pubsub.v1beta2.ListSubscriptionsRequest 1691 (*ListSubscriptionsResponse)(nil), // 15: google.pubsub.v1beta2.ListSubscriptionsResponse 1692 (*DeleteSubscriptionRequest)(nil), // 16: google.pubsub.v1beta2.DeleteSubscriptionRequest 1693 (*ModifyPushConfigRequest)(nil), // 17: google.pubsub.v1beta2.ModifyPushConfigRequest 1694 (*PullRequest)(nil), // 18: google.pubsub.v1beta2.PullRequest 1695 (*PullResponse)(nil), // 19: google.pubsub.v1beta2.PullResponse 1696 (*ModifyAckDeadlineRequest)(nil), // 20: google.pubsub.v1beta2.ModifyAckDeadlineRequest 1697 (*AcknowledgeRequest)(nil), // 21: google.pubsub.v1beta2.AcknowledgeRequest 1698 nil, // 22: google.pubsub.v1beta2.PubsubMessage.AttributesEntry 1699 nil, // 23: google.pubsub.v1beta2.PushConfig.AttributesEntry 1700 (*emptypb.Empty)(nil), // 24: google.protobuf.Empty 1701} 1702var file_google_pubsub_v1beta2_pubsub_proto_depIdxs = []int32{ 1703 22, // 0: google.pubsub.v1beta2.PubsubMessage.attributes:type_name -> google.pubsub.v1beta2.PubsubMessage.AttributesEntry 1704 1, // 1: google.pubsub.v1beta2.PublishRequest.messages:type_name -> google.pubsub.v1beta2.PubsubMessage 1705 0, // 2: google.pubsub.v1beta2.ListTopicsResponse.topics:type_name -> google.pubsub.v1beta2.Topic 1706 11, // 3: google.pubsub.v1beta2.Subscription.push_config:type_name -> google.pubsub.v1beta2.PushConfig 1707 23, // 4: google.pubsub.v1beta2.PushConfig.attributes:type_name -> google.pubsub.v1beta2.PushConfig.AttributesEntry 1708 1, // 5: google.pubsub.v1beta2.ReceivedMessage.message:type_name -> google.pubsub.v1beta2.PubsubMessage 1709 10, // 6: google.pubsub.v1beta2.ListSubscriptionsResponse.subscriptions:type_name -> google.pubsub.v1beta2.Subscription 1710 11, // 7: google.pubsub.v1beta2.ModifyPushConfigRequest.push_config:type_name -> google.pubsub.v1beta2.PushConfig 1711 12, // 8: google.pubsub.v1beta2.PullResponse.received_messages:type_name -> google.pubsub.v1beta2.ReceivedMessage 1712 10, // 9: google.pubsub.v1beta2.Subscriber.CreateSubscription:input_type -> google.pubsub.v1beta2.Subscription 1713 13, // 10: google.pubsub.v1beta2.Subscriber.GetSubscription:input_type -> google.pubsub.v1beta2.GetSubscriptionRequest 1714 14, // 11: google.pubsub.v1beta2.Subscriber.ListSubscriptions:input_type -> google.pubsub.v1beta2.ListSubscriptionsRequest 1715 16, // 12: google.pubsub.v1beta2.Subscriber.DeleteSubscription:input_type -> google.pubsub.v1beta2.DeleteSubscriptionRequest 1716 20, // 13: google.pubsub.v1beta2.Subscriber.ModifyAckDeadline:input_type -> google.pubsub.v1beta2.ModifyAckDeadlineRequest 1717 21, // 14: google.pubsub.v1beta2.Subscriber.Acknowledge:input_type -> google.pubsub.v1beta2.AcknowledgeRequest 1718 18, // 15: google.pubsub.v1beta2.Subscriber.Pull:input_type -> google.pubsub.v1beta2.PullRequest 1719 17, // 16: google.pubsub.v1beta2.Subscriber.ModifyPushConfig:input_type -> google.pubsub.v1beta2.ModifyPushConfigRequest 1720 0, // 17: google.pubsub.v1beta2.Publisher.CreateTopic:input_type -> google.pubsub.v1beta2.Topic 1721 3, // 18: google.pubsub.v1beta2.Publisher.Publish:input_type -> google.pubsub.v1beta2.PublishRequest 1722 2, // 19: google.pubsub.v1beta2.Publisher.GetTopic:input_type -> google.pubsub.v1beta2.GetTopicRequest 1723 5, // 20: google.pubsub.v1beta2.Publisher.ListTopics:input_type -> google.pubsub.v1beta2.ListTopicsRequest 1724 7, // 21: google.pubsub.v1beta2.Publisher.ListTopicSubscriptions:input_type -> google.pubsub.v1beta2.ListTopicSubscriptionsRequest 1725 9, // 22: google.pubsub.v1beta2.Publisher.DeleteTopic:input_type -> google.pubsub.v1beta2.DeleteTopicRequest 1726 10, // 23: google.pubsub.v1beta2.Subscriber.CreateSubscription:output_type -> google.pubsub.v1beta2.Subscription 1727 10, // 24: google.pubsub.v1beta2.Subscriber.GetSubscription:output_type -> google.pubsub.v1beta2.Subscription 1728 15, // 25: google.pubsub.v1beta2.Subscriber.ListSubscriptions:output_type -> google.pubsub.v1beta2.ListSubscriptionsResponse 1729 24, // 26: google.pubsub.v1beta2.Subscriber.DeleteSubscription:output_type -> google.protobuf.Empty 1730 24, // 27: google.pubsub.v1beta2.Subscriber.ModifyAckDeadline:output_type -> google.protobuf.Empty 1731 24, // 28: google.pubsub.v1beta2.Subscriber.Acknowledge:output_type -> google.protobuf.Empty 1732 19, // 29: google.pubsub.v1beta2.Subscriber.Pull:output_type -> google.pubsub.v1beta2.PullResponse 1733 24, // 30: google.pubsub.v1beta2.Subscriber.ModifyPushConfig:output_type -> google.protobuf.Empty 1734 0, // 31: google.pubsub.v1beta2.Publisher.CreateTopic:output_type -> google.pubsub.v1beta2.Topic 1735 4, // 32: google.pubsub.v1beta2.Publisher.Publish:output_type -> google.pubsub.v1beta2.PublishResponse 1736 0, // 33: google.pubsub.v1beta2.Publisher.GetTopic:output_type -> google.pubsub.v1beta2.Topic 1737 6, // 34: google.pubsub.v1beta2.Publisher.ListTopics:output_type -> google.pubsub.v1beta2.ListTopicsResponse 1738 8, // 35: google.pubsub.v1beta2.Publisher.ListTopicSubscriptions:output_type -> google.pubsub.v1beta2.ListTopicSubscriptionsResponse 1739 24, // 36: google.pubsub.v1beta2.Publisher.DeleteTopic:output_type -> google.protobuf.Empty 1740 23, // [23:37] is the sub-list for method output_type 1741 9, // [9:23] is the sub-list for method input_type 1742 9, // [9:9] is the sub-list for extension type_name 1743 9, // [9:9] is the sub-list for extension extendee 1744 0, // [0:9] is the sub-list for field type_name 1745} 1746 1747func init() { file_google_pubsub_v1beta2_pubsub_proto_init() } 1748func file_google_pubsub_v1beta2_pubsub_proto_init() { 1749 if File_google_pubsub_v1beta2_pubsub_proto != nil { 1750 return 1751 } 1752 if !protoimpl.UnsafeEnabled { 1753 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 1754 switch v := v.(*Topic); i { 1755 case 0: 1756 return &v.state 1757 case 1: 1758 return &v.sizeCache 1759 case 2: 1760 return &v.unknownFields 1761 default: 1762 return nil 1763 } 1764 } 1765 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 1766 switch v := v.(*PubsubMessage); i { 1767 case 0: 1768 return &v.state 1769 case 1: 1770 return &v.sizeCache 1771 case 2: 1772 return &v.unknownFields 1773 default: 1774 return nil 1775 } 1776 } 1777 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 1778 switch v := v.(*GetTopicRequest); i { 1779 case 0: 1780 return &v.state 1781 case 1: 1782 return &v.sizeCache 1783 case 2: 1784 return &v.unknownFields 1785 default: 1786 return nil 1787 } 1788 } 1789 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 1790 switch v := v.(*PublishRequest); i { 1791 case 0: 1792 return &v.state 1793 case 1: 1794 return &v.sizeCache 1795 case 2: 1796 return &v.unknownFields 1797 default: 1798 return nil 1799 } 1800 } 1801 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 1802 switch v := v.(*PublishResponse); i { 1803 case 0: 1804 return &v.state 1805 case 1: 1806 return &v.sizeCache 1807 case 2: 1808 return &v.unknownFields 1809 default: 1810 return nil 1811 } 1812 } 1813 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 1814 switch v := v.(*ListTopicsRequest); i { 1815 case 0: 1816 return &v.state 1817 case 1: 1818 return &v.sizeCache 1819 case 2: 1820 return &v.unknownFields 1821 default: 1822 return nil 1823 } 1824 } 1825 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 1826 switch v := v.(*ListTopicsResponse); i { 1827 case 0: 1828 return &v.state 1829 case 1: 1830 return &v.sizeCache 1831 case 2: 1832 return &v.unknownFields 1833 default: 1834 return nil 1835 } 1836 } 1837 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { 1838 switch v := v.(*ListTopicSubscriptionsRequest); i { 1839 case 0: 1840 return &v.state 1841 case 1: 1842 return &v.sizeCache 1843 case 2: 1844 return &v.unknownFields 1845 default: 1846 return nil 1847 } 1848 } 1849 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { 1850 switch v := v.(*ListTopicSubscriptionsResponse); i { 1851 case 0: 1852 return &v.state 1853 case 1: 1854 return &v.sizeCache 1855 case 2: 1856 return &v.unknownFields 1857 default: 1858 return nil 1859 } 1860 } 1861 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { 1862 switch v := v.(*DeleteTopicRequest); i { 1863 case 0: 1864 return &v.state 1865 case 1: 1866 return &v.sizeCache 1867 case 2: 1868 return &v.unknownFields 1869 default: 1870 return nil 1871 } 1872 } 1873 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { 1874 switch v := v.(*Subscription); i { 1875 case 0: 1876 return &v.state 1877 case 1: 1878 return &v.sizeCache 1879 case 2: 1880 return &v.unknownFields 1881 default: 1882 return nil 1883 } 1884 } 1885 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { 1886 switch v := v.(*PushConfig); i { 1887 case 0: 1888 return &v.state 1889 case 1: 1890 return &v.sizeCache 1891 case 2: 1892 return &v.unknownFields 1893 default: 1894 return nil 1895 } 1896 } 1897 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { 1898 switch v := v.(*ReceivedMessage); i { 1899 case 0: 1900 return &v.state 1901 case 1: 1902 return &v.sizeCache 1903 case 2: 1904 return &v.unknownFields 1905 default: 1906 return nil 1907 } 1908 } 1909 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { 1910 switch v := v.(*GetSubscriptionRequest); i { 1911 case 0: 1912 return &v.state 1913 case 1: 1914 return &v.sizeCache 1915 case 2: 1916 return &v.unknownFields 1917 default: 1918 return nil 1919 } 1920 } 1921 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { 1922 switch v := v.(*ListSubscriptionsRequest); i { 1923 case 0: 1924 return &v.state 1925 case 1: 1926 return &v.sizeCache 1927 case 2: 1928 return &v.unknownFields 1929 default: 1930 return nil 1931 } 1932 } 1933 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} { 1934 switch v := v.(*ListSubscriptionsResponse); i { 1935 case 0: 1936 return &v.state 1937 case 1: 1938 return &v.sizeCache 1939 case 2: 1940 return &v.unknownFields 1941 default: 1942 return nil 1943 } 1944 } 1945 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} { 1946 switch v := v.(*DeleteSubscriptionRequest); i { 1947 case 0: 1948 return &v.state 1949 case 1: 1950 return &v.sizeCache 1951 case 2: 1952 return &v.unknownFields 1953 default: 1954 return nil 1955 } 1956 } 1957 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} { 1958 switch v := v.(*ModifyPushConfigRequest); i { 1959 case 0: 1960 return &v.state 1961 case 1: 1962 return &v.sizeCache 1963 case 2: 1964 return &v.unknownFields 1965 default: 1966 return nil 1967 } 1968 } 1969 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} { 1970 switch v := v.(*PullRequest); i { 1971 case 0: 1972 return &v.state 1973 case 1: 1974 return &v.sizeCache 1975 case 2: 1976 return &v.unknownFields 1977 default: 1978 return nil 1979 } 1980 } 1981 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} { 1982 switch v := v.(*PullResponse); i { 1983 case 0: 1984 return &v.state 1985 case 1: 1986 return &v.sizeCache 1987 case 2: 1988 return &v.unknownFields 1989 default: 1990 return nil 1991 } 1992 } 1993 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} { 1994 switch v := v.(*ModifyAckDeadlineRequest); i { 1995 case 0: 1996 return &v.state 1997 case 1: 1998 return &v.sizeCache 1999 case 2: 2000 return &v.unknownFields 2001 default: 2002 return nil 2003 } 2004 } 2005 file_google_pubsub_v1beta2_pubsub_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} { 2006 switch v := v.(*AcknowledgeRequest); i { 2007 case 0: 2008 return &v.state 2009 case 1: 2010 return &v.sizeCache 2011 case 2: 2012 return &v.unknownFields 2013 default: 2014 return nil 2015 } 2016 } 2017 } 2018 type x struct{} 2019 out := protoimpl.TypeBuilder{ 2020 File: protoimpl.DescBuilder{ 2021 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 2022 RawDescriptor: file_google_pubsub_v1beta2_pubsub_proto_rawDesc, 2023 NumEnums: 0, 2024 NumMessages: 24, 2025 NumExtensions: 0, 2026 NumServices: 2, 2027 }, 2028 GoTypes: file_google_pubsub_v1beta2_pubsub_proto_goTypes, 2029 DependencyIndexes: file_google_pubsub_v1beta2_pubsub_proto_depIdxs, 2030 MessageInfos: file_google_pubsub_v1beta2_pubsub_proto_msgTypes, 2031 }.Build() 2032 File_google_pubsub_v1beta2_pubsub_proto = out.File 2033 file_google_pubsub_v1beta2_pubsub_proto_rawDesc = nil 2034 file_google_pubsub_v1beta2_pubsub_proto_goTypes = nil 2035 file_google_pubsub_v1beta2_pubsub_proto_depIdxs = nil 2036} 2037 2038// Reference imports to suppress errors if they are not otherwise used. 2039var _ context.Context 2040var _ grpc.ClientConnInterface 2041 2042// This is a compile-time assertion to ensure that this generated file 2043// is compatible with the grpc package it is being compiled against. 2044const _ = grpc.SupportPackageIsVersion6 2045 2046// SubscriberClient is the client API for Subscriber service. 2047// 2048// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 2049type SubscriberClient interface { 2050 // Creates a subscription to a given topic for a given subscriber. 2051 // If the subscription already exists, returns ALREADY_EXISTS. 2052 // If the corresponding topic doesn't exist, returns NOT_FOUND. 2053 // 2054 // If the name is not provided in the request, the server will assign a random 2055 // name for this subscription on the same project as the topic. 2056 CreateSubscription(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (*Subscription, error) 2057 // Gets the configuration details of a subscription. 2058 GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error) 2059 // Lists matching subscriptions. 2060 ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error) 2061 // Deletes an existing subscription. All pending messages in the subscription 2062 // are immediately dropped. Calls to Pull after deletion will return 2063 // NOT_FOUND. After a subscription is deleted, a new one may be created with 2064 // the same name, but the new one has no association with the old 2065 // subscription, or its topic unless the same topic is specified. 2066 DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 2067 // Modifies the ack deadline for a specific message. This method is useful to 2068 // indicate that more time is needed to process a message by the subscriber, 2069 // or to make the message available for redelivery if the processing was 2070 // interrupted. 2071 ModifyAckDeadline(ctx context.Context, in *ModifyAckDeadlineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 2072 // Acknowledges the messages associated with the ack tokens in the 2073 // AcknowledgeRequest. The Pub/Sub system can remove the relevant messages 2074 // from the subscription. 2075 // 2076 // Acknowledging a message whose ack deadline has expired may succeed, 2077 // but such a message may be redelivered later. Acknowledging a message more 2078 // than once will not result in an error. 2079 Acknowledge(ctx context.Context, in *AcknowledgeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 2080 // Pulls messages from the server. Returns an empty list if there are no 2081 // messages available in the backlog. The server may return UNAVAILABLE if 2082 // there are too many concurrent pull requests pending for the given 2083 // subscription. 2084 Pull(ctx context.Context, in *PullRequest, opts ...grpc.CallOption) (*PullResponse, error) 2085 // Modifies the PushConfig for a specified subscription. 2086 // 2087 // This may be used to change a push subscription to a pull one (signified 2088 // by an empty PushConfig) or vice versa, or change the endpoint URL and other 2089 // attributes of a push subscription. Messages will accumulate for 2090 // delivery continuously through the call regardless of changes to the 2091 // PushConfig. 2092 ModifyPushConfig(ctx context.Context, in *ModifyPushConfigRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 2093} 2094 2095type subscriberClient struct { 2096 cc grpc.ClientConnInterface 2097} 2098 2099func NewSubscriberClient(cc grpc.ClientConnInterface) SubscriberClient { 2100 return &subscriberClient{cc} 2101} 2102 2103func (c *subscriberClient) CreateSubscription(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (*Subscription, error) { 2104 out := new(Subscription) 2105 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/CreateSubscription", in, out, opts...) 2106 if err != nil { 2107 return nil, err 2108 } 2109 return out, nil 2110} 2111 2112func (c *subscriberClient) GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error) { 2113 out := new(Subscription) 2114 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/GetSubscription", in, out, opts...) 2115 if err != nil { 2116 return nil, err 2117 } 2118 return out, nil 2119} 2120 2121func (c *subscriberClient) ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error) { 2122 out := new(ListSubscriptionsResponse) 2123 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/ListSubscriptions", in, out, opts...) 2124 if err != nil { 2125 return nil, err 2126 } 2127 return out, nil 2128} 2129 2130func (c *subscriberClient) DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 2131 out := new(emptypb.Empty) 2132 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/DeleteSubscription", in, out, opts...) 2133 if err != nil { 2134 return nil, err 2135 } 2136 return out, nil 2137} 2138 2139func (c *subscriberClient) ModifyAckDeadline(ctx context.Context, in *ModifyAckDeadlineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 2140 out := new(emptypb.Empty) 2141 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/ModifyAckDeadline", in, out, opts...) 2142 if err != nil { 2143 return nil, err 2144 } 2145 return out, nil 2146} 2147 2148func (c *subscriberClient) Acknowledge(ctx context.Context, in *AcknowledgeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 2149 out := new(emptypb.Empty) 2150 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/Acknowledge", in, out, opts...) 2151 if err != nil { 2152 return nil, err 2153 } 2154 return out, nil 2155} 2156 2157func (c *subscriberClient) Pull(ctx context.Context, in *PullRequest, opts ...grpc.CallOption) (*PullResponse, error) { 2158 out := new(PullResponse) 2159 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/Pull", in, out, opts...) 2160 if err != nil { 2161 return nil, err 2162 } 2163 return out, nil 2164} 2165 2166func (c *subscriberClient) ModifyPushConfig(ctx context.Context, in *ModifyPushConfigRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 2167 out := new(emptypb.Empty) 2168 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/ModifyPushConfig", in, out, opts...) 2169 if err != nil { 2170 return nil, err 2171 } 2172 return out, nil 2173} 2174 2175// SubscriberServer is the server API for Subscriber service. 2176type SubscriberServer interface { 2177 // Creates a subscription to a given topic for a given subscriber. 2178 // If the subscription already exists, returns ALREADY_EXISTS. 2179 // If the corresponding topic doesn't exist, returns NOT_FOUND. 2180 // 2181 // If the name is not provided in the request, the server will assign a random 2182 // name for this subscription on the same project as the topic. 2183 CreateSubscription(context.Context, *Subscription) (*Subscription, error) 2184 // Gets the configuration details of a subscription. 2185 GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error) 2186 // Lists matching subscriptions. 2187 ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error) 2188 // Deletes an existing subscription. All pending messages in the subscription 2189 // are immediately dropped. Calls to Pull after deletion will return 2190 // NOT_FOUND. After a subscription is deleted, a new one may be created with 2191 // the same name, but the new one has no association with the old 2192 // subscription, or its topic unless the same topic is specified. 2193 DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*emptypb.Empty, error) 2194 // Modifies the ack deadline for a specific message. This method is useful to 2195 // indicate that more time is needed to process a message by the subscriber, 2196 // or to make the message available for redelivery if the processing was 2197 // interrupted. 2198 ModifyAckDeadline(context.Context, *ModifyAckDeadlineRequest) (*emptypb.Empty, error) 2199 // Acknowledges the messages associated with the ack tokens in the 2200 // AcknowledgeRequest. The Pub/Sub system can remove the relevant messages 2201 // from the subscription. 2202 // 2203 // Acknowledging a message whose ack deadline has expired may succeed, 2204 // but such a message may be redelivered later. Acknowledging a message more 2205 // than once will not result in an error. 2206 Acknowledge(context.Context, *AcknowledgeRequest) (*emptypb.Empty, error) 2207 // Pulls messages from the server. Returns an empty list if there are no 2208 // messages available in the backlog. The server may return UNAVAILABLE if 2209 // there are too many concurrent pull requests pending for the given 2210 // subscription. 2211 Pull(context.Context, *PullRequest) (*PullResponse, error) 2212 // Modifies the PushConfig for a specified subscription. 2213 // 2214 // This may be used to change a push subscription to a pull one (signified 2215 // by an empty PushConfig) or vice versa, or change the endpoint URL and other 2216 // attributes of a push subscription. Messages will accumulate for 2217 // delivery continuously through the call regardless of changes to the 2218 // PushConfig. 2219 ModifyPushConfig(context.Context, *ModifyPushConfigRequest) (*emptypb.Empty, error) 2220} 2221 2222// UnimplementedSubscriberServer can be embedded to have forward compatible implementations. 2223type UnimplementedSubscriberServer struct { 2224} 2225 2226func (*UnimplementedSubscriberServer) CreateSubscription(context.Context, *Subscription) (*Subscription, error) { 2227 return nil, status.Errorf(codes.Unimplemented, "method CreateSubscription not implemented") 2228} 2229func (*UnimplementedSubscriberServer) GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error) { 2230 return nil, status.Errorf(codes.Unimplemented, "method GetSubscription not implemented") 2231} 2232func (*UnimplementedSubscriberServer) ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error) { 2233 return nil, status.Errorf(codes.Unimplemented, "method ListSubscriptions not implemented") 2234} 2235func (*UnimplementedSubscriberServer) DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*emptypb.Empty, error) { 2236 return nil, status.Errorf(codes.Unimplemented, "method DeleteSubscription not implemented") 2237} 2238func (*UnimplementedSubscriberServer) ModifyAckDeadline(context.Context, *ModifyAckDeadlineRequest) (*emptypb.Empty, error) { 2239 return nil, status.Errorf(codes.Unimplemented, "method ModifyAckDeadline not implemented") 2240} 2241func (*UnimplementedSubscriberServer) Acknowledge(context.Context, *AcknowledgeRequest) (*emptypb.Empty, error) { 2242 return nil, status.Errorf(codes.Unimplemented, "method Acknowledge not implemented") 2243} 2244func (*UnimplementedSubscriberServer) Pull(context.Context, *PullRequest) (*PullResponse, error) { 2245 return nil, status.Errorf(codes.Unimplemented, "method Pull not implemented") 2246} 2247func (*UnimplementedSubscriberServer) ModifyPushConfig(context.Context, *ModifyPushConfigRequest) (*emptypb.Empty, error) { 2248 return nil, status.Errorf(codes.Unimplemented, "method ModifyPushConfig not implemented") 2249} 2250 2251func RegisterSubscriberServer(s *grpc.Server, srv SubscriberServer) { 2252 s.RegisterService(&_Subscriber_serviceDesc, srv) 2253} 2254 2255func _Subscriber_CreateSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2256 in := new(Subscription) 2257 if err := dec(in); err != nil { 2258 return nil, err 2259 } 2260 if interceptor == nil { 2261 return srv.(SubscriberServer).CreateSubscription(ctx, in) 2262 } 2263 info := &grpc.UnaryServerInfo{ 2264 Server: srv, 2265 FullMethod: "/google.pubsub.v1beta2.Subscriber/CreateSubscription", 2266 } 2267 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2268 return srv.(SubscriberServer).CreateSubscription(ctx, req.(*Subscription)) 2269 } 2270 return interceptor(ctx, in, info, handler) 2271} 2272 2273func _Subscriber_GetSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2274 in := new(GetSubscriptionRequest) 2275 if err := dec(in); err != nil { 2276 return nil, err 2277 } 2278 if interceptor == nil { 2279 return srv.(SubscriberServer).GetSubscription(ctx, in) 2280 } 2281 info := &grpc.UnaryServerInfo{ 2282 Server: srv, 2283 FullMethod: "/google.pubsub.v1beta2.Subscriber/GetSubscription", 2284 } 2285 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2286 return srv.(SubscriberServer).GetSubscription(ctx, req.(*GetSubscriptionRequest)) 2287 } 2288 return interceptor(ctx, in, info, handler) 2289} 2290 2291func _Subscriber_ListSubscriptions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2292 in := new(ListSubscriptionsRequest) 2293 if err := dec(in); err != nil { 2294 return nil, err 2295 } 2296 if interceptor == nil { 2297 return srv.(SubscriberServer).ListSubscriptions(ctx, in) 2298 } 2299 info := &grpc.UnaryServerInfo{ 2300 Server: srv, 2301 FullMethod: "/google.pubsub.v1beta2.Subscriber/ListSubscriptions", 2302 } 2303 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2304 return srv.(SubscriberServer).ListSubscriptions(ctx, req.(*ListSubscriptionsRequest)) 2305 } 2306 return interceptor(ctx, in, info, handler) 2307} 2308 2309func _Subscriber_DeleteSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2310 in := new(DeleteSubscriptionRequest) 2311 if err := dec(in); err != nil { 2312 return nil, err 2313 } 2314 if interceptor == nil { 2315 return srv.(SubscriberServer).DeleteSubscription(ctx, in) 2316 } 2317 info := &grpc.UnaryServerInfo{ 2318 Server: srv, 2319 FullMethod: "/google.pubsub.v1beta2.Subscriber/DeleteSubscription", 2320 } 2321 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2322 return srv.(SubscriberServer).DeleteSubscription(ctx, req.(*DeleteSubscriptionRequest)) 2323 } 2324 return interceptor(ctx, in, info, handler) 2325} 2326 2327func _Subscriber_ModifyAckDeadline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2328 in := new(ModifyAckDeadlineRequest) 2329 if err := dec(in); err != nil { 2330 return nil, err 2331 } 2332 if interceptor == nil { 2333 return srv.(SubscriberServer).ModifyAckDeadline(ctx, in) 2334 } 2335 info := &grpc.UnaryServerInfo{ 2336 Server: srv, 2337 FullMethod: "/google.pubsub.v1beta2.Subscriber/ModifyAckDeadline", 2338 } 2339 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2340 return srv.(SubscriberServer).ModifyAckDeadline(ctx, req.(*ModifyAckDeadlineRequest)) 2341 } 2342 return interceptor(ctx, in, info, handler) 2343} 2344 2345func _Subscriber_Acknowledge_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2346 in := new(AcknowledgeRequest) 2347 if err := dec(in); err != nil { 2348 return nil, err 2349 } 2350 if interceptor == nil { 2351 return srv.(SubscriberServer).Acknowledge(ctx, in) 2352 } 2353 info := &grpc.UnaryServerInfo{ 2354 Server: srv, 2355 FullMethod: "/google.pubsub.v1beta2.Subscriber/Acknowledge", 2356 } 2357 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2358 return srv.(SubscriberServer).Acknowledge(ctx, req.(*AcknowledgeRequest)) 2359 } 2360 return interceptor(ctx, in, info, handler) 2361} 2362 2363func _Subscriber_Pull_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2364 in := new(PullRequest) 2365 if err := dec(in); err != nil { 2366 return nil, err 2367 } 2368 if interceptor == nil { 2369 return srv.(SubscriberServer).Pull(ctx, in) 2370 } 2371 info := &grpc.UnaryServerInfo{ 2372 Server: srv, 2373 FullMethod: "/google.pubsub.v1beta2.Subscriber/Pull", 2374 } 2375 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2376 return srv.(SubscriberServer).Pull(ctx, req.(*PullRequest)) 2377 } 2378 return interceptor(ctx, in, info, handler) 2379} 2380 2381func _Subscriber_ModifyPushConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2382 in := new(ModifyPushConfigRequest) 2383 if err := dec(in); err != nil { 2384 return nil, err 2385 } 2386 if interceptor == nil { 2387 return srv.(SubscriberServer).ModifyPushConfig(ctx, in) 2388 } 2389 info := &grpc.UnaryServerInfo{ 2390 Server: srv, 2391 FullMethod: "/google.pubsub.v1beta2.Subscriber/ModifyPushConfig", 2392 } 2393 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2394 return srv.(SubscriberServer).ModifyPushConfig(ctx, req.(*ModifyPushConfigRequest)) 2395 } 2396 return interceptor(ctx, in, info, handler) 2397} 2398 2399var _Subscriber_serviceDesc = grpc.ServiceDesc{ 2400 ServiceName: "google.pubsub.v1beta2.Subscriber", 2401 HandlerType: (*SubscriberServer)(nil), 2402 Methods: []grpc.MethodDesc{ 2403 { 2404 MethodName: "CreateSubscription", 2405 Handler: _Subscriber_CreateSubscription_Handler, 2406 }, 2407 { 2408 MethodName: "GetSubscription", 2409 Handler: _Subscriber_GetSubscription_Handler, 2410 }, 2411 { 2412 MethodName: "ListSubscriptions", 2413 Handler: _Subscriber_ListSubscriptions_Handler, 2414 }, 2415 { 2416 MethodName: "DeleteSubscription", 2417 Handler: _Subscriber_DeleteSubscription_Handler, 2418 }, 2419 { 2420 MethodName: "ModifyAckDeadline", 2421 Handler: _Subscriber_ModifyAckDeadline_Handler, 2422 }, 2423 { 2424 MethodName: "Acknowledge", 2425 Handler: _Subscriber_Acknowledge_Handler, 2426 }, 2427 { 2428 MethodName: "Pull", 2429 Handler: _Subscriber_Pull_Handler, 2430 }, 2431 { 2432 MethodName: "ModifyPushConfig", 2433 Handler: _Subscriber_ModifyPushConfig_Handler, 2434 }, 2435 }, 2436 Streams: []grpc.StreamDesc{}, 2437 Metadata: "google/pubsub/v1beta2/pubsub.proto", 2438} 2439 2440// PublisherClient is the client API for Publisher service. 2441// 2442// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 2443type PublisherClient interface { 2444 // Creates the given topic with the given name. 2445 CreateTopic(ctx context.Context, in *Topic, opts ...grpc.CallOption) (*Topic, error) 2446 // Adds one or more messages to the topic. Returns NOT_FOUND if the topic does 2447 // not exist. 2448 Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error) 2449 // Gets the configuration of a topic. 2450 GetTopic(ctx context.Context, in *GetTopicRequest, opts ...grpc.CallOption) (*Topic, error) 2451 // Lists matching topics. 2452 ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error) 2453 // Lists the name of the subscriptions for this topic. 2454 ListTopicSubscriptions(ctx context.Context, in *ListTopicSubscriptionsRequest, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error) 2455 // Deletes the topic with the given name. Returns NOT_FOUND if the topic does 2456 // not exist. After a topic is deleted, a new topic may be created with the 2457 // same name; this is an entirely new topic with none of the old 2458 // configuration or subscriptions. Existing subscriptions to this topic are 2459 // not deleted. 2460 DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) 2461} 2462 2463type publisherClient struct { 2464 cc grpc.ClientConnInterface 2465} 2466 2467func NewPublisherClient(cc grpc.ClientConnInterface) PublisherClient { 2468 return &publisherClient{cc} 2469} 2470 2471func (c *publisherClient) CreateTopic(ctx context.Context, in *Topic, opts ...grpc.CallOption) (*Topic, error) { 2472 out := new(Topic) 2473 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Publisher/CreateTopic", in, out, opts...) 2474 if err != nil { 2475 return nil, err 2476 } 2477 return out, nil 2478} 2479 2480func (c *publisherClient) Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error) { 2481 out := new(PublishResponse) 2482 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Publisher/Publish", in, out, opts...) 2483 if err != nil { 2484 return nil, err 2485 } 2486 return out, nil 2487} 2488 2489func (c *publisherClient) GetTopic(ctx context.Context, in *GetTopicRequest, opts ...grpc.CallOption) (*Topic, error) { 2490 out := new(Topic) 2491 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Publisher/GetTopic", in, out, opts...) 2492 if err != nil { 2493 return nil, err 2494 } 2495 return out, nil 2496} 2497 2498func (c *publisherClient) ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error) { 2499 out := new(ListTopicsResponse) 2500 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Publisher/ListTopics", in, out, opts...) 2501 if err != nil { 2502 return nil, err 2503 } 2504 return out, nil 2505} 2506 2507func (c *publisherClient) ListTopicSubscriptions(ctx context.Context, in *ListTopicSubscriptionsRequest, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error) { 2508 out := new(ListTopicSubscriptionsResponse) 2509 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Publisher/ListTopicSubscriptions", in, out, opts...) 2510 if err != nil { 2511 return nil, err 2512 } 2513 return out, nil 2514} 2515 2516func (c *publisherClient) DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { 2517 out := new(emptypb.Empty) 2518 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Publisher/DeleteTopic", in, out, opts...) 2519 if err != nil { 2520 return nil, err 2521 } 2522 return out, nil 2523} 2524 2525// PublisherServer is the server API for Publisher service. 2526type PublisherServer interface { 2527 // Creates the given topic with the given name. 2528 CreateTopic(context.Context, *Topic) (*Topic, error) 2529 // Adds one or more messages to the topic. Returns NOT_FOUND if the topic does 2530 // not exist. 2531 Publish(context.Context, *PublishRequest) (*PublishResponse, error) 2532 // Gets the configuration of a topic. 2533 GetTopic(context.Context, *GetTopicRequest) (*Topic, error) 2534 // Lists matching topics. 2535 ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error) 2536 // Lists the name of the subscriptions for this topic. 2537 ListTopicSubscriptions(context.Context, *ListTopicSubscriptionsRequest) (*ListTopicSubscriptionsResponse, error) 2538 // Deletes the topic with the given name. Returns NOT_FOUND if the topic does 2539 // not exist. After a topic is deleted, a new topic may be created with the 2540 // same name; this is an entirely new topic with none of the old 2541 // configuration or subscriptions. Existing subscriptions to this topic are 2542 // not deleted. 2543 DeleteTopic(context.Context, *DeleteTopicRequest) (*emptypb.Empty, error) 2544} 2545 2546// UnimplementedPublisherServer can be embedded to have forward compatible implementations. 2547type UnimplementedPublisherServer struct { 2548} 2549 2550func (*UnimplementedPublisherServer) CreateTopic(context.Context, *Topic) (*Topic, error) { 2551 return nil, status.Errorf(codes.Unimplemented, "method CreateTopic not implemented") 2552} 2553func (*UnimplementedPublisherServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error) { 2554 return nil, status.Errorf(codes.Unimplemented, "method Publish not implemented") 2555} 2556func (*UnimplementedPublisherServer) GetTopic(context.Context, *GetTopicRequest) (*Topic, error) { 2557 return nil, status.Errorf(codes.Unimplemented, "method GetTopic not implemented") 2558} 2559func (*UnimplementedPublisherServer) ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error) { 2560 return nil, status.Errorf(codes.Unimplemented, "method ListTopics not implemented") 2561} 2562func (*UnimplementedPublisherServer) ListTopicSubscriptions(context.Context, *ListTopicSubscriptionsRequest) (*ListTopicSubscriptionsResponse, error) { 2563 return nil, status.Errorf(codes.Unimplemented, "method ListTopicSubscriptions not implemented") 2564} 2565func (*UnimplementedPublisherServer) DeleteTopic(context.Context, *DeleteTopicRequest) (*emptypb.Empty, error) { 2566 return nil, status.Errorf(codes.Unimplemented, "method DeleteTopic not implemented") 2567} 2568 2569func RegisterPublisherServer(s *grpc.Server, srv PublisherServer) { 2570 s.RegisterService(&_Publisher_serviceDesc, srv) 2571} 2572 2573func _Publisher_CreateTopic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2574 in := new(Topic) 2575 if err := dec(in); err != nil { 2576 return nil, err 2577 } 2578 if interceptor == nil { 2579 return srv.(PublisherServer).CreateTopic(ctx, in) 2580 } 2581 info := &grpc.UnaryServerInfo{ 2582 Server: srv, 2583 FullMethod: "/google.pubsub.v1beta2.Publisher/CreateTopic", 2584 } 2585 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2586 return srv.(PublisherServer).CreateTopic(ctx, req.(*Topic)) 2587 } 2588 return interceptor(ctx, in, info, handler) 2589} 2590 2591func _Publisher_Publish_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2592 in := new(PublishRequest) 2593 if err := dec(in); err != nil { 2594 return nil, err 2595 } 2596 if interceptor == nil { 2597 return srv.(PublisherServer).Publish(ctx, in) 2598 } 2599 info := &grpc.UnaryServerInfo{ 2600 Server: srv, 2601 FullMethod: "/google.pubsub.v1beta2.Publisher/Publish", 2602 } 2603 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2604 return srv.(PublisherServer).Publish(ctx, req.(*PublishRequest)) 2605 } 2606 return interceptor(ctx, in, info, handler) 2607} 2608 2609func _Publisher_GetTopic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2610 in := new(GetTopicRequest) 2611 if err := dec(in); err != nil { 2612 return nil, err 2613 } 2614 if interceptor == nil { 2615 return srv.(PublisherServer).GetTopic(ctx, in) 2616 } 2617 info := &grpc.UnaryServerInfo{ 2618 Server: srv, 2619 FullMethod: "/google.pubsub.v1beta2.Publisher/GetTopic", 2620 } 2621 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2622 return srv.(PublisherServer).GetTopic(ctx, req.(*GetTopicRequest)) 2623 } 2624 return interceptor(ctx, in, info, handler) 2625} 2626 2627func _Publisher_ListTopics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2628 in := new(ListTopicsRequest) 2629 if err := dec(in); err != nil { 2630 return nil, err 2631 } 2632 if interceptor == nil { 2633 return srv.(PublisherServer).ListTopics(ctx, in) 2634 } 2635 info := &grpc.UnaryServerInfo{ 2636 Server: srv, 2637 FullMethod: "/google.pubsub.v1beta2.Publisher/ListTopics", 2638 } 2639 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2640 return srv.(PublisherServer).ListTopics(ctx, req.(*ListTopicsRequest)) 2641 } 2642 return interceptor(ctx, in, info, handler) 2643} 2644 2645func _Publisher_ListTopicSubscriptions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2646 in := new(ListTopicSubscriptionsRequest) 2647 if err := dec(in); err != nil { 2648 return nil, err 2649 } 2650 if interceptor == nil { 2651 return srv.(PublisherServer).ListTopicSubscriptions(ctx, in) 2652 } 2653 info := &grpc.UnaryServerInfo{ 2654 Server: srv, 2655 FullMethod: "/google.pubsub.v1beta2.Publisher/ListTopicSubscriptions", 2656 } 2657 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2658 return srv.(PublisherServer).ListTopicSubscriptions(ctx, req.(*ListTopicSubscriptionsRequest)) 2659 } 2660 return interceptor(ctx, in, info, handler) 2661} 2662 2663func _Publisher_DeleteTopic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2664 in := new(DeleteTopicRequest) 2665 if err := dec(in); err != nil { 2666 return nil, err 2667 } 2668 if interceptor == nil { 2669 return srv.(PublisherServer).DeleteTopic(ctx, in) 2670 } 2671 info := &grpc.UnaryServerInfo{ 2672 Server: srv, 2673 FullMethod: "/google.pubsub.v1beta2.Publisher/DeleteTopic", 2674 } 2675 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2676 return srv.(PublisherServer).DeleteTopic(ctx, req.(*DeleteTopicRequest)) 2677 } 2678 return interceptor(ctx, in, info, handler) 2679} 2680 2681var _Publisher_serviceDesc = grpc.ServiceDesc{ 2682 ServiceName: "google.pubsub.v1beta2.Publisher", 2683 HandlerType: (*PublisherServer)(nil), 2684 Methods: []grpc.MethodDesc{ 2685 { 2686 MethodName: "CreateTopic", 2687 Handler: _Publisher_CreateTopic_Handler, 2688 }, 2689 { 2690 MethodName: "Publish", 2691 Handler: _Publisher_Publish_Handler, 2692 }, 2693 { 2694 MethodName: "GetTopic", 2695 Handler: _Publisher_GetTopic_Handler, 2696 }, 2697 { 2698 MethodName: "ListTopics", 2699 Handler: _Publisher_ListTopics_Handler, 2700 }, 2701 { 2702 MethodName: "ListTopicSubscriptions", 2703 Handler: _Publisher_ListTopicSubscriptions_Handler, 2704 }, 2705 { 2706 MethodName: "DeleteTopic", 2707 Handler: _Publisher_DeleteTopic_Handler, 2708 }, 2709 }, 2710 Streams: []grpc.StreamDesc{}, 2711 Metadata: "google/pubsub/v1beta2/pubsub.proto", 2712} 2713