1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google/pubsub/v1/pubsub.proto 3 4package pubsub // import "google.golang.org/genproto/googleapis/pubsub/v1" 5 6import proto "github.com/golang/protobuf/proto" 7import fmt "fmt" 8import math "math" 9import duration "github.com/golang/protobuf/ptypes/duration" 10import empty "github.com/golang/protobuf/ptypes/empty" 11import timestamp "github.com/golang/protobuf/ptypes/timestamp" 12import _ "google.golang.org/genproto/googleapis/api/annotations" 13import field_mask "google.golang.org/genproto/protobuf/field_mask" 14 15import ( 16 context "golang.org/x/net/context" 17 grpc "google.golang.org/grpc" 18) 19 20// Reference imports to suppress errors if they are not otherwise used. 21var _ = proto.Marshal 22var _ = fmt.Errorf 23var _ = math.Inf 24 25// This is a compile-time assertion to ensure that this generated file 26// is compatible with the proto package it is being compiled against. 27// A compilation error at this line likely means your copy of the 28// proto package needs to be updated. 29const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package 30 31type MessageStoragePolicy struct { 32 // The list of GCP regions where messages that are published to the topic may 33 // be persisted in storage. Messages published by publishers running in 34 // non-allowed GCP regions (or running outside of GCP altogether) will be 35 // routed for storage in one of the allowed regions. An empty list indicates a 36 // misconfiguration at the project or organization level, which will result in 37 // all Publish operations failing. 38 AllowedPersistenceRegions []string `protobuf:"bytes,1,rep,name=allowed_persistence_regions,json=allowedPersistenceRegions,proto3" json:"allowed_persistence_regions,omitempty"` 39 XXX_NoUnkeyedLiteral struct{} `json:"-"` 40 XXX_unrecognized []byte `json:"-"` 41 XXX_sizecache int32 `json:"-"` 42} 43 44func (m *MessageStoragePolicy) Reset() { *m = MessageStoragePolicy{} } 45func (m *MessageStoragePolicy) String() string { return proto.CompactTextString(m) } 46func (*MessageStoragePolicy) ProtoMessage() {} 47func (*MessageStoragePolicy) Descriptor() ([]byte, []int) { 48 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{0} 49} 50func (m *MessageStoragePolicy) XXX_Unmarshal(b []byte) error { 51 return xxx_messageInfo_MessageStoragePolicy.Unmarshal(m, b) 52} 53func (m *MessageStoragePolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 54 return xxx_messageInfo_MessageStoragePolicy.Marshal(b, m, deterministic) 55} 56func (dst *MessageStoragePolicy) XXX_Merge(src proto.Message) { 57 xxx_messageInfo_MessageStoragePolicy.Merge(dst, src) 58} 59func (m *MessageStoragePolicy) XXX_Size() int { 60 return xxx_messageInfo_MessageStoragePolicy.Size(m) 61} 62func (m *MessageStoragePolicy) XXX_DiscardUnknown() { 63 xxx_messageInfo_MessageStoragePolicy.DiscardUnknown(m) 64} 65 66var xxx_messageInfo_MessageStoragePolicy proto.InternalMessageInfo 67 68func (m *MessageStoragePolicy) GetAllowedPersistenceRegions() []string { 69 if m != nil { 70 return m.AllowedPersistenceRegions 71 } 72 return nil 73} 74 75// A topic resource. 76type Topic struct { 77 // The name of the topic. It must have the format 78 // `"projects/{project}/topics/{topic}"`. `{topic}` must start with a letter, 79 // and contain only letters (`[A-Za-z]`), numbers (`[0-9]`), dashes (`-`), 80 // underscores (`_`), periods (`.`), tildes (`~`), plus (`+`) or percent 81 // signs (`%`). It must be between 3 and 255 characters in length, and it 82 // must not start with `"goog"`. 83 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 84 // User labels. 85 Labels map[string]string `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 86 // Policy constraining how messages published to the topic may be stored. It 87 // is determined when the topic is created based on the policy configured at 88 // the project level. It must not be set by the caller in the request to 89 // CreateTopic or to UpdateTopic. This field will be populated in the 90 // responses for GetTopic, CreateTopic, and UpdateTopic: if not present in the 91 // response, then no constraints are in effect. 92 MessageStoragePolicy *MessageStoragePolicy `protobuf:"bytes,3,opt,name=message_storage_policy,json=messageStoragePolicy,proto3" json:"message_storage_policy,omitempty"` 93 XXX_NoUnkeyedLiteral struct{} `json:"-"` 94 XXX_unrecognized []byte `json:"-"` 95 XXX_sizecache int32 `json:"-"` 96} 97 98func (m *Topic) Reset() { *m = Topic{} } 99func (m *Topic) String() string { return proto.CompactTextString(m) } 100func (*Topic) ProtoMessage() {} 101func (*Topic) Descriptor() ([]byte, []int) { 102 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{1} 103} 104func (m *Topic) XXX_Unmarshal(b []byte) error { 105 return xxx_messageInfo_Topic.Unmarshal(m, b) 106} 107func (m *Topic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 108 return xxx_messageInfo_Topic.Marshal(b, m, deterministic) 109} 110func (dst *Topic) XXX_Merge(src proto.Message) { 111 xxx_messageInfo_Topic.Merge(dst, src) 112} 113func (m *Topic) XXX_Size() int { 114 return xxx_messageInfo_Topic.Size(m) 115} 116func (m *Topic) XXX_DiscardUnknown() { 117 xxx_messageInfo_Topic.DiscardUnknown(m) 118} 119 120var xxx_messageInfo_Topic proto.InternalMessageInfo 121 122func (m *Topic) GetName() string { 123 if m != nil { 124 return m.Name 125 } 126 return "" 127} 128 129func (m *Topic) GetLabels() map[string]string { 130 if m != nil { 131 return m.Labels 132 } 133 return nil 134} 135 136func (m *Topic) GetMessageStoragePolicy() *MessageStoragePolicy { 137 if m != nil { 138 return m.MessageStoragePolicy 139 } 140 return nil 141} 142 143// A message data and its attributes. The message payload must not be empty; 144// it must contain either a non-empty data field, or at least one attribute. 145type PubsubMessage struct { 146 // The message payload. 147 Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` 148 // Optional attributes for this message. 149 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"` 150 // ID of this message, assigned by the server when the message is published. 151 // Guaranteed to be unique within the topic. This value may be read by a 152 // subscriber that receives a `PubsubMessage` via a `Pull` call or a push 153 // delivery. It must not be populated by the publisher in a `Publish` call. 154 MessageId string `protobuf:"bytes,3,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` 155 // The time at which the message was published, populated by the server when 156 // it receives the `Publish` call. It must not be populated by the 157 // publisher in a `Publish` call. 158 PublishTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=publish_time,json=publishTime,proto3" json:"publish_time,omitempty"` 159 XXX_NoUnkeyedLiteral struct{} `json:"-"` 160 XXX_unrecognized []byte `json:"-"` 161 XXX_sizecache int32 `json:"-"` 162} 163 164func (m *PubsubMessage) Reset() { *m = PubsubMessage{} } 165func (m *PubsubMessage) String() string { return proto.CompactTextString(m) } 166func (*PubsubMessage) ProtoMessage() {} 167func (*PubsubMessage) Descriptor() ([]byte, []int) { 168 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{2} 169} 170func (m *PubsubMessage) XXX_Unmarshal(b []byte) error { 171 return xxx_messageInfo_PubsubMessage.Unmarshal(m, b) 172} 173func (m *PubsubMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 174 return xxx_messageInfo_PubsubMessage.Marshal(b, m, deterministic) 175} 176func (dst *PubsubMessage) XXX_Merge(src proto.Message) { 177 xxx_messageInfo_PubsubMessage.Merge(dst, src) 178} 179func (m *PubsubMessage) XXX_Size() int { 180 return xxx_messageInfo_PubsubMessage.Size(m) 181} 182func (m *PubsubMessage) XXX_DiscardUnknown() { 183 xxx_messageInfo_PubsubMessage.DiscardUnknown(m) 184} 185 186var xxx_messageInfo_PubsubMessage proto.InternalMessageInfo 187 188func (m *PubsubMessage) GetData() []byte { 189 if m != nil { 190 return m.Data 191 } 192 return nil 193} 194 195func (m *PubsubMessage) GetAttributes() map[string]string { 196 if m != nil { 197 return m.Attributes 198 } 199 return nil 200} 201 202func (m *PubsubMessage) GetMessageId() string { 203 if m != nil { 204 return m.MessageId 205 } 206 return "" 207} 208 209func (m *PubsubMessage) GetPublishTime() *timestamp.Timestamp { 210 if m != nil { 211 return m.PublishTime 212 } 213 return nil 214} 215 216// Request for the GetTopic method. 217type GetTopicRequest struct { 218 // The name of the topic to get. 219 // Format is `projects/{project}/topics/{topic}`. 220 Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` 221 XXX_NoUnkeyedLiteral struct{} `json:"-"` 222 XXX_unrecognized []byte `json:"-"` 223 XXX_sizecache int32 `json:"-"` 224} 225 226func (m *GetTopicRequest) Reset() { *m = GetTopicRequest{} } 227func (m *GetTopicRequest) String() string { return proto.CompactTextString(m) } 228func (*GetTopicRequest) ProtoMessage() {} 229func (*GetTopicRequest) Descriptor() ([]byte, []int) { 230 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{3} 231} 232func (m *GetTopicRequest) XXX_Unmarshal(b []byte) error { 233 return xxx_messageInfo_GetTopicRequest.Unmarshal(m, b) 234} 235func (m *GetTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 236 return xxx_messageInfo_GetTopicRequest.Marshal(b, m, deterministic) 237} 238func (dst *GetTopicRequest) XXX_Merge(src proto.Message) { 239 xxx_messageInfo_GetTopicRequest.Merge(dst, src) 240} 241func (m *GetTopicRequest) XXX_Size() int { 242 return xxx_messageInfo_GetTopicRequest.Size(m) 243} 244func (m *GetTopicRequest) XXX_DiscardUnknown() { 245 xxx_messageInfo_GetTopicRequest.DiscardUnknown(m) 246} 247 248var xxx_messageInfo_GetTopicRequest proto.InternalMessageInfo 249 250func (m *GetTopicRequest) GetTopic() string { 251 if m != nil { 252 return m.Topic 253 } 254 return "" 255} 256 257// Request for the UpdateTopic method. 258type UpdateTopicRequest struct { 259 // The updated topic object. 260 Topic *Topic `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` 261 // Indicates which fields in the provided topic to update. Must be specified 262 // and non-empty. Note that if `update_mask` contains 263 // "message_storage_policy" then the new value will be determined based on the 264 // policy configured at the project or organization level. The 265 // `message_storage_policy` must not be set in the `topic` provided above. 266 UpdateMask *field_mask.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` 267 XXX_NoUnkeyedLiteral struct{} `json:"-"` 268 XXX_unrecognized []byte `json:"-"` 269 XXX_sizecache int32 `json:"-"` 270} 271 272func (m *UpdateTopicRequest) Reset() { *m = UpdateTopicRequest{} } 273func (m *UpdateTopicRequest) String() string { return proto.CompactTextString(m) } 274func (*UpdateTopicRequest) ProtoMessage() {} 275func (*UpdateTopicRequest) Descriptor() ([]byte, []int) { 276 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{4} 277} 278func (m *UpdateTopicRequest) XXX_Unmarshal(b []byte) error { 279 return xxx_messageInfo_UpdateTopicRequest.Unmarshal(m, b) 280} 281func (m *UpdateTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 282 return xxx_messageInfo_UpdateTopicRequest.Marshal(b, m, deterministic) 283} 284func (dst *UpdateTopicRequest) XXX_Merge(src proto.Message) { 285 xxx_messageInfo_UpdateTopicRequest.Merge(dst, src) 286} 287func (m *UpdateTopicRequest) XXX_Size() int { 288 return xxx_messageInfo_UpdateTopicRequest.Size(m) 289} 290func (m *UpdateTopicRequest) XXX_DiscardUnknown() { 291 xxx_messageInfo_UpdateTopicRequest.DiscardUnknown(m) 292} 293 294var xxx_messageInfo_UpdateTopicRequest proto.InternalMessageInfo 295 296func (m *UpdateTopicRequest) GetTopic() *Topic { 297 if m != nil { 298 return m.Topic 299 } 300 return nil 301} 302 303func (m *UpdateTopicRequest) GetUpdateMask() *field_mask.FieldMask { 304 if m != nil { 305 return m.UpdateMask 306 } 307 return nil 308} 309 310// Request for the Publish method. 311type PublishRequest struct { 312 // The messages in the request will be published on this topic. 313 // Format is `projects/{project}/topics/{topic}`. 314 Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` 315 // The messages to publish. 316 Messages []*PubsubMessage `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"` 317 XXX_NoUnkeyedLiteral struct{} `json:"-"` 318 XXX_unrecognized []byte `json:"-"` 319 XXX_sizecache int32 `json:"-"` 320} 321 322func (m *PublishRequest) Reset() { *m = PublishRequest{} } 323func (m *PublishRequest) String() string { return proto.CompactTextString(m) } 324func (*PublishRequest) ProtoMessage() {} 325func (*PublishRequest) Descriptor() ([]byte, []int) { 326 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{5} 327} 328func (m *PublishRequest) XXX_Unmarshal(b []byte) error { 329 return xxx_messageInfo_PublishRequest.Unmarshal(m, b) 330} 331func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 332 return xxx_messageInfo_PublishRequest.Marshal(b, m, deterministic) 333} 334func (dst *PublishRequest) XXX_Merge(src proto.Message) { 335 xxx_messageInfo_PublishRequest.Merge(dst, src) 336} 337func (m *PublishRequest) XXX_Size() int { 338 return xxx_messageInfo_PublishRequest.Size(m) 339} 340func (m *PublishRequest) XXX_DiscardUnknown() { 341 xxx_messageInfo_PublishRequest.DiscardUnknown(m) 342} 343 344var xxx_messageInfo_PublishRequest proto.InternalMessageInfo 345 346func (m *PublishRequest) GetTopic() string { 347 if m != nil { 348 return m.Topic 349 } 350 return "" 351} 352 353func (m *PublishRequest) GetMessages() []*PubsubMessage { 354 if m != nil { 355 return m.Messages 356 } 357 return nil 358} 359 360// Response for the `Publish` method. 361type PublishResponse struct { 362 // The server-assigned ID of each published message, in the same order as 363 // the messages in the request. IDs are guaranteed to be unique within 364 // the topic. 365 MessageIds []string `protobuf:"bytes,1,rep,name=message_ids,json=messageIds,proto3" json:"message_ids,omitempty"` 366 XXX_NoUnkeyedLiteral struct{} `json:"-"` 367 XXX_unrecognized []byte `json:"-"` 368 XXX_sizecache int32 `json:"-"` 369} 370 371func (m *PublishResponse) Reset() { *m = PublishResponse{} } 372func (m *PublishResponse) String() string { return proto.CompactTextString(m) } 373func (*PublishResponse) ProtoMessage() {} 374func (*PublishResponse) Descriptor() ([]byte, []int) { 375 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{6} 376} 377func (m *PublishResponse) XXX_Unmarshal(b []byte) error { 378 return xxx_messageInfo_PublishResponse.Unmarshal(m, b) 379} 380func (m *PublishResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 381 return xxx_messageInfo_PublishResponse.Marshal(b, m, deterministic) 382} 383func (dst *PublishResponse) XXX_Merge(src proto.Message) { 384 xxx_messageInfo_PublishResponse.Merge(dst, src) 385} 386func (m *PublishResponse) XXX_Size() int { 387 return xxx_messageInfo_PublishResponse.Size(m) 388} 389func (m *PublishResponse) XXX_DiscardUnknown() { 390 xxx_messageInfo_PublishResponse.DiscardUnknown(m) 391} 392 393var xxx_messageInfo_PublishResponse proto.InternalMessageInfo 394 395func (m *PublishResponse) GetMessageIds() []string { 396 if m != nil { 397 return m.MessageIds 398 } 399 return nil 400} 401 402// Request for the `ListTopics` method. 403type ListTopicsRequest struct { 404 // The name of the cloud project that topics belong to. 405 // Format is `projects/{project}`. 406 Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` 407 // Maximum number of topics to return. 408 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 409 // The value returned by the last `ListTopicsResponse`; indicates that this is 410 // a continuation of a prior `ListTopics` call, and that the system should 411 // return the next page of data. 412 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 413 XXX_NoUnkeyedLiteral struct{} `json:"-"` 414 XXX_unrecognized []byte `json:"-"` 415 XXX_sizecache int32 `json:"-"` 416} 417 418func (m *ListTopicsRequest) Reset() { *m = ListTopicsRequest{} } 419func (m *ListTopicsRequest) String() string { return proto.CompactTextString(m) } 420func (*ListTopicsRequest) ProtoMessage() {} 421func (*ListTopicsRequest) Descriptor() ([]byte, []int) { 422 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{7} 423} 424func (m *ListTopicsRequest) XXX_Unmarshal(b []byte) error { 425 return xxx_messageInfo_ListTopicsRequest.Unmarshal(m, b) 426} 427func (m *ListTopicsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 428 return xxx_messageInfo_ListTopicsRequest.Marshal(b, m, deterministic) 429} 430func (dst *ListTopicsRequest) XXX_Merge(src proto.Message) { 431 xxx_messageInfo_ListTopicsRequest.Merge(dst, src) 432} 433func (m *ListTopicsRequest) XXX_Size() int { 434 return xxx_messageInfo_ListTopicsRequest.Size(m) 435} 436func (m *ListTopicsRequest) XXX_DiscardUnknown() { 437 xxx_messageInfo_ListTopicsRequest.DiscardUnknown(m) 438} 439 440var xxx_messageInfo_ListTopicsRequest proto.InternalMessageInfo 441 442func (m *ListTopicsRequest) GetProject() string { 443 if m != nil { 444 return m.Project 445 } 446 return "" 447} 448 449func (m *ListTopicsRequest) GetPageSize() int32 { 450 if m != nil { 451 return m.PageSize 452 } 453 return 0 454} 455 456func (m *ListTopicsRequest) GetPageToken() string { 457 if m != nil { 458 return m.PageToken 459 } 460 return "" 461} 462 463// Response for the `ListTopics` method. 464type ListTopicsResponse struct { 465 // The resulting topics. 466 Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"` 467 // If not empty, indicates that there may be more topics that match the 468 // request; this value should be passed in a new `ListTopicsRequest`. 469 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 470 XXX_NoUnkeyedLiteral struct{} `json:"-"` 471 XXX_unrecognized []byte `json:"-"` 472 XXX_sizecache int32 `json:"-"` 473} 474 475func (m *ListTopicsResponse) Reset() { *m = ListTopicsResponse{} } 476func (m *ListTopicsResponse) String() string { return proto.CompactTextString(m) } 477func (*ListTopicsResponse) ProtoMessage() {} 478func (*ListTopicsResponse) Descriptor() ([]byte, []int) { 479 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{8} 480} 481func (m *ListTopicsResponse) XXX_Unmarshal(b []byte) error { 482 return xxx_messageInfo_ListTopicsResponse.Unmarshal(m, b) 483} 484func (m *ListTopicsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 485 return xxx_messageInfo_ListTopicsResponse.Marshal(b, m, deterministic) 486} 487func (dst *ListTopicsResponse) XXX_Merge(src proto.Message) { 488 xxx_messageInfo_ListTopicsResponse.Merge(dst, src) 489} 490func (m *ListTopicsResponse) XXX_Size() int { 491 return xxx_messageInfo_ListTopicsResponse.Size(m) 492} 493func (m *ListTopicsResponse) XXX_DiscardUnknown() { 494 xxx_messageInfo_ListTopicsResponse.DiscardUnknown(m) 495} 496 497var xxx_messageInfo_ListTopicsResponse proto.InternalMessageInfo 498 499func (m *ListTopicsResponse) GetTopics() []*Topic { 500 if m != nil { 501 return m.Topics 502 } 503 return nil 504} 505 506func (m *ListTopicsResponse) GetNextPageToken() string { 507 if m != nil { 508 return m.NextPageToken 509 } 510 return "" 511} 512 513// Request for the `ListTopicSubscriptions` method. 514type ListTopicSubscriptionsRequest struct { 515 // The name of the topic that subscriptions are attached to. 516 // Format is `projects/{project}/topics/{topic}`. 517 Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` 518 // Maximum number of subscription names to return. 519 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 520 // The value returned by the last `ListTopicSubscriptionsResponse`; indicates 521 // that this is a continuation of a prior `ListTopicSubscriptions` call, and 522 // that the system should return the next page of data. 523 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 524 XXX_NoUnkeyedLiteral struct{} `json:"-"` 525 XXX_unrecognized []byte `json:"-"` 526 XXX_sizecache int32 `json:"-"` 527} 528 529func (m *ListTopicSubscriptionsRequest) Reset() { *m = ListTopicSubscriptionsRequest{} } 530func (m *ListTopicSubscriptionsRequest) String() string { return proto.CompactTextString(m) } 531func (*ListTopicSubscriptionsRequest) ProtoMessage() {} 532func (*ListTopicSubscriptionsRequest) Descriptor() ([]byte, []int) { 533 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{9} 534} 535func (m *ListTopicSubscriptionsRequest) XXX_Unmarshal(b []byte) error { 536 return xxx_messageInfo_ListTopicSubscriptionsRequest.Unmarshal(m, b) 537} 538func (m *ListTopicSubscriptionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 539 return xxx_messageInfo_ListTopicSubscriptionsRequest.Marshal(b, m, deterministic) 540} 541func (dst *ListTopicSubscriptionsRequest) XXX_Merge(src proto.Message) { 542 xxx_messageInfo_ListTopicSubscriptionsRequest.Merge(dst, src) 543} 544func (m *ListTopicSubscriptionsRequest) XXX_Size() int { 545 return xxx_messageInfo_ListTopicSubscriptionsRequest.Size(m) 546} 547func (m *ListTopicSubscriptionsRequest) XXX_DiscardUnknown() { 548 xxx_messageInfo_ListTopicSubscriptionsRequest.DiscardUnknown(m) 549} 550 551var xxx_messageInfo_ListTopicSubscriptionsRequest proto.InternalMessageInfo 552 553func (m *ListTopicSubscriptionsRequest) GetTopic() string { 554 if m != nil { 555 return m.Topic 556 } 557 return "" 558} 559 560func (m *ListTopicSubscriptionsRequest) GetPageSize() int32 { 561 if m != nil { 562 return m.PageSize 563 } 564 return 0 565} 566 567func (m *ListTopicSubscriptionsRequest) GetPageToken() string { 568 if m != nil { 569 return m.PageToken 570 } 571 return "" 572} 573 574// Response for the `ListTopicSubscriptions` method. 575type ListTopicSubscriptionsResponse struct { 576 // The names of the subscriptions that match the request. 577 Subscriptions []string `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` 578 // If not empty, indicates that there may be more subscriptions that match 579 // the request; this value should be passed in a new 580 // `ListTopicSubscriptionsRequest` to get more subscriptions. 581 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 582 XXX_NoUnkeyedLiteral struct{} `json:"-"` 583 XXX_unrecognized []byte `json:"-"` 584 XXX_sizecache int32 `json:"-"` 585} 586 587func (m *ListTopicSubscriptionsResponse) Reset() { *m = ListTopicSubscriptionsResponse{} } 588func (m *ListTopicSubscriptionsResponse) String() string { return proto.CompactTextString(m) } 589func (*ListTopicSubscriptionsResponse) ProtoMessage() {} 590func (*ListTopicSubscriptionsResponse) Descriptor() ([]byte, []int) { 591 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{10} 592} 593func (m *ListTopicSubscriptionsResponse) XXX_Unmarshal(b []byte) error { 594 return xxx_messageInfo_ListTopicSubscriptionsResponse.Unmarshal(m, b) 595} 596func (m *ListTopicSubscriptionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 597 return xxx_messageInfo_ListTopicSubscriptionsResponse.Marshal(b, m, deterministic) 598} 599func (dst *ListTopicSubscriptionsResponse) XXX_Merge(src proto.Message) { 600 xxx_messageInfo_ListTopicSubscriptionsResponse.Merge(dst, src) 601} 602func (m *ListTopicSubscriptionsResponse) XXX_Size() int { 603 return xxx_messageInfo_ListTopicSubscriptionsResponse.Size(m) 604} 605func (m *ListTopicSubscriptionsResponse) XXX_DiscardUnknown() { 606 xxx_messageInfo_ListTopicSubscriptionsResponse.DiscardUnknown(m) 607} 608 609var xxx_messageInfo_ListTopicSubscriptionsResponse proto.InternalMessageInfo 610 611func (m *ListTopicSubscriptionsResponse) GetSubscriptions() []string { 612 if m != nil { 613 return m.Subscriptions 614 } 615 return nil 616} 617 618func (m *ListTopicSubscriptionsResponse) GetNextPageToken() string { 619 if m != nil { 620 return m.NextPageToken 621 } 622 return "" 623} 624 625// Request for the `ListTopicSnapshots` method.<br><br> 626// <b>ALPHA:</b> This feature is part of an alpha release. This API might be 627// changed in backward-incompatible ways and is not recommended for production 628// use. It is not subject to any SLA or deprecation policy. 629type ListTopicSnapshotsRequest struct { 630 // The name of the topic that snapshots are attached to. 631 // Format is `projects/{project}/topics/{topic}`. 632 Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` 633 // Maximum number of snapshot names to return. 634 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 635 // The value returned by the last `ListTopicSnapshotsResponse`; indicates 636 // that this is a continuation of a prior `ListTopicSnapshots` call, and 637 // that the system should return the next page of data. 638 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 639 XXX_NoUnkeyedLiteral struct{} `json:"-"` 640 XXX_unrecognized []byte `json:"-"` 641 XXX_sizecache int32 `json:"-"` 642} 643 644func (m *ListTopicSnapshotsRequest) Reset() { *m = ListTopicSnapshotsRequest{} } 645func (m *ListTopicSnapshotsRequest) String() string { return proto.CompactTextString(m) } 646func (*ListTopicSnapshotsRequest) ProtoMessage() {} 647func (*ListTopicSnapshotsRequest) Descriptor() ([]byte, []int) { 648 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{11} 649} 650func (m *ListTopicSnapshotsRequest) XXX_Unmarshal(b []byte) error { 651 return xxx_messageInfo_ListTopicSnapshotsRequest.Unmarshal(m, b) 652} 653func (m *ListTopicSnapshotsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 654 return xxx_messageInfo_ListTopicSnapshotsRequest.Marshal(b, m, deterministic) 655} 656func (dst *ListTopicSnapshotsRequest) XXX_Merge(src proto.Message) { 657 xxx_messageInfo_ListTopicSnapshotsRequest.Merge(dst, src) 658} 659func (m *ListTopicSnapshotsRequest) XXX_Size() int { 660 return xxx_messageInfo_ListTopicSnapshotsRequest.Size(m) 661} 662func (m *ListTopicSnapshotsRequest) XXX_DiscardUnknown() { 663 xxx_messageInfo_ListTopicSnapshotsRequest.DiscardUnknown(m) 664} 665 666var xxx_messageInfo_ListTopicSnapshotsRequest proto.InternalMessageInfo 667 668func (m *ListTopicSnapshotsRequest) GetTopic() string { 669 if m != nil { 670 return m.Topic 671 } 672 return "" 673} 674 675func (m *ListTopicSnapshotsRequest) GetPageSize() int32 { 676 if m != nil { 677 return m.PageSize 678 } 679 return 0 680} 681 682func (m *ListTopicSnapshotsRequest) GetPageToken() string { 683 if m != nil { 684 return m.PageToken 685 } 686 return "" 687} 688 689// Response for the `ListTopicSnapshots` method.<br><br> 690// <b>ALPHA:</b> This feature is part of an alpha release. This API might be 691// changed in backward-incompatible ways and is not recommended for production 692// use. It is not subject to any SLA or deprecation policy. 693type ListTopicSnapshotsResponse struct { 694 // The names of the snapshots that match the request. 695 Snapshots []string `protobuf:"bytes,1,rep,name=snapshots,proto3" json:"snapshots,omitempty"` 696 // If not empty, indicates that there may be more snapshots that match 697 // the request; this value should be passed in a new 698 // `ListTopicSnapshotsRequest` to get more snapshots. 699 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 700 XXX_NoUnkeyedLiteral struct{} `json:"-"` 701 XXX_unrecognized []byte `json:"-"` 702 XXX_sizecache int32 `json:"-"` 703} 704 705func (m *ListTopicSnapshotsResponse) Reset() { *m = ListTopicSnapshotsResponse{} } 706func (m *ListTopicSnapshotsResponse) String() string { return proto.CompactTextString(m) } 707func (*ListTopicSnapshotsResponse) ProtoMessage() {} 708func (*ListTopicSnapshotsResponse) Descriptor() ([]byte, []int) { 709 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{12} 710} 711func (m *ListTopicSnapshotsResponse) XXX_Unmarshal(b []byte) error { 712 return xxx_messageInfo_ListTopicSnapshotsResponse.Unmarshal(m, b) 713} 714func (m *ListTopicSnapshotsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 715 return xxx_messageInfo_ListTopicSnapshotsResponse.Marshal(b, m, deterministic) 716} 717func (dst *ListTopicSnapshotsResponse) XXX_Merge(src proto.Message) { 718 xxx_messageInfo_ListTopicSnapshotsResponse.Merge(dst, src) 719} 720func (m *ListTopicSnapshotsResponse) XXX_Size() int { 721 return xxx_messageInfo_ListTopicSnapshotsResponse.Size(m) 722} 723func (m *ListTopicSnapshotsResponse) XXX_DiscardUnknown() { 724 xxx_messageInfo_ListTopicSnapshotsResponse.DiscardUnknown(m) 725} 726 727var xxx_messageInfo_ListTopicSnapshotsResponse proto.InternalMessageInfo 728 729func (m *ListTopicSnapshotsResponse) GetSnapshots() []string { 730 if m != nil { 731 return m.Snapshots 732 } 733 return nil 734} 735 736func (m *ListTopicSnapshotsResponse) GetNextPageToken() string { 737 if m != nil { 738 return m.NextPageToken 739 } 740 return "" 741} 742 743// Request for the `DeleteTopic` method. 744type DeleteTopicRequest struct { 745 // Name of the topic to delete. 746 // Format is `projects/{project}/topics/{topic}`. 747 Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` 748 XXX_NoUnkeyedLiteral struct{} `json:"-"` 749 XXX_unrecognized []byte `json:"-"` 750 XXX_sizecache int32 `json:"-"` 751} 752 753func (m *DeleteTopicRequest) Reset() { *m = DeleteTopicRequest{} } 754func (m *DeleteTopicRequest) String() string { return proto.CompactTextString(m) } 755func (*DeleteTopicRequest) ProtoMessage() {} 756func (*DeleteTopicRequest) Descriptor() ([]byte, []int) { 757 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{13} 758} 759func (m *DeleteTopicRequest) XXX_Unmarshal(b []byte) error { 760 return xxx_messageInfo_DeleteTopicRequest.Unmarshal(m, b) 761} 762func (m *DeleteTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 763 return xxx_messageInfo_DeleteTopicRequest.Marshal(b, m, deterministic) 764} 765func (dst *DeleteTopicRequest) XXX_Merge(src proto.Message) { 766 xxx_messageInfo_DeleteTopicRequest.Merge(dst, src) 767} 768func (m *DeleteTopicRequest) XXX_Size() int { 769 return xxx_messageInfo_DeleteTopicRequest.Size(m) 770} 771func (m *DeleteTopicRequest) XXX_DiscardUnknown() { 772 xxx_messageInfo_DeleteTopicRequest.DiscardUnknown(m) 773} 774 775var xxx_messageInfo_DeleteTopicRequest proto.InternalMessageInfo 776 777func (m *DeleteTopicRequest) GetTopic() string { 778 if m != nil { 779 return m.Topic 780 } 781 return "" 782} 783 784// A subscription resource. 785type Subscription struct { 786 // The name of the subscription. It must have the format 787 // `"projects/{project}/subscriptions/{subscription}"`. `{subscription}` must 788 // start with a letter, and contain only letters (`[A-Za-z]`), numbers 789 // (`[0-9]`), dashes (`-`), underscores (`_`), periods (`.`), tildes (`~`), 790 // plus (`+`) or percent signs (`%`). It must be between 3 and 255 characters 791 // in length, and it must not start with `"goog"`. 792 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 793 // The name of the topic from which this subscription is receiving messages. 794 // Format is `projects/{project}/topics/{topic}`. 795 // The value of this field will be `_deleted-topic_` if the topic has been 796 // deleted. 797 Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` 798 // If push delivery is used with this subscription, this field is 799 // used to configure it. An empty `pushConfig` signifies that the subscriber 800 // will pull and ack messages using API methods. 801 PushConfig *PushConfig `protobuf:"bytes,4,opt,name=push_config,json=pushConfig,proto3" json:"push_config,omitempty"` 802 // This value is the maximum time after a subscriber receives a message 803 // before the subscriber should acknowledge the message. After message 804 // delivery but before the ack deadline expires and before the message is 805 // acknowledged, it is an outstanding message and will not be delivered 806 // again during that time (on a best-effort basis). 807 // 808 // For pull subscriptions, this value is used as the initial value for the ack 809 // deadline. To override this value for a given message, call 810 // `ModifyAckDeadline` with the corresponding `ack_id` if using 811 // non-streaming pull or send the `ack_id` in a 812 // `StreamingModifyAckDeadlineRequest` if using streaming pull. 813 // The minimum custom deadline you can specify is 10 seconds. 814 // The maximum custom deadline you can specify is 600 seconds (10 minutes). 815 // If this parameter is 0, a default value of 10 seconds is used. 816 // 817 // For push delivery, this value is also used to set the request timeout for 818 // the call to the push endpoint. 819 // 820 // If the subscriber never acknowledges the message, the Pub/Sub 821 // system will eventually redeliver the message. 822 AckDeadlineSeconds int32 `protobuf:"varint,5,opt,name=ack_deadline_seconds,json=ackDeadlineSeconds,proto3" json:"ack_deadline_seconds,omitempty"` 823 // Indicates whether to retain acknowledged messages. If true, then 824 // messages are not expunged from the subscription's backlog, even if they are 825 // acknowledged, until they fall out of the `message_retention_duration` 826 // window.<br><br> 827 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 828 // changed in backward-incompatible ways and is not recommended for production 829 // use. It is not subject to any SLA or deprecation policy. 830 RetainAckedMessages bool `protobuf:"varint,7,opt,name=retain_acked_messages,json=retainAckedMessages,proto3" json:"retain_acked_messages,omitempty"` 831 // How long to retain unacknowledged messages in the subscription's backlog, 832 // from the moment a message is published. 833 // If `retain_acked_messages` is true, then this also configures the retention 834 // of acknowledged messages, and thus configures how far back in time a `Seek` 835 // can be done. Defaults to 7 days. Cannot be more than 7 days or less than 10 836 // minutes.<br><br> 837 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 838 // changed in backward-incompatible ways and is not recommended for production 839 // use. It is not subject to any SLA or deprecation policy. 840 MessageRetentionDuration *duration.Duration `protobuf:"bytes,8,opt,name=message_retention_duration,json=messageRetentionDuration,proto3" json:"message_retention_duration,omitempty"` 841 // User labels. 842 Labels map[string]string `protobuf:"bytes,9,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 843 XXX_NoUnkeyedLiteral struct{} `json:"-"` 844 XXX_unrecognized []byte `json:"-"` 845 XXX_sizecache int32 `json:"-"` 846} 847 848func (m *Subscription) Reset() { *m = Subscription{} } 849func (m *Subscription) String() string { return proto.CompactTextString(m) } 850func (*Subscription) ProtoMessage() {} 851func (*Subscription) Descriptor() ([]byte, []int) { 852 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{14} 853} 854func (m *Subscription) XXX_Unmarshal(b []byte) error { 855 return xxx_messageInfo_Subscription.Unmarshal(m, b) 856} 857func (m *Subscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 858 return xxx_messageInfo_Subscription.Marshal(b, m, deterministic) 859} 860func (dst *Subscription) XXX_Merge(src proto.Message) { 861 xxx_messageInfo_Subscription.Merge(dst, src) 862} 863func (m *Subscription) XXX_Size() int { 864 return xxx_messageInfo_Subscription.Size(m) 865} 866func (m *Subscription) XXX_DiscardUnknown() { 867 xxx_messageInfo_Subscription.DiscardUnknown(m) 868} 869 870var xxx_messageInfo_Subscription proto.InternalMessageInfo 871 872func (m *Subscription) GetName() string { 873 if m != nil { 874 return m.Name 875 } 876 return "" 877} 878 879func (m *Subscription) GetTopic() string { 880 if m != nil { 881 return m.Topic 882 } 883 return "" 884} 885 886func (m *Subscription) GetPushConfig() *PushConfig { 887 if m != nil { 888 return m.PushConfig 889 } 890 return nil 891} 892 893func (m *Subscription) GetAckDeadlineSeconds() int32 { 894 if m != nil { 895 return m.AckDeadlineSeconds 896 } 897 return 0 898} 899 900func (m *Subscription) GetRetainAckedMessages() bool { 901 if m != nil { 902 return m.RetainAckedMessages 903 } 904 return false 905} 906 907func (m *Subscription) GetMessageRetentionDuration() *duration.Duration { 908 if m != nil { 909 return m.MessageRetentionDuration 910 } 911 return nil 912} 913 914func (m *Subscription) GetLabels() map[string]string { 915 if m != nil { 916 return m.Labels 917 } 918 return nil 919} 920 921// Configuration for a push delivery endpoint. 922type PushConfig struct { 923 // A URL locating the endpoint to which messages should be pushed. 924 // For example, a Webhook endpoint might use "https://example.com/push". 925 PushEndpoint string `protobuf:"bytes,1,opt,name=push_endpoint,json=pushEndpoint,proto3" json:"push_endpoint,omitempty"` 926 // Endpoint configuration attributes. 927 // 928 // Every endpoint has a set of API supported attributes that can be used to 929 // control different aspects of the message delivery. 930 // 931 // The currently supported attribute is `x-goog-version`, which you can 932 // use to change the format of the pushed message. This attribute 933 // indicates the version of the data expected by the endpoint. This 934 // controls the shape of the pushed message (i.e., its fields and metadata). 935 // The endpoint version is based on the version of the Pub/Sub API. 936 // 937 // If not present during the `CreateSubscription` call, it will default to 938 // the version of the API used to make such call. If not present during a 939 // `ModifyPushConfig` call, its value will not be changed. `GetSubscription` 940 // calls will always return a valid version, even if the subscription was 941 // created without this attribute. 942 // 943 // The possible values for this attribute are: 944 // 945 // * `v1beta1`: uses the push format defined in the v1beta1 Pub/Sub API. 946 // * `v1` or `v1beta2`: uses the push format defined in the v1 Pub/Sub API. 947 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"` 948 XXX_NoUnkeyedLiteral struct{} `json:"-"` 949 XXX_unrecognized []byte `json:"-"` 950 XXX_sizecache int32 `json:"-"` 951} 952 953func (m *PushConfig) Reset() { *m = PushConfig{} } 954func (m *PushConfig) String() string { return proto.CompactTextString(m) } 955func (*PushConfig) ProtoMessage() {} 956func (*PushConfig) Descriptor() ([]byte, []int) { 957 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{15} 958} 959func (m *PushConfig) XXX_Unmarshal(b []byte) error { 960 return xxx_messageInfo_PushConfig.Unmarshal(m, b) 961} 962func (m *PushConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 963 return xxx_messageInfo_PushConfig.Marshal(b, m, deterministic) 964} 965func (dst *PushConfig) XXX_Merge(src proto.Message) { 966 xxx_messageInfo_PushConfig.Merge(dst, src) 967} 968func (m *PushConfig) XXX_Size() int { 969 return xxx_messageInfo_PushConfig.Size(m) 970} 971func (m *PushConfig) XXX_DiscardUnknown() { 972 xxx_messageInfo_PushConfig.DiscardUnknown(m) 973} 974 975var xxx_messageInfo_PushConfig proto.InternalMessageInfo 976 977func (m *PushConfig) GetPushEndpoint() string { 978 if m != nil { 979 return m.PushEndpoint 980 } 981 return "" 982} 983 984func (m *PushConfig) GetAttributes() map[string]string { 985 if m != nil { 986 return m.Attributes 987 } 988 return nil 989} 990 991// A message and its corresponding acknowledgment ID. 992type ReceivedMessage struct { 993 // This ID can be used to acknowledge the received message. 994 AckId string `protobuf:"bytes,1,opt,name=ack_id,json=ackId,proto3" json:"ack_id,omitempty"` 995 // The message. 996 Message *PubsubMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` 997 XXX_NoUnkeyedLiteral struct{} `json:"-"` 998 XXX_unrecognized []byte `json:"-"` 999 XXX_sizecache int32 `json:"-"` 1000} 1001 1002func (m *ReceivedMessage) Reset() { *m = ReceivedMessage{} } 1003func (m *ReceivedMessage) String() string { return proto.CompactTextString(m) } 1004func (*ReceivedMessage) ProtoMessage() {} 1005func (*ReceivedMessage) Descriptor() ([]byte, []int) { 1006 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{16} 1007} 1008func (m *ReceivedMessage) XXX_Unmarshal(b []byte) error { 1009 return xxx_messageInfo_ReceivedMessage.Unmarshal(m, b) 1010} 1011func (m *ReceivedMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1012 return xxx_messageInfo_ReceivedMessage.Marshal(b, m, deterministic) 1013} 1014func (dst *ReceivedMessage) XXX_Merge(src proto.Message) { 1015 xxx_messageInfo_ReceivedMessage.Merge(dst, src) 1016} 1017func (m *ReceivedMessage) XXX_Size() int { 1018 return xxx_messageInfo_ReceivedMessage.Size(m) 1019} 1020func (m *ReceivedMessage) XXX_DiscardUnknown() { 1021 xxx_messageInfo_ReceivedMessage.DiscardUnknown(m) 1022} 1023 1024var xxx_messageInfo_ReceivedMessage proto.InternalMessageInfo 1025 1026func (m *ReceivedMessage) GetAckId() string { 1027 if m != nil { 1028 return m.AckId 1029 } 1030 return "" 1031} 1032 1033func (m *ReceivedMessage) GetMessage() *PubsubMessage { 1034 if m != nil { 1035 return m.Message 1036 } 1037 return nil 1038} 1039 1040// Request for the GetSubscription method. 1041type GetSubscriptionRequest struct { 1042 // The name of the subscription to get. 1043 // Format is `projects/{project}/subscriptions/{sub}`. 1044 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 1045 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1046 XXX_unrecognized []byte `json:"-"` 1047 XXX_sizecache int32 `json:"-"` 1048} 1049 1050func (m *GetSubscriptionRequest) Reset() { *m = GetSubscriptionRequest{} } 1051func (m *GetSubscriptionRequest) String() string { return proto.CompactTextString(m) } 1052func (*GetSubscriptionRequest) ProtoMessage() {} 1053func (*GetSubscriptionRequest) Descriptor() ([]byte, []int) { 1054 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{17} 1055} 1056func (m *GetSubscriptionRequest) XXX_Unmarshal(b []byte) error { 1057 return xxx_messageInfo_GetSubscriptionRequest.Unmarshal(m, b) 1058} 1059func (m *GetSubscriptionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1060 return xxx_messageInfo_GetSubscriptionRequest.Marshal(b, m, deterministic) 1061} 1062func (dst *GetSubscriptionRequest) XXX_Merge(src proto.Message) { 1063 xxx_messageInfo_GetSubscriptionRequest.Merge(dst, src) 1064} 1065func (m *GetSubscriptionRequest) XXX_Size() int { 1066 return xxx_messageInfo_GetSubscriptionRequest.Size(m) 1067} 1068func (m *GetSubscriptionRequest) XXX_DiscardUnknown() { 1069 xxx_messageInfo_GetSubscriptionRequest.DiscardUnknown(m) 1070} 1071 1072var xxx_messageInfo_GetSubscriptionRequest proto.InternalMessageInfo 1073 1074func (m *GetSubscriptionRequest) GetSubscription() string { 1075 if m != nil { 1076 return m.Subscription 1077 } 1078 return "" 1079} 1080 1081// Request for the UpdateSubscription method. 1082type UpdateSubscriptionRequest struct { 1083 // The updated subscription object. 1084 Subscription *Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 1085 // Indicates which fields in the provided subscription to update. 1086 // Must be specified and non-empty. 1087 UpdateMask *field_mask.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` 1088 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1089 XXX_unrecognized []byte `json:"-"` 1090 XXX_sizecache int32 `json:"-"` 1091} 1092 1093func (m *UpdateSubscriptionRequest) Reset() { *m = UpdateSubscriptionRequest{} } 1094func (m *UpdateSubscriptionRequest) String() string { return proto.CompactTextString(m) } 1095func (*UpdateSubscriptionRequest) ProtoMessage() {} 1096func (*UpdateSubscriptionRequest) Descriptor() ([]byte, []int) { 1097 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{18} 1098} 1099func (m *UpdateSubscriptionRequest) XXX_Unmarshal(b []byte) error { 1100 return xxx_messageInfo_UpdateSubscriptionRequest.Unmarshal(m, b) 1101} 1102func (m *UpdateSubscriptionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1103 return xxx_messageInfo_UpdateSubscriptionRequest.Marshal(b, m, deterministic) 1104} 1105func (dst *UpdateSubscriptionRequest) XXX_Merge(src proto.Message) { 1106 xxx_messageInfo_UpdateSubscriptionRequest.Merge(dst, src) 1107} 1108func (m *UpdateSubscriptionRequest) XXX_Size() int { 1109 return xxx_messageInfo_UpdateSubscriptionRequest.Size(m) 1110} 1111func (m *UpdateSubscriptionRequest) XXX_DiscardUnknown() { 1112 xxx_messageInfo_UpdateSubscriptionRequest.DiscardUnknown(m) 1113} 1114 1115var xxx_messageInfo_UpdateSubscriptionRequest proto.InternalMessageInfo 1116 1117func (m *UpdateSubscriptionRequest) GetSubscription() *Subscription { 1118 if m != nil { 1119 return m.Subscription 1120 } 1121 return nil 1122} 1123 1124func (m *UpdateSubscriptionRequest) GetUpdateMask() *field_mask.FieldMask { 1125 if m != nil { 1126 return m.UpdateMask 1127 } 1128 return nil 1129} 1130 1131// Request for the `ListSubscriptions` method. 1132type ListSubscriptionsRequest struct { 1133 // The name of the cloud project that subscriptions belong to. 1134 // Format is `projects/{project}`. 1135 Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` 1136 // Maximum number of subscriptions to return. 1137 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 1138 // The value returned by the last `ListSubscriptionsResponse`; indicates that 1139 // this is a continuation of a prior `ListSubscriptions` call, and that the 1140 // system should return the next page of data. 1141 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 1142 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1143 XXX_unrecognized []byte `json:"-"` 1144 XXX_sizecache int32 `json:"-"` 1145} 1146 1147func (m *ListSubscriptionsRequest) Reset() { *m = ListSubscriptionsRequest{} } 1148func (m *ListSubscriptionsRequest) String() string { return proto.CompactTextString(m) } 1149func (*ListSubscriptionsRequest) ProtoMessage() {} 1150func (*ListSubscriptionsRequest) Descriptor() ([]byte, []int) { 1151 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{19} 1152} 1153func (m *ListSubscriptionsRequest) XXX_Unmarshal(b []byte) error { 1154 return xxx_messageInfo_ListSubscriptionsRequest.Unmarshal(m, b) 1155} 1156func (m *ListSubscriptionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1157 return xxx_messageInfo_ListSubscriptionsRequest.Marshal(b, m, deterministic) 1158} 1159func (dst *ListSubscriptionsRequest) XXX_Merge(src proto.Message) { 1160 xxx_messageInfo_ListSubscriptionsRequest.Merge(dst, src) 1161} 1162func (m *ListSubscriptionsRequest) XXX_Size() int { 1163 return xxx_messageInfo_ListSubscriptionsRequest.Size(m) 1164} 1165func (m *ListSubscriptionsRequest) XXX_DiscardUnknown() { 1166 xxx_messageInfo_ListSubscriptionsRequest.DiscardUnknown(m) 1167} 1168 1169var xxx_messageInfo_ListSubscriptionsRequest proto.InternalMessageInfo 1170 1171func (m *ListSubscriptionsRequest) GetProject() string { 1172 if m != nil { 1173 return m.Project 1174 } 1175 return "" 1176} 1177 1178func (m *ListSubscriptionsRequest) GetPageSize() int32 { 1179 if m != nil { 1180 return m.PageSize 1181 } 1182 return 0 1183} 1184 1185func (m *ListSubscriptionsRequest) GetPageToken() string { 1186 if m != nil { 1187 return m.PageToken 1188 } 1189 return "" 1190} 1191 1192// Response for the `ListSubscriptions` method. 1193type ListSubscriptionsResponse struct { 1194 // The subscriptions that match the request. 1195 Subscriptions []*Subscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` 1196 // If not empty, indicates that there may be more subscriptions that match 1197 // the request; this value should be passed in a new 1198 // `ListSubscriptionsRequest` to get more subscriptions. 1199 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 1200 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1201 XXX_unrecognized []byte `json:"-"` 1202 XXX_sizecache int32 `json:"-"` 1203} 1204 1205func (m *ListSubscriptionsResponse) Reset() { *m = ListSubscriptionsResponse{} } 1206func (m *ListSubscriptionsResponse) String() string { return proto.CompactTextString(m) } 1207func (*ListSubscriptionsResponse) ProtoMessage() {} 1208func (*ListSubscriptionsResponse) Descriptor() ([]byte, []int) { 1209 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{20} 1210} 1211func (m *ListSubscriptionsResponse) XXX_Unmarshal(b []byte) error { 1212 return xxx_messageInfo_ListSubscriptionsResponse.Unmarshal(m, b) 1213} 1214func (m *ListSubscriptionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1215 return xxx_messageInfo_ListSubscriptionsResponse.Marshal(b, m, deterministic) 1216} 1217func (dst *ListSubscriptionsResponse) XXX_Merge(src proto.Message) { 1218 xxx_messageInfo_ListSubscriptionsResponse.Merge(dst, src) 1219} 1220func (m *ListSubscriptionsResponse) XXX_Size() int { 1221 return xxx_messageInfo_ListSubscriptionsResponse.Size(m) 1222} 1223func (m *ListSubscriptionsResponse) XXX_DiscardUnknown() { 1224 xxx_messageInfo_ListSubscriptionsResponse.DiscardUnknown(m) 1225} 1226 1227var xxx_messageInfo_ListSubscriptionsResponse proto.InternalMessageInfo 1228 1229func (m *ListSubscriptionsResponse) GetSubscriptions() []*Subscription { 1230 if m != nil { 1231 return m.Subscriptions 1232 } 1233 return nil 1234} 1235 1236func (m *ListSubscriptionsResponse) GetNextPageToken() string { 1237 if m != nil { 1238 return m.NextPageToken 1239 } 1240 return "" 1241} 1242 1243// Request for the DeleteSubscription method. 1244type DeleteSubscriptionRequest struct { 1245 // The subscription to delete. 1246 // Format is `projects/{project}/subscriptions/{sub}`. 1247 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 1248 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1249 XXX_unrecognized []byte `json:"-"` 1250 XXX_sizecache int32 `json:"-"` 1251} 1252 1253func (m *DeleteSubscriptionRequest) Reset() { *m = DeleteSubscriptionRequest{} } 1254func (m *DeleteSubscriptionRequest) String() string { return proto.CompactTextString(m) } 1255func (*DeleteSubscriptionRequest) ProtoMessage() {} 1256func (*DeleteSubscriptionRequest) Descriptor() ([]byte, []int) { 1257 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{21} 1258} 1259func (m *DeleteSubscriptionRequest) XXX_Unmarshal(b []byte) error { 1260 return xxx_messageInfo_DeleteSubscriptionRequest.Unmarshal(m, b) 1261} 1262func (m *DeleteSubscriptionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1263 return xxx_messageInfo_DeleteSubscriptionRequest.Marshal(b, m, deterministic) 1264} 1265func (dst *DeleteSubscriptionRequest) XXX_Merge(src proto.Message) { 1266 xxx_messageInfo_DeleteSubscriptionRequest.Merge(dst, src) 1267} 1268func (m *DeleteSubscriptionRequest) XXX_Size() int { 1269 return xxx_messageInfo_DeleteSubscriptionRequest.Size(m) 1270} 1271func (m *DeleteSubscriptionRequest) XXX_DiscardUnknown() { 1272 xxx_messageInfo_DeleteSubscriptionRequest.DiscardUnknown(m) 1273} 1274 1275var xxx_messageInfo_DeleteSubscriptionRequest proto.InternalMessageInfo 1276 1277func (m *DeleteSubscriptionRequest) GetSubscription() string { 1278 if m != nil { 1279 return m.Subscription 1280 } 1281 return "" 1282} 1283 1284// Request for the ModifyPushConfig method. 1285type ModifyPushConfigRequest struct { 1286 // The name of the subscription. 1287 // Format is `projects/{project}/subscriptions/{sub}`. 1288 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 1289 // The push configuration for future deliveries. 1290 // 1291 // An empty `pushConfig` indicates that the Pub/Sub system should 1292 // stop pushing messages from the given subscription and allow 1293 // messages to be pulled and acknowledged - effectively pausing 1294 // the subscription if `Pull` or `StreamingPull` is not called. 1295 PushConfig *PushConfig `protobuf:"bytes,2,opt,name=push_config,json=pushConfig,proto3" json:"push_config,omitempty"` 1296 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1297 XXX_unrecognized []byte `json:"-"` 1298 XXX_sizecache int32 `json:"-"` 1299} 1300 1301func (m *ModifyPushConfigRequest) Reset() { *m = ModifyPushConfigRequest{} } 1302func (m *ModifyPushConfigRequest) String() string { return proto.CompactTextString(m) } 1303func (*ModifyPushConfigRequest) ProtoMessage() {} 1304func (*ModifyPushConfigRequest) Descriptor() ([]byte, []int) { 1305 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{22} 1306} 1307func (m *ModifyPushConfigRequest) XXX_Unmarshal(b []byte) error { 1308 return xxx_messageInfo_ModifyPushConfigRequest.Unmarshal(m, b) 1309} 1310func (m *ModifyPushConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1311 return xxx_messageInfo_ModifyPushConfigRequest.Marshal(b, m, deterministic) 1312} 1313func (dst *ModifyPushConfigRequest) XXX_Merge(src proto.Message) { 1314 xxx_messageInfo_ModifyPushConfigRequest.Merge(dst, src) 1315} 1316func (m *ModifyPushConfigRequest) XXX_Size() int { 1317 return xxx_messageInfo_ModifyPushConfigRequest.Size(m) 1318} 1319func (m *ModifyPushConfigRequest) XXX_DiscardUnknown() { 1320 xxx_messageInfo_ModifyPushConfigRequest.DiscardUnknown(m) 1321} 1322 1323var xxx_messageInfo_ModifyPushConfigRequest proto.InternalMessageInfo 1324 1325func (m *ModifyPushConfigRequest) GetSubscription() string { 1326 if m != nil { 1327 return m.Subscription 1328 } 1329 return "" 1330} 1331 1332func (m *ModifyPushConfigRequest) GetPushConfig() *PushConfig { 1333 if m != nil { 1334 return m.PushConfig 1335 } 1336 return nil 1337} 1338 1339// Request for the `Pull` method. 1340type PullRequest struct { 1341 // The subscription from which messages should be pulled. 1342 // Format is `projects/{project}/subscriptions/{sub}`. 1343 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 1344 // If this field set to true, the system will respond immediately even if 1345 // it there are no messages available to return in the `Pull` response. 1346 // Otherwise, the system may wait (for a bounded amount of time) until at 1347 // least one message is available, rather than returning no messages. The 1348 // client may cancel the request if it does not wish to wait any longer for 1349 // the response. 1350 ReturnImmediately bool `protobuf:"varint,2,opt,name=return_immediately,json=returnImmediately,proto3" json:"return_immediately,omitempty"` 1351 // The maximum number of messages returned for this request. The Pub/Sub 1352 // system may return fewer than the number specified. 1353 MaxMessages int32 `protobuf:"varint,3,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"` 1354 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1355 XXX_unrecognized []byte `json:"-"` 1356 XXX_sizecache int32 `json:"-"` 1357} 1358 1359func (m *PullRequest) Reset() { *m = PullRequest{} } 1360func (m *PullRequest) String() string { return proto.CompactTextString(m) } 1361func (*PullRequest) ProtoMessage() {} 1362func (*PullRequest) Descriptor() ([]byte, []int) { 1363 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{23} 1364} 1365func (m *PullRequest) XXX_Unmarshal(b []byte) error { 1366 return xxx_messageInfo_PullRequest.Unmarshal(m, b) 1367} 1368func (m *PullRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1369 return xxx_messageInfo_PullRequest.Marshal(b, m, deterministic) 1370} 1371func (dst *PullRequest) XXX_Merge(src proto.Message) { 1372 xxx_messageInfo_PullRequest.Merge(dst, src) 1373} 1374func (m *PullRequest) XXX_Size() int { 1375 return xxx_messageInfo_PullRequest.Size(m) 1376} 1377func (m *PullRequest) XXX_DiscardUnknown() { 1378 xxx_messageInfo_PullRequest.DiscardUnknown(m) 1379} 1380 1381var xxx_messageInfo_PullRequest proto.InternalMessageInfo 1382 1383func (m *PullRequest) GetSubscription() string { 1384 if m != nil { 1385 return m.Subscription 1386 } 1387 return "" 1388} 1389 1390func (m *PullRequest) GetReturnImmediately() bool { 1391 if m != nil { 1392 return m.ReturnImmediately 1393 } 1394 return false 1395} 1396 1397func (m *PullRequest) GetMaxMessages() int32 { 1398 if m != nil { 1399 return m.MaxMessages 1400 } 1401 return 0 1402} 1403 1404// Response for the `Pull` method. 1405type PullResponse struct { 1406 // Received Pub/Sub messages. The Pub/Sub system will return zero messages if 1407 // there are no more available in the backlog. The Pub/Sub system may return 1408 // fewer than the `maxMessages` requested even if there are more messages 1409 // available in the backlog. 1410 ReceivedMessages []*ReceivedMessage `protobuf:"bytes,1,rep,name=received_messages,json=receivedMessages,proto3" json:"received_messages,omitempty"` 1411 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1412 XXX_unrecognized []byte `json:"-"` 1413 XXX_sizecache int32 `json:"-"` 1414} 1415 1416func (m *PullResponse) Reset() { *m = PullResponse{} } 1417func (m *PullResponse) String() string { return proto.CompactTextString(m) } 1418func (*PullResponse) ProtoMessage() {} 1419func (*PullResponse) Descriptor() ([]byte, []int) { 1420 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{24} 1421} 1422func (m *PullResponse) XXX_Unmarshal(b []byte) error { 1423 return xxx_messageInfo_PullResponse.Unmarshal(m, b) 1424} 1425func (m *PullResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1426 return xxx_messageInfo_PullResponse.Marshal(b, m, deterministic) 1427} 1428func (dst *PullResponse) XXX_Merge(src proto.Message) { 1429 xxx_messageInfo_PullResponse.Merge(dst, src) 1430} 1431func (m *PullResponse) XXX_Size() int { 1432 return xxx_messageInfo_PullResponse.Size(m) 1433} 1434func (m *PullResponse) XXX_DiscardUnknown() { 1435 xxx_messageInfo_PullResponse.DiscardUnknown(m) 1436} 1437 1438var xxx_messageInfo_PullResponse proto.InternalMessageInfo 1439 1440func (m *PullResponse) GetReceivedMessages() []*ReceivedMessage { 1441 if m != nil { 1442 return m.ReceivedMessages 1443 } 1444 return nil 1445} 1446 1447// Request for the ModifyAckDeadline method. 1448type ModifyAckDeadlineRequest struct { 1449 // The name of the subscription. 1450 // Format is `projects/{project}/subscriptions/{sub}`. 1451 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 1452 // List of acknowledgment IDs. 1453 AckIds []string `protobuf:"bytes,4,rep,name=ack_ids,json=ackIds,proto3" json:"ack_ids,omitempty"` 1454 // The new ack deadline with respect to the time this request was sent to 1455 // the Pub/Sub system. For example, if the value is 10, the new 1456 // ack deadline will expire 10 seconds after the `ModifyAckDeadline` call 1457 // was made. Specifying zero may immediately make the message available for 1458 // another pull request. 1459 // The minimum deadline you can specify is 0 seconds. 1460 // The maximum deadline you can specify is 600 seconds (10 minutes). 1461 AckDeadlineSeconds int32 `protobuf:"varint,3,opt,name=ack_deadline_seconds,json=ackDeadlineSeconds,proto3" json:"ack_deadline_seconds,omitempty"` 1462 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1463 XXX_unrecognized []byte `json:"-"` 1464 XXX_sizecache int32 `json:"-"` 1465} 1466 1467func (m *ModifyAckDeadlineRequest) Reset() { *m = ModifyAckDeadlineRequest{} } 1468func (m *ModifyAckDeadlineRequest) String() string { return proto.CompactTextString(m) } 1469func (*ModifyAckDeadlineRequest) ProtoMessage() {} 1470func (*ModifyAckDeadlineRequest) Descriptor() ([]byte, []int) { 1471 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{25} 1472} 1473func (m *ModifyAckDeadlineRequest) XXX_Unmarshal(b []byte) error { 1474 return xxx_messageInfo_ModifyAckDeadlineRequest.Unmarshal(m, b) 1475} 1476func (m *ModifyAckDeadlineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1477 return xxx_messageInfo_ModifyAckDeadlineRequest.Marshal(b, m, deterministic) 1478} 1479func (dst *ModifyAckDeadlineRequest) XXX_Merge(src proto.Message) { 1480 xxx_messageInfo_ModifyAckDeadlineRequest.Merge(dst, src) 1481} 1482func (m *ModifyAckDeadlineRequest) XXX_Size() int { 1483 return xxx_messageInfo_ModifyAckDeadlineRequest.Size(m) 1484} 1485func (m *ModifyAckDeadlineRequest) XXX_DiscardUnknown() { 1486 xxx_messageInfo_ModifyAckDeadlineRequest.DiscardUnknown(m) 1487} 1488 1489var xxx_messageInfo_ModifyAckDeadlineRequest proto.InternalMessageInfo 1490 1491func (m *ModifyAckDeadlineRequest) GetSubscription() string { 1492 if m != nil { 1493 return m.Subscription 1494 } 1495 return "" 1496} 1497 1498func (m *ModifyAckDeadlineRequest) GetAckIds() []string { 1499 if m != nil { 1500 return m.AckIds 1501 } 1502 return nil 1503} 1504 1505func (m *ModifyAckDeadlineRequest) GetAckDeadlineSeconds() int32 { 1506 if m != nil { 1507 return m.AckDeadlineSeconds 1508 } 1509 return 0 1510} 1511 1512// Request for the Acknowledge method. 1513type AcknowledgeRequest struct { 1514 // The subscription whose message is being acknowledged. 1515 // Format is `projects/{project}/subscriptions/{sub}`. 1516 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 1517 // The acknowledgment ID for the messages being acknowledged that was returned 1518 // by the Pub/Sub system in the `Pull` response. Must not be empty. 1519 AckIds []string `protobuf:"bytes,2,rep,name=ack_ids,json=ackIds,proto3" json:"ack_ids,omitempty"` 1520 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1521 XXX_unrecognized []byte `json:"-"` 1522 XXX_sizecache int32 `json:"-"` 1523} 1524 1525func (m *AcknowledgeRequest) Reset() { *m = AcknowledgeRequest{} } 1526func (m *AcknowledgeRequest) String() string { return proto.CompactTextString(m) } 1527func (*AcknowledgeRequest) ProtoMessage() {} 1528func (*AcknowledgeRequest) Descriptor() ([]byte, []int) { 1529 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{26} 1530} 1531func (m *AcknowledgeRequest) XXX_Unmarshal(b []byte) error { 1532 return xxx_messageInfo_AcknowledgeRequest.Unmarshal(m, b) 1533} 1534func (m *AcknowledgeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1535 return xxx_messageInfo_AcknowledgeRequest.Marshal(b, m, deterministic) 1536} 1537func (dst *AcknowledgeRequest) XXX_Merge(src proto.Message) { 1538 xxx_messageInfo_AcknowledgeRequest.Merge(dst, src) 1539} 1540func (m *AcknowledgeRequest) XXX_Size() int { 1541 return xxx_messageInfo_AcknowledgeRequest.Size(m) 1542} 1543func (m *AcknowledgeRequest) XXX_DiscardUnknown() { 1544 xxx_messageInfo_AcknowledgeRequest.DiscardUnknown(m) 1545} 1546 1547var xxx_messageInfo_AcknowledgeRequest proto.InternalMessageInfo 1548 1549func (m *AcknowledgeRequest) GetSubscription() string { 1550 if m != nil { 1551 return m.Subscription 1552 } 1553 return "" 1554} 1555 1556func (m *AcknowledgeRequest) GetAckIds() []string { 1557 if m != nil { 1558 return m.AckIds 1559 } 1560 return nil 1561} 1562 1563// Request for the `StreamingPull` streaming RPC method. This request is used to 1564// establish the initial stream as well as to stream acknowledgements and ack 1565// deadline modifications from the client to the server. 1566type StreamingPullRequest struct { 1567 // The subscription for which to initialize the new stream. This must be 1568 // provided in the first request on the stream, and must not be set in 1569 // subsequent requests from client to server. 1570 // Format is `projects/{project}/subscriptions/{sub}`. 1571 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 1572 // List of acknowledgement IDs for acknowledging previously received messages 1573 // (received on this stream or a different stream). If an ack ID has expired, 1574 // the corresponding message may be redelivered later. Acknowledging a message 1575 // more than once will not result in an error. If the acknowledgement ID is 1576 // malformed, the stream will be aborted with status `INVALID_ARGUMENT`. 1577 AckIds []string `protobuf:"bytes,2,rep,name=ack_ids,json=ackIds,proto3" json:"ack_ids,omitempty"` 1578 // The list of new ack deadlines for the IDs listed in 1579 // `modify_deadline_ack_ids`. The size of this list must be the same as the 1580 // size of `modify_deadline_ack_ids`. If it differs the stream will be aborted 1581 // with `INVALID_ARGUMENT`. Each element in this list is applied to the 1582 // element in the same position in `modify_deadline_ack_ids`. The new ack 1583 // deadline is with respect to the time this request was sent to the Pub/Sub 1584 // system. Must be >= 0. For example, if the value is 10, the new ack deadline 1585 // will expire 10 seconds after this request is received. If the value is 0, 1586 // the message is immediately made available for another streaming or 1587 // non-streaming pull request. If the value is < 0 (an error), the stream will 1588 // be aborted with status `INVALID_ARGUMENT`. 1589 ModifyDeadlineSeconds []int32 `protobuf:"varint,3,rep,packed,name=modify_deadline_seconds,json=modifyDeadlineSeconds,proto3" json:"modify_deadline_seconds,omitempty"` 1590 // List of acknowledgement IDs whose deadline will be modified based on the 1591 // corresponding element in `modify_deadline_seconds`. This field can be used 1592 // to indicate that more time is needed to process a message by the 1593 // subscriber, or to make the message available for redelivery if the 1594 // processing was interrupted. 1595 ModifyDeadlineAckIds []string `protobuf:"bytes,4,rep,name=modify_deadline_ack_ids,json=modifyDeadlineAckIds,proto3" json:"modify_deadline_ack_ids,omitempty"` 1596 // The ack deadline to use for the stream. This must be provided in the 1597 // first request on the stream, but it can also be updated on subsequent 1598 // requests from client to server. The minimum deadline you can specify is 10 1599 // seconds. The maximum deadline you can specify is 600 seconds (10 minutes). 1600 StreamAckDeadlineSeconds int32 `protobuf:"varint,5,opt,name=stream_ack_deadline_seconds,json=streamAckDeadlineSeconds,proto3" json:"stream_ack_deadline_seconds,omitempty"` 1601 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1602 XXX_unrecognized []byte `json:"-"` 1603 XXX_sizecache int32 `json:"-"` 1604} 1605 1606func (m *StreamingPullRequest) Reset() { *m = StreamingPullRequest{} } 1607func (m *StreamingPullRequest) String() string { return proto.CompactTextString(m) } 1608func (*StreamingPullRequest) ProtoMessage() {} 1609func (*StreamingPullRequest) Descriptor() ([]byte, []int) { 1610 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{27} 1611} 1612func (m *StreamingPullRequest) XXX_Unmarshal(b []byte) error { 1613 return xxx_messageInfo_StreamingPullRequest.Unmarshal(m, b) 1614} 1615func (m *StreamingPullRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1616 return xxx_messageInfo_StreamingPullRequest.Marshal(b, m, deterministic) 1617} 1618func (dst *StreamingPullRequest) XXX_Merge(src proto.Message) { 1619 xxx_messageInfo_StreamingPullRequest.Merge(dst, src) 1620} 1621func (m *StreamingPullRequest) XXX_Size() int { 1622 return xxx_messageInfo_StreamingPullRequest.Size(m) 1623} 1624func (m *StreamingPullRequest) XXX_DiscardUnknown() { 1625 xxx_messageInfo_StreamingPullRequest.DiscardUnknown(m) 1626} 1627 1628var xxx_messageInfo_StreamingPullRequest proto.InternalMessageInfo 1629 1630func (m *StreamingPullRequest) GetSubscription() string { 1631 if m != nil { 1632 return m.Subscription 1633 } 1634 return "" 1635} 1636 1637func (m *StreamingPullRequest) GetAckIds() []string { 1638 if m != nil { 1639 return m.AckIds 1640 } 1641 return nil 1642} 1643 1644func (m *StreamingPullRequest) GetModifyDeadlineSeconds() []int32 { 1645 if m != nil { 1646 return m.ModifyDeadlineSeconds 1647 } 1648 return nil 1649} 1650 1651func (m *StreamingPullRequest) GetModifyDeadlineAckIds() []string { 1652 if m != nil { 1653 return m.ModifyDeadlineAckIds 1654 } 1655 return nil 1656} 1657 1658func (m *StreamingPullRequest) GetStreamAckDeadlineSeconds() int32 { 1659 if m != nil { 1660 return m.StreamAckDeadlineSeconds 1661 } 1662 return 0 1663} 1664 1665// Response for the `StreamingPull` method. This response is used to stream 1666// messages from the server to the client. 1667type StreamingPullResponse struct { 1668 // Received Pub/Sub messages. This will not be empty. 1669 ReceivedMessages []*ReceivedMessage `protobuf:"bytes,1,rep,name=received_messages,json=receivedMessages,proto3" json:"received_messages,omitempty"` 1670 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1671 XXX_unrecognized []byte `json:"-"` 1672 XXX_sizecache int32 `json:"-"` 1673} 1674 1675func (m *StreamingPullResponse) Reset() { *m = StreamingPullResponse{} } 1676func (m *StreamingPullResponse) String() string { return proto.CompactTextString(m) } 1677func (*StreamingPullResponse) ProtoMessage() {} 1678func (*StreamingPullResponse) Descriptor() ([]byte, []int) { 1679 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{28} 1680} 1681func (m *StreamingPullResponse) XXX_Unmarshal(b []byte) error { 1682 return xxx_messageInfo_StreamingPullResponse.Unmarshal(m, b) 1683} 1684func (m *StreamingPullResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1685 return xxx_messageInfo_StreamingPullResponse.Marshal(b, m, deterministic) 1686} 1687func (dst *StreamingPullResponse) XXX_Merge(src proto.Message) { 1688 xxx_messageInfo_StreamingPullResponse.Merge(dst, src) 1689} 1690func (m *StreamingPullResponse) XXX_Size() int { 1691 return xxx_messageInfo_StreamingPullResponse.Size(m) 1692} 1693func (m *StreamingPullResponse) XXX_DiscardUnknown() { 1694 xxx_messageInfo_StreamingPullResponse.DiscardUnknown(m) 1695} 1696 1697var xxx_messageInfo_StreamingPullResponse proto.InternalMessageInfo 1698 1699func (m *StreamingPullResponse) GetReceivedMessages() []*ReceivedMessage { 1700 if m != nil { 1701 return m.ReceivedMessages 1702 } 1703 return nil 1704} 1705 1706// Request for the `CreateSnapshot` method.<br><br> 1707// <b>ALPHA:</b> This feature is part of an alpha release. This API might be changed in 1708// backward-incompatible ways and is not recommended for production use. 1709// It is not subject to any SLA or deprecation policy. 1710type CreateSnapshotRequest struct { 1711 // Optional user-provided name for this snapshot. 1712 // If the name is not provided in the request, the server will assign a random 1713 // name for this snapshot on the same project as the subscription. 1714 // Note that for REST API requests, you must specify a name. 1715 // Format is `projects/{project}/snapshots/{snap}`. 1716 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 1717 // The subscription whose backlog the snapshot retains. 1718 // Specifically, the created snapshot is guaranteed to retain: 1719 // (a) The existing backlog on the subscription. More precisely, this is 1720 // defined as the messages in the subscription's backlog that are 1721 // unacknowledged upon the successful completion of the 1722 // `CreateSnapshot` request; as well as: 1723 // (b) Any messages published to the subscription's topic following the 1724 // successful completion of the CreateSnapshot request. 1725 // Format is `projects/{project}/subscriptions/{sub}`. 1726 Subscription string `protobuf:"bytes,2,opt,name=subscription,proto3" json:"subscription,omitempty"` 1727 // User labels. 1728 Labels map[string]string `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 1729 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1730 XXX_unrecognized []byte `json:"-"` 1731 XXX_sizecache int32 `json:"-"` 1732} 1733 1734func (m *CreateSnapshotRequest) Reset() { *m = CreateSnapshotRequest{} } 1735func (m *CreateSnapshotRequest) String() string { return proto.CompactTextString(m) } 1736func (*CreateSnapshotRequest) ProtoMessage() {} 1737func (*CreateSnapshotRequest) Descriptor() ([]byte, []int) { 1738 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{29} 1739} 1740func (m *CreateSnapshotRequest) XXX_Unmarshal(b []byte) error { 1741 return xxx_messageInfo_CreateSnapshotRequest.Unmarshal(m, b) 1742} 1743func (m *CreateSnapshotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1744 return xxx_messageInfo_CreateSnapshotRequest.Marshal(b, m, deterministic) 1745} 1746func (dst *CreateSnapshotRequest) XXX_Merge(src proto.Message) { 1747 xxx_messageInfo_CreateSnapshotRequest.Merge(dst, src) 1748} 1749func (m *CreateSnapshotRequest) XXX_Size() int { 1750 return xxx_messageInfo_CreateSnapshotRequest.Size(m) 1751} 1752func (m *CreateSnapshotRequest) XXX_DiscardUnknown() { 1753 xxx_messageInfo_CreateSnapshotRequest.DiscardUnknown(m) 1754} 1755 1756var xxx_messageInfo_CreateSnapshotRequest proto.InternalMessageInfo 1757 1758func (m *CreateSnapshotRequest) GetName() string { 1759 if m != nil { 1760 return m.Name 1761 } 1762 return "" 1763} 1764 1765func (m *CreateSnapshotRequest) GetSubscription() string { 1766 if m != nil { 1767 return m.Subscription 1768 } 1769 return "" 1770} 1771 1772func (m *CreateSnapshotRequest) GetLabels() map[string]string { 1773 if m != nil { 1774 return m.Labels 1775 } 1776 return nil 1777} 1778 1779// Request for the UpdateSnapshot method.<br><br> 1780// <b>ALPHA:</b> This feature is part of an alpha release. This API might be 1781// changed in backward-incompatible ways and is not recommended for production 1782// use. It is not subject to any SLA or deprecation policy. 1783type UpdateSnapshotRequest struct { 1784 // The updated snapshot object. 1785 Snapshot *Snapshot `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"` 1786 // Indicates which fields in the provided snapshot to update. 1787 // Must be specified and non-empty. 1788 UpdateMask *field_mask.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` 1789 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1790 XXX_unrecognized []byte `json:"-"` 1791 XXX_sizecache int32 `json:"-"` 1792} 1793 1794func (m *UpdateSnapshotRequest) Reset() { *m = UpdateSnapshotRequest{} } 1795func (m *UpdateSnapshotRequest) String() string { return proto.CompactTextString(m) } 1796func (*UpdateSnapshotRequest) ProtoMessage() {} 1797func (*UpdateSnapshotRequest) Descriptor() ([]byte, []int) { 1798 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{30} 1799} 1800func (m *UpdateSnapshotRequest) XXX_Unmarshal(b []byte) error { 1801 return xxx_messageInfo_UpdateSnapshotRequest.Unmarshal(m, b) 1802} 1803func (m *UpdateSnapshotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1804 return xxx_messageInfo_UpdateSnapshotRequest.Marshal(b, m, deterministic) 1805} 1806func (dst *UpdateSnapshotRequest) XXX_Merge(src proto.Message) { 1807 xxx_messageInfo_UpdateSnapshotRequest.Merge(dst, src) 1808} 1809func (m *UpdateSnapshotRequest) XXX_Size() int { 1810 return xxx_messageInfo_UpdateSnapshotRequest.Size(m) 1811} 1812func (m *UpdateSnapshotRequest) XXX_DiscardUnknown() { 1813 xxx_messageInfo_UpdateSnapshotRequest.DiscardUnknown(m) 1814} 1815 1816var xxx_messageInfo_UpdateSnapshotRequest proto.InternalMessageInfo 1817 1818func (m *UpdateSnapshotRequest) GetSnapshot() *Snapshot { 1819 if m != nil { 1820 return m.Snapshot 1821 } 1822 return nil 1823} 1824 1825func (m *UpdateSnapshotRequest) GetUpdateMask() *field_mask.FieldMask { 1826 if m != nil { 1827 return m.UpdateMask 1828 } 1829 return nil 1830} 1831 1832// A snapshot resource.<br><br> 1833// <b>ALPHA:</b> This feature is part of an alpha release. This API might be 1834// changed in backward-incompatible ways and is not recommended for production 1835// use. It is not subject to any SLA or deprecation policy. 1836type Snapshot struct { 1837 // The name of the snapshot. 1838 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 1839 // The name of the topic from which this snapshot is retaining messages. 1840 Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` 1841 // The snapshot is guaranteed to exist up until this time. 1842 // A newly-created snapshot expires no later than 7 days from the time of its 1843 // creation. Its exact lifetime is determined at creation by the existing 1844 // backlog in the source subscription. Specifically, the lifetime of the 1845 // snapshot is `7 days - (age of oldest unacked message in the subscription)`. 1846 // For example, consider a subscription whose oldest unacked message is 3 days 1847 // old. If a snapshot is created from this subscription, the snapshot -- which 1848 // will always capture this 3-day-old backlog as long as the snapshot 1849 // exists -- will expire in 4 days. The service will refuse to create a 1850 // snapshot that would expire in less than 1 hour after creation. 1851 ExpireTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"` 1852 // User labels. 1853 Labels map[string]string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 1854 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1855 XXX_unrecognized []byte `json:"-"` 1856 XXX_sizecache int32 `json:"-"` 1857} 1858 1859func (m *Snapshot) Reset() { *m = Snapshot{} } 1860func (m *Snapshot) String() string { return proto.CompactTextString(m) } 1861func (*Snapshot) ProtoMessage() {} 1862func (*Snapshot) Descriptor() ([]byte, []int) { 1863 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{31} 1864} 1865func (m *Snapshot) XXX_Unmarshal(b []byte) error { 1866 return xxx_messageInfo_Snapshot.Unmarshal(m, b) 1867} 1868func (m *Snapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1869 return xxx_messageInfo_Snapshot.Marshal(b, m, deterministic) 1870} 1871func (dst *Snapshot) XXX_Merge(src proto.Message) { 1872 xxx_messageInfo_Snapshot.Merge(dst, src) 1873} 1874func (m *Snapshot) XXX_Size() int { 1875 return xxx_messageInfo_Snapshot.Size(m) 1876} 1877func (m *Snapshot) XXX_DiscardUnknown() { 1878 xxx_messageInfo_Snapshot.DiscardUnknown(m) 1879} 1880 1881var xxx_messageInfo_Snapshot proto.InternalMessageInfo 1882 1883func (m *Snapshot) GetName() string { 1884 if m != nil { 1885 return m.Name 1886 } 1887 return "" 1888} 1889 1890func (m *Snapshot) GetTopic() string { 1891 if m != nil { 1892 return m.Topic 1893 } 1894 return "" 1895} 1896 1897func (m *Snapshot) GetExpireTime() *timestamp.Timestamp { 1898 if m != nil { 1899 return m.ExpireTime 1900 } 1901 return nil 1902} 1903 1904func (m *Snapshot) GetLabels() map[string]string { 1905 if m != nil { 1906 return m.Labels 1907 } 1908 return nil 1909} 1910 1911// Request for the GetSnapshot method.<br><br> 1912// <b>ALPHA:</b> This feature is part of an alpha release. This API might be 1913// changed in backward-incompatible ways and is not recommended for production 1914// use. It is not subject to any SLA or deprecation policy. 1915type GetSnapshotRequest struct { 1916 // The name of the snapshot to get. 1917 // Format is `projects/{project}/snapshots/{snap}`. 1918 Snapshot string `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"` 1919 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1920 XXX_unrecognized []byte `json:"-"` 1921 XXX_sizecache int32 `json:"-"` 1922} 1923 1924func (m *GetSnapshotRequest) Reset() { *m = GetSnapshotRequest{} } 1925func (m *GetSnapshotRequest) String() string { return proto.CompactTextString(m) } 1926func (*GetSnapshotRequest) ProtoMessage() {} 1927func (*GetSnapshotRequest) Descriptor() ([]byte, []int) { 1928 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{32} 1929} 1930func (m *GetSnapshotRequest) XXX_Unmarshal(b []byte) error { 1931 return xxx_messageInfo_GetSnapshotRequest.Unmarshal(m, b) 1932} 1933func (m *GetSnapshotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1934 return xxx_messageInfo_GetSnapshotRequest.Marshal(b, m, deterministic) 1935} 1936func (dst *GetSnapshotRequest) XXX_Merge(src proto.Message) { 1937 xxx_messageInfo_GetSnapshotRequest.Merge(dst, src) 1938} 1939func (m *GetSnapshotRequest) XXX_Size() int { 1940 return xxx_messageInfo_GetSnapshotRequest.Size(m) 1941} 1942func (m *GetSnapshotRequest) XXX_DiscardUnknown() { 1943 xxx_messageInfo_GetSnapshotRequest.DiscardUnknown(m) 1944} 1945 1946var xxx_messageInfo_GetSnapshotRequest proto.InternalMessageInfo 1947 1948func (m *GetSnapshotRequest) GetSnapshot() string { 1949 if m != nil { 1950 return m.Snapshot 1951 } 1952 return "" 1953} 1954 1955// Request for the `ListSnapshots` method.<br><br> 1956// <b>ALPHA:</b> This feature is part of an alpha release. This API might be 1957// changed in backward-incompatible ways and is not recommended for production 1958// use. It is not subject to any SLA or deprecation policy. 1959type ListSnapshotsRequest struct { 1960 // The name of the cloud project that snapshots belong to. 1961 // Format is `projects/{project}`. 1962 Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` 1963 // Maximum number of snapshots to return. 1964 PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` 1965 // The value returned by the last `ListSnapshotsResponse`; indicates that this 1966 // is a continuation of a prior `ListSnapshots` call, and that the system 1967 // should return the next page of data. 1968 PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` 1969 XXX_NoUnkeyedLiteral struct{} `json:"-"` 1970 XXX_unrecognized []byte `json:"-"` 1971 XXX_sizecache int32 `json:"-"` 1972} 1973 1974func (m *ListSnapshotsRequest) Reset() { *m = ListSnapshotsRequest{} } 1975func (m *ListSnapshotsRequest) String() string { return proto.CompactTextString(m) } 1976func (*ListSnapshotsRequest) ProtoMessage() {} 1977func (*ListSnapshotsRequest) Descriptor() ([]byte, []int) { 1978 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{33} 1979} 1980func (m *ListSnapshotsRequest) XXX_Unmarshal(b []byte) error { 1981 return xxx_messageInfo_ListSnapshotsRequest.Unmarshal(m, b) 1982} 1983func (m *ListSnapshotsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 1984 return xxx_messageInfo_ListSnapshotsRequest.Marshal(b, m, deterministic) 1985} 1986func (dst *ListSnapshotsRequest) XXX_Merge(src proto.Message) { 1987 xxx_messageInfo_ListSnapshotsRequest.Merge(dst, src) 1988} 1989func (m *ListSnapshotsRequest) XXX_Size() int { 1990 return xxx_messageInfo_ListSnapshotsRequest.Size(m) 1991} 1992func (m *ListSnapshotsRequest) XXX_DiscardUnknown() { 1993 xxx_messageInfo_ListSnapshotsRequest.DiscardUnknown(m) 1994} 1995 1996var xxx_messageInfo_ListSnapshotsRequest proto.InternalMessageInfo 1997 1998func (m *ListSnapshotsRequest) GetProject() string { 1999 if m != nil { 2000 return m.Project 2001 } 2002 return "" 2003} 2004 2005func (m *ListSnapshotsRequest) GetPageSize() int32 { 2006 if m != nil { 2007 return m.PageSize 2008 } 2009 return 0 2010} 2011 2012func (m *ListSnapshotsRequest) GetPageToken() string { 2013 if m != nil { 2014 return m.PageToken 2015 } 2016 return "" 2017} 2018 2019// Response for the `ListSnapshots` method.<br><br> 2020// <b>ALPHA:</b> This feature is part of an alpha release. This API might be 2021// changed in backward-incompatible ways and is not recommended for production 2022// use. It is not subject to any SLA or deprecation policy. 2023type ListSnapshotsResponse struct { 2024 // The resulting snapshots. 2025 Snapshots []*Snapshot `protobuf:"bytes,1,rep,name=snapshots,proto3" json:"snapshots,omitempty"` 2026 // If not empty, indicates that there may be more snapshot that match the 2027 // request; this value should be passed in a new `ListSnapshotsRequest`. 2028 NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` 2029 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2030 XXX_unrecognized []byte `json:"-"` 2031 XXX_sizecache int32 `json:"-"` 2032} 2033 2034func (m *ListSnapshotsResponse) Reset() { *m = ListSnapshotsResponse{} } 2035func (m *ListSnapshotsResponse) String() string { return proto.CompactTextString(m) } 2036func (*ListSnapshotsResponse) ProtoMessage() {} 2037func (*ListSnapshotsResponse) Descriptor() ([]byte, []int) { 2038 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{34} 2039} 2040func (m *ListSnapshotsResponse) XXX_Unmarshal(b []byte) error { 2041 return xxx_messageInfo_ListSnapshotsResponse.Unmarshal(m, b) 2042} 2043func (m *ListSnapshotsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2044 return xxx_messageInfo_ListSnapshotsResponse.Marshal(b, m, deterministic) 2045} 2046func (dst *ListSnapshotsResponse) XXX_Merge(src proto.Message) { 2047 xxx_messageInfo_ListSnapshotsResponse.Merge(dst, src) 2048} 2049func (m *ListSnapshotsResponse) XXX_Size() int { 2050 return xxx_messageInfo_ListSnapshotsResponse.Size(m) 2051} 2052func (m *ListSnapshotsResponse) XXX_DiscardUnknown() { 2053 xxx_messageInfo_ListSnapshotsResponse.DiscardUnknown(m) 2054} 2055 2056var xxx_messageInfo_ListSnapshotsResponse proto.InternalMessageInfo 2057 2058func (m *ListSnapshotsResponse) GetSnapshots() []*Snapshot { 2059 if m != nil { 2060 return m.Snapshots 2061 } 2062 return nil 2063} 2064 2065func (m *ListSnapshotsResponse) GetNextPageToken() string { 2066 if m != nil { 2067 return m.NextPageToken 2068 } 2069 return "" 2070} 2071 2072// Request for the `DeleteSnapshot` method.<br><br> 2073// <b>ALPHA:</b> This feature is part of an alpha release. This API might be 2074// changed in backward-incompatible ways and is not recommended for production 2075// use. It is not subject to any SLA or deprecation policy. 2076type DeleteSnapshotRequest struct { 2077 // The name of the snapshot to delete. 2078 // Format is `projects/{project}/snapshots/{snap}`. 2079 Snapshot string `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"` 2080 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2081 XXX_unrecognized []byte `json:"-"` 2082 XXX_sizecache int32 `json:"-"` 2083} 2084 2085func (m *DeleteSnapshotRequest) Reset() { *m = DeleteSnapshotRequest{} } 2086func (m *DeleteSnapshotRequest) String() string { return proto.CompactTextString(m) } 2087func (*DeleteSnapshotRequest) ProtoMessage() {} 2088func (*DeleteSnapshotRequest) Descriptor() ([]byte, []int) { 2089 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{35} 2090} 2091func (m *DeleteSnapshotRequest) XXX_Unmarshal(b []byte) error { 2092 return xxx_messageInfo_DeleteSnapshotRequest.Unmarshal(m, b) 2093} 2094func (m *DeleteSnapshotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2095 return xxx_messageInfo_DeleteSnapshotRequest.Marshal(b, m, deterministic) 2096} 2097func (dst *DeleteSnapshotRequest) XXX_Merge(src proto.Message) { 2098 xxx_messageInfo_DeleteSnapshotRequest.Merge(dst, src) 2099} 2100func (m *DeleteSnapshotRequest) XXX_Size() int { 2101 return xxx_messageInfo_DeleteSnapshotRequest.Size(m) 2102} 2103func (m *DeleteSnapshotRequest) XXX_DiscardUnknown() { 2104 xxx_messageInfo_DeleteSnapshotRequest.DiscardUnknown(m) 2105} 2106 2107var xxx_messageInfo_DeleteSnapshotRequest proto.InternalMessageInfo 2108 2109func (m *DeleteSnapshotRequest) GetSnapshot() string { 2110 if m != nil { 2111 return m.Snapshot 2112 } 2113 return "" 2114} 2115 2116// Request for the `Seek` method.<br><br> 2117// <b>ALPHA:</b> This feature is part of an alpha release. This API might be 2118// changed in backward-incompatible ways and is not recommended for production 2119// use. It is not subject to any SLA or deprecation policy. 2120type SeekRequest struct { 2121 // The subscription to affect. 2122 Subscription string `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` 2123 // Types that are valid to be assigned to Target: 2124 // *SeekRequest_Time 2125 // *SeekRequest_Snapshot 2126 Target isSeekRequest_Target `protobuf_oneof:"target"` 2127 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2128 XXX_unrecognized []byte `json:"-"` 2129 XXX_sizecache int32 `json:"-"` 2130} 2131 2132func (m *SeekRequest) Reset() { *m = SeekRequest{} } 2133func (m *SeekRequest) String() string { return proto.CompactTextString(m) } 2134func (*SeekRequest) ProtoMessage() {} 2135func (*SeekRequest) Descriptor() ([]byte, []int) { 2136 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{36} 2137} 2138func (m *SeekRequest) XXX_Unmarshal(b []byte) error { 2139 return xxx_messageInfo_SeekRequest.Unmarshal(m, b) 2140} 2141func (m *SeekRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2142 return xxx_messageInfo_SeekRequest.Marshal(b, m, deterministic) 2143} 2144func (dst *SeekRequest) XXX_Merge(src proto.Message) { 2145 xxx_messageInfo_SeekRequest.Merge(dst, src) 2146} 2147func (m *SeekRequest) XXX_Size() int { 2148 return xxx_messageInfo_SeekRequest.Size(m) 2149} 2150func (m *SeekRequest) XXX_DiscardUnknown() { 2151 xxx_messageInfo_SeekRequest.DiscardUnknown(m) 2152} 2153 2154var xxx_messageInfo_SeekRequest proto.InternalMessageInfo 2155 2156type isSeekRequest_Target interface { 2157 isSeekRequest_Target() 2158} 2159 2160type SeekRequest_Time struct { 2161 Time *timestamp.Timestamp `protobuf:"bytes,2,opt,name=time,proto3,oneof"` 2162} 2163type SeekRequest_Snapshot struct { 2164 Snapshot string `protobuf:"bytes,3,opt,name=snapshot,proto3,oneof"` 2165} 2166 2167func (*SeekRequest_Time) isSeekRequest_Target() {} 2168func (*SeekRequest_Snapshot) isSeekRequest_Target() {} 2169 2170func (m *SeekRequest) GetTarget() isSeekRequest_Target { 2171 if m != nil { 2172 return m.Target 2173 } 2174 return nil 2175} 2176 2177func (m *SeekRequest) GetSubscription() string { 2178 if m != nil { 2179 return m.Subscription 2180 } 2181 return "" 2182} 2183 2184func (m *SeekRequest) GetTime() *timestamp.Timestamp { 2185 if x, ok := m.GetTarget().(*SeekRequest_Time); ok { 2186 return x.Time 2187 } 2188 return nil 2189} 2190 2191func (m *SeekRequest) GetSnapshot() string { 2192 if x, ok := m.GetTarget().(*SeekRequest_Snapshot); ok { 2193 return x.Snapshot 2194 } 2195 return "" 2196} 2197 2198// XXX_OneofFuncs is for the internal use of the proto package. 2199func (*SeekRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{}) { 2200 return _SeekRequest_OneofMarshaler, _SeekRequest_OneofUnmarshaler, _SeekRequest_OneofSizer, []interface{}{ 2201 (*SeekRequest_Time)(nil), 2202 (*SeekRequest_Snapshot)(nil), 2203 } 2204} 2205 2206func _SeekRequest_OneofMarshaler(msg proto.Message, b *proto.Buffer) error { 2207 m := msg.(*SeekRequest) 2208 // target 2209 switch x := m.Target.(type) { 2210 case *SeekRequest_Time: 2211 b.EncodeVarint(2<<3 | proto.WireBytes) 2212 if err := b.EncodeMessage(x.Time); err != nil { 2213 return err 2214 } 2215 case *SeekRequest_Snapshot: 2216 b.EncodeVarint(3<<3 | proto.WireBytes) 2217 b.EncodeStringBytes(x.Snapshot) 2218 case nil: 2219 default: 2220 return fmt.Errorf("SeekRequest.Target has unexpected type %T", x) 2221 } 2222 return nil 2223} 2224 2225func _SeekRequest_OneofUnmarshaler(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error) { 2226 m := msg.(*SeekRequest) 2227 switch tag { 2228 case 2: // target.time 2229 if wire != proto.WireBytes { 2230 return true, proto.ErrInternalBadWireType 2231 } 2232 msg := new(timestamp.Timestamp) 2233 err := b.DecodeMessage(msg) 2234 m.Target = &SeekRequest_Time{msg} 2235 return true, err 2236 case 3: // target.snapshot 2237 if wire != proto.WireBytes { 2238 return true, proto.ErrInternalBadWireType 2239 } 2240 x, err := b.DecodeStringBytes() 2241 m.Target = &SeekRequest_Snapshot{x} 2242 return true, err 2243 default: 2244 return false, nil 2245 } 2246} 2247 2248func _SeekRequest_OneofSizer(msg proto.Message) (n int) { 2249 m := msg.(*SeekRequest) 2250 // target 2251 switch x := m.Target.(type) { 2252 case *SeekRequest_Time: 2253 s := proto.Size(x.Time) 2254 n += 1 // tag and wire 2255 n += proto.SizeVarint(uint64(s)) 2256 n += s 2257 case *SeekRequest_Snapshot: 2258 n += 1 // tag and wire 2259 n += proto.SizeVarint(uint64(len(x.Snapshot))) 2260 n += len(x.Snapshot) 2261 case nil: 2262 default: 2263 panic(fmt.Sprintf("proto: unexpected type %T in oneof", x)) 2264 } 2265 return n 2266} 2267 2268type SeekResponse struct { 2269 XXX_NoUnkeyedLiteral struct{} `json:"-"` 2270 XXX_unrecognized []byte `json:"-"` 2271 XXX_sizecache int32 `json:"-"` 2272} 2273 2274func (m *SeekResponse) Reset() { *m = SeekResponse{} } 2275func (m *SeekResponse) String() string { return proto.CompactTextString(m) } 2276func (*SeekResponse) ProtoMessage() {} 2277func (*SeekResponse) Descriptor() ([]byte, []int) { 2278 return fileDescriptor_pubsub_ccb5b83827ebb62b, []int{37} 2279} 2280func (m *SeekResponse) XXX_Unmarshal(b []byte) error { 2281 return xxx_messageInfo_SeekResponse.Unmarshal(m, b) 2282} 2283func (m *SeekResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 2284 return xxx_messageInfo_SeekResponse.Marshal(b, m, deterministic) 2285} 2286func (dst *SeekResponse) XXX_Merge(src proto.Message) { 2287 xxx_messageInfo_SeekResponse.Merge(dst, src) 2288} 2289func (m *SeekResponse) XXX_Size() int { 2290 return xxx_messageInfo_SeekResponse.Size(m) 2291} 2292func (m *SeekResponse) XXX_DiscardUnknown() { 2293 xxx_messageInfo_SeekResponse.DiscardUnknown(m) 2294} 2295 2296var xxx_messageInfo_SeekResponse proto.InternalMessageInfo 2297 2298func init() { 2299 proto.RegisterType((*MessageStoragePolicy)(nil), "google.pubsub.v1.MessageStoragePolicy") 2300 proto.RegisterType((*Topic)(nil), "google.pubsub.v1.Topic") 2301 proto.RegisterMapType((map[string]string)(nil), "google.pubsub.v1.Topic.LabelsEntry") 2302 proto.RegisterType((*PubsubMessage)(nil), "google.pubsub.v1.PubsubMessage") 2303 proto.RegisterMapType((map[string]string)(nil), "google.pubsub.v1.PubsubMessage.AttributesEntry") 2304 proto.RegisterType((*GetTopicRequest)(nil), "google.pubsub.v1.GetTopicRequest") 2305 proto.RegisterType((*UpdateTopicRequest)(nil), "google.pubsub.v1.UpdateTopicRequest") 2306 proto.RegisterType((*PublishRequest)(nil), "google.pubsub.v1.PublishRequest") 2307 proto.RegisterType((*PublishResponse)(nil), "google.pubsub.v1.PublishResponse") 2308 proto.RegisterType((*ListTopicsRequest)(nil), "google.pubsub.v1.ListTopicsRequest") 2309 proto.RegisterType((*ListTopicsResponse)(nil), "google.pubsub.v1.ListTopicsResponse") 2310 proto.RegisterType((*ListTopicSubscriptionsRequest)(nil), "google.pubsub.v1.ListTopicSubscriptionsRequest") 2311 proto.RegisterType((*ListTopicSubscriptionsResponse)(nil), "google.pubsub.v1.ListTopicSubscriptionsResponse") 2312 proto.RegisterType((*ListTopicSnapshotsRequest)(nil), "google.pubsub.v1.ListTopicSnapshotsRequest") 2313 proto.RegisterType((*ListTopicSnapshotsResponse)(nil), "google.pubsub.v1.ListTopicSnapshotsResponse") 2314 proto.RegisterType((*DeleteTopicRequest)(nil), "google.pubsub.v1.DeleteTopicRequest") 2315 proto.RegisterType((*Subscription)(nil), "google.pubsub.v1.Subscription") 2316 proto.RegisterMapType((map[string]string)(nil), "google.pubsub.v1.Subscription.LabelsEntry") 2317 proto.RegisterType((*PushConfig)(nil), "google.pubsub.v1.PushConfig") 2318 proto.RegisterMapType((map[string]string)(nil), "google.pubsub.v1.PushConfig.AttributesEntry") 2319 proto.RegisterType((*ReceivedMessage)(nil), "google.pubsub.v1.ReceivedMessage") 2320 proto.RegisterType((*GetSubscriptionRequest)(nil), "google.pubsub.v1.GetSubscriptionRequest") 2321 proto.RegisterType((*UpdateSubscriptionRequest)(nil), "google.pubsub.v1.UpdateSubscriptionRequest") 2322 proto.RegisterType((*ListSubscriptionsRequest)(nil), "google.pubsub.v1.ListSubscriptionsRequest") 2323 proto.RegisterType((*ListSubscriptionsResponse)(nil), "google.pubsub.v1.ListSubscriptionsResponse") 2324 proto.RegisterType((*DeleteSubscriptionRequest)(nil), "google.pubsub.v1.DeleteSubscriptionRequest") 2325 proto.RegisterType((*ModifyPushConfigRequest)(nil), "google.pubsub.v1.ModifyPushConfigRequest") 2326 proto.RegisterType((*PullRequest)(nil), "google.pubsub.v1.PullRequest") 2327 proto.RegisterType((*PullResponse)(nil), "google.pubsub.v1.PullResponse") 2328 proto.RegisterType((*ModifyAckDeadlineRequest)(nil), "google.pubsub.v1.ModifyAckDeadlineRequest") 2329 proto.RegisterType((*AcknowledgeRequest)(nil), "google.pubsub.v1.AcknowledgeRequest") 2330 proto.RegisterType((*StreamingPullRequest)(nil), "google.pubsub.v1.StreamingPullRequest") 2331 proto.RegisterType((*StreamingPullResponse)(nil), "google.pubsub.v1.StreamingPullResponse") 2332 proto.RegisterType((*CreateSnapshotRequest)(nil), "google.pubsub.v1.CreateSnapshotRequest") 2333 proto.RegisterMapType((map[string]string)(nil), "google.pubsub.v1.CreateSnapshotRequest.LabelsEntry") 2334 proto.RegisterType((*UpdateSnapshotRequest)(nil), "google.pubsub.v1.UpdateSnapshotRequest") 2335 proto.RegisterType((*Snapshot)(nil), "google.pubsub.v1.Snapshot") 2336 proto.RegisterMapType((map[string]string)(nil), "google.pubsub.v1.Snapshot.LabelsEntry") 2337 proto.RegisterType((*GetSnapshotRequest)(nil), "google.pubsub.v1.GetSnapshotRequest") 2338 proto.RegisterType((*ListSnapshotsRequest)(nil), "google.pubsub.v1.ListSnapshotsRequest") 2339 proto.RegisterType((*ListSnapshotsResponse)(nil), "google.pubsub.v1.ListSnapshotsResponse") 2340 proto.RegisterType((*DeleteSnapshotRequest)(nil), "google.pubsub.v1.DeleteSnapshotRequest") 2341 proto.RegisterType((*SeekRequest)(nil), "google.pubsub.v1.SeekRequest") 2342 proto.RegisterType((*SeekResponse)(nil), "google.pubsub.v1.SeekResponse") 2343} 2344 2345// Reference imports to suppress errors if they are not otherwise used. 2346var _ context.Context 2347var _ grpc.ClientConn 2348 2349// This is a compile-time assertion to ensure that this generated file 2350// is compatible with the grpc package it is being compiled against. 2351const _ = grpc.SupportPackageIsVersion4 2352 2353// PublisherClient is the client API for Publisher service. 2354// 2355// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 2356type PublisherClient interface { 2357 // Creates the given topic with the given name. See the 2358 // <a href="/pubsub/docs/admin#resource_names"> resource name rules</a>. 2359 CreateTopic(ctx context.Context, in *Topic, opts ...grpc.CallOption) (*Topic, error) 2360 // Updates an existing topic. Note that certain properties of a 2361 // topic are not modifiable. 2362 UpdateTopic(ctx context.Context, in *UpdateTopicRequest, opts ...grpc.CallOption) (*Topic, error) 2363 // Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic 2364 // does not exist. The message payload must not be empty; it must contain 2365 // either a non-empty data field, or at least one attribute. 2366 Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error) 2367 // Gets the configuration of a topic. 2368 GetTopic(ctx context.Context, in *GetTopicRequest, opts ...grpc.CallOption) (*Topic, error) 2369 // Lists matching topics. 2370 ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error) 2371 // Lists the names of the subscriptions on this topic. 2372 ListTopicSubscriptions(ctx context.Context, in *ListTopicSubscriptionsRequest, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error) 2373 // Lists the names of the snapshots on this topic.<br><br> 2374 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 2375 // changed in backward-incompatible ways and is not recommended for production 2376 // use. It is not subject to any SLA or deprecation policy. 2377 ListTopicSnapshots(ctx context.Context, in *ListTopicSnapshotsRequest, opts ...grpc.CallOption) (*ListTopicSnapshotsResponse, error) 2378 // Deletes the topic with the given name. Returns `NOT_FOUND` if the topic 2379 // does not exist. After a topic is deleted, a new topic may be created with 2380 // the same name; this is an entirely new topic with none of the old 2381 // configuration or subscriptions. Existing subscriptions to this topic are 2382 // not deleted, but their `topic` field is set to `_deleted-topic_`. 2383 DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*empty.Empty, error) 2384} 2385 2386type publisherClient struct { 2387 cc *grpc.ClientConn 2388} 2389 2390func NewPublisherClient(cc *grpc.ClientConn) PublisherClient { 2391 return &publisherClient{cc} 2392} 2393 2394func (c *publisherClient) CreateTopic(ctx context.Context, in *Topic, opts ...grpc.CallOption) (*Topic, error) { 2395 out := new(Topic) 2396 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Publisher/CreateTopic", in, out, opts...) 2397 if err != nil { 2398 return nil, err 2399 } 2400 return out, nil 2401} 2402 2403func (c *publisherClient) UpdateTopic(ctx context.Context, in *UpdateTopicRequest, opts ...grpc.CallOption) (*Topic, error) { 2404 out := new(Topic) 2405 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Publisher/UpdateTopic", in, out, opts...) 2406 if err != nil { 2407 return nil, err 2408 } 2409 return out, nil 2410} 2411 2412func (c *publisherClient) Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error) { 2413 out := new(PublishResponse) 2414 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Publisher/Publish", in, out, opts...) 2415 if err != nil { 2416 return nil, err 2417 } 2418 return out, nil 2419} 2420 2421func (c *publisherClient) GetTopic(ctx context.Context, in *GetTopicRequest, opts ...grpc.CallOption) (*Topic, error) { 2422 out := new(Topic) 2423 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Publisher/GetTopic", in, out, opts...) 2424 if err != nil { 2425 return nil, err 2426 } 2427 return out, nil 2428} 2429 2430func (c *publisherClient) ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error) { 2431 out := new(ListTopicsResponse) 2432 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Publisher/ListTopics", in, out, opts...) 2433 if err != nil { 2434 return nil, err 2435 } 2436 return out, nil 2437} 2438 2439func (c *publisherClient) ListTopicSubscriptions(ctx context.Context, in *ListTopicSubscriptionsRequest, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error) { 2440 out := new(ListTopicSubscriptionsResponse) 2441 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Publisher/ListTopicSubscriptions", in, out, opts...) 2442 if err != nil { 2443 return nil, err 2444 } 2445 return out, nil 2446} 2447 2448func (c *publisherClient) ListTopicSnapshots(ctx context.Context, in *ListTopicSnapshotsRequest, opts ...grpc.CallOption) (*ListTopicSnapshotsResponse, error) { 2449 out := new(ListTopicSnapshotsResponse) 2450 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Publisher/ListTopicSnapshots", in, out, opts...) 2451 if err != nil { 2452 return nil, err 2453 } 2454 return out, nil 2455} 2456 2457func (c *publisherClient) DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 2458 out := new(empty.Empty) 2459 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Publisher/DeleteTopic", in, out, opts...) 2460 if err != nil { 2461 return nil, err 2462 } 2463 return out, nil 2464} 2465 2466// PublisherServer is the server API for Publisher service. 2467type PublisherServer interface { 2468 // Creates the given topic with the given name. See the 2469 // <a href="/pubsub/docs/admin#resource_names"> resource name rules</a>. 2470 CreateTopic(context.Context, *Topic) (*Topic, error) 2471 // Updates an existing topic. Note that certain properties of a 2472 // topic are not modifiable. 2473 UpdateTopic(context.Context, *UpdateTopicRequest) (*Topic, error) 2474 // Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic 2475 // does not exist. The message payload must not be empty; it must contain 2476 // either a non-empty data field, or at least one attribute. 2477 Publish(context.Context, *PublishRequest) (*PublishResponse, error) 2478 // Gets the configuration of a topic. 2479 GetTopic(context.Context, *GetTopicRequest) (*Topic, error) 2480 // Lists matching topics. 2481 ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error) 2482 // Lists the names of the subscriptions on this topic. 2483 ListTopicSubscriptions(context.Context, *ListTopicSubscriptionsRequest) (*ListTopicSubscriptionsResponse, error) 2484 // Lists the names of the snapshots on this topic.<br><br> 2485 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 2486 // changed in backward-incompatible ways and is not recommended for production 2487 // use. It is not subject to any SLA or deprecation policy. 2488 ListTopicSnapshots(context.Context, *ListTopicSnapshotsRequest) (*ListTopicSnapshotsResponse, error) 2489 // Deletes the topic with the given name. Returns `NOT_FOUND` if the topic 2490 // does not exist. After a topic is deleted, a new topic may be created with 2491 // the same name; this is an entirely new topic with none of the old 2492 // configuration or subscriptions. Existing subscriptions to this topic are 2493 // not deleted, but their `topic` field is set to `_deleted-topic_`. 2494 DeleteTopic(context.Context, *DeleteTopicRequest) (*empty.Empty, error) 2495} 2496 2497func RegisterPublisherServer(s *grpc.Server, srv PublisherServer) { 2498 s.RegisterService(&_Publisher_serviceDesc, srv) 2499} 2500 2501func _Publisher_CreateTopic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2502 in := new(Topic) 2503 if err := dec(in); err != nil { 2504 return nil, err 2505 } 2506 if interceptor == nil { 2507 return srv.(PublisherServer).CreateTopic(ctx, in) 2508 } 2509 info := &grpc.UnaryServerInfo{ 2510 Server: srv, 2511 FullMethod: "/google.pubsub.v1.Publisher/CreateTopic", 2512 } 2513 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2514 return srv.(PublisherServer).CreateTopic(ctx, req.(*Topic)) 2515 } 2516 return interceptor(ctx, in, info, handler) 2517} 2518 2519func _Publisher_UpdateTopic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2520 in := new(UpdateTopicRequest) 2521 if err := dec(in); err != nil { 2522 return nil, err 2523 } 2524 if interceptor == nil { 2525 return srv.(PublisherServer).UpdateTopic(ctx, in) 2526 } 2527 info := &grpc.UnaryServerInfo{ 2528 Server: srv, 2529 FullMethod: "/google.pubsub.v1.Publisher/UpdateTopic", 2530 } 2531 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2532 return srv.(PublisherServer).UpdateTopic(ctx, req.(*UpdateTopicRequest)) 2533 } 2534 return interceptor(ctx, in, info, handler) 2535} 2536 2537func _Publisher_Publish_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2538 in := new(PublishRequest) 2539 if err := dec(in); err != nil { 2540 return nil, err 2541 } 2542 if interceptor == nil { 2543 return srv.(PublisherServer).Publish(ctx, in) 2544 } 2545 info := &grpc.UnaryServerInfo{ 2546 Server: srv, 2547 FullMethod: "/google.pubsub.v1.Publisher/Publish", 2548 } 2549 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2550 return srv.(PublisherServer).Publish(ctx, req.(*PublishRequest)) 2551 } 2552 return interceptor(ctx, in, info, handler) 2553} 2554 2555func _Publisher_GetTopic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2556 in := new(GetTopicRequest) 2557 if err := dec(in); err != nil { 2558 return nil, err 2559 } 2560 if interceptor == nil { 2561 return srv.(PublisherServer).GetTopic(ctx, in) 2562 } 2563 info := &grpc.UnaryServerInfo{ 2564 Server: srv, 2565 FullMethod: "/google.pubsub.v1.Publisher/GetTopic", 2566 } 2567 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2568 return srv.(PublisherServer).GetTopic(ctx, req.(*GetTopicRequest)) 2569 } 2570 return interceptor(ctx, in, info, handler) 2571} 2572 2573func _Publisher_ListTopics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2574 in := new(ListTopicsRequest) 2575 if err := dec(in); err != nil { 2576 return nil, err 2577 } 2578 if interceptor == nil { 2579 return srv.(PublisherServer).ListTopics(ctx, in) 2580 } 2581 info := &grpc.UnaryServerInfo{ 2582 Server: srv, 2583 FullMethod: "/google.pubsub.v1.Publisher/ListTopics", 2584 } 2585 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2586 return srv.(PublisherServer).ListTopics(ctx, req.(*ListTopicsRequest)) 2587 } 2588 return interceptor(ctx, in, info, handler) 2589} 2590 2591func _Publisher_ListTopicSubscriptions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2592 in := new(ListTopicSubscriptionsRequest) 2593 if err := dec(in); err != nil { 2594 return nil, err 2595 } 2596 if interceptor == nil { 2597 return srv.(PublisherServer).ListTopicSubscriptions(ctx, in) 2598 } 2599 info := &grpc.UnaryServerInfo{ 2600 Server: srv, 2601 FullMethod: "/google.pubsub.v1.Publisher/ListTopicSubscriptions", 2602 } 2603 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2604 return srv.(PublisherServer).ListTopicSubscriptions(ctx, req.(*ListTopicSubscriptionsRequest)) 2605 } 2606 return interceptor(ctx, in, info, handler) 2607} 2608 2609func _Publisher_ListTopicSnapshots_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2610 in := new(ListTopicSnapshotsRequest) 2611 if err := dec(in); err != nil { 2612 return nil, err 2613 } 2614 if interceptor == nil { 2615 return srv.(PublisherServer).ListTopicSnapshots(ctx, in) 2616 } 2617 info := &grpc.UnaryServerInfo{ 2618 Server: srv, 2619 FullMethod: "/google.pubsub.v1.Publisher/ListTopicSnapshots", 2620 } 2621 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2622 return srv.(PublisherServer).ListTopicSnapshots(ctx, req.(*ListTopicSnapshotsRequest)) 2623 } 2624 return interceptor(ctx, in, info, handler) 2625} 2626 2627func _Publisher_DeleteTopic_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 2628 in := new(DeleteTopicRequest) 2629 if err := dec(in); err != nil { 2630 return nil, err 2631 } 2632 if interceptor == nil { 2633 return srv.(PublisherServer).DeleteTopic(ctx, in) 2634 } 2635 info := &grpc.UnaryServerInfo{ 2636 Server: srv, 2637 FullMethod: "/google.pubsub.v1.Publisher/DeleteTopic", 2638 } 2639 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 2640 return srv.(PublisherServer).DeleteTopic(ctx, req.(*DeleteTopicRequest)) 2641 } 2642 return interceptor(ctx, in, info, handler) 2643} 2644 2645var _Publisher_serviceDesc = grpc.ServiceDesc{ 2646 ServiceName: "google.pubsub.v1.Publisher", 2647 HandlerType: (*PublisherServer)(nil), 2648 Methods: []grpc.MethodDesc{ 2649 { 2650 MethodName: "CreateTopic", 2651 Handler: _Publisher_CreateTopic_Handler, 2652 }, 2653 { 2654 MethodName: "UpdateTopic", 2655 Handler: _Publisher_UpdateTopic_Handler, 2656 }, 2657 { 2658 MethodName: "Publish", 2659 Handler: _Publisher_Publish_Handler, 2660 }, 2661 { 2662 MethodName: "GetTopic", 2663 Handler: _Publisher_GetTopic_Handler, 2664 }, 2665 { 2666 MethodName: "ListTopics", 2667 Handler: _Publisher_ListTopics_Handler, 2668 }, 2669 { 2670 MethodName: "ListTopicSubscriptions", 2671 Handler: _Publisher_ListTopicSubscriptions_Handler, 2672 }, 2673 { 2674 MethodName: "ListTopicSnapshots", 2675 Handler: _Publisher_ListTopicSnapshots_Handler, 2676 }, 2677 { 2678 MethodName: "DeleteTopic", 2679 Handler: _Publisher_DeleteTopic_Handler, 2680 }, 2681 }, 2682 Streams: []grpc.StreamDesc{}, 2683 Metadata: "google/pubsub/v1/pubsub.proto", 2684} 2685 2686// SubscriberClient is the client API for Subscriber service. 2687// 2688// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 2689type SubscriberClient interface { 2690 // Creates a subscription to a given topic. See the 2691 // <a href="/pubsub/docs/admin#resource_names"> resource name rules</a>. 2692 // If the subscription already exists, returns `ALREADY_EXISTS`. 2693 // If the corresponding topic doesn't exist, returns `NOT_FOUND`. 2694 // 2695 // If the name is not provided in the request, the server will assign a random 2696 // name for this subscription on the same project as the topic, conforming 2697 // to the 2698 // [resource name format](https://cloud.google.com/pubsub/docs/overview#names). 2699 // The generated name is populated in the returned Subscription object. 2700 // Note that for REST API requests, you must specify a name in the request. 2701 CreateSubscription(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (*Subscription, error) 2702 // Gets the configuration details of a subscription. 2703 GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error) 2704 // Updates an existing subscription. Note that certain properties of a 2705 // subscription, such as its topic, are not modifiable. 2706 UpdateSubscription(ctx context.Context, in *UpdateSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error) 2707 // Lists matching subscriptions. 2708 ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error) 2709 // Deletes an existing subscription. All messages retained in the subscription 2710 // are immediately dropped. Calls to `Pull` after deletion will return 2711 // `NOT_FOUND`. After a subscription is deleted, a new one may be created with 2712 // the same name, but the new one has no association with the old 2713 // subscription or its topic unless the same topic is specified. 2714 DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*empty.Empty, error) 2715 // Modifies the ack deadline for a specific message. This method is useful 2716 // to indicate that more time is needed to process a message by the 2717 // subscriber, or to make the message available for redelivery if the 2718 // processing was interrupted. Note that this does not modify the 2719 // subscription-level `ackDeadlineSeconds` used for subsequent messages. 2720 ModifyAckDeadline(ctx context.Context, in *ModifyAckDeadlineRequest, opts ...grpc.CallOption) (*empty.Empty, error) 2721 // Acknowledges the messages associated with the `ack_ids` in the 2722 // `AcknowledgeRequest`. The Pub/Sub system can remove the relevant messages 2723 // from the subscription. 2724 // 2725 // Acknowledging a message whose ack deadline has expired may succeed, 2726 // but such a message may be redelivered later. Acknowledging a message more 2727 // than once will not result in an error. 2728 Acknowledge(ctx context.Context, in *AcknowledgeRequest, opts ...grpc.CallOption) (*empty.Empty, error) 2729 // Pulls messages from the server. Returns an empty list if there are no 2730 // messages available in the backlog. The server may return `UNAVAILABLE` if 2731 // there are too many concurrent pull requests pending for the given 2732 // subscription. 2733 Pull(ctx context.Context, in *PullRequest, opts ...grpc.CallOption) (*PullResponse, error) 2734 // Establishes a stream with the server, which sends messages down to the 2735 // client. The client streams acknowledgements and ack deadline modifications 2736 // back to the server. The server will close the stream and return the status 2737 // on any error. The server may close the stream with status `UNAVAILABLE` to 2738 // reassign server-side resources, in which case, the client should 2739 // re-establish the stream. Flow control can be achieved by configuring the 2740 // underlying RPC channel. 2741 StreamingPull(ctx context.Context, opts ...grpc.CallOption) (Subscriber_StreamingPullClient, error) 2742 // Modifies the `PushConfig` for a specified subscription. 2743 // 2744 // This may be used to change a push subscription to a pull one (signified by 2745 // an empty `PushConfig`) or vice versa, or change the endpoint URL and other 2746 // attributes of a push subscription. Messages will accumulate for delivery 2747 // continuously through the call regardless of changes to the `PushConfig`. 2748 ModifyPushConfig(ctx context.Context, in *ModifyPushConfigRequest, opts ...grpc.CallOption) (*empty.Empty, error) 2749 // Gets the configuration details of a snapshot.<br><br> 2750 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 2751 // changed in backward-incompatible ways and is not recommended for production 2752 // use. It is not subject to any SLA or deprecation policy. 2753 GetSnapshot(ctx context.Context, in *GetSnapshotRequest, opts ...grpc.CallOption) (*Snapshot, error) 2754 // Lists the existing snapshots.<br><br> 2755 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 2756 // changed in backward-incompatible ways and is not recommended for production 2757 // use. It is not subject to any SLA or deprecation policy. 2758 ListSnapshots(ctx context.Context, in *ListSnapshotsRequest, opts ...grpc.CallOption) (*ListSnapshotsResponse, error) 2759 // Creates a snapshot from the requested subscription.<br><br> 2760 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 2761 // changed in backward-incompatible ways and is not recommended for production 2762 // use. It is not subject to any SLA or deprecation policy. 2763 // If the snapshot already exists, returns `ALREADY_EXISTS`. 2764 // If the requested subscription doesn't exist, returns `NOT_FOUND`. 2765 // If the backlog in the subscription is too old -- and the resulting snapshot 2766 // would expire in less than 1 hour -- then `FAILED_PRECONDITION` is returned. 2767 // See also the `Snapshot.expire_time` field. If the name is not provided in 2768 // the request, the server will assign a random 2769 // name for this snapshot on the same project as the subscription, conforming 2770 // to the [resource name format](https://cloud.google.com/pubsub/docs/overview#names). 2771 // The generated 2772 // name is populated in the returned Snapshot object. Note that for REST API 2773 // requests, you must specify a name in the request. 2774 CreateSnapshot(ctx context.Context, in *CreateSnapshotRequest, opts ...grpc.CallOption) (*Snapshot, error) 2775 // Updates an existing snapshot.<br><br> 2776 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 2777 // changed in backward-incompatible ways and is not recommended for production 2778 // use. It is not subject to any SLA or deprecation policy. 2779 // Note that certain properties of a snapshot are not modifiable. 2780 UpdateSnapshot(ctx context.Context, in *UpdateSnapshotRequest, opts ...grpc.CallOption) (*Snapshot, error) 2781 // Removes an existing snapshot. <br><br> 2782 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 2783 // changed in backward-incompatible ways and is not recommended for production 2784 // use. It is not subject to any SLA or deprecation policy. 2785 // When the snapshot is deleted, all messages retained in the snapshot 2786 // are immediately dropped. After a snapshot is deleted, a new one may be 2787 // created with the same name, but the new one has no association with the old 2788 // snapshot or its subscription, unless the same subscription is specified. 2789 DeleteSnapshot(ctx context.Context, in *DeleteSnapshotRequest, opts ...grpc.CallOption) (*empty.Empty, error) 2790 // Seeks an existing subscription to a point in time or to a given snapshot, 2791 // whichever is provided in the request.<br><br> 2792 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 2793 // changed in backward-incompatible ways and is not recommended for production 2794 // use. It is not subject to any SLA or deprecation policy. 2795 Seek(ctx context.Context, in *SeekRequest, opts ...grpc.CallOption) (*SeekResponse, error) 2796} 2797 2798type subscriberClient struct { 2799 cc *grpc.ClientConn 2800} 2801 2802func NewSubscriberClient(cc *grpc.ClientConn) SubscriberClient { 2803 return &subscriberClient{cc} 2804} 2805 2806func (c *subscriberClient) CreateSubscription(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (*Subscription, error) { 2807 out := new(Subscription) 2808 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Subscriber/CreateSubscription", in, out, opts...) 2809 if err != nil { 2810 return nil, err 2811 } 2812 return out, nil 2813} 2814 2815func (c *subscriberClient) GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error) { 2816 out := new(Subscription) 2817 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Subscriber/GetSubscription", in, out, opts...) 2818 if err != nil { 2819 return nil, err 2820 } 2821 return out, nil 2822} 2823 2824func (c *subscriberClient) UpdateSubscription(ctx context.Context, in *UpdateSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error) { 2825 out := new(Subscription) 2826 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Subscriber/UpdateSubscription", in, out, opts...) 2827 if err != nil { 2828 return nil, err 2829 } 2830 return out, nil 2831} 2832 2833func (c *subscriberClient) ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error) { 2834 out := new(ListSubscriptionsResponse) 2835 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Subscriber/ListSubscriptions", in, out, opts...) 2836 if err != nil { 2837 return nil, err 2838 } 2839 return out, nil 2840} 2841 2842func (c *subscriberClient) DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 2843 out := new(empty.Empty) 2844 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Subscriber/DeleteSubscription", in, out, opts...) 2845 if err != nil { 2846 return nil, err 2847 } 2848 return out, nil 2849} 2850 2851func (c *subscriberClient) ModifyAckDeadline(ctx context.Context, in *ModifyAckDeadlineRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 2852 out := new(empty.Empty) 2853 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Subscriber/ModifyAckDeadline", in, out, opts...) 2854 if err != nil { 2855 return nil, err 2856 } 2857 return out, nil 2858} 2859 2860func (c *subscriberClient) Acknowledge(ctx context.Context, in *AcknowledgeRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 2861 out := new(empty.Empty) 2862 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Subscriber/Acknowledge", in, out, opts...) 2863 if err != nil { 2864 return nil, err 2865 } 2866 return out, nil 2867} 2868 2869func (c *subscriberClient) Pull(ctx context.Context, in *PullRequest, opts ...grpc.CallOption) (*PullResponse, error) { 2870 out := new(PullResponse) 2871 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Subscriber/Pull", in, out, opts...) 2872 if err != nil { 2873 return nil, err 2874 } 2875 return out, nil 2876} 2877 2878func (c *subscriberClient) StreamingPull(ctx context.Context, opts ...grpc.CallOption) (Subscriber_StreamingPullClient, error) { 2879 stream, err := c.cc.NewStream(ctx, &_Subscriber_serviceDesc.Streams[0], "/google.pubsub.v1.Subscriber/StreamingPull", opts...) 2880 if err != nil { 2881 return nil, err 2882 } 2883 x := &subscriberStreamingPullClient{stream} 2884 return x, nil 2885} 2886 2887type Subscriber_StreamingPullClient interface { 2888 Send(*StreamingPullRequest) error 2889 Recv() (*StreamingPullResponse, error) 2890 grpc.ClientStream 2891} 2892 2893type subscriberStreamingPullClient struct { 2894 grpc.ClientStream 2895} 2896 2897func (x *subscriberStreamingPullClient) Send(m *StreamingPullRequest) error { 2898 return x.ClientStream.SendMsg(m) 2899} 2900 2901func (x *subscriberStreamingPullClient) Recv() (*StreamingPullResponse, error) { 2902 m := new(StreamingPullResponse) 2903 if err := x.ClientStream.RecvMsg(m); err != nil { 2904 return nil, err 2905 } 2906 return m, nil 2907} 2908 2909func (c *subscriberClient) ModifyPushConfig(ctx context.Context, in *ModifyPushConfigRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 2910 out := new(empty.Empty) 2911 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Subscriber/ModifyPushConfig", in, out, opts...) 2912 if err != nil { 2913 return nil, err 2914 } 2915 return out, nil 2916} 2917 2918func (c *subscriberClient) GetSnapshot(ctx context.Context, in *GetSnapshotRequest, opts ...grpc.CallOption) (*Snapshot, error) { 2919 out := new(Snapshot) 2920 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Subscriber/GetSnapshot", in, out, opts...) 2921 if err != nil { 2922 return nil, err 2923 } 2924 return out, nil 2925} 2926 2927func (c *subscriberClient) ListSnapshots(ctx context.Context, in *ListSnapshotsRequest, opts ...grpc.CallOption) (*ListSnapshotsResponse, error) { 2928 out := new(ListSnapshotsResponse) 2929 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Subscriber/ListSnapshots", in, out, opts...) 2930 if err != nil { 2931 return nil, err 2932 } 2933 return out, nil 2934} 2935 2936func (c *subscriberClient) CreateSnapshot(ctx context.Context, in *CreateSnapshotRequest, opts ...grpc.CallOption) (*Snapshot, error) { 2937 out := new(Snapshot) 2938 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Subscriber/CreateSnapshot", in, out, opts...) 2939 if err != nil { 2940 return nil, err 2941 } 2942 return out, nil 2943} 2944 2945func (c *subscriberClient) UpdateSnapshot(ctx context.Context, in *UpdateSnapshotRequest, opts ...grpc.CallOption) (*Snapshot, error) { 2946 out := new(Snapshot) 2947 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Subscriber/UpdateSnapshot", in, out, opts...) 2948 if err != nil { 2949 return nil, err 2950 } 2951 return out, nil 2952} 2953 2954func (c *subscriberClient) DeleteSnapshot(ctx context.Context, in *DeleteSnapshotRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 2955 out := new(empty.Empty) 2956 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Subscriber/DeleteSnapshot", in, out, opts...) 2957 if err != nil { 2958 return nil, err 2959 } 2960 return out, nil 2961} 2962 2963func (c *subscriberClient) Seek(ctx context.Context, in *SeekRequest, opts ...grpc.CallOption) (*SeekResponse, error) { 2964 out := new(SeekResponse) 2965 err := c.cc.Invoke(ctx, "/google.pubsub.v1.Subscriber/Seek", in, out, opts...) 2966 if err != nil { 2967 return nil, err 2968 } 2969 return out, nil 2970} 2971 2972// SubscriberServer is the server API for Subscriber service. 2973type SubscriberServer interface { 2974 // Creates a subscription to a given topic. See the 2975 // <a href="/pubsub/docs/admin#resource_names"> resource name rules</a>. 2976 // If the subscription already exists, returns `ALREADY_EXISTS`. 2977 // If the corresponding topic doesn't exist, returns `NOT_FOUND`. 2978 // 2979 // If the name is not provided in the request, the server will assign a random 2980 // name for this subscription on the same project as the topic, conforming 2981 // to the 2982 // [resource name format](https://cloud.google.com/pubsub/docs/overview#names). 2983 // The generated name is populated in the returned Subscription object. 2984 // Note that for REST API requests, you must specify a name in the request. 2985 CreateSubscription(context.Context, *Subscription) (*Subscription, error) 2986 // Gets the configuration details of a subscription. 2987 GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error) 2988 // Updates an existing subscription. Note that certain properties of a 2989 // subscription, such as its topic, are not modifiable. 2990 UpdateSubscription(context.Context, *UpdateSubscriptionRequest) (*Subscription, error) 2991 // Lists matching subscriptions. 2992 ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error) 2993 // Deletes an existing subscription. All messages retained in the subscription 2994 // are immediately dropped. Calls to `Pull` after deletion will return 2995 // `NOT_FOUND`. After a subscription is deleted, a new one may be created with 2996 // the same name, but the new one has no association with the old 2997 // subscription or its topic unless the same topic is specified. 2998 DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*empty.Empty, error) 2999 // Modifies the ack deadline for a specific message. This method is useful 3000 // to indicate that more time is needed to process a message by the 3001 // subscriber, or to make the message available for redelivery if the 3002 // processing was interrupted. Note that this does not modify the 3003 // subscription-level `ackDeadlineSeconds` used for subsequent messages. 3004 ModifyAckDeadline(context.Context, *ModifyAckDeadlineRequest) (*empty.Empty, error) 3005 // Acknowledges the messages associated with the `ack_ids` in the 3006 // `AcknowledgeRequest`. The Pub/Sub system can remove the relevant messages 3007 // from the subscription. 3008 // 3009 // Acknowledging a message whose ack deadline has expired may succeed, 3010 // but such a message may be redelivered later. Acknowledging a message more 3011 // than once will not result in an error. 3012 Acknowledge(context.Context, *AcknowledgeRequest) (*empty.Empty, error) 3013 // Pulls messages from the server. Returns an empty list if there are no 3014 // messages available in the backlog. The server may return `UNAVAILABLE` if 3015 // there are too many concurrent pull requests pending for the given 3016 // subscription. 3017 Pull(context.Context, *PullRequest) (*PullResponse, error) 3018 // Establishes a stream with the server, which sends messages down to the 3019 // client. The client streams acknowledgements and ack deadline modifications 3020 // back to the server. The server will close the stream and return the status 3021 // on any error. The server may close the stream with status `UNAVAILABLE` to 3022 // reassign server-side resources, in which case, the client should 3023 // re-establish the stream. Flow control can be achieved by configuring the 3024 // underlying RPC channel. 3025 StreamingPull(Subscriber_StreamingPullServer) error 3026 // Modifies the `PushConfig` for a specified subscription. 3027 // 3028 // This may be used to change a push subscription to a pull one (signified by 3029 // an empty `PushConfig`) or vice versa, or change the endpoint URL and other 3030 // attributes of a push subscription. Messages will accumulate for delivery 3031 // continuously through the call regardless of changes to the `PushConfig`. 3032 ModifyPushConfig(context.Context, *ModifyPushConfigRequest) (*empty.Empty, error) 3033 // Gets the configuration details of a snapshot.<br><br> 3034 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 3035 // changed in backward-incompatible ways and is not recommended for production 3036 // use. It is not subject to any SLA or deprecation policy. 3037 GetSnapshot(context.Context, *GetSnapshotRequest) (*Snapshot, error) 3038 // Lists the existing snapshots.<br><br> 3039 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 3040 // changed in backward-incompatible ways and is not recommended for production 3041 // use. It is not subject to any SLA or deprecation policy. 3042 ListSnapshots(context.Context, *ListSnapshotsRequest) (*ListSnapshotsResponse, error) 3043 // Creates a snapshot from the requested subscription.<br><br> 3044 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 3045 // changed in backward-incompatible ways and is not recommended for production 3046 // use. It is not subject to any SLA or deprecation policy. 3047 // If the snapshot already exists, returns `ALREADY_EXISTS`. 3048 // If the requested subscription doesn't exist, returns `NOT_FOUND`. 3049 // If the backlog in the subscription is too old -- and the resulting snapshot 3050 // would expire in less than 1 hour -- then `FAILED_PRECONDITION` is returned. 3051 // See also the `Snapshot.expire_time` field. If the name is not provided in 3052 // the request, the server will assign a random 3053 // name for this snapshot on the same project as the subscription, conforming 3054 // to the [resource name format](https://cloud.google.com/pubsub/docs/overview#names). 3055 // The generated 3056 // name is populated in the returned Snapshot object. Note that for REST API 3057 // requests, you must specify a name in the request. 3058 CreateSnapshot(context.Context, *CreateSnapshotRequest) (*Snapshot, error) 3059 // Updates an existing snapshot.<br><br> 3060 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 3061 // changed in backward-incompatible ways and is not recommended for production 3062 // use. It is not subject to any SLA or deprecation policy. 3063 // Note that certain properties of a snapshot are not modifiable. 3064 UpdateSnapshot(context.Context, *UpdateSnapshotRequest) (*Snapshot, error) 3065 // Removes an existing snapshot. <br><br> 3066 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 3067 // changed in backward-incompatible ways and is not recommended for production 3068 // use. It is not subject to any SLA or deprecation policy. 3069 // When the snapshot is deleted, all messages retained in the snapshot 3070 // are immediately dropped. After a snapshot is deleted, a new one may be 3071 // created with the same name, but the new one has no association with the old 3072 // snapshot or its subscription, unless the same subscription is specified. 3073 DeleteSnapshot(context.Context, *DeleteSnapshotRequest) (*empty.Empty, error) 3074 // Seeks an existing subscription to a point in time or to a given snapshot, 3075 // whichever is provided in the request.<br><br> 3076 // <b>ALPHA:</b> This feature is part of an alpha release. This API might be 3077 // changed in backward-incompatible ways and is not recommended for production 3078 // use. It is not subject to any SLA or deprecation policy. 3079 Seek(context.Context, *SeekRequest) (*SeekResponse, error) 3080} 3081 3082func RegisterSubscriberServer(s *grpc.Server, srv SubscriberServer) { 3083 s.RegisterService(&_Subscriber_serviceDesc, srv) 3084} 3085 3086func _Subscriber_CreateSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3087 in := new(Subscription) 3088 if err := dec(in); err != nil { 3089 return nil, err 3090 } 3091 if interceptor == nil { 3092 return srv.(SubscriberServer).CreateSubscription(ctx, in) 3093 } 3094 info := &grpc.UnaryServerInfo{ 3095 Server: srv, 3096 FullMethod: "/google.pubsub.v1.Subscriber/CreateSubscription", 3097 } 3098 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3099 return srv.(SubscriberServer).CreateSubscription(ctx, req.(*Subscription)) 3100 } 3101 return interceptor(ctx, in, info, handler) 3102} 3103 3104func _Subscriber_GetSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3105 in := new(GetSubscriptionRequest) 3106 if err := dec(in); err != nil { 3107 return nil, err 3108 } 3109 if interceptor == nil { 3110 return srv.(SubscriberServer).GetSubscription(ctx, in) 3111 } 3112 info := &grpc.UnaryServerInfo{ 3113 Server: srv, 3114 FullMethod: "/google.pubsub.v1.Subscriber/GetSubscription", 3115 } 3116 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3117 return srv.(SubscriberServer).GetSubscription(ctx, req.(*GetSubscriptionRequest)) 3118 } 3119 return interceptor(ctx, in, info, handler) 3120} 3121 3122func _Subscriber_UpdateSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3123 in := new(UpdateSubscriptionRequest) 3124 if err := dec(in); err != nil { 3125 return nil, err 3126 } 3127 if interceptor == nil { 3128 return srv.(SubscriberServer).UpdateSubscription(ctx, in) 3129 } 3130 info := &grpc.UnaryServerInfo{ 3131 Server: srv, 3132 FullMethod: "/google.pubsub.v1.Subscriber/UpdateSubscription", 3133 } 3134 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3135 return srv.(SubscriberServer).UpdateSubscription(ctx, req.(*UpdateSubscriptionRequest)) 3136 } 3137 return interceptor(ctx, in, info, handler) 3138} 3139 3140func _Subscriber_ListSubscriptions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3141 in := new(ListSubscriptionsRequest) 3142 if err := dec(in); err != nil { 3143 return nil, err 3144 } 3145 if interceptor == nil { 3146 return srv.(SubscriberServer).ListSubscriptions(ctx, in) 3147 } 3148 info := &grpc.UnaryServerInfo{ 3149 Server: srv, 3150 FullMethod: "/google.pubsub.v1.Subscriber/ListSubscriptions", 3151 } 3152 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3153 return srv.(SubscriberServer).ListSubscriptions(ctx, req.(*ListSubscriptionsRequest)) 3154 } 3155 return interceptor(ctx, in, info, handler) 3156} 3157 3158func _Subscriber_DeleteSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3159 in := new(DeleteSubscriptionRequest) 3160 if err := dec(in); err != nil { 3161 return nil, err 3162 } 3163 if interceptor == nil { 3164 return srv.(SubscriberServer).DeleteSubscription(ctx, in) 3165 } 3166 info := &grpc.UnaryServerInfo{ 3167 Server: srv, 3168 FullMethod: "/google.pubsub.v1.Subscriber/DeleteSubscription", 3169 } 3170 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3171 return srv.(SubscriberServer).DeleteSubscription(ctx, req.(*DeleteSubscriptionRequest)) 3172 } 3173 return interceptor(ctx, in, info, handler) 3174} 3175 3176func _Subscriber_ModifyAckDeadline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3177 in := new(ModifyAckDeadlineRequest) 3178 if err := dec(in); err != nil { 3179 return nil, err 3180 } 3181 if interceptor == nil { 3182 return srv.(SubscriberServer).ModifyAckDeadline(ctx, in) 3183 } 3184 info := &grpc.UnaryServerInfo{ 3185 Server: srv, 3186 FullMethod: "/google.pubsub.v1.Subscriber/ModifyAckDeadline", 3187 } 3188 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3189 return srv.(SubscriberServer).ModifyAckDeadline(ctx, req.(*ModifyAckDeadlineRequest)) 3190 } 3191 return interceptor(ctx, in, info, handler) 3192} 3193 3194func _Subscriber_Acknowledge_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3195 in := new(AcknowledgeRequest) 3196 if err := dec(in); err != nil { 3197 return nil, err 3198 } 3199 if interceptor == nil { 3200 return srv.(SubscriberServer).Acknowledge(ctx, in) 3201 } 3202 info := &grpc.UnaryServerInfo{ 3203 Server: srv, 3204 FullMethod: "/google.pubsub.v1.Subscriber/Acknowledge", 3205 } 3206 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3207 return srv.(SubscriberServer).Acknowledge(ctx, req.(*AcknowledgeRequest)) 3208 } 3209 return interceptor(ctx, in, info, handler) 3210} 3211 3212func _Subscriber_Pull_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3213 in := new(PullRequest) 3214 if err := dec(in); err != nil { 3215 return nil, err 3216 } 3217 if interceptor == nil { 3218 return srv.(SubscriberServer).Pull(ctx, in) 3219 } 3220 info := &grpc.UnaryServerInfo{ 3221 Server: srv, 3222 FullMethod: "/google.pubsub.v1.Subscriber/Pull", 3223 } 3224 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3225 return srv.(SubscriberServer).Pull(ctx, req.(*PullRequest)) 3226 } 3227 return interceptor(ctx, in, info, handler) 3228} 3229 3230func _Subscriber_StreamingPull_Handler(srv interface{}, stream grpc.ServerStream) error { 3231 return srv.(SubscriberServer).StreamingPull(&subscriberStreamingPullServer{stream}) 3232} 3233 3234type Subscriber_StreamingPullServer interface { 3235 Send(*StreamingPullResponse) error 3236 Recv() (*StreamingPullRequest, error) 3237 grpc.ServerStream 3238} 3239 3240type subscriberStreamingPullServer struct { 3241 grpc.ServerStream 3242} 3243 3244func (x *subscriberStreamingPullServer) Send(m *StreamingPullResponse) error { 3245 return x.ServerStream.SendMsg(m) 3246} 3247 3248func (x *subscriberStreamingPullServer) Recv() (*StreamingPullRequest, error) { 3249 m := new(StreamingPullRequest) 3250 if err := x.ServerStream.RecvMsg(m); err != nil { 3251 return nil, err 3252 } 3253 return m, nil 3254} 3255 3256func _Subscriber_ModifyPushConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3257 in := new(ModifyPushConfigRequest) 3258 if err := dec(in); err != nil { 3259 return nil, err 3260 } 3261 if interceptor == nil { 3262 return srv.(SubscriberServer).ModifyPushConfig(ctx, in) 3263 } 3264 info := &grpc.UnaryServerInfo{ 3265 Server: srv, 3266 FullMethod: "/google.pubsub.v1.Subscriber/ModifyPushConfig", 3267 } 3268 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3269 return srv.(SubscriberServer).ModifyPushConfig(ctx, req.(*ModifyPushConfigRequest)) 3270 } 3271 return interceptor(ctx, in, info, handler) 3272} 3273 3274func _Subscriber_GetSnapshot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3275 in := new(GetSnapshotRequest) 3276 if err := dec(in); err != nil { 3277 return nil, err 3278 } 3279 if interceptor == nil { 3280 return srv.(SubscriberServer).GetSnapshot(ctx, in) 3281 } 3282 info := &grpc.UnaryServerInfo{ 3283 Server: srv, 3284 FullMethod: "/google.pubsub.v1.Subscriber/GetSnapshot", 3285 } 3286 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3287 return srv.(SubscriberServer).GetSnapshot(ctx, req.(*GetSnapshotRequest)) 3288 } 3289 return interceptor(ctx, in, info, handler) 3290} 3291 3292func _Subscriber_ListSnapshots_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3293 in := new(ListSnapshotsRequest) 3294 if err := dec(in); err != nil { 3295 return nil, err 3296 } 3297 if interceptor == nil { 3298 return srv.(SubscriberServer).ListSnapshots(ctx, in) 3299 } 3300 info := &grpc.UnaryServerInfo{ 3301 Server: srv, 3302 FullMethod: "/google.pubsub.v1.Subscriber/ListSnapshots", 3303 } 3304 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3305 return srv.(SubscriberServer).ListSnapshots(ctx, req.(*ListSnapshotsRequest)) 3306 } 3307 return interceptor(ctx, in, info, handler) 3308} 3309 3310func _Subscriber_CreateSnapshot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3311 in := new(CreateSnapshotRequest) 3312 if err := dec(in); err != nil { 3313 return nil, err 3314 } 3315 if interceptor == nil { 3316 return srv.(SubscriberServer).CreateSnapshot(ctx, in) 3317 } 3318 info := &grpc.UnaryServerInfo{ 3319 Server: srv, 3320 FullMethod: "/google.pubsub.v1.Subscriber/CreateSnapshot", 3321 } 3322 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3323 return srv.(SubscriberServer).CreateSnapshot(ctx, req.(*CreateSnapshotRequest)) 3324 } 3325 return interceptor(ctx, in, info, handler) 3326} 3327 3328func _Subscriber_UpdateSnapshot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3329 in := new(UpdateSnapshotRequest) 3330 if err := dec(in); err != nil { 3331 return nil, err 3332 } 3333 if interceptor == nil { 3334 return srv.(SubscriberServer).UpdateSnapshot(ctx, in) 3335 } 3336 info := &grpc.UnaryServerInfo{ 3337 Server: srv, 3338 FullMethod: "/google.pubsub.v1.Subscriber/UpdateSnapshot", 3339 } 3340 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3341 return srv.(SubscriberServer).UpdateSnapshot(ctx, req.(*UpdateSnapshotRequest)) 3342 } 3343 return interceptor(ctx, in, info, handler) 3344} 3345 3346func _Subscriber_DeleteSnapshot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3347 in := new(DeleteSnapshotRequest) 3348 if err := dec(in); err != nil { 3349 return nil, err 3350 } 3351 if interceptor == nil { 3352 return srv.(SubscriberServer).DeleteSnapshot(ctx, in) 3353 } 3354 info := &grpc.UnaryServerInfo{ 3355 Server: srv, 3356 FullMethod: "/google.pubsub.v1.Subscriber/DeleteSnapshot", 3357 } 3358 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3359 return srv.(SubscriberServer).DeleteSnapshot(ctx, req.(*DeleteSnapshotRequest)) 3360 } 3361 return interceptor(ctx, in, info, handler) 3362} 3363 3364func _Subscriber_Seek_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 3365 in := new(SeekRequest) 3366 if err := dec(in); err != nil { 3367 return nil, err 3368 } 3369 if interceptor == nil { 3370 return srv.(SubscriberServer).Seek(ctx, in) 3371 } 3372 info := &grpc.UnaryServerInfo{ 3373 Server: srv, 3374 FullMethod: "/google.pubsub.v1.Subscriber/Seek", 3375 } 3376 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 3377 return srv.(SubscriberServer).Seek(ctx, req.(*SeekRequest)) 3378 } 3379 return interceptor(ctx, in, info, handler) 3380} 3381 3382var _Subscriber_serviceDesc = grpc.ServiceDesc{ 3383 ServiceName: "google.pubsub.v1.Subscriber", 3384 HandlerType: (*SubscriberServer)(nil), 3385 Methods: []grpc.MethodDesc{ 3386 { 3387 MethodName: "CreateSubscription", 3388 Handler: _Subscriber_CreateSubscription_Handler, 3389 }, 3390 { 3391 MethodName: "GetSubscription", 3392 Handler: _Subscriber_GetSubscription_Handler, 3393 }, 3394 { 3395 MethodName: "UpdateSubscription", 3396 Handler: _Subscriber_UpdateSubscription_Handler, 3397 }, 3398 { 3399 MethodName: "ListSubscriptions", 3400 Handler: _Subscriber_ListSubscriptions_Handler, 3401 }, 3402 { 3403 MethodName: "DeleteSubscription", 3404 Handler: _Subscriber_DeleteSubscription_Handler, 3405 }, 3406 { 3407 MethodName: "ModifyAckDeadline", 3408 Handler: _Subscriber_ModifyAckDeadline_Handler, 3409 }, 3410 { 3411 MethodName: "Acknowledge", 3412 Handler: _Subscriber_Acknowledge_Handler, 3413 }, 3414 { 3415 MethodName: "Pull", 3416 Handler: _Subscriber_Pull_Handler, 3417 }, 3418 { 3419 MethodName: "ModifyPushConfig", 3420 Handler: _Subscriber_ModifyPushConfig_Handler, 3421 }, 3422 { 3423 MethodName: "GetSnapshot", 3424 Handler: _Subscriber_GetSnapshot_Handler, 3425 }, 3426 { 3427 MethodName: "ListSnapshots", 3428 Handler: _Subscriber_ListSnapshots_Handler, 3429 }, 3430 { 3431 MethodName: "CreateSnapshot", 3432 Handler: _Subscriber_CreateSnapshot_Handler, 3433 }, 3434 { 3435 MethodName: "UpdateSnapshot", 3436 Handler: _Subscriber_UpdateSnapshot_Handler, 3437 }, 3438 { 3439 MethodName: "DeleteSnapshot", 3440 Handler: _Subscriber_DeleteSnapshot_Handler, 3441 }, 3442 { 3443 MethodName: "Seek", 3444 Handler: _Subscriber_Seek_Handler, 3445 }, 3446 }, 3447 Streams: []grpc.StreamDesc{ 3448 { 3449 StreamName: "StreamingPull", 3450 Handler: _Subscriber_StreamingPull_Handler, 3451 ServerStreams: true, 3452 ClientStreams: true, 3453 }, 3454 }, 3455 Metadata: "google/pubsub/v1/pubsub.proto", 3456} 3457 3458func init() { 3459 proto.RegisterFile("google/pubsub/v1/pubsub.proto", fileDescriptor_pubsub_ccb5b83827ebb62b) 3460} 3461 3462var fileDescriptor_pubsub_ccb5b83827ebb62b = []byte{ 3463 // 2199 bytes of a gzipped FileDescriptorProto 3464 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x5a, 0xcd, 0x73, 0x1b, 0x49, 3465 0x15, 0xdf, 0x96, 0x1c, 0x47, 0x7e, 0xb2, 0xe3, 0xb8, 0xb1, 0x1d, 0x79, 0xf2, 0x65, 0x4f, 0x8c, 3466 0xed, 0x28, 0x89, 0x64, 0x2b, 0xb5, 0x61, 0x13, 0xe3, 0x6c, 0xd9, 0x71, 0xc8, 0x06, 0x12, 0x30, 3467 0xe3, 0x10, 0xaa, 0xa8, 0x14, 0xaa, 0x91, 0xd4, 0x51, 0x66, 0x35, 0x9a, 0x99, 0x9d, 0x19, 0x79, 3468 0xe3, 0x85, 0x50, 0x61, 0x97, 0xa2, 0x8a, 0x22, 0x07, 0x76, 0xb9, 0xee, 0x81, 0x82, 0x1b, 0x47, 3469 0xaa, 0xb8, 0xc2, 0x9d, 0x2b, 0x07, 0xfe, 0x01, 0x8e, 0x5c, 0x38, 0xc1, 0x71, 0xab, 0x3f, 0x66, 3470 0x34, 0x1f, 0x3d, 0x92, 0x65, 0x6f, 0x6e, 0xa3, 0xee, 0xd7, 0xfd, 0x7e, 0xef, 0xbb, 0xdf, 0x2b, 3471 0xc1, 0xc5, 0xb6, 0x6d, 0xb7, 0x4d, 0x52, 0x75, 0x7a, 0x0d, 0xaf, 0xd7, 0xa8, 0x1e, 0x6c, 0x88, 3472 0xaf, 0x8a, 0xe3, 0xda, 0xbe, 0x8d, 0xcf, 0xf2, 0xed, 0x8a, 0x58, 0x3c, 0xd8, 0x50, 0x2e, 0x88, 3473 0x03, 0xba, 0x63, 0x54, 0x75, 0xcb, 0xb2, 0x7d, 0xdd, 0x37, 0x6c, 0xcb, 0xe3, 0xf4, 0xca, 0xa5, 3474 0xe0, 0x3a, 0xfa, 0xab, 0xd1, 0x7b, 0x5e, 0x6d, 0xf5, 0x5c, 0x46, 0x20, 0xf6, 0xcf, 0x27, 0xf7, 3475 0x49, 0xd7, 0xf1, 0x0f, 0xc5, 0xe6, 0x62, 0x72, 0xf3, 0xb9, 0x41, 0xcc, 0x56, 0xbd, 0xab, 0x7b, 3476 0x1d, 0x41, 0x71, 0x39, 0x49, 0xe1, 0x1b, 0x5d, 0xe2, 0xf9, 0x7a, 0xd7, 0xe1, 0x04, 0xea, 0x53, 3477 0x98, 0x7d, 0x4c, 0x3c, 0x4f, 0x6f, 0x93, 0x7d, 0xdf, 0x76, 0xf5, 0x36, 0xd9, 0xb3, 0x4d, 0xa3, 3478 0x79, 0x88, 0xef, 0xc2, 0x79, 0xdd, 0x34, 0xed, 0x8f, 0x49, 0xab, 0xee, 0x10, 0xd7, 0x33, 0x3c, 3479 0x9f, 0x58, 0x4d, 0x52, 0x77, 0x49, 0x9b, 0x82, 0x2f, 0xa1, 0xc5, 0xfc, 0xda, 0x84, 0xb6, 0x20, 3480 0x48, 0xf6, 0xfa, 0x14, 0x1a, 0x27, 0x50, 0xff, 0x8b, 0xe0, 0xd4, 0x13, 0xdb, 0x31, 0x9a, 0x18, 3481 0xc3, 0x98, 0xa5, 0x77, 0x49, 0x09, 0x2d, 0xa2, 0xb5, 0x09, 0x8d, 0x7d, 0xe3, 0x4d, 0x18, 0x37, 3482 0xf5, 0x06, 0x31, 0xbd, 0x52, 0x6e, 0x31, 0xbf, 0x56, 0xac, 0x5d, 0xa9, 0x24, 0xd5, 0x56, 0x61, 3483 0x87, 0x2b, 0x8f, 0x18, 0xd5, 0x7d, 0xcb, 0x77, 0x0f, 0x35, 0x71, 0x04, 0x3f, 0x83, 0xf9, 0x2e, 3484 0x87, 0x5c, 0xf7, 0x38, 0xe6, 0xba, 0xc3, 0x40, 0x97, 0xf2, 0x8b, 0x68, 0xad, 0x58, 0x5b, 0x49, 3485 0x5f, 0x26, 0x13, 0x51, 0x9b, 0xed, 0x4a, 0x56, 0x95, 0xdb, 0x50, 0x8c, 0x30, 0xc5, 0x67, 0x21, 3486 0xdf, 0x21, 0x87, 0x02, 0x3c, 0xfd, 0xc4, 0xb3, 0x70, 0xea, 0x40, 0x37, 0x7b, 0xa4, 0x94, 0x63, 3487 0x6b, 0xfc, 0xc7, 0x9d, 0xdc, 0x7b, 0x48, 0xfd, 0x3c, 0x07, 0x53, 0x7b, 0x8c, 0xa7, 0xe0, 0x47, 3488 0x65, 0x6f, 0xe9, 0xbe, 0xce, 0x8e, 0x4f, 0x6a, 0xec, 0x1b, 0xff, 0x00, 0x40, 0xf7, 0x7d, 0xd7, 3489 0x68, 0xf4, 0x7c, 0x12, 0xc8, 0x5f, 0x4d, 0x43, 0x8e, 0x5d, 0x54, 0xd9, 0x0e, 0x4f, 0x70, 0x5d, 3490 0x44, 0xae, 0xc0, 0x17, 0x01, 0x02, 0x7d, 0x18, 0x2d, 0xa6, 0x83, 0x09, 0x6d, 0x42, 0xac, 0x3c, 3491 0x6c, 0xe1, 0x2d, 0x98, 0x74, 0x7a, 0x0d, 0xd3, 0xf0, 0x5e, 0xd4, 0xa9, 0xf1, 0x4b, 0x63, 0x4c, 3492 0x49, 0x4a, 0xc8, 0x51, 0x78, 0x46, 0xe5, 0x49, 0xe0, 0x19, 0x5a, 0x51, 0xd0, 0xd3, 0x15, 0x65, 3493 0x0b, 0xa6, 0x13, 0xcc, 0x47, 0xd2, 0xc9, 0x2a, 0x4c, 0x3f, 0x20, 0x3e, 0x33, 0xa6, 0x46, 0x3e, 3494 0xea, 0x11, 0xcf, 0xa7, 0xc4, 0x3e, 0xfd, 0x2d, 0x2e, 0xe0, 0x3f, 0xd4, 0xd7, 0x08, 0xf0, 0x8f, 3495 0x9c, 0x96, 0xee, 0x93, 0x18, 0xf1, 0x8d, 0x28, 0x71, 0xb1, 0x76, 0x2e, 0xc3, 0x51, 0xc4, 0x2d, 3496 0x78, 0x13, 0x8a, 0x3d, 0x76, 0x09, 0x0b, 0x02, 0x06, 0x47, 0x26, 0xeb, 0x77, 0x68, 0x9c, 0x3c, 3497 0xd6, 0xbd, 0x8e, 0x06, 0x9c, 0x9c, 0x7e, 0xab, 0x4d, 0x38, 0xb3, 0xc7, 0x25, 0x1f, 0x08, 0x15, 3498 0x6f, 0x42, 0x41, 0xa8, 0x37, 0xb0, 0xdf, 0xe5, 0x21, 0xf6, 0xd3, 0xc2, 0x03, 0x6a, 0x0d, 0xa6, 3499 0x43, 0x26, 0x9e, 0x63, 0x5b, 0x1e, 0xc1, 0x97, 0xa1, 0xd8, 0x37, 0x60, 0x10, 0x5b, 0x10, 0x5a, 3500 0xd0, 0x53, 0x0d, 0x98, 0x79, 0x64, 0x78, 0x5c, 0x8b, 0x5e, 0x80, 0xad, 0x04, 0xa7, 0x1d, 0xd7, 3501 0xfe, 0x90, 0x34, 0x7d, 0x81, 0x2e, 0xf8, 0x89, 0xcf, 0xc3, 0x84, 0xc3, 0xa2, 0xc3, 0xf8, 0x84, 3502 0x5b, 0xe4, 0x94, 0x56, 0xa0, 0x0b, 0xfb, 0xc6, 0x27, 0x84, 0x7a, 0x0b, 0xdb, 0xf4, 0xed, 0x0e, 3503 0xb1, 0x02, 0x6f, 0xa1, 0x2b, 0x4f, 0xe8, 0x82, 0xda, 0x05, 0x1c, 0x65, 0x25, 0x10, 0x56, 0x61, 3504 0x9c, 0x89, 0xce, 0xc1, 0x0d, 0x30, 0x83, 0x20, 0xc3, 0x2b, 0x30, 0x6d, 0x91, 0x97, 0x7e, 0x3d, 3505 0xc2, 0x8a, 0xbb, 0xc6, 0x14, 0x5d, 0xde, 0x0b, 0xd9, 0x7d, 0x04, 0x17, 0x43, 0x76, 0xfb, 0xbd, 3506 0x86, 0xd7, 0x74, 0x0d, 0x87, 0xa5, 0xc7, 0xc1, 0x16, 0x38, 0x89, 0x84, 0x16, 0x5c, 0xca, 0x62, 3507 0x29, 0xa4, 0x5d, 0x86, 0x29, 0x2f, 0xba, 0x21, 0x2c, 0x12, 0x5f, 0x3c, 0xb2, 0x88, 0x5d, 0x58, 3508 0xe8, 0xf3, 0xb3, 0x74, 0xc7, 0x7b, 0x61, 0xfb, 0x6f, 0x51, 0xbc, 0x06, 0x28, 0x32, 0x76, 0x42, 3509 0xb4, 0x0b, 0x30, 0xe1, 0x05, 0x8b, 0x42, 0xac, 0xfe, 0xc2, 0x91, 0x45, 0x2a, 0x03, 0xde, 0x25, 3510 0x26, 0x49, 0x84, 0xaa, 0x3c, 0xae, 0xff, 0x9a, 0x87, 0xc9, 0xa8, 0x9a, 0xa5, 0xf5, 0x20, 0x3c, 3511 0x9a, 0x8b, 0xaa, 0x61, 0x0b, 0x8a, 0x4e, 0xcf, 0x7b, 0x51, 0x6f, 0xda, 0xd6, 0x73, 0xa3, 0x2d, 3512 0x12, 0xd7, 0x05, 0x59, 0xa8, 0x79, 0x2f, 0xee, 0x31, 0x1a, 0x0d, 0x9c, 0xf0, 0x1b, 0xaf, 0xc3, 3513 0xac, 0xde, 0xec, 0xd4, 0x5b, 0x44, 0x6f, 0x99, 0x86, 0x45, 0xea, 0x1e, 0x69, 0xda, 0x56, 0xcb, 3514 0x2b, 0x9d, 0x62, 0x0a, 0xc5, 0x7a, 0xb3, 0xb3, 0x2b, 0xb6, 0xf6, 0xf9, 0x0e, 0xae, 0xc1, 0x9c, 3515 0x4b, 0x7c, 0xdd, 0xb0, 0xea, 0x7a, 0xb3, 0x43, 0x5a, 0xf5, 0x30, 0xca, 0x4f, 0x2f, 0xa2, 0xb5, 3516 0x82, 0xf6, 0x0d, 0xbe, 0xb9, 0x4d, 0xf7, 0x44, 0x60, 0x7b, 0xf8, 0xc7, 0xa0, 0x04, 0xc1, 0xeb, 3517 0x12, 0x9f, 0x58, 0x54, 0xc6, 0x7a, 0x50, 0xc4, 0x4b, 0x05, 0x86, 0x79, 0x21, 0x95, 0x80, 0x76, 3518 0x05, 0x81, 0x56, 0x12, 0x87, 0xb5, 0xe0, 0x6c, 0xb0, 0x83, 0x77, 0xc2, 0x1a, 0x39, 0xc1, 0x62, 3519 0xae, 0x9c, 0x16, 0x3c, 0xaa, 0x57, 0x59, 0xa9, 0x3c, 0x49, 0x31, 0xfb, 0x1b, 0x02, 0xe8, 0x2b, 3520 0x16, 0x5f, 0x81, 0x29, 0x66, 0x0b, 0x62, 0xb5, 0x1c, 0xdb, 0xb0, 0x82, 0x9c, 0x33, 0x49, 0x17, 3521 0xef, 0x8b, 0x35, 0xfc, 0x48, 0x52, 0xda, 0xae, 0x0f, 0xb2, 0xd7, 0xa0, 0xba, 0x76, 0xd2, 0xca, 3522 0xd3, 0x84, 0x69, 0x8d, 0x34, 0x89, 0x71, 0x10, 0x1a, 0x0b, 0xcf, 0xc1, 0x38, 0xf5, 0x08, 0xa3, 3523 0x15, 0xb8, 0xa8, 0xde, 0xec, 0x3c, 0x6c, 0xe1, 0xdb, 0x70, 0x5a, 0x58, 0x41, 0x14, 0x8c, 0xa1, 3524 0xe9, 0x3c, 0xa0, 0x57, 0xbf, 0x0d, 0xf3, 0x0f, 0x88, 0x1f, 0xb5, 0x43, 0x10, 0x0d, 0x2a, 0x4c, 3525 0x46, 0xf3, 0x45, 0xa0, 0xaf, 0xe8, 0x9a, 0xfa, 0x25, 0x82, 0x05, 0x5e, 0xf3, 0x64, 0x37, 0xec, 3526 0x48, 0x6e, 0x28, 0xd6, 0x2e, 0x0d, 0x76, 0x83, 0x38, 0x87, 0x93, 0xd5, 0x43, 0x07, 0x4a, 0x34, 3527 0x95, 0x48, 0xf3, 0xf2, 0xdb, 0xa9, 0x3e, 0xbf, 0x41, 0x3c, 0x59, 0xca, 0xf3, 0xf2, 0xae, 0x2c, 3528 0x2f, 0x0f, 0xd7, 0xc8, 0x31, 0xf3, 0xf6, 0xfb, 0xb0, 0xc0, 0x93, 0xdc, 0x71, 0xad, 0xfb, 0x73, 3529 0x38, 0xf7, 0xd8, 0x6e, 0x19, 0xcf, 0x0f, 0x23, 0xf9, 0xe9, 0xe8, 0xc7, 0x93, 0xd9, 0x2f, 0x37, 3530 0x5a, 0xf6, 0x53, 0x3f, 0x43, 0x50, 0xdc, 0xeb, 0x99, 0xe6, 0x28, 0x2c, 0x6f, 0x00, 0x76, 0x89, 3531 0xdf, 0x73, 0xad, 0xba, 0xd1, 0xed, 0x92, 0x96, 0xa1, 0xfb, 0xc4, 0x3c, 0x64, 0x9c, 0x0b, 0xda, 3532 0x0c, 0xdf, 0x79, 0xd8, 0xdf, 0xc0, 0x4b, 0x30, 0xd9, 0xd5, 0x5f, 0xf6, 0xb3, 0x64, 0x9e, 0x19, 3533 0xbb, 0xd8, 0xd5, 0x5f, 0x06, 0xd9, 0x51, 0xfd, 0x29, 0x4c, 0x72, 0x10, 0xc2, 0x84, 0xdf, 0x87, 3534 0x19, 0x57, 0x04, 0x65, 0xff, 0x1c, 0x37, 0xe3, 0x52, 0x5a, 0xb4, 0x44, 0xfc, 0x6a, 0x67, 0xdd, 3535 0xf8, 0x82, 0x47, 0x1d, 0xa6, 0xc4, 0x95, 0xbc, 0xdd, 0x4f, 0xe7, 0xa3, 0x88, 0x7c, 0x0e, 0x4e, 3536 0xf3, 0x94, 0xe0, 0x95, 0xc6, 0x58, 0x39, 0x1c, 0x67, 0x39, 0xc1, 0xcb, 0xac, 0x1e, 0xf9, 0xac, 3537 0xea, 0xa1, 0xfe, 0x10, 0xf0, 0x76, 0xb3, 0x63, 0xd9, 0x1f, 0x9b, 0xa4, 0xd5, 0x3e, 0x2e, 0x88, 3538 0x5c, 0x14, 0x84, 0xfa, 0xcb, 0x1c, 0xcc, 0xee, 0xfb, 0x2e, 0xd1, 0xbb, 0x86, 0xd5, 0x1e, 0xd5, 3539 0x9a, 0x59, 0xb7, 0xe2, 0x5b, 0x70, 0xae, 0xcb, 0x74, 0x26, 0x93, 0x2e, 0xbf, 0x76, 0x4a, 0x9b, 3540 0xe3, 0xdb, 0xc9, 0xf2, 0xf8, 0x6e, 0xfa, 0x5c, 0x5c, 0x77, 0xb3, 0xf1, 0x73, 0xdb, 0x9c, 0xdd, 3541 0x16, 0x9c, 0xf7, 0x98, 0x0c, 0xf5, 0x01, 0xe5, 0xb8, 0xc4, 0x49, 0xb6, 0xd3, 0x6a, 0x6d, 0xc3, 3542 0x5c, 0x42, 0x05, 0x6f, 0xc9, 0x97, 0xfe, 0x85, 0x60, 0xee, 0x9e, 0x4b, 0x68, 0x36, 0x16, 0x2f, 3543 0xa2, 0x40, 0xdb, 0xb2, 0x27, 0x4b, 0xd2, 0x02, 0x39, 0x89, 0x05, 0xbe, 0x17, 0x96, 0xf0, 0x3c, 3544 0x83, 0x75, 0x33, 0x0d, 0x4b, 0xca, 0xf0, 0xeb, 0xae, 0xe5, 0x6f, 0x10, 0xcc, 0x89, 0x3a, 0x93, 3545 0x90, 0xec, 0x16, 0x14, 0x82, 0xe7, 0x9f, 0xa8, 0x2f, 0x8a, 0x24, 0x9b, 0x06, 0x87, 0x42, 0xda, 3546 0x93, 0xd5, 0x95, 0xff, 0x20, 0x28, 0x04, 0x77, 0x8e, 0xf0, 0x1c, 0xdc, 0x84, 0x22, 0x79, 0xe9, 3547 0x18, 0x2e, 0xe1, 0x7d, 0x6c, 0x7e, 0x68, 0x1f, 0x0b, 0x9c, 0x9c, 0x2e, 0xe0, 0xbb, 0xa1, 0x29, 3548 0xc6, 0x98, 0x29, 0x56, 0xb2, 0xc5, 0xfc, 0xba, 0xb5, 0xbf, 0x0e, 0x98, 0xbe, 0x11, 0x12, 0x9a, 3549 0x57, 0x12, 0x9a, 0x9f, 0xe8, 0x6b, 0x57, 0x35, 0x61, 0x96, 0x55, 0xc1, 0x64, 0xb7, 0xf0, 0x76, 3550 0x8a, 0xee, 0x21, 0xcc, 0x25, 0xb8, 0x89, 0x00, 0x7b, 0x2f, 0xd9, 0x2c, 0x0c, 0xf6, 0x8e, 0x63, 3551 0x34, 0x12, 0x37, 0x61, 0x4e, 0xd4, 0xd8, 0x11, 0xb4, 0xf3, 0x5b, 0x04, 0xc5, 0x7d, 0x42, 0x3a, 3552 0xa3, 0xe4, 0xc2, 0x75, 0x18, 0x63, 0x4e, 0x93, 0x1b, 0xe6, 0x34, 0x1f, 0xbc, 0xa3, 0x31, 0x4a, 3553 0x7c, 0x21, 0x82, 0x80, 0xa9, 0xec, 0x83, 0x77, 0xfa, 0x18, 0x76, 0x0a, 0x30, 0xee, 0xeb, 0x6e, 3554 0x9b, 0xf8, 0xea, 0x19, 0x98, 0xe4, 0x60, 0xb8, 0xd2, 0x6a, 0x7f, 0x2f, 0xc0, 0x84, 0x68, 0xf0, 3555 0x89, 0x8b, 0x3f, 0x84, 0x22, 0x8f, 0x70, 0x3e, 0x0b, 0xcb, 0xea, 0x9b, 0x95, 0xac, 0x0d, 0xf5, 3556 0xea, 0xa7, 0xff, 0xfc, 0xf7, 0xef, 0x73, 0x57, 0x94, 0x4b, 0xd5, 0x83, 0x8d, 0xea, 0xcf, 0x68, 3557 0x74, 0x6c, 0x09, 0x9b, 0x7b, 0xd5, 0x72, 0x95, 0x77, 0xdb, 0xd5, 0xf2, 0xab, 0x3b, 0xa8, 0x8c, 3558 0x5f, 0x41, 0x31, 0x32, 0x40, 0xc1, 0xcb, 0xe9, 0x2b, 0xd3, 0xf3, 0x95, 0x6c, 0xc6, 0x55, 0xc6, 3559 0xf8, 0x6a, 0x6d, 0x99, 0x31, 0x66, 0x8c, 0x2a, 0x03, 0xd9, 0x7f, 0x8a, 0xe0, 0xb4, 0x10, 0x1c, 3560 0x2f, 0x4a, 0x1f, 0xd0, 0x91, 0xc9, 0x8a, 0xb2, 0x34, 0x80, 0x82, 0x6b, 0x52, 0xad, 0x31, 0x04, 3561 0xd7, 0xd5, 0xd5, 0x3e, 0x02, 0x39, 0x73, 0x31, 0xae, 0xa2, 0x20, 0x6c, 0x28, 0x04, 0xe3, 0x26, 3562 0x2c, 0x61, 0x91, 0x18, 0x45, 0x65, 0x4b, 0xbf, 0xca, 0x78, 0x2f, 0xe1, 0xcb, 0x43, 0x78, 0xe3, 3563 0xd7, 0x08, 0xa0, 0x3f, 0x30, 0xc1, 0x92, 0x41, 0x66, 0x6a, 0x72, 0xa3, 0x2c, 0x0f, 0x26, 0x12, 3564 0xe2, 0xc7, 0x21, 0x08, 0xe6, 0x11, 0x10, 0xaf, 0x04, 0x0a, 0xfc, 0x17, 0x04, 0xf3, 0xf2, 0x89, 3565 0x06, 0xae, 0x0e, 0xe0, 0x24, 0x7b, 0xd6, 0x2b, 0xeb, 0x47, 0x3f, 0x20, 0x60, 0xbe, 0xcb, 0x60, 3566 0x56, 0xf1, 0x8d, 0x21, 0x9a, 0xaa, 0xc6, 0x5f, 0xe1, 0x7f, 0x44, 0x91, 0x41, 0x53, 0x98, 0x7a, 3567 0xf0, 0xb5, 0x41, 0xfc, 0x13, 0xe9, 0x50, 0xb9, 0x7e, 0x34, 0x62, 0x01, 0x74, 0x83, 0x01, 0xbd, 3568 0x86, 0xaf, 0x0e, 0x05, 0x1a, 0xa2, 0xf1, 0xa1, 0x18, 0x99, 0x73, 0xc8, 0x22, 0x2a, 0x3d, 0x06, 3569 0x51, 0xe6, 0x53, 0xc9, 0xe5, 0x7e, 0xd7, 0xf1, 0x0f, 0x03, 0x7b, 0x96, 0x87, 0xb9, 0x54, 0xed, 3570 0x7f, 0x33, 0x00, 0x42, 0xd7, 0x0d, 0xe2, 0xe2, 0x5f, 0x23, 0xc0, 0xe2, 0x95, 0x10, 0xcd, 0x68, 3571 0x43, 0xba, 0x1e, 0x65, 0xc8, 0xbe, 0xba, 0xce, 0xe0, 0x94, 0x95, 0x6f, 0x4a, 0x13, 0x4b, 0xcc, 3572 0x58, 0x22, 0xc0, 0xbf, 0x40, 0x6c, 0x96, 0x1b, 0x43, 0xb1, 0x26, 0x8d, 0x31, 0x49, 0xc7, 0x34, 3573 0x14, 0x4f, 0xdc, 0x8f, 0xa2, 0xfc, 0x07, 0xe1, 0xc2, 0x7f, 0x08, 0xc7, 0xc6, 0x31, 0x5c, 0xd7, 3574 0xb2, 0x92, 0xdf, 0x71, 0xa0, 0x6d, 0x31, 0x68, 0xdf, 0xaa, 0xd5, 0x52, 0xd0, 0x2a, 0x47, 0xd1, 3575 0xdb, 0x97, 0x88, 0x8f, 0x6f, 0xe3, 0xa1, 0x59, 0x96, 0x3b, 0xaf, 0x34, 0x2a, 0xaf, 0x1d, 0x89, 3576 0x56, 0xf8, 0x79, 0x85, 0xa1, 0x5d, 0xc3, 0x2b, 0x99, 0x79, 0x23, 0x1e, 0x89, 0xbf, 0x43, 0xc1, 3577 0x34, 0x6f, 0x98, 0x06, 0x33, 0xdb, 0xe1, 0x4c, 0x9f, 0x17, 0x46, 0x2d, 0x8f, 0x68, 0xd4, 0x3f, 3578 0x21, 0x98, 0x49, 0x75, 0x75, 0x32, 0x8d, 0x65, 0xb5, 0x7e, 0x99, 0x80, 0xbe, 0xcb, 0x00, 0xed, 3579 0xaa, 0xef, 0x8f, 0x04, 0xe8, 0x4e, 0x37, 0xc9, 0x87, 0xda, 0xf5, 0x73, 0x04, 0xc5, 0x48, 0xc3, 3580 0x27, 0x4b, 0x0f, 0xe9, 0x7e, 0x30, 0x13, 0xd9, 0x2e, 0x43, 0x76, 0x57, 0xbd, 0x3d, 0x1a, 0x32, 3581 0xbd, 0xcf, 0x81, 0x62, 0xfa, 0x15, 0x82, 0x31, 0xda, 0x24, 0xe1, 0x8b, 0xb2, 0xfa, 0x1a, 0xf6, 3582 0x8f, 0x32, 0x97, 0x8f, 0xf6, 0x56, 0x81, 0xcb, 0xab, 0xb5, 0xd1, 0xd0, 0x38, 0x3d, 0xd3, 0xa4, 3583 0x30, 0x5a, 0x30, 0x15, 0xeb, 0xd9, 0xb0, 0xec, 0xb9, 0x2d, 0xe9, 0x6b, 0x95, 0xd5, 0xa1, 0x74, 3584 0x1c, 0xe0, 0x1a, 0x5a, 0x47, 0x34, 0xf6, 0xcf, 0x26, 0x27, 0x2c, 0xf8, 0x6a, 0x96, 0x97, 0xa4, 3585 0xa6, 0x30, 0x99, 0xa6, 0x78, 0xc8, 0x84, 0xbf, 0xa7, 0xde, 0x3d, 0x8e, 0x93, 0xf4, 0xd9, 0x50, 3586 0x45, 0xfc, 0x02, 0x8a, 0x91, 0xb7, 0xbf, 0xcc, 0x45, 0xd2, 0xad, 0x81, 0x32, 0xe0, 0x91, 0xad, 3587 0xde, 0x60, 0xd8, 0x56, 0x31, 0x4f, 0xdb, 0x41, 0xa9, 0x8a, 0xe1, 0x0a, 0xca, 0x17, 0x8d, 0xa4, 3588 0x37, 0x08, 0xa6, 0x62, 0x8f, 0x7b, 0x99, 0x25, 0x64, 0xbd, 0x86, 0xcc, 0x12, 0xd2, 0x2e, 0x41, 3589 0x2d, 0x33, 0x44, 0xcb, 0x58, 0xcd, 0xce, 0x37, 0x21, 0xf3, 0xcf, 0x10, 0x9c, 0x89, 0x77, 0xbc, 3590 0x78, 0xf5, 0x88, 0x3d, 0xf1, 0x40, 0xad, 0x5c, 0x67, 0x18, 0x56, 0x94, 0x25, 0x79, 0x31, 0x8b, 3591 0x68, 0x84, 0x1a, 0xe5, 0x0d, 0x82, 0x33, 0xf1, 0x76, 0x58, 0x86, 0x42, 0xda, 0x30, 0x0f, 0x44, 3592 0x21, 0xb2, 0x5d, 0xad, 0x1c, 0xb3, 0x4d, 0x65, 0x18, 0x9c, 0xd7, 0x08, 0xce, 0xc4, 0xbb, 0x20, 3593 0x19, 0x1c, 0x69, 0x9f, 0x94, 0xe9, 0xc2, 0xc2, 0x4d, 0xca, 0x47, 0x74, 0x13, 0x9a, 0x36, 0x68, 3594 0x17, 0x23, 0x4b, 0x1b, 0x91, 0x56, 0x4b, 0x5a, 0x29, 0x23, 0xcd, 0xcf, 0x71, 0xd3, 0x86, 0x47, 3595 0x48, 0xe7, 0x0e, 0x2a, 0xef, 0x7c, 0x81, 0x60, 0xb6, 0x69, 0x77, 0x53, 0x4c, 0x76, 0x8a, 0x7c, 3596 0xfc, 0xbe, 0x47, 0x85, 0xdc, 0x43, 0x3f, 0xb9, 0x25, 0x08, 0xda, 0xb6, 0xa9, 0x5b, 0xed, 0x8a, 3597 0xed, 0xb6, 0xab, 0x6d, 0x62, 0x31, 0x15, 0x54, 0xf9, 0x96, 0xee, 0x18, 0x5e, 0xff, 0x2f, 0x1a, 3598 0x9b, 0xfc, 0xeb, 0xff, 0x08, 0xfd, 0x39, 0x37, 0xff, 0x80, 0x9f, 0xbd, 0x67, 0xda, 0xbd, 0x16, 3599 0xed, 0x39, 0xf6, 0x7b, 0x8d, 0xca, 0xd3, 0x8d, 0x7f, 0x04, 0x1b, 0xcf, 0xd8, 0xc6, 0x33, 0xbe, 3600 0xf1, 0xec, 0xe9, 0x46, 0x63, 0x9c, 0xdd, 0x7b, 0xf3, 0xab, 0x00, 0x00, 0x00, 0xff, 0xff, 0x52, 3601 0x93, 0x85, 0x71, 0xf9, 0x21, 0x00, 0x00, 3602} 3603