1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google/pubsub/v1beta2/pubsub.proto 3 4package pubsub 5 6import ( 7 context "context" 8 fmt "fmt" 9 math "math" 10 11 proto "github.com/golang/protobuf/proto" 12 empty "github.com/golang/protobuf/ptypes/empty" 13 grpc "google.golang.org/grpc" 14) 15 16// Reference imports to suppress errors if they are not otherwise used. 17var _ = proto.Marshal 18var _ = fmt.Errorf 19var _ = math.Inf 20 21// This is a compile-time assertion to ensure that this generated file 22// is compatible with the proto package it is being compiled against. 23// A compilation error at this line likely means your copy of the 24// proto package needs to be updated. 25const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 26 27// A topic resource. 28type Topic struct { 29 // Name of the topic. 30 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 31 XXX_NoUnkeyedLiteral struct{} `json:"-"` 32 XXX_unrecognized []byte `json:"-"` 33 XXX_sizecache int32 `json:"-"` 34} 35 36func (m *Topic) Reset() { *m = Topic{} } 37func (m *Topic) String() string { return proto.CompactTextString(m) } 38func (*Topic) ProtoMessage() {} 39func (*Topic) Descriptor() ([]byte, []int) { 40 return fileDescriptor_2b98a574e1e7c287, []int{0} 41} 42 43func (m *Topic) XXX_Unmarshal(b []byte) error { 44 return xxx_messageInfo_Topic.Unmarshal(m, b) 45} 46func (m *Topic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 47 return xxx_messageInfo_Topic.Marshal(b, m, deterministic) 48} 49func (m *Topic) XXX_Merge(src proto.Message) { 50 xxx_messageInfo_Topic.Merge(m, src) 51} 52func (m *Topic) XXX_Size() int { 53 return xxx_messageInfo_Topic.Size(m) 54} 55func (m *Topic) XXX_DiscardUnknown() { 56 xxx_messageInfo_Topic.DiscardUnknown(m) 57} 58 59var xxx_messageInfo_Topic proto.InternalMessageInfo 60 61func (m *Topic) GetName() string { 62 if m != nil { 63 return m.Name 64 } 65 return "" 66} 67 68// A message data and its attributes. 69type PubsubMessage struct { 70 // The message payload. For JSON requests, the value of this field must be 71 // base64-encoded. 72 Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` 73 // Optional attributes for this message. 74 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"` 75 // ID of this message assigned by the server at publication time. Guaranteed 76 // to be unique within the topic. This value may be read by a subscriber 77 // that receives a PubsubMessage via a Pull call or a push delivery. It must 78 // not be populated by a publisher in a Publish call. 79 MessageId string `protobuf:"bytes,3,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` 80 XXX_NoUnkeyedLiteral struct{} `json:"-"` 81 XXX_unrecognized []byte `json:"-"` 82 XXX_sizecache int32 `json:"-"` 83} 84 85func (m *PubsubMessage) Reset() { *m = PubsubMessage{} } 86func (m *PubsubMessage) String() string { return proto.CompactTextString(m) } 87func (*PubsubMessage) ProtoMessage() {} 88func (*PubsubMessage) Descriptor() ([]byte, []int) { 89 return fileDescriptor_2b98a574e1e7c287, []int{1} 90} 91 92func (m *PubsubMessage) XXX_Unmarshal(b []byte) error { 93 return xxx_messageInfo_PubsubMessage.Unmarshal(m, b) 94} 95func (m *PubsubMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 96 return xxx_messageInfo_PubsubMessage.Marshal(b, m, deterministic) 97} 98func (m *PubsubMessage) XXX_Merge(src proto.Message) { 99 xxx_messageInfo_PubsubMessage.Merge(m, src) 100} 101func (m *PubsubMessage) XXX_Size() int { 102 return xxx_messageInfo_PubsubMessage.Size(m) 103} 104func (m *PubsubMessage) XXX_DiscardUnknown() { 105 xxx_messageInfo_PubsubMessage.DiscardUnknown(m) 106} 107 108var xxx_messageInfo_PubsubMessage proto.InternalMessageInfo 109 110func (m *PubsubMessage) GetData() []byte { 111 if m != nil { 112 return m.Data 113 } 114 return nil 115} 116 117func (m *PubsubMessage) GetAttributes() map[string]string { 118 if m != nil { 119 return m.Attributes 120 } 121 return nil 122} 123 124func (m *PubsubMessage) GetMessageId() string { 125 if m != nil { 126 return m.MessageId 127 } 128 return "" 129} 130 131// Request for the GetTopic method. 132type GetTopicRequest struct { 133 // The name of the topic to get. 134 Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` 135 XXX_NoUnkeyedLiteral struct{} `json:"-"` 136 XXX_unrecognized []byte `json:"-"` 137 XXX_sizecache int32 `json:"-"` 138} 139 140func (m *GetTopicRequest) Reset() { *m = GetTopicRequest{} } 141func (m *GetTopicRequest) String() string { return proto.CompactTextString(m) } 142func (*GetTopicRequest) ProtoMessage() {} 143func (*GetTopicRequest) Descriptor() ([]byte, []int) { 144 return fileDescriptor_2b98a574e1e7c287, []int{2} 145} 146 147func (m *GetTopicRequest) XXX_Unmarshal(b []byte) error { 148 return xxx_messageInfo_GetTopicRequest.Unmarshal(m, b) 149} 150func (m *GetTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 151 return xxx_messageInfo_GetTopicRequest.Marshal(b, m, deterministic) 152} 153func (m *GetTopicRequest) XXX_Merge(src proto.Message) { 154 xxx_messageInfo_GetTopicRequest.Merge(m, src) 155} 156func (m *GetTopicRequest) XXX_Size() int { 157 return xxx_messageInfo_GetTopicRequest.Size(m) 158} 159func (m *GetTopicRequest) XXX_DiscardUnknown() { 160 xxx_messageInfo_GetTopicRequest.DiscardUnknown(m) 161} 162 163var xxx_messageInfo_GetTopicRequest proto.InternalMessageInfo 164 165func (m *GetTopicRequest) GetTopic() string { 166 if m != nil { 167 return m.Topic 168 } 169 return "" 170} 171 172// Request for the Publish method. 173type PublishRequest struct { 174 // The messages in the request will be published on this topic. 175 Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` 176 // The messages to publish. 177 Messages []*PubsubMessage `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"` 178 XXX_NoUnkeyedLiteral struct{} `json:"-"` 179 XXX_unrecognized []byte `json:"-"` 180 XXX_sizecache int32 `json:"-"` 181} 182 183func (m *PublishRequest) Reset() { *m = PublishRequest{} } 184func (m *PublishRequest) String() string { return proto.CompactTextString(m) } 185func (*PublishRequest) ProtoMessage() {} 186func (*PublishRequest) Descriptor() ([]byte, []int) { 187 return fileDescriptor_2b98a574e1e7c287, []int{3} 188} 189 190func (m *PublishRequest) XXX_Unmarshal(b []byte) error { 191 return xxx_messageInfo_PublishRequest.Unmarshal(m, b) 192} 193func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 194 return xxx_messageInfo_PublishRequest.Marshal(b, m, deterministic) 195} 196func (m *PublishRequest) XXX_Merge(src proto.Message) { 197 xxx_messageInfo_PublishRequest.Merge(m, src) 198} 199func (m *PublishRequest) XXX_Size() int { 200 return xxx_messageInfo_PublishRequest.Size(m) 201} 202func (m *PublishRequest) XXX_DiscardUnknown() { 203 xxx_messageInfo_PublishRequest.DiscardUnknown(m) 204} 205 206var xxx_messageInfo_PublishRequest proto.InternalMessageInfo 207 208func (m *PublishRequest) GetTopic() string { 209 if m != nil { 210 return m.Topic 211 } 212 return "" 213} 214 215func (m *PublishRequest) GetMessages() []*PubsubMessage { 216 if m != nil { 217 return m.Messages 218 } 219 return nil 220} 221 222// Response for the Publish method. 223type PublishResponse struct { 224 // The server-assigned ID of each published message, in the same order as 225 // the messages in the request. IDs are guaranteed to be unique within 226 // the topic. 227 MessageIds []string `protobuf:"bytes,1,rep,name=message_ids,json=messageIds,proto3" json:"message_ids,omitempty"` 228 XXX_NoUnkeyedLiteral struct{} `json:"-"` 229 XXX_unrecognized []byte `json:"-"` 230 XXX_sizecache int32 `json:"-"` 231} 232 233func (m *PublishResponse) Reset() { *m = PublishResponse{} } 234func (m *PublishResponse) String() string { return proto.CompactTextString(m) } 235func (*PublishResponse) ProtoMessage() {} 236func (*PublishResponse) Descriptor() ([]byte, []int) { 237 return fileDescriptor_2b98a574e1e7c287, []int{4} 238} 239 240func (m *PublishResponse) XXX_Unmarshal(b []byte) error { 241 return xxx_messageInfo_PublishResponse.Unmarshal(m, b) 242} 243func (m *PublishResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 244 return xxx_messageInfo_PublishResponse.Marshal(b, m, deterministic) 245} 246func (m *PublishResponse) XXX_Merge(src proto.Message) { 247 xxx_messageInfo_PublishResponse.Merge(m, src) 248} 249func (m *PublishResponse) XXX_Size() int { 250 return xxx_messageInfo_PublishResponse.Size(m) 251} 252func (m *PublishResponse) XXX_DiscardUnknown() { 253 xxx_messageInfo_PublishResponse.DiscardUnknown(m) 254} 255 256var xxx_messageInfo_PublishResponse proto.InternalMessageInfo 257 258func (m *PublishResponse) GetMessageIds() []string { 259 if m != nil { 260 return m.MessageIds 261 } 262 return nil 263} 264 265// Request for the ListTopics method. 266type ListTopicsRequest struct { 267 // The name of the cloud project that topics belong to. 268 Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` 269 // Maximum number of topics to return. 270 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 271 // The value returned by the last ListTopicsResponse; indicates that this is 272 // a continuation of a prior ListTopics call, and that the system should 273 // return the next page of data. 274 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 275 XXX_NoUnkeyedLiteral struct{} `json:"-"` 276 XXX_unrecognized []byte `json:"-"` 277 XXX_sizecache int32 `json:"-"` 278} 279 280func (m *ListTopicsRequest) Reset() { *m = ListTopicsRequest{} } 281func (m *ListTopicsRequest) String() string { return proto.CompactTextString(m) } 282func (*ListTopicsRequest) ProtoMessage() {} 283func (*ListTopicsRequest) Descriptor() ([]byte, []int) { 284 return fileDescriptor_2b98a574e1e7c287, []int{5} 285} 286 287func (m *ListTopicsRequest) XXX_Unmarshal(b []byte) error { 288 return xxx_messageInfo_ListTopicsRequest.Unmarshal(m, b) 289} 290func (m *ListTopicsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 291 return xxx_messageInfo_ListTopicsRequest.Marshal(b, m, deterministic) 292} 293func (m *ListTopicsRequest) XXX_Merge(src proto.Message) { 294 xxx_messageInfo_ListTopicsRequest.Merge(m, src) 295} 296func (m *ListTopicsRequest) XXX_Size() int { 297 return xxx_messageInfo_ListTopicsRequest.Size(m) 298} 299func (m *ListTopicsRequest) XXX_DiscardUnknown() { 300 xxx_messageInfo_ListTopicsRequest.DiscardUnknown(m) 301} 302 303var xxx_messageInfo_ListTopicsRequest proto.InternalMessageInfo 304 305func (m *ListTopicsRequest) GetProject() string { 306 if m != nil { 307 return m.Project 308 } 309 return "" 310} 311 312func (m *ListTopicsRequest) GetPageSize() int32 { 313 if m != nil { 314 return m.PageSize 315 } 316 return 0 317} 318 319func (m *ListTopicsRequest) GetPageToken() string { 320 if m != nil { 321 return m.PageToken 322 } 323 return "" 324} 325 326// Response for the ListTopics method. 327type ListTopicsResponse struct { 328 // The resulting topics. 329 Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"` 330 // If not empty, indicates that there may be more topics that match the 331 // request; this value should be passed in a new ListTopicsRequest. 332 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 333 XXX_NoUnkeyedLiteral struct{} `json:"-"` 334 XXX_unrecognized []byte `json:"-"` 335 XXX_sizecache int32 `json:"-"` 336} 337 338func (m *ListTopicsResponse) Reset() { *m = ListTopicsResponse{} } 339func (m *ListTopicsResponse) String() string { return proto.CompactTextString(m) } 340func (*ListTopicsResponse) ProtoMessage() {} 341func (*ListTopicsResponse) Descriptor() ([]byte, []int) { 342 return fileDescriptor_2b98a574e1e7c287, []int{6} 343} 344 345func (m *ListTopicsResponse) XXX_Unmarshal(b []byte) error { 346 return xxx_messageInfo_ListTopicsResponse.Unmarshal(m, b) 347} 348func (m *ListTopicsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 349 return xxx_messageInfo_ListTopicsResponse.Marshal(b, m, deterministic) 350} 351func (m *ListTopicsResponse) XXX_Merge(src proto.Message) { 352 xxx_messageInfo_ListTopicsResponse.Merge(m, src) 353} 354func (m *ListTopicsResponse) XXX_Size() int { 355 return xxx_messageInfo_ListTopicsResponse.Size(m) 356} 357func (m *ListTopicsResponse) XXX_DiscardUnknown() { 358 xxx_messageInfo_ListTopicsResponse.DiscardUnknown(m) 359} 360 361var xxx_messageInfo_ListTopicsResponse proto.InternalMessageInfo 362 363func (m *ListTopicsResponse) GetTopics() []*Topic { 364 if m != nil { 365 return m.Topics 366 } 367 return nil 368} 369 370func (m *ListTopicsResponse) GetNextPageToken() string { 371 if m != nil { 372 return m.NextPageToken 373 } 374 return "" 375} 376 377// Request for the ListTopicSubscriptions method. 378type ListTopicSubscriptionsRequest struct { 379 // The name of the topic that subscriptions are attached to. 380 Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` 381 // Maximum number of subscription names to return. 382 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 383 // The value returned by the last ListTopicSubscriptionsResponse; indicates 384 // that this is a continuation of a prior ListTopicSubscriptions call, and 385 // that the system should return the next page of data. 386 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 387 XXX_NoUnkeyedLiteral struct{} `json:"-"` 388 XXX_unrecognized []byte `json:"-"` 389 XXX_sizecache int32 `json:"-"` 390} 391 392func (m *ListTopicSubscriptionsRequest) Reset() { *m = ListTopicSubscriptionsRequest{} } 393func (m *ListTopicSubscriptionsRequest) String() string { return proto.CompactTextString(m) } 394func (*ListTopicSubscriptionsRequest) ProtoMessage() {} 395func (*ListTopicSubscriptionsRequest) Descriptor() ([]byte, []int) { 396 return fileDescriptor_2b98a574e1e7c287, []int{7} 397} 398 399func (m *ListTopicSubscriptionsRequest) XXX_Unmarshal(b []byte) error { 400 return xxx_messageInfo_ListTopicSubscriptionsRequest.Unmarshal(m, b) 401} 402func (m *ListTopicSubscriptionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 403 return xxx_messageInfo_ListTopicSubscriptionsRequest.Marshal(b, m, deterministic) 404} 405func (m *ListTopicSubscriptionsRequest) XXX_Merge(src proto.Message) { 406 xxx_messageInfo_ListTopicSubscriptionsRequest.Merge(m, src) 407} 408func (m *ListTopicSubscriptionsRequest) XXX_Size() int { 409 return xxx_messageInfo_ListTopicSubscriptionsRequest.Size(m) 410} 411func (m *ListTopicSubscriptionsRequest) XXX_DiscardUnknown() { 412 xxx_messageInfo_ListTopicSubscriptionsRequest.DiscardUnknown(m) 413} 414 415var xxx_messageInfo_ListTopicSubscriptionsRequest proto.InternalMessageInfo 416 417func (m *ListTopicSubscriptionsRequest) GetTopic() string { 418 if m != nil { 419 return m.Topic 420 } 421 return "" 422} 423 424func (m *ListTopicSubscriptionsRequest) GetPageSize() int32 { 425 if m != nil { 426 return m.PageSize 427 } 428 return 0 429} 430 431func (m *ListTopicSubscriptionsRequest) GetPageToken() string { 432 if m != nil { 433 return m.PageToken 434 } 435 return "" 436} 437 438// Response for the ListTopicSubscriptions method. 439type ListTopicSubscriptionsResponse struct { 440 // The names of the subscriptions that match the request. 441 Subscriptions []string `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` 442 // If not empty, indicates that there may be more subscriptions that match 443 // the request; this value should be passed in a new 444 // ListTopicSubscriptionsRequest to get more subscriptions. 445 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 446 XXX_NoUnkeyedLiteral struct{} `json:"-"` 447 XXX_unrecognized []byte `json:"-"` 448 XXX_sizecache int32 `json:"-"` 449} 450 451func (m *ListTopicSubscriptionsResponse) Reset() { *m = ListTopicSubscriptionsResponse{} } 452func (m *ListTopicSubscriptionsResponse) String() string { return proto.CompactTextString(m) } 453func (*ListTopicSubscriptionsResponse) ProtoMessage() {} 454func (*ListTopicSubscriptionsResponse) Descriptor() ([]byte, []int) { 455 return fileDescriptor_2b98a574e1e7c287, []int{8} 456} 457 458func (m *ListTopicSubscriptionsResponse) XXX_Unmarshal(b []byte) error { 459 return xxx_messageInfo_ListTopicSubscriptionsResponse.Unmarshal(m, b) 460} 461func (m *ListTopicSubscriptionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 462 return xxx_messageInfo_ListTopicSubscriptionsResponse.Marshal(b, m, deterministic) 463} 464func (m *ListTopicSubscriptionsResponse) XXX_Merge(src proto.Message) { 465 xxx_messageInfo_ListTopicSubscriptionsResponse.Merge(m, src) 466} 467func (m *ListTopicSubscriptionsResponse) XXX_Size() int { 468 return xxx_messageInfo_ListTopicSubscriptionsResponse.Size(m) 469} 470func (m *ListTopicSubscriptionsResponse) XXX_DiscardUnknown() { 471 xxx_messageInfo_ListTopicSubscriptionsResponse.DiscardUnknown(m) 472} 473 474var xxx_messageInfo_ListTopicSubscriptionsResponse proto.InternalMessageInfo 475 476func (m *ListTopicSubscriptionsResponse) GetSubscriptions() []string { 477 if m != nil { 478 return m.Subscriptions 479 } 480 return nil 481} 482 483func (m *ListTopicSubscriptionsResponse) GetNextPageToken() string { 484 if m != nil { 485 return m.NextPageToken 486 } 487 return "" 488} 489 490// Request for the DeleteTopic method. 491type DeleteTopicRequest struct { 492 // Name of the topic to delete. 493 Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` 494 XXX_NoUnkeyedLiteral struct{} `json:"-"` 495 XXX_unrecognized []byte `json:"-"` 496 XXX_sizecache int32 `json:"-"` 497} 498 499func (m *DeleteTopicRequest) Reset() { *m = DeleteTopicRequest{} } 500func (m *DeleteTopicRequest) String() string { return proto.CompactTextString(m) } 501func (*DeleteTopicRequest) ProtoMessage() {} 502func (*DeleteTopicRequest) Descriptor() ([]byte, []int) { 503 return fileDescriptor_2b98a574e1e7c287, []int{9} 504} 505 506func (m *DeleteTopicRequest) XXX_Unmarshal(b []byte) error { 507 return xxx_messageInfo_DeleteTopicRequest.Unmarshal(m, b) 508} 509func (m *DeleteTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 510 return xxx_messageInfo_DeleteTopicRequest.Marshal(b, m, deterministic) 511} 512func (m *DeleteTopicRequest) XXX_Merge(src proto.Message) { 513 xxx_messageInfo_DeleteTopicRequest.Merge(m, src) 514} 515func (m *DeleteTopicRequest) XXX_Size() int { 516 return xxx_messageInfo_DeleteTopicRequest.Size(m) 517} 518func (m *DeleteTopicRequest) XXX_DiscardUnknown() { 519 xxx_messageInfo_DeleteTopicRequest.DiscardUnknown(m) 520} 521 522var xxx_messageInfo_DeleteTopicRequest proto.InternalMessageInfo 523 524func (m *DeleteTopicRequest) GetTopic() string { 525 if m != nil { 526 return m.Topic 527 } 528 return "" 529} 530 531// A subscription resource. 532type Subscription struct { 533 // Name of the subscription. 534 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 535 // The name of the topic from which this subscription is receiving messages. 536 // This will be present if and only if the subscription has not been detached 537 // from its topic. 538 Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` 539 // If push delivery is used with this subscription, this field is 540 // used to configure it. An empty pushConfig signifies that the subscriber 541 // will pull and ack messages using API methods. 542 PushConfig *PushConfig `protobuf:"bytes,4,opt,name=push_config,json=pushConfig,proto3" json:"push_config,omitempty"` 543 // This value is the maximum time after a subscriber receives a message 544 // before the subscriber should acknowledge the message. After message 545 // delivery but before the ack deadline expires and before the message is 546 // acknowledged, it is an outstanding message and will not be delivered 547 // again during that time (on a best-effort basis). 548 // 549 // For pull delivery this value 550 // is used as the initial value for the ack deadline. It may be overridden 551 // for a specific message by calling ModifyAckDeadline. 552 // 553 // For push delivery, this value is also used to set the request timeout for 554 // the call to the push endpoint. 555 // 556 // If the subscriber never acknowledges the message, the Pub/Sub 557 // system will eventually redeliver the message. 558 AckDeadlineSeconds int32 `protobuf:"varint,5,opt,name=ack_deadline_seconds,json=ackDeadlineSeconds,proto3" json:"ack_deadline_seconds,omitempty"` 559 XXX_NoUnkeyedLiteral struct{} `json:"-"` 560 XXX_unrecognized []byte `json:"-"` 561 XXX_sizecache int32 `json:"-"` 562} 563 564func (m *Subscription) Reset() { *m = Subscription{} } 565func (m *Subscription) String() string { return proto.CompactTextString(m) } 566func (*Subscription) ProtoMessage() {} 567func (*Subscription) Descriptor() ([]byte, []int) { 568 return fileDescriptor_2b98a574e1e7c287, []int{10} 569} 570 571func (m *Subscription) XXX_Unmarshal(b []byte) error { 572 return xxx_messageInfo_Subscription.Unmarshal(m, b) 573} 574func (m *Subscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 575 return xxx_messageInfo_Subscription.Marshal(b, m, deterministic) 576} 577func (m *Subscription) XXX_Merge(src proto.Message) { 578 xxx_messageInfo_Subscription.Merge(m, src) 579} 580func (m *Subscription) XXX_Size() int { 581 return xxx_messageInfo_Subscription.Size(m) 582} 583func (m *Subscription) XXX_DiscardUnknown() { 584 xxx_messageInfo_Subscription.DiscardUnknown(m) 585} 586 587var xxx_messageInfo_Subscription proto.InternalMessageInfo 588 589func (m *Subscription) GetName() string { 590 if m != nil { 591 return m.Name 592 } 593 return "" 594} 595 596func (m *Subscription) GetTopic() string { 597 if m != nil { 598 return m.Topic 599 } 600 return "" 601} 602 603func (m *Subscription) GetPushConfig() *PushConfig { 604 if m != nil { 605 return m.PushConfig 606 } 607 return nil 608} 609 610func (m *Subscription) GetAckDeadlineSeconds() int32 { 611 if m != nil { 612 return m.AckDeadlineSeconds 613 } 614 return 0 615} 616 617// Configuration for a push delivery endpoint. 618type PushConfig struct { 619 // A URL locating the endpoint to which messages should be pushed. 620 // For example, a Webhook endpoint might use "https://example.com/push". 621 PushEndpoint string `protobuf:"bytes,1,opt,name=push_endpoint,json=pushEndpoint,proto3" json:"push_endpoint,omitempty"` 622 // Endpoint configuration attributes. 623 // 624 // Every endpoint has a set of API supported attributes that can be used to 625 // control different aspects of the message delivery. 626 // 627 // The currently supported attribute is `x-goog-version`, which you can 628 // use to change the format of the push message. This attribute 629 // indicates the version of the data expected by the endpoint. This 630 // controls the shape of the envelope (i.e. its fields and metadata). 631 // The endpoint version is based on the version of the Pub/Sub 632 // API. 633 // 634 // If not present during the CreateSubscription call, it will default to 635 // the version of the API used to make such call. If not present during a 636 // ModifyPushConfig call, its value will not be changed. GetSubscription 637 // calls will always return a valid version, even if the subscription was 638 // created without this attribute. 639 // 640 // The possible values for this attribute are: 641 // 642 // * `v1beta1`: uses the push format defined in the v1beta1 Pub/Sub API. 643 // * `v1beta2`: uses the push format defined in the v1beta2 Pub/Sub API. 644 // 645 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"` 646 XXX_NoUnkeyedLiteral struct{} `json:"-"` 647 XXX_unrecognized []byte `json:"-"` 648 XXX_sizecache int32 `json:"-"` 649} 650 651func (m *PushConfig) Reset() { *m = PushConfig{} } 652func (m *PushConfig) String() string { return proto.CompactTextString(m) } 653func (*PushConfig) ProtoMessage() {} 654func (*PushConfig) Descriptor() ([]byte, []int) { 655 return fileDescriptor_2b98a574e1e7c287, []int{11} 656} 657 658func (m *PushConfig) XXX_Unmarshal(b []byte) error { 659 return xxx_messageInfo_PushConfig.Unmarshal(m, b) 660} 661func (m *PushConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 662 return xxx_messageInfo_PushConfig.Marshal(b, m, deterministic) 663} 664func (m *PushConfig) XXX_Merge(src proto.Message) { 665 xxx_messageInfo_PushConfig.Merge(m, src) 666} 667func (m *PushConfig) XXX_Size() int { 668 return xxx_messageInfo_PushConfig.Size(m) 669} 670func (m *PushConfig) XXX_DiscardUnknown() { 671 xxx_messageInfo_PushConfig.DiscardUnknown(m) 672} 673 674var xxx_messageInfo_PushConfig proto.InternalMessageInfo 675 676func (m *PushConfig) GetPushEndpoint() string { 677 if m != nil { 678 return m.PushEndpoint 679 } 680 return "" 681} 682 683func (m *PushConfig) GetAttributes() map[string]string { 684 if m != nil { 685 return m.Attributes 686 } 687 return nil 688} 689 690// A message and its corresponding acknowledgment ID. 691type ReceivedMessage struct { 692 // This ID can be used to acknowledge the received message. 693 AckId string `protobuf:"bytes,1,opt,name=ack_id,json=ackId,proto3" json:"ack_id,omitempty"` 694 // The message. 695 Message *PubsubMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` 696 XXX_NoUnkeyedLiteral struct{} `json:"-"` 697 XXX_unrecognized []byte `json:"-"` 698 XXX_sizecache int32 `json:"-"` 699} 700 701func (m *ReceivedMessage) Reset() { *m = ReceivedMessage{} } 702func (m *ReceivedMessage) String() string { return proto.CompactTextString(m) } 703func (*ReceivedMessage) ProtoMessage() {} 704func (*ReceivedMessage) Descriptor() ([]byte, []int) { 705 return fileDescriptor_2b98a574e1e7c287, []int{12} 706} 707 708func (m *ReceivedMessage) XXX_Unmarshal(b []byte) error { 709 return xxx_messageInfo_ReceivedMessage.Unmarshal(m, b) 710} 711func (m *ReceivedMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 712 return xxx_messageInfo_ReceivedMessage.Marshal(b, m, deterministic) 713} 714func (m *ReceivedMessage) XXX_Merge(src proto.Message) { 715 xxx_messageInfo_ReceivedMessage.Merge(m, src) 716} 717func (m *ReceivedMessage) XXX_Size() int { 718 return xxx_messageInfo_ReceivedMessage.Size(m) 719} 720func (m *ReceivedMessage) XXX_DiscardUnknown() { 721 xxx_messageInfo_ReceivedMessage.DiscardUnknown(m) 722} 723 724var xxx_messageInfo_ReceivedMessage proto.InternalMessageInfo 725 726func (m *ReceivedMessage) GetAckId() string { 727 if m != nil { 728 return m.AckId 729 } 730 return "" 731} 732 733func (m *ReceivedMessage) GetMessage() *PubsubMessage { 734 if m != nil { 735 return m.Message 736 } 737 return nil 738} 739 740// Request for the GetSubscription method. 741type GetSubscriptionRequest struct { 742 // The name of the subscription to get. 743 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 744 XXX_NoUnkeyedLiteral struct{} `json:"-"` 745 XXX_unrecognized []byte `json:"-"` 746 XXX_sizecache int32 `json:"-"` 747} 748 749func (m *GetSubscriptionRequest) Reset() { *m = GetSubscriptionRequest{} } 750func (m *GetSubscriptionRequest) String() string { return proto.CompactTextString(m) } 751func (*GetSubscriptionRequest) ProtoMessage() {} 752func (*GetSubscriptionRequest) Descriptor() ([]byte, []int) { 753 return fileDescriptor_2b98a574e1e7c287, []int{13} 754} 755 756func (m *GetSubscriptionRequest) XXX_Unmarshal(b []byte) error { 757 return xxx_messageInfo_GetSubscriptionRequest.Unmarshal(m, b) 758} 759func (m *GetSubscriptionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 760 return xxx_messageInfo_GetSubscriptionRequest.Marshal(b, m, deterministic) 761} 762func (m *GetSubscriptionRequest) XXX_Merge(src proto.Message) { 763 xxx_messageInfo_GetSubscriptionRequest.Merge(m, src) 764} 765func (m *GetSubscriptionRequest) XXX_Size() int { 766 return xxx_messageInfo_GetSubscriptionRequest.Size(m) 767} 768func (m *GetSubscriptionRequest) XXX_DiscardUnknown() { 769 xxx_messageInfo_GetSubscriptionRequest.DiscardUnknown(m) 770} 771 772var xxx_messageInfo_GetSubscriptionRequest proto.InternalMessageInfo 773 774func (m *GetSubscriptionRequest) GetSubscription() string { 775 if m != nil { 776 return m.Subscription 777 } 778 return "" 779} 780 781// Request for the ListSubscriptions method. 782type ListSubscriptionsRequest struct { 783 // The name of the cloud project that subscriptions belong to. 784 Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` 785 // Maximum number of subscriptions to return. 786 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 787 // The value returned by the last ListSubscriptionsResponse; indicates that 788 // this is a continuation of a prior ListSubscriptions call, and that the 789 // system should return the next page of data. 790 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 791 XXX_NoUnkeyedLiteral struct{} `json:"-"` 792 XXX_unrecognized []byte `json:"-"` 793 XXX_sizecache int32 `json:"-"` 794} 795 796func (m *ListSubscriptionsRequest) Reset() { *m = ListSubscriptionsRequest{} } 797func (m *ListSubscriptionsRequest) String() string { return proto.CompactTextString(m) } 798func (*ListSubscriptionsRequest) ProtoMessage() {} 799func (*ListSubscriptionsRequest) Descriptor() ([]byte, []int) { 800 return fileDescriptor_2b98a574e1e7c287, []int{14} 801} 802 803func (m *ListSubscriptionsRequest) XXX_Unmarshal(b []byte) error { 804 return xxx_messageInfo_ListSubscriptionsRequest.Unmarshal(m, b) 805} 806func (m *ListSubscriptionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 807 return xxx_messageInfo_ListSubscriptionsRequest.Marshal(b, m, deterministic) 808} 809func (m *ListSubscriptionsRequest) XXX_Merge(src proto.Message) { 810 xxx_messageInfo_ListSubscriptionsRequest.Merge(m, src) 811} 812func (m *ListSubscriptionsRequest) XXX_Size() int { 813 return xxx_messageInfo_ListSubscriptionsRequest.Size(m) 814} 815func (m *ListSubscriptionsRequest) XXX_DiscardUnknown() { 816 xxx_messageInfo_ListSubscriptionsRequest.DiscardUnknown(m) 817} 818 819var xxx_messageInfo_ListSubscriptionsRequest proto.InternalMessageInfo 820 821func (m *ListSubscriptionsRequest) GetProject() string { 822 if m != nil { 823 return m.Project 824 } 825 return "" 826} 827 828func (m *ListSubscriptionsRequest) GetPageSize() int32 { 829 if m != nil { 830 return m.PageSize 831 } 832 return 0 833} 834 835func (m *ListSubscriptionsRequest) GetPageToken() string { 836 if m != nil { 837 return m.PageToken 838 } 839 return "" 840} 841 842// Response for the ListSubscriptions method. 843type ListSubscriptionsResponse struct { 844 // The subscriptions that match the request. 845 Subscriptions []*Subscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` 846 // If not empty, indicates that there may be more subscriptions that match 847 // the request; this value should be passed in a new ListSubscriptionsRequest 848 // to get more subscriptions. 849 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 850 XXX_NoUnkeyedLiteral struct{} `json:"-"` 851 XXX_unrecognized []byte `json:"-"` 852 XXX_sizecache int32 `json:"-"` 853} 854 855func (m *ListSubscriptionsResponse) Reset() { *m = ListSubscriptionsResponse{} } 856func (m *ListSubscriptionsResponse) String() string { return proto.CompactTextString(m) } 857func (*ListSubscriptionsResponse) ProtoMessage() {} 858func (*ListSubscriptionsResponse) Descriptor() ([]byte, []int) { 859 return fileDescriptor_2b98a574e1e7c287, []int{15} 860} 861 862func (m *ListSubscriptionsResponse) XXX_Unmarshal(b []byte) error { 863 return xxx_messageInfo_ListSubscriptionsResponse.Unmarshal(m, b) 864} 865func (m *ListSubscriptionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 866 return xxx_messageInfo_ListSubscriptionsResponse.Marshal(b, m, deterministic) 867} 868func (m *ListSubscriptionsResponse) XXX_Merge(src proto.Message) { 869 xxx_messageInfo_ListSubscriptionsResponse.Merge(m, src) 870} 871func (m *ListSubscriptionsResponse) XXX_Size() int { 872 return xxx_messageInfo_ListSubscriptionsResponse.Size(m) 873} 874func (m *ListSubscriptionsResponse) XXX_DiscardUnknown() { 875 xxx_messageInfo_ListSubscriptionsResponse.DiscardUnknown(m) 876} 877 878var xxx_messageInfo_ListSubscriptionsResponse proto.InternalMessageInfo 879 880func (m *ListSubscriptionsResponse) GetSubscriptions() []*Subscription { 881 if m != nil { 882 return m.Subscriptions 883 } 884 return nil 885} 886 887func (m *ListSubscriptionsResponse) GetNextPageToken() string { 888 if m != nil { 889 return m.NextPageToken 890 } 891 return "" 892} 893 894// Request for the DeleteSubscription method. 895type DeleteSubscriptionRequest struct { 896 // The subscription to delete. 897 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 898 XXX_NoUnkeyedLiteral struct{} `json:"-"` 899 XXX_unrecognized []byte `json:"-"` 900 XXX_sizecache int32 `json:"-"` 901} 902 903func (m *DeleteSubscriptionRequest) Reset() { *m = DeleteSubscriptionRequest{} } 904func (m *DeleteSubscriptionRequest) String() string { return proto.CompactTextString(m) } 905func (*DeleteSubscriptionRequest) ProtoMessage() {} 906func (*DeleteSubscriptionRequest) Descriptor() ([]byte, []int) { 907 return fileDescriptor_2b98a574e1e7c287, []int{16} 908} 909 910func (m *DeleteSubscriptionRequest) XXX_Unmarshal(b []byte) error { 911 return xxx_messageInfo_DeleteSubscriptionRequest.Unmarshal(m, b) 912} 913func (m *DeleteSubscriptionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 914 return xxx_messageInfo_DeleteSubscriptionRequest.Marshal(b, m, deterministic) 915} 916func (m *DeleteSubscriptionRequest) XXX_Merge(src proto.Message) { 917 xxx_messageInfo_DeleteSubscriptionRequest.Merge(m, src) 918} 919func (m *DeleteSubscriptionRequest) XXX_Size() int { 920 return xxx_messageInfo_DeleteSubscriptionRequest.Size(m) 921} 922func (m *DeleteSubscriptionRequest) XXX_DiscardUnknown() { 923 xxx_messageInfo_DeleteSubscriptionRequest.DiscardUnknown(m) 924} 925 926var xxx_messageInfo_DeleteSubscriptionRequest proto.InternalMessageInfo 927 928func (m *DeleteSubscriptionRequest) GetSubscription() string { 929 if m != nil { 930 return m.Subscription 931 } 932 return "" 933} 934 935// Request for the ModifyPushConfig method. 936type ModifyPushConfigRequest struct { 937 // The name of the subscription. 938 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 939 // The push configuration for future deliveries. 940 // 941 // An empty pushConfig indicates that the Pub/Sub system should 942 // stop pushing messages from the given subscription and allow 943 // messages to be pulled and acknowledged - effectively pausing 944 // the subscription if Pull is not called. 945 PushConfig *PushConfig `protobuf:"bytes,2,opt,name=push_config,json=pushConfig,proto3" json:"push_config,omitempty"` 946 XXX_NoUnkeyedLiteral struct{} `json:"-"` 947 XXX_unrecognized []byte `json:"-"` 948 XXX_sizecache int32 `json:"-"` 949} 950 951func (m *ModifyPushConfigRequest) Reset() { *m = ModifyPushConfigRequest{} } 952func (m *ModifyPushConfigRequest) String() string { return proto.CompactTextString(m) } 953func (*ModifyPushConfigRequest) ProtoMessage() {} 954func (*ModifyPushConfigRequest) Descriptor() ([]byte, []int) { 955 return fileDescriptor_2b98a574e1e7c287, []int{17} 956} 957 958func (m *ModifyPushConfigRequest) XXX_Unmarshal(b []byte) error { 959 return xxx_messageInfo_ModifyPushConfigRequest.Unmarshal(m, b) 960} 961func (m *ModifyPushConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 962 return xxx_messageInfo_ModifyPushConfigRequest.Marshal(b, m, deterministic) 963} 964func (m *ModifyPushConfigRequest) XXX_Merge(src proto.Message) { 965 xxx_messageInfo_ModifyPushConfigRequest.Merge(m, src) 966} 967func (m *ModifyPushConfigRequest) XXX_Size() int { 968 return xxx_messageInfo_ModifyPushConfigRequest.Size(m) 969} 970func (m *ModifyPushConfigRequest) XXX_DiscardUnknown() { 971 xxx_messageInfo_ModifyPushConfigRequest.DiscardUnknown(m) 972} 973 974var xxx_messageInfo_ModifyPushConfigRequest proto.InternalMessageInfo 975 976func (m *ModifyPushConfigRequest) GetSubscription() string { 977 if m != nil { 978 return m.Subscription 979 } 980 return "" 981} 982 983func (m *ModifyPushConfigRequest) GetPushConfig() *PushConfig { 984 if m != nil { 985 return m.PushConfig 986 } 987 return nil 988} 989 990// Request for the Pull method. 991type PullRequest struct { 992 // The subscription from which messages should be pulled. 993 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 994 // If this is specified as true the system will respond immediately even if 995 // it is not able to return a message in the Pull response. Otherwise the 996 // system is allowed to wait until at least one message is available rather 997 // than returning no messages. The client may cancel the request if it does 998 // not wish to wait any longer for the response. 999 ReturnImmediately bool `protobuf:"varint,2,opt,name=return_immediately,json=returnImmediately,proto3" json:"return_immediately,omitempty"` 1000 // The maximum number of messages returned for this request. The Pub/Sub 1001 // system may return fewer than the number specified. 1002 MaxMessages int32 `protobuf:"varint,3,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"` 1003 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1004 XXX_unrecognized []byte `json:"-"` 1005 XXX_sizecache int32 `json:"-"` 1006} 1007 1008func (m *PullRequest) Reset() { *m = PullRequest{} } 1009func (m *PullRequest) String() string { return proto.CompactTextString(m) } 1010func (*PullRequest) ProtoMessage() {} 1011func (*PullRequest) Descriptor() ([]byte, []int) { 1012 return fileDescriptor_2b98a574e1e7c287, []int{18} 1013} 1014 1015func (m *PullRequest) XXX_Unmarshal(b []byte) error { 1016 return xxx_messageInfo_PullRequest.Unmarshal(m, b) 1017} 1018func (m *PullRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1019 return xxx_messageInfo_PullRequest.Marshal(b, m, deterministic) 1020} 1021func (m *PullRequest) XXX_Merge(src proto.Message) { 1022 xxx_messageInfo_PullRequest.Merge(m, src) 1023} 1024func (m *PullRequest) XXX_Size() int { 1025 return xxx_messageInfo_PullRequest.Size(m) 1026} 1027func (m *PullRequest) XXX_DiscardUnknown() { 1028 xxx_messageInfo_PullRequest.DiscardUnknown(m) 1029} 1030 1031var xxx_messageInfo_PullRequest proto.InternalMessageInfo 1032 1033func (m *PullRequest) GetSubscription() string { 1034 if m != nil { 1035 return m.Subscription 1036 } 1037 return "" 1038} 1039 1040func (m *PullRequest) GetReturnImmediately() bool { 1041 if m != nil { 1042 return m.ReturnImmediately 1043 } 1044 return false 1045} 1046 1047func (m *PullRequest) GetMaxMessages() int32 { 1048 if m != nil { 1049 return m.MaxMessages 1050 } 1051 return 0 1052} 1053 1054// Response for the Pull method. 1055type PullResponse struct { 1056 // Received Pub/Sub messages. The Pub/Sub system will return zero messages if 1057 // there are no more available in the backlog. The Pub/Sub system may return 1058 // fewer than the maxMessages requested even if there are more messages 1059 // available in the backlog. 1060 ReceivedMessages []*ReceivedMessage `protobuf:"bytes,1,rep,name=received_messages,json=receivedMessages,proto3" json:"received_messages,omitempty"` 1061 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1062 XXX_unrecognized []byte `json:"-"` 1063 XXX_sizecache int32 `json:"-"` 1064} 1065 1066func (m *PullResponse) Reset() { *m = PullResponse{} } 1067func (m *PullResponse) String() string { return proto.CompactTextString(m) } 1068func (*PullResponse) ProtoMessage() {} 1069func (*PullResponse) Descriptor() ([]byte, []int) { 1070 return fileDescriptor_2b98a574e1e7c287, []int{19} 1071} 1072 1073func (m *PullResponse) XXX_Unmarshal(b []byte) error { 1074 return xxx_messageInfo_PullResponse.Unmarshal(m, b) 1075} 1076func (m *PullResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1077 return xxx_messageInfo_PullResponse.Marshal(b, m, deterministic) 1078} 1079func (m *PullResponse) XXX_Merge(src proto.Message) { 1080 xxx_messageInfo_PullResponse.Merge(m, src) 1081} 1082func (m *PullResponse) XXX_Size() int { 1083 return xxx_messageInfo_PullResponse.Size(m) 1084} 1085func (m *PullResponse) XXX_DiscardUnknown() { 1086 xxx_messageInfo_PullResponse.DiscardUnknown(m) 1087} 1088 1089var xxx_messageInfo_PullResponse proto.InternalMessageInfo 1090 1091func (m *PullResponse) GetReceivedMessages() []*ReceivedMessage { 1092 if m != nil { 1093 return m.ReceivedMessages 1094 } 1095 return nil 1096} 1097 1098// Request for the ModifyAckDeadline method. 1099type ModifyAckDeadlineRequest struct { 1100 // The name of the subscription. 1101 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 1102 // The acknowledgment ID. 1103 AckId string `protobuf:"bytes,2,opt,name=ack_id,json=ackId,proto3" json:"ack_id,omitempty"` 1104 // The new ack deadline with respect to the time this request was sent to the 1105 // Pub/Sub system. Must be >= 0. For example, if the value is 10, the new ack 1106 // deadline will expire 10 seconds after the ModifyAckDeadline call was made. 1107 // Specifying zero may immediately make the message available for another pull 1108 // request. 1109 AckDeadlineSeconds int32 `protobuf:"varint,3,opt,name=ack_deadline_seconds,json=ackDeadlineSeconds,proto3" json:"ack_deadline_seconds,omitempty"` 1110 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1111 XXX_unrecognized []byte `json:"-"` 1112 XXX_sizecache int32 `json:"-"` 1113} 1114 1115func (m *ModifyAckDeadlineRequest) Reset() { *m = ModifyAckDeadlineRequest{} } 1116func (m *ModifyAckDeadlineRequest) String() string { return proto.CompactTextString(m) } 1117func (*ModifyAckDeadlineRequest) ProtoMessage() {} 1118func (*ModifyAckDeadlineRequest) Descriptor() ([]byte, []int) { 1119 return fileDescriptor_2b98a574e1e7c287, []int{20} 1120} 1121 1122func (m *ModifyAckDeadlineRequest) XXX_Unmarshal(b []byte) error { 1123 return xxx_messageInfo_ModifyAckDeadlineRequest.Unmarshal(m, b) 1124} 1125func (m *ModifyAckDeadlineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1126 return xxx_messageInfo_ModifyAckDeadlineRequest.Marshal(b, m, deterministic) 1127} 1128func (m *ModifyAckDeadlineRequest) XXX_Merge(src proto.Message) { 1129 xxx_messageInfo_ModifyAckDeadlineRequest.Merge(m, src) 1130} 1131func (m *ModifyAckDeadlineRequest) XXX_Size() int { 1132 return xxx_messageInfo_ModifyAckDeadlineRequest.Size(m) 1133} 1134func (m *ModifyAckDeadlineRequest) XXX_DiscardUnknown() { 1135 xxx_messageInfo_ModifyAckDeadlineRequest.DiscardUnknown(m) 1136} 1137 1138var xxx_messageInfo_ModifyAckDeadlineRequest proto.InternalMessageInfo 1139 1140func (m *ModifyAckDeadlineRequest) GetSubscription() string { 1141 if m != nil { 1142 return m.Subscription 1143 } 1144 return "" 1145} 1146 1147func (m *ModifyAckDeadlineRequest) GetAckId() string { 1148 if m != nil { 1149 return m.AckId 1150 } 1151 return "" 1152} 1153 1154func (m *ModifyAckDeadlineRequest) GetAckDeadlineSeconds() int32 { 1155 if m != nil { 1156 return m.AckDeadlineSeconds 1157 } 1158 return 0 1159} 1160 1161// Request for the Acknowledge method. 1162type AcknowledgeRequest struct { 1163 // The subscription whose message is being acknowledged. 1164 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 1165 // The acknowledgment ID for the messages being acknowledged that was returned 1166 // by the Pub/Sub system in the Pull response. Must not be empty. 1167 AckIds []string `protobuf:"bytes,2,rep,name=ack_ids,json=ackIds,proto3" json:"ack_ids,omitempty"` 1168 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1169 XXX_unrecognized []byte `json:"-"` 1170 XXX_sizecache int32 `json:"-"` 1171} 1172 1173func (m *AcknowledgeRequest) Reset() { *m = AcknowledgeRequest{} } 1174func (m *AcknowledgeRequest) String() string { return proto.CompactTextString(m) } 1175func (*AcknowledgeRequest) ProtoMessage() {} 1176func (*AcknowledgeRequest) Descriptor() ([]byte, []int) { 1177 return fileDescriptor_2b98a574e1e7c287, []int{21} 1178} 1179 1180func (m *AcknowledgeRequest) XXX_Unmarshal(b []byte) error { 1181 return xxx_messageInfo_AcknowledgeRequest.Unmarshal(m, b) 1182} 1183func (m *AcknowledgeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1184 return xxx_messageInfo_AcknowledgeRequest.Marshal(b, m, deterministic) 1185} 1186func (m *AcknowledgeRequest) XXX_Merge(src proto.Message) { 1187 xxx_messageInfo_AcknowledgeRequest.Merge(m, src) 1188} 1189func (m *AcknowledgeRequest) XXX_Size() int { 1190 return xxx_messageInfo_AcknowledgeRequest.Size(m) 1191} 1192func (m *AcknowledgeRequest) XXX_DiscardUnknown() { 1193 xxx_messageInfo_AcknowledgeRequest.DiscardUnknown(m) 1194} 1195 1196var xxx_messageInfo_AcknowledgeRequest proto.InternalMessageInfo 1197 1198func (m *AcknowledgeRequest) GetSubscription() string { 1199 if m != nil { 1200 return m.Subscription 1201 } 1202 return "" 1203} 1204 1205func (m *AcknowledgeRequest) GetAckIds() []string { 1206 if m != nil { 1207 return m.AckIds 1208 } 1209 return nil 1210} 1211 1212func init() { 1213 proto.RegisterType((*Topic)(nil), "google.pubsub.v1beta2.Topic") 1214 proto.RegisterType((*PubsubMessage)(nil), "google.pubsub.v1beta2.PubsubMessage") 1215 proto.RegisterMapType((map[string]string)(nil), "google.pubsub.v1beta2.PubsubMessage.AttributesEntry") 1216 proto.RegisterType((*GetTopicRequest)(nil), "google.pubsub.v1beta2.GetTopicRequest") 1217 proto.RegisterType((*PublishRequest)(nil), "google.pubsub.v1beta2.PublishRequest") 1218 proto.RegisterType((*PublishResponse)(nil), "google.pubsub.v1beta2.PublishResponse") 1219 proto.RegisterType((*ListTopicsRequest)(nil), "google.pubsub.v1beta2.ListTopicsRequest") 1220 proto.RegisterType((*ListTopicsResponse)(nil), "google.pubsub.v1beta2.ListTopicsResponse") 1221 proto.RegisterType((*ListTopicSubscriptionsRequest)(nil), "google.pubsub.v1beta2.ListTopicSubscriptionsRequest") 1222 proto.RegisterType((*ListTopicSubscriptionsResponse)(nil), "google.pubsub.v1beta2.ListTopicSubscriptionsResponse") 1223 proto.RegisterType((*DeleteTopicRequest)(nil), "google.pubsub.v1beta2.DeleteTopicRequest") 1224 proto.RegisterType((*Subscription)(nil), "google.pubsub.v1beta2.Subscription") 1225 proto.RegisterType((*PushConfig)(nil), "google.pubsub.v1beta2.PushConfig") 1226 proto.RegisterMapType((map[string]string)(nil), "google.pubsub.v1beta2.PushConfig.AttributesEntry") 1227 proto.RegisterType((*ReceivedMessage)(nil), "google.pubsub.v1beta2.ReceivedMessage") 1228 proto.RegisterType((*GetSubscriptionRequest)(nil), "google.pubsub.v1beta2.GetSubscriptionRequest") 1229 proto.RegisterType((*ListSubscriptionsRequest)(nil), "google.pubsub.v1beta2.ListSubscriptionsRequest") 1230 proto.RegisterType((*ListSubscriptionsResponse)(nil), "google.pubsub.v1beta2.ListSubscriptionsResponse") 1231 proto.RegisterType((*DeleteSubscriptionRequest)(nil), "google.pubsub.v1beta2.DeleteSubscriptionRequest") 1232 proto.RegisterType((*ModifyPushConfigRequest)(nil), "google.pubsub.v1beta2.ModifyPushConfigRequest") 1233 proto.RegisterType((*PullRequest)(nil), "google.pubsub.v1beta2.PullRequest") 1234 proto.RegisterType((*PullResponse)(nil), "google.pubsub.v1beta2.PullResponse") 1235 proto.RegisterType((*ModifyAckDeadlineRequest)(nil), "google.pubsub.v1beta2.ModifyAckDeadlineRequest") 1236 proto.RegisterType((*AcknowledgeRequest)(nil), "google.pubsub.v1beta2.AcknowledgeRequest") 1237} 1238 1239func init() { proto.RegisterFile("google/pubsub/v1beta2/pubsub.proto", fileDescriptor_2b98a574e1e7c287) } 1240 1241var fileDescriptor_2b98a574e1e7c287 = []byte{ 1242 // 1107 bytes of a gzipped FileDescriptorProto 1243 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x57, 0x5f, 0x6f, 0xdb, 0x54, 1244 0x14, 0x97, 0x93, 0xfe, 0xcb, 0x71, 0x4a, 0xda, 0xab, 0xad, 0x73, 0x53, 0x06, 0x9d, 0x37, 0x4a, 1245 0x86, 0xb4, 0x64, 0x0b, 0x45, 0x42, 0x8c, 0x7f, 0xed, 0x56, 0x4d, 0x91, 0xa8, 0xc8, 0xdc, 0x3e, 1246 0xa0, 0x09, 0x2d, 0x72, 0xec, 0x5b, 0xc7, 0xc4, 0xb1, 0x3d, 0x5f, 0xbb, 0x34, 0x7b, 0x43, 0x08, 1247 0xc1, 0x13, 0x1f, 0x85, 0xaf, 0xc0, 0x03, 0x1f, 0x82, 0xaf, 0x83, 0x7c, 0xef, 0xb5, 0x63, 0xa7, 1248 0xbe, 0xa9, 0xdb, 0x89, 0x37, 0xdf, 0x73, 0xcf, 0xff, 0x73, 0x7e, 0xe7, 0x1e, 0x83, 0x6a, 0x79, 1249 0x9e, 0xe5, 0xe0, 0x8e, 0x1f, 0x0d, 0x49, 0x34, 0xec, 0x9c, 0x3f, 0x19, 0xe2, 0x50, 0xef, 0xf2, 1250 0x63, 0xdb, 0x0f, 0xbc, 0xd0, 0x43, 0xb7, 0x19, 0x4f, 0x9b, 0x13, 0x39, 0x4f, 0x73, 0x27, 0x11, 1251 0x8d, 0x99, 0x86, 0xd1, 0x59, 0x07, 0x4f, 0xfc, 0x70, 0xca, 0x64, 0xd4, 0x1d, 0x58, 0x3e, 0xf5, 1252 0x7c, 0xdb, 0x40, 0x08, 0x96, 0x5c, 0x7d, 0x82, 0x15, 0x69, 0x57, 0x6a, 0xd5, 0x34, 0xfa, 0xad, 1253 0xfe, 0x2b, 0xc1, 0x7a, 0x9f, 0x2a, 0x3b, 0xc6, 0x84, 0xe8, 0x16, 0x8e, 0xb9, 0x4c, 0x3d, 0xd4, 1254 0x29, 0x57, 0x5d, 0xa3, 0xdf, 0xe8, 0x14, 0x40, 0x0f, 0xc3, 0xc0, 0x1e, 0x46, 0x21, 0x26, 0x4a, 1255 0x65, 0xb7, 0xda, 0x92, 0xbb, 0xfb, 0xed, 0x42, 0x5f, 0xda, 0x39, 0x6d, 0xed, 0x83, 0x54, 0xec, 1256 0xc8, 0x0d, 0x83, 0xa9, 0x96, 0xd1, 0x83, 0xee, 0x02, 0x4c, 0x18, 0xdb, 0xc0, 0x36, 0x95, 0x2a, 1257 0xf5, 0xaa, 0xc6, 0x29, 0x3d, 0xb3, 0xf9, 0x15, 0x34, 0xe6, 0xa4, 0xd1, 0x06, 0x54, 0xc7, 0x78, 1258 0xca, 0x03, 0x88, 0x3f, 0xd1, 0x2d, 0x58, 0x3e, 0xd7, 0x9d, 0x08, 0x2b, 0x15, 0x4a, 0x63, 0x87, 1259 0x2f, 0x2a, 0x9f, 0x4b, 0xea, 0xc7, 0xd0, 0x78, 0x81, 0x43, 0x1a, 0xb9, 0x86, 0xdf, 0x44, 0x98, 1260 0x84, 0x31, 0x73, 0x18, 0x9f, 0xb9, 0x02, 0x76, 0x50, 0x47, 0xf0, 0x5e, 0x3f, 0x1a, 0x3a, 0x36, 1261 0x19, 0x2d, 0xe4, 0x43, 0xdf, 0xc2, 0x1a, 0x77, 0x2e, 0x49, 0xc1, 0x83, 0x32, 0x29, 0xd0, 0x52, 1262 0x29, 0xb5, 0x0b, 0x8d, 0xd4, 0x12, 0xf1, 0x3d, 0x97, 0x60, 0xf4, 0x21, 0xc8, 0xb3, 0x1c, 0x10, 1263 0x45, 0xda, 0xad, 0xb6, 0x6a, 0x1a, 0xa4, 0x49, 0x20, 0xaa, 0x0d, 0x9b, 0xdf, 0xd9, 0x84, 0xc5, 1264 0x41, 0x12, 0x07, 0x15, 0x58, 0xf5, 0x03, 0xef, 0x27, 0x6c, 0x84, 0xdc, 0xc5, 0xe4, 0x88, 0x76, 1265 0xa0, 0xe6, 0xc7, 0xca, 0x88, 0xfd, 0x96, 0xe5, 0x64, 0x59, 0x5b, 0x8b, 0x09, 0x27, 0xf6, 0x5b, 1266 0x1c, 0x27, 0x9c, 0x5e, 0x86, 0xde, 0x18, 0xbb, 0x49, 0xc2, 0x63, 0xca, 0x69, 0x4c, 0x50, 0x03, 1267 0x40, 0x59, 0x53, 0xdc, 0xc3, 0x7d, 0x58, 0xa1, 0xf1, 0x33, 0xe7, 0xe4, 0xee, 0xfb, 0x82, 0xa0, 1268 0x59, 0xa6, 0x39, 0x2f, 0xda, 0x83, 0x86, 0x8b, 0x2f, 0xc2, 0x41, 0xc6, 0x1e, 0xab, 0xd0, 0x7a, 1269 0x4c, 0xee, 0xa7, 0x36, 0xdf, 0xc0, 0xdd, 0xd4, 0xe6, 0x49, 0x34, 0x24, 0x46, 0x60, 0xfb, 0xa1, 1270 0xed, 0xb9, 0x64, 0x71, 0x2d, 0xde, 0x25, 0x4c, 0x17, 0x3e, 0x10, 0x99, 0xe4, 0x21, 0x3f, 0x80, 1271 0x75, 0x92, 0xbd, 0xe0, 0x65, 0xc9, 0x13, 0x4b, 0x87, 0xf8, 0x09, 0xa0, 0xe7, 0xd8, 0xc1, 0x21, 1272 0x2e, 0xd1, 0x8b, 0x7f, 0x49, 0x50, 0xcf, 0xfa, 0x54, 0x84, 0xd9, 0x99, 0x68, 0x25, 0x9b, 0x92, 1273 0x43, 0x90, 0xfd, 0x88, 0x8c, 0x06, 0x86, 0xe7, 0x9e, 0xd9, 0x96, 0xb2, 0xb4, 0x2b, 0xb5, 0xe4, 1274 0xee, 0x3d, 0x61, 0x87, 0x92, 0xd1, 0x33, 0xca, 0xa8, 0x81, 0x9f, 0x7e, 0xa3, 0xc7, 0x70, 0x4b, 1275 0x37, 0xc6, 0x03, 0x13, 0xeb, 0xa6, 0x63, 0xbb, 0x78, 0x40, 0xb0, 0xe1, 0xb9, 0x26, 0x51, 0x96, 1276 0x69, 0x86, 0x91, 0x6e, 0x8c, 0x9f, 0xf3, 0xab, 0x13, 0x76, 0xa3, 0xfe, 0x23, 0x01, 0xcc, 0x94, 1277 0xa1, 0xfb, 0xb0, 0x4e, 0x9d, 0xc0, 0xae, 0xe9, 0x7b, 0xb6, 0x9b, 0xb4, 0x67, 0x3d, 0x26, 0x1e, 1278 0x71, 0x1a, 0x7a, 0x59, 0x30, 0x4d, 0x9e, 0x5c, 0xe9, 0xe8, 0xa2, 0x51, 0xf2, 0xae, 0xb3, 0x62, 1279 0x04, 0x0d, 0x0d, 0x1b, 0xd8, 0x3e, 0xc7, 0x66, 0x32, 0x06, 0x6f, 0xc3, 0x4a, 0x9c, 0x0a, 0xdb, 1280 0x4c, 0x0a, 0xa4, 0x1b, 0xe3, 0x9e, 0x89, 0xbe, 0x86, 0x55, 0x0e, 0x4e, 0xaa, 0xa5, 0xec, 0x0c, 1281 0x48, 0x84, 0xd4, 0x2f, 0x61, 0xeb, 0x05, 0x0e, 0xb3, 0x25, 0x4e, 0x1a, 0x42, 0x85, 0x7a, 0xb6, 1282 0xbf, 0x92, 0xcc, 0x65, 0x69, 0xaa, 0x0f, 0x4a, 0xdc, 0xba, 0x85, 0x40, 0xf9, 0x7f, 0x66, 0xc2, 1283 0x9f, 0x12, 0x6c, 0x17, 0x98, 0xe4, 0x40, 0xe9, 0x15, 0x01, 0x45, 0xee, 0xde, 0x17, 0xe4, 0x24, 1284 0x17, 0xf6, 0x0d, 0xd1, 0xf4, 0x0d, 0x6c, 0x33, 0x34, 0xdd, 0x34, 0x87, 0xbf, 0x48, 0x70, 0xe7, 1285 0xd8, 0x33, 0xed, 0xb3, 0x69, 0x06, 0x04, 0xe5, 0xe5, 0xe7, 0x71, 0x56, 0xb9, 0x01, 0xce, 0xd4, 1286 0x5f, 0x25, 0x90, 0xfb, 0x91, 0xe3, 0x5c, 0xc7, 0xee, 0x23, 0x40, 0x01, 0x0e, 0xa3, 0xc0, 0x1d, 1287 0xd8, 0x93, 0x09, 0x36, 0x6d, 0x3d, 0xc4, 0xce, 0x94, 0x9a, 0x5f, 0xd3, 0x36, 0xd9, 0x4d, 0x6f, 1288 0x76, 0x81, 0xee, 0x41, 0x7d, 0xa2, 0x5f, 0x0c, 0xd2, 0x17, 0xab, 0x4a, 0xeb, 0x2e, 0x4f, 0xf4, 1289 0x8b, 0xe3, 0xe4, 0x39, 0x32, 0xa0, 0xce, 0x9c, 0xe0, 0xd5, 0x3c, 0x81, 0xcd, 0x80, 0xa3, 0x60, 1290 0x26, 0xc7, 0x2a, 0xba, 0x27, 0x88, 0x6f, 0x0e, 0x35, 0xda, 0x46, 0x90, 0x27, 0x10, 0xf5, 0x77, 1291 0x09, 0x14, 0x96, 0xee, 0x83, 0xd9, 0xf4, 0xb8, 0x4e, 0xdc, 0x33, 0x20, 0x56, 0xb2, 0x40, 0x14, 1292 0x8d, 0xaa, 0xaa, 0x70, 0x54, 0xbd, 0x04, 0x74, 0x60, 0x8c, 0x5d, 0xef, 0x67, 0x07, 0x9b, 0xd6, 1293 0xb5, 0x5c, 0xb8, 0x03, 0xab, 0xcc, 0x05, 0x36, 0xad, 0x6a, 0xda, 0x0a, 0xf5, 0x81, 0x74, 0xff, 1294 0x58, 0x01, 0xe0, 0x7d, 0x38, 0xc4, 0x01, 0x7a, 0x0d, 0xe8, 0x59, 0x80, 0xf5, 0x7c, 0x6f, 0xa2, 1295 0x32, 0x68, 0x68, 0x96, 0x61, 0x42, 0x98, 0xae, 0x34, 0x39, 0xd2, 0x23, 0x81, 0x5c, 0xf1, 0x90, 1296 0x29, 0x67, 0xe6, 0x9c, 0xad, 0x1c, 0x39, 0xc8, 0xa3, 0x8e, 0x40, 0x52, 0x34, 0x8f, 0x9a, 0x8f, 1297 0xcb, 0x0b, 0xf0, 0xfe, 0x7b, 0x9d, 0x3c, 0x94, 0x39, 0x6f, 0x44, 0x7a, 0x84, 0x53, 0xa0, 0xb9, 1298 0x95, 0x4a, 0xf0, 0x75, 0xb8, 0x7d, 0x14, 0xaf, 0xc3, 0xe8, 0x47, 0xd8, 0xbc, 0xd4, 0x89, 0xc2, 1299 0xb8, 0x44, 0x3d, 0x2b, 0xd4, 0xde, 0x07, 0x39, 0xd3, 0x5e, 0xe8, 0xa1, 0x40, 0xef, 0xe5, 0x16, 1300 0x14, 0x6a, 0xfc, 0x1e, 0x96, 0x62, 0x7c, 0x22, 0x55, 0x38, 0x5c, 0xd2, 0x09, 0x22, 0x2c, 0x6c, 1301 0x0e, 0xe0, 0xaf, 0x60, 0x63, 0x7e, 0xf2, 0xa1, 0xf6, 0xc2, 0xf8, 0x2f, 0x8d, 0x48, 0x91, 0xb3, 1302 0xdd, 0xbf, 0x97, 0xa0, 0xc6, 0x97, 0x5b, 0x1c, 0xa0, 0x1e, 0xc8, 0x0c, 0x09, 0xec, 0xcf, 0x63, 1303 0xe1, 0xce, 0xd8, 0x5c, 0x78, 0x8b, 0x7e, 0x80, 0x55, 0xae, 0x17, 0x7d, 0x24, 0x7e, 0x6b, 0x33, 1304 0xeb, 0x7b, 0x73, 0xef, 0x2a, 0x36, 0x9e, 0x8e, 0x3e, 0xac, 0x25, 0x7f, 0x08, 0x68, 0x4f, 0x8c, 1305 0xa3, 0xec, 0xda, 0x76, 0x85, 0xaf, 0x3a, 0xc0, 0x6c, 0x83, 0x46, 0xad, 0x05, 0x08, 0xc8, 0xed, 1306 0xf3, 0xcd, 0x87, 0x25, 0x38, 0xb9, 0xd3, 0xbf, 0x49, 0xb0, 0x55, 0xbc, 0xbe, 0xa2, 0xfd, 0xab, 1307 0xb4, 0x14, 0xe2, 0xf4, 0xb3, 0x6b, 0x4a, 0xa5, 0xc9, 0x93, 0x33, 0x5b, 0xad, 0xb0, 0xdd, 0x2f, 1308 0x6f, 0xbe, 0xa2, 0x0e, 0x3a, 0xb4, 0x60, 0xdb, 0xf0, 0x26, 0xc5, 0x7a, 0x0e, 0x65, 0xb6, 0x4f, 1309 0xf5, 0x63, 0x91, 0xbe, 0xf4, 0xea, 0x29, 0xe7, 0xb2, 0x3c, 0x47, 0x77, 0xad, 0xb6, 0x17, 0x58, 1310 0x1d, 0x0b, 0xbb, 0x54, 0x61, 0x87, 0x5d, 0xe9, 0xbe, 0x4d, 0xe6, 0x7e, 0xa5, 0x9f, 0xb2, 0xe3, 1311 0x70, 0x85, 0xf2, 0x7d, 0xfa, 0x5f, 0x00, 0x00, 0x00, 0xff, 0xff, 0xe2, 0x2d, 0xb0, 0x67, 0x71, 1312 0x0f, 0x00, 0x00, 1313} 1314 1315// Reference imports to suppress errors if they are not otherwise used. 1316var _ context.Context 1317var _ grpc.ClientConn 1318 1319// This is a compile-time assertion to ensure that this generated file 1320// is compatible with the grpc package it is being compiled against. 1321const _ = grpc.SupportPackageIsVersion4 1322 1323// SubscriberClient is the client API for Subscriber service. 1324// 1325// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1326type SubscriberClient interface { 1327 // Creates a subscription to a given topic for a given subscriber. 1328 // If the subscription already exists, returns ALREADY_EXISTS. 1329 // If the corresponding topic doesn't exist, returns NOT_FOUND. 1330 // 1331 // If the name is not provided in the request, the server will assign a random 1332 // name for this subscription on the same project as the topic. 1333 CreateSubscription(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (*Subscription, error) 1334 // Gets the configuration details of a subscription. 1335 GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error) 1336 // Lists matching subscriptions. 1337 ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error) 1338 // Deletes an existing subscription. All pending messages in the subscription 1339 // are immediately dropped. Calls to Pull after deletion will return 1340 // NOT_FOUND. After a subscription is deleted, a new one may be created with 1341 // the same name, but the new one has no association with the old 1342 // subscription, or its topic unless the same topic is specified. 1343 DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*empty.Empty, error) 1344 // Modifies the ack deadline for a specific message. This method is useful to 1345 // indicate that more time is needed to process a message by the subscriber, 1346 // or to make the message available for redelivery if the processing was 1347 // interrupted. 1348 ModifyAckDeadline(ctx context.Context, in *ModifyAckDeadlineRequest, opts ...grpc.CallOption) (*empty.Empty, error) 1349 // Acknowledges the messages associated with the ack tokens in the 1350 // AcknowledgeRequest. The Pub/Sub system can remove the relevant messages 1351 // from the subscription. 1352 // 1353 // Acknowledging a message whose ack deadline has expired may succeed, 1354 // but such a message may be redelivered later. Acknowledging a message more 1355 // than once will not result in an error. 1356 Acknowledge(ctx context.Context, in *AcknowledgeRequest, opts ...grpc.CallOption) (*empty.Empty, error) 1357 // Pulls messages from the server. Returns an empty list if there are no 1358 // messages available in the backlog. The server may return UNAVAILABLE if 1359 // there are too many concurrent pull requests pending for the given 1360 // subscription. 1361 Pull(ctx context.Context, in *PullRequest, opts ...grpc.CallOption) (*PullResponse, error) 1362 // Modifies the PushConfig for a specified subscription. 1363 // 1364 // This may be used to change a push subscription to a pull one (signified 1365 // by an empty PushConfig) or vice versa, or change the endpoint URL and other 1366 // attributes of a push subscription. Messages will accumulate for 1367 // delivery continuously through the call regardless of changes to the 1368 // PushConfig. 1369 ModifyPushConfig(ctx context.Context, in *ModifyPushConfigRequest, opts ...grpc.CallOption) (*empty.Empty, error) 1370} 1371 1372type subscriberClient struct { 1373 cc *grpc.ClientConn 1374} 1375 1376func NewSubscriberClient(cc *grpc.ClientConn) SubscriberClient { 1377 return &subscriberClient{cc} 1378} 1379 1380func (c *subscriberClient) CreateSubscription(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (*Subscription, error) { 1381 out := new(Subscription) 1382 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/CreateSubscription", in, out, opts...) 1383 if err != nil { 1384 return nil, err 1385 } 1386 return out, nil 1387} 1388 1389func (c *subscriberClient) GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error) { 1390 out := new(Subscription) 1391 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/GetSubscription", in, out, opts...) 1392 if err != nil { 1393 return nil, err 1394 } 1395 return out, nil 1396} 1397 1398func (c *subscriberClient) ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error) { 1399 out := new(ListSubscriptionsResponse) 1400 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/ListSubscriptions", in, out, opts...) 1401 if err != nil { 1402 return nil, err 1403 } 1404 return out, nil 1405} 1406 1407func (c *subscriberClient) DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 1408 out := new(empty.Empty) 1409 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/DeleteSubscription", in, out, opts...) 1410 if err != nil { 1411 return nil, err 1412 } 1413 return out, nil 1414} 1415 1416func (c *subscriberClient) ModifyAckDeadline(ctx context.Context, in *ModifyAckDeadlineRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 1417 out := new(empty.Empty) 1418 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/ModifyAckDeadline", in, out, opts...) 1419 if err != nil { 1420 return nil, err 1421 } 1422 return out, nil 1423} 1424 1425func (c *subscriberClient) Acknowledge(ctx context.Context, in *AcknowledgeRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 1426 out := new(empty.Empty) 1427 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/Acknowledge", in, out, opts...) 1428 if err != nil { 1429 return nil, err 1430 } 1431 return out, nil 1432} 1433 1434func (c *subscriberClient) Pull(ctx context.Context, in *PullRequest, opts ...grpc.CallOption) (*PullResponse, error) { 1435 out := new(PullResponse) 1436 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/Pull", in, out, opts...) 1437 if err != nil { 1438 return nil, err 1439 } 1440 return out, nil 1441} 1442 1443func (c *subscriberClient) ModifyPushConfig(ctx context.Context, in *ModifyPushConfigRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 1444 out := new(empty.Empty) 1445 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Subscriber/ModifyPushConfig", in, out, opts...) 1446 if err != nil { 1447 return nil, err 1448 } 1449 return out, nil 1450} 1451 1452// SubscriberServer is the server API for Subscriber service. 1453type SubscriberServer interface { 1454 // Creates a subscription to a given topic for a given subscriber. 1455 // If the subscription already exists, returns ALREADY_EXISTS. 1456 // If the corresponding topic doesn't exist, returns NOT_FOUND. 1457 // 1458 // If the name is not provided in the request, the server will assign a random 1459 // name for this subscription on the same project as the topic. 1460 CreateSubscription(context.Context, *Subscription) (*Subscription, error) 1461 // Gets the configuration details of a subscription. 1462 GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error) 1463 // Lists matching subscriptions. 1464 ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error) 1465 // Deletes an existing subscription. All pending messages in the subscription 1466 // are immediately dropped. Calls to Pull after deletion will return 1467 // NOT_FOUND. After a subscription is deleted, a new one may be created with 1468 // the same name, but the new one has no association with the old 1469 // subscription, or its topic unless the same topic is specified. 1470 DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*empty.Empty, error) 1471 // Modifies the ack deadline for a specific message. This method is useful to 1472 // indicate that more time is needed to process a message by the subscriber, 1473 // or to make the message available for redelivery if the processing was 1474 // interrupted. 1475 ModifyAckDeadline(context.Context, *ModifyAckDeadlineRequest) (*empty.Empty, error) 1476 // Acknowledges the messages associated with the ack tokens in the 1477 // AcknowledgeRequest. The Pub/Sub system can remove the relevant messages 1478 // from the subscription. 1479 // 1480 // Acknowledging a message whose ack deadline has expired may succeed, 1481 // but such a message may be redelivered later. Acknowledging a message more 1482 // than once will not result in an error. 1483 Acknowledge(context.Context, *AcknowledgeRequest) (*empty.Empty, error) 1484 // Pulls messages from the server. Returns an empty list if there are no 1485 // messages available in the backlog. The server may return UNAVAILABLE if 1486 // there are too many concurrent pull requests pending for the given 1487 // subscription. 1488 Pull(context.Context, *PullRequest) (*PullResponse, error) 1489 // Modifies the PushConfig for a specified subscription. 1490 // 1491 // This may be used to change a push subscription to a pull one (signified 1492 // by an empty PushConfig) or vice versa, or change the endpoint URL and other 1493 // attributes of a push subscription. Messages will accumulate for 1494 // delivery continuously through the call regardless of changes to the 1495 // PushConfig. 1496 ModifyPushConfig(context.Context, *ModifyPushConfigRequest) (*empty.Empty, error) 1497} 1498 1499func RegisterSubscriberServer(s *grpc.Server, srv SubscriberServer) { 1500 s.RegisterService(&_Subscriber_serviceDesc, srv) 1501} 1502 1503func _Subscriber_CreateSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1504 in := new(Subscription) 1505 if err := dec(in); err != nil { 1506 return nil, err 1507 } 1508 if interceptor == nil { 1509 return srv.(SubscriberServer).CreateSubscription(ctx, in) 1510 } 1511 info := &grpc.UnaryServerInfo{ 1512 Server: srv, 1513 FullMethod: "/google.pubsub.v1beta2.Subscriber/CreateSubscription", 1514 } 1515 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1516 return srv.(SubscriberServer).CreateSubscription(ctx, req.(*Subscription)) 1517 } 1518 return interceptor(ctx, in, info, handler) 1519} 1520 1521func _Subscriber_GetSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1522 in := new(GetSubscriptionRequest) 1523 if err := dec(in); err != nil { 1524 return nil, err 1525 } 1526 if interceptor == nil { 1527 return srv.(SubscriberServer).GetSubscription(ctx, in) 1528 } 1529 info := &grpc.UnaryServerInfo{ 1530 Server: srv, 1531 FullMethod: "/google.pubsub.v1beta2.Subscriber/GetSubscription", 1532 } 1533 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1534 return srv.(SubscriberServer).GetSubscription(ctx, req.(*GetSubscriptionRequest)) 1535 } 1536 return interceptor(ctx, in, info, handler) 1537} 1538 1539func _Subscriber_ListSubscriptions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1540 in := new(ListSubscriptionsRequest) 1541 if err := dec(in); err != nil { 1542 return nil, err 1543 } 1544 if interceptor == nil { 1545 return srv.(SubscriberServer).ListSubscriptions(ctx, in) 1546 } 1547 info := &grpc.UnaryServerInfo{ 1548 Server: srv, 1549 FullMethod: "/google.pubsub.v1beta2.Subscriber/ListSubscriptions", 1550 } 1551 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1552 return srv.(SubscriberServer).ListSubscriptions(ctx, req.(*ListSubscriptionsRequest)) 1553 } 1554 return interceptor(ctx, in, info, handler) 1555} 1556 1557func _Subscriber_DeleteSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1558 in := new(DeleteSubscriptionRequest) 1559 if err := dec(in); err != nil { 1560 return nil, err 1561 } 1562 if interceptor == nil { 1563 return srv.(SubscriberServer).DeleteSubscription(ctx, in) 1564 } 1565 info := &grpc.UnaryServerInfo{ 1566 Server: srv, 1567 FullMethod: "/google.pubsub.v1beta2.Subscriber/DeleteSubscription", 1568 } 1569 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1570 return srv.(SubscriberServer).DeleteSubscription(ctx, req.(*DeleteSubscriptionRequest)) 1571 } 1572 return interceptor(ctx, in, info, handler) 1573} 1574 1575func _Subscriber_ModifyAckDeadline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1576 in := new(ModifyAckDeadlineRequest) 1577 if err := dec(in); err != nil { 1578 return nil, err 1579 } 1580 if interceptor == nil { 1581 return srv.(SubscriberServer).ModifyAckDeadline(ctx, in) 1582 } 1583 info := &grpc.UnaryServerInfo{ 1584 Server: srv, 1585 FullMethod: "/google.pubsub.v1beta2.Subscriber/ModifyAckDeadline", 1586 } 1587 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1588 return srv.(SubscriberServer).ModifyAckDeadline(ctx, req.(*ModifyAckDeadlineRequest)) 1589 } 1590 return interceptor(ctx, in, info, handler) 1591} 1592 1593func _Subscriber_Acknowledge_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1594 in := new(AcknowledgeRequest) 1595 if err := dec(in); err != nil { 1596 return nil, err 1597 } 1598 if interceptor == nil { 1599 return srv.(SubscriberServer).Acknowledge(ctx, in) 1600 } 1601 info := &grpc.UnaryServerInfo{ 1602 Server: srv, 1603 FullMethod: "/google.pubsub.v1beta2.Subscriber/Acknowledge", 1604 } 1605 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1606 return srv.(SubscriberServer).Acknowledge(ctx, req.(*AcknowledgeRequest)) 1607 } 1608 return interceptor(ctx, in, info, handler) 1609} 1610 1611func _Subscriber_Pull_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1612 in := new(PullRequest) 1613 if err := dec(in); err != nil { 1614 return nil, err 1615 } 1616 if interceptor == nil { 1617 return srv.(SubscriberServer).Pull(ctx, in) 1618 } 1619 info := &grpc.UnaryServerInfo{ 1620 Server: srv, 1621 FullMethod: "/google.pubsub.v1beta2.Subscriber/Pull", 1622 } 1623 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1624 return srv.(SubscriberServer).Pull(ctx, req.(*PullRequest)) 1625 } 1626 return interceptor(ctx, in, info, handler) 1627} 1628 1629func _Subscriber_ModifyPushConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1630 in := new(ModifyPushConfigRequest) 1631 if err := dec(in); err != nil { 1632 return nil, err 1633 } 1634 if interceptor == nil { 1635 return srv.(SubscriberServer).ModifyPushConfig(ctx, in) 1636 } 1637 info := &grpc.UnaryServerInfo{ 1638 Server: srv, 1639 FullMethod: "/google.pubsub.v1beta2.Subscriber/ModifyPushConfig", 1640 } 1641 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1642 return srv.(SubscriberServer).ModifyPushConfig(ctx, req.(*ModifyPushConfigRequest)) 1643 } 1644 return interceptor(ctx, in, info, handler) 1645} 1646 1647var _Subscriber_serviceDesc = grpc.ServiceDesc{ 1648 ServiceName: "google.pubsub.v1beta2.Subscriber", 1649 HandlerType: (*SubscriberServer)(nil), 1650 Methods: []grpc.MethodDesc{ 1651 { 1652 MethodName: "CreateSubscription", 1653 Handler: _Subscriber_CreateSubscription_Handler, 1654 }, 1655 { 1656 MethodName: "GetSubscription", 1657 Handler: _Subscriber_GetSubscription_Handler, 1658 }, 1659 { 1660 MethodName: "ListSubscriptions", 1661 Handler: _Subscriber_ListSubscriptions_Handler, 1662 }, 1663 { 1664 MethodName: "DeleteSubscription", 1665 Handler: _Subscriber_DeleteSubscription_Handler, 1666 }, 1667 { 1668 MethodName: "ModifyAckDeadline", 1669 Handler: _Subscriber_ModifyAckDeadline_Handler, 1670 }, 1671 { 1672 MethodName: "Acknowledge", 1673 Handler: _Subscriber_Acknowledge_Handler, 1674 }, 1675 { 1676 MethodName: "Pull", 1677 Handler: _Subscriber_Pull_Handler, 1678 }, 1679 { 1680 MethodName: "ModifyPushConfig", 1681 Handler: _Subscriber_ModifyPushConfig_Handler, 1682 }, 1683 }, 1684 Streams: []grpc.StreamDesc{}, 1685 Metadata: "google/pubsub/v1beta2/pubsub.proto", 1686} 1687 1688// PublisherClient is the client API for Publisher service. 1689// 1690// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 1691type PublisherClient interface { 1692 // Creates the given topic with the given name. 1693 CreateTopic(ctx context.Context, in *Topic, opts ...grpc.CallOption) (*Topic, error) 1694 // Adds one or more messages to the topic. Returns NOT_FOUND if the topic does 1695 // not exist. 1696 Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error) 1697 // Gets the configuration of a topic. 1698 GetTopic(ctx context.Context, in *GetTopicRequest, opts ...grpc.CallOption) (*Topic, error) 1699 // Lists matching topics. 1700 ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error) 1701 // Lists the name of the subscriptions for this topic. 1702 ListTopicSubscriptions(ctx context.Context, in *ListTopicSubscriptionsRequest, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error) 1703 // Deletes the topic with the given name. Returns NOT_FOUND if the topic does 1704 // not exist. After a topic is deleted, a new topic may be created with the 1705 // same name; this is an entirely new topic with none of the old 1706 // configuration or subscriptions. Existing subscriptions to this topic are 1707 // not deleted. 1708 DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*empty.Empty, error) 1709} 1710 1711type publisherClient struct { 1712 cc *grpc.ClientConn 1713} 1714 1715func NewPublisherClient(cc *grpc.ClientConn) PublisherClient { 1716 return &publisherClient{cc} 1717} 1718 1719func (c *publisherClient) CreateTopic(ctx context.Context, in *Topic, opts ...grpc.CallOption) (*Topic, error) { 1720 out := new(Topic) 1721 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Publisher/CreateTopic", in, out, opts...) 1722 if err != nil { 1723 return nil, err 1724 } 1725 return out, nil 1726} 1727 1728func (c *publisherClient) Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error) { 1729 out := new(PublishResponse) 1730 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Publisher/Publish", in, out, opts...) 1731 if err != nil { 1732 return nil, err 1733 } 1734 return out, nil 1735} 1736 1737func (c *publisherClient) GetTopic(ctx context.Context, in *GetTopicRequest, opts ...grpc.CallOption) (*Topic, error) { 1738 out := new(Topic) 1739 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Publisher/GetTopic", in, out, opts...) 1740 if err != nil { 1741 return nil, err 1742 } 1743 return out, nil 1744} 1745 1746func (c *publisherClient) ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error) { 1747 out := new(ListTopicsResponse) 1748 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Publisher/ListTopics", in, out, opts...) 1749 if err != nil { 1750 return nil, err 1751 } 1752 return out, nil 1753} 1754 1755func (c *publisherClient) ListTopicSubscriptions(ctx context.Context, in *ListTopicSubscriptionsRequest, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error) { 1756 out := new(ListTopicSubscriptionsResponse) 1757 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Publisher/ListTopicSubscriptions", in, out, opts...) 1758 if err != nil { 1759 return nil, err 1760 } 1761 return out, nil 1762} 1763 1764func (c *publisherClient) DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 1765 out := new(empty.Empty) 1766 err := c.cc.Invoke(ctx, "/google.pubsub.v1beta2.Publisher/DeleteTopic", in, out, opts...) 1767 if err != nil { 1768 return nil, err 1769 } 1770 return out, nil 1771} 1772 1773// PublisherServer is the server API for Publisher service. 1774type PublisherServer interface { 1775 // Creates the given topic with the given name. 1776 CreateTopic(context.Context, *Topic) (*Topic, error) 1777 // Adds one or more messages to the topic. Returns NOT_FOUND if the topic does 1778 // not exist. 1779 Publish(context.Context, *PublishRequest) (*PublishResponse, error) 1780 // Gets the configuration of a topic. 1781 GetTopic(context.Context, *GetTopicRequest) (*Topic, error) 1782 // Lists matching topics. 1783 ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error) 1784 // Lists the name of the subscriptions for this topic. 1785 ListTopicSubscriptions(context.Context, *ListTopicSubscriptionsRequest) (*ListTopicSubscriptionsResponse, error) 1786 // Deletes the topic with the given name. Returns NOT_FOUND if the topic does 1787 // not exist. After a topic is deleted, a new topic may be created with the 1788 // same name; this is an entirely new topic with none of the old 1789 // configuration or subscriptions. Existing subscriptions to this topic are 1790 // not deleted. 1791 DeleteTopic(context.Context, *DeleteTopicRequest) (*empty.Empty, error) 1792} 1793 1794func RegisterPublisherServer(s *grpc.Server, srv PublisherServer) { 1795 s.RegisterService(&_Publisher_serviceDesc, srv) 1796} 1797 1798func _Publisher_CreateTopic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1799 in := new(Topic) 1800 if err := dec(in); err != nil { 1801 return nil, err 1802 } 1803 if interceptor == nil { 1804 return srv.(PublisherServer).CreateTopic(ctx, in) 1805 } 1806 info := &grpc.UnaryServerInfo{ 1807 Server: srv, 1808 FullMethod: "/google.pubsub.v1beta2.Publisher/CreateTopic", 1809 } 1810 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1811 return srv.(PublisherServer).CreateTopic(ctx, req.(*Topic)) 1812 } 1813 return interceptor(ctx, in, info, handler) 1814} 1815 1816func _Publisher_Publish_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1817 in := new(PublishRequest) 1818 if err := dec(in); err != nil { 1819 return nil, err 1820 } 1821 if interceptor == nil { 1822 return srv.(PublisherServer).Publish(ctx, in) 1823 } 1824 info := &grpc.UnaryServerInfo{ 1825 Server: srv, 1826 FullMethod: "/google.pubsub.v1beta2.Publisher/Publish", 1827 } 1828 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1829 return srv.(PublisherServer).Publish(ctx, req.(*PublishRequest)) 1830 } 1831 return interceptor(ctx, in, info, handler) 1832} 1833 1834func _Publisher_GetTopic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1835 in := new(GetTopicRequest) 1836 if err := dec(in); err != nil { 1837 return nil, err 1838 } 1839 if interceptor == nil { 1840 return srv.(PublisherServer).GetTopic(ctx, in) 1841 } 1842 info := &grpc.UnaryServerInfo{ 1843 Server: srv, 1844 FullMethod: "/google.pubsub.v1beta2.Publisher/GetTopic", 1845 } 1846 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1847 return srv.(PublisherServer).GetTopic(ctx, req.(*GetTopicRequest)) 1848 } 1849 return interceptor(ctx, in, info, handler) 1850} 1851 1852func _Publisher_ListTopics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1853 in := new(ListTopicsRequest) 1854 if err := dec(in); err != nil { 1855 return nil, err 1856 } 1857 if interceptor == nil { 1858 return srv.(PublisherServer).ListTopics(ctx, in) 1859 } 1860 info := &grpc.UnaryServerInfo{ 1861 Server: srv, 1862 FullMethod: "/google.pubsub.v1beta2.Publisher/ListTopics", 1863 } 1864 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1865 return srv.(PublisherServer).ListTopics(ctx, req.(*ListTopicsRequest)) 1866 } 1867 return interceptor(ctx, in, info, handler) 1868} 1869 1870func _Publisher_ListTopicSubscriptions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1871 in := new(ListTopicSubscriptionsRequest) 1872 if err := dec(in); err != nil { 1873 return nil, err 1874 } 1875 if interceptor == nil { 1876 return srv.(PublisherServer).ListTopicSubscriptions(ctx, in) 1877 } 1878 info := &grpc.UnaryServerInfo{ 1879 Server: srv, 1880 FullMethod: "/google.pubsub.v1beta2.Publisher/ListTopicSubscriptions", 1881 } 1882 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1883 return srv.(PublisherServer).ListTopicSubscriptions(ctx, req.(*ListTopicSubscriptionsRequest)) 1884 } 1885 return interceptor(ctx, in, info, handler) 1886} 1887 1888func _Publisher_DeleteTopic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 1889 in := new(DeleteTopicRequest) 1890 if err := dec(in); err != nil { 1891 return nil, err 1892 } 1893 if interceptor == nil { 1894 return srv.(PublisherServer).DeleteTopic(ctx, in) 1895 } 1896 info := &grpc.UnaryServerInfo{ 1897 Server: srv, 1898 FullMethod: "/google.pubsub.v1beta2.Publisher/DeleteTopic", 1899 } 1900 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 1901 return srv.(PublisherServer).DeleteTopic(ctx, req.(*DeleteTopicRequest)) 1902 } 1903 return interceptor(ctx, in, info, handler) 1904} 1905 1906var _Publisher_serviceDesc = grpc.ServiceDesc{ 1907 ServiceName: "google.pubsub.v1beta2.Publisher", 1908 HandlerType: (*PublisherServer)(nil), 1909 Methods: []grpc.MethodDesc{ 1910 { 1911 MethodName: "CreateTopic", 1912 Handler: _Publisher_CreateTopic_Handler, 1913 }, 1914 { 1915 MethodName: "Publish", 1916 Handler: _Publisher_Publish_Handler, 1917 }, 1918 { 1919 MethodName: "GetTopic", 1920 Handler: _Publisher_GetTopic_Handler, 1921 }, 1922 { 1923 MethodName: "ListTopics", 1924 Handler: _Publisher_ListTopics_Handler, 1925 }, 1926 { 1927 MethodName: "ListTopicSubscriptions", 1928 Handler: _Publisher_ListTopicSubscriptions_Handler, 1929 }, 1930 { 1931 MethodName: "DeleteTopic", 1932 Handler: _Publisher_DeleteTopic_Handler, 1933 }, 1934 }, 1935 Streams: []grpc.StreamDesc{}, 1936 Metadata: "google/pubsub/v1beta2/pubsub.proto", 1937} 1938