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