vendor/google.golang.org/genproto/googleapis/pubsub/v1beta2/pubsub.pb.go

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