1// Copyright 2021 Google LLC 2// 3// Licensed under the Apache License, Version 2.0 (the "License"); 4// you may not use this file except in compliance with the License. 5// You may obtain a copy of the License at 6// 7// http://www.apache.org/licenses/LICENSE-2.0 8// 9// Unless required by applicable law or agreed to in writing, software 10// distributed under the License is distributed on an "AS IS" BASIS, 11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12// See the License for the specific language governing permissions and 13// limitations under the License. 14 15// Code generated by protoc-gen-go. DO NOT EDIT. 16// versions: 17// protoc-gen-go v1.25.0-devel 18// protoc v3.12.2 19// source: google/cloud/pubsublite/v1/common.proto 20 21package pubsublite 22 23import ( 24 reflect "reflect" 25 sync "sync" 26 27 proto "github.com/golang/protobuf/proto" 28 _ "google.golang.org/genproto/googleapis/api/annotations" 29 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 30 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 31 durationpb "google.golang.org/protobuf/types/known/durationpb" 32 timestamppb "google.golang.org/protobuf/types/known/timestamppb" 33) 34 35const ( 36 // Verify that this generated code is sufficiently up-to-date. 37 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 38 // Verify that runtime/protoimpl is sufficiently up-to-date. 39 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 40) 41 42// This is a compile-time assertion that a sufficiently up-to-date version 43// of the legacy proto package is being used. 44const _ = proto.ProtoPackageIsVersion4 45 46// When this subscription should send messages to subscribers relative to 47// messages persistence in storage. For details, see [Creating Lite 48// subscriptions](https://cloud.google.com/pubsub/lite/docs/subscriptions#creating_lite_subscriptions). 49type Subscription_DeliveryConfig_DeliveryRequirement int32 50 51const ( 52 // Default value. This value is unused. 53 Subscription_DeliveryConfig_DELIVERY_REQUIREMENT_UNSPECIFIED Subscription_DeliveryConfig_DeliveryRequirement = 0 54 // The server does not wait for a published message to be successfully 55 // written to storage before delivering it to subscribers. 56 Subscription_DeliveryConfig_DELIVER_IMMEDIATELY Subscription_DeliveryConfig_DeliveryRequirement = 1 57 // The server will not deliver a published message to subscribers until 58 // the message has been successfully written to storage. This will result 59 // in higher end-to-end latency, but consistent delivery. 60 Subscription_DeliveryConfig_DELIVER_AFTER_STORED Subscription_DeliveryConfig_DeliveryRequirement = 2 61) 62 63// Enum value maps for Subscription_DeliveryConfig_DeliveryRequirement. 64var ( 65 Subscription_DeliveryConfig_DeliveryRequirement_name = map[int32]string{ 66 0: "DELIVERY_REQUIREMENT_UNSPECIFIED", 67 1: "DELIVER_IMMEDIATELY", 68 2: "DELIVER_AFTER_STORED", 69 } 70 Subscription_DeliveryConfig_DeliveryRequirement_value = map[string]int32{ 71 "DELIVERY_REQUIREMENT_UNSPECIFIED": 0, 72 "DELIVER_IMMEDIATELY": 1, 73 "DELIVER_AFTER_STORED": 2, 74 } 75) 76 77func (x Subscription_DeliveryConfig_DeliveryRequirement) Enum() *Subscription_DeliveryConfig_DeliveryRequirement { 78 p := new(Subscription_DeliveryConfig_DeliveryRequirement) 79 *p = x 80 return p 81} 82 83func (x Subscription_DeliveryConfig_DeliveryRequirement) String() string { 84 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 85} 86 87func (Subscription_DeliveryConfig_DeliveryRequirement) Descriptor() protoreflect.EnumDescriptor { 88 return file_google_cloud_pubsublite_v1_common_proto_enumTypes[0].Descriptor() 89} 90 91func (Subscription_DeliveryConfig_DeliveryRequirement) Type() protoreflect.EnumType { 92 return &file_google_cloud_pubsublite_v1_common_proto_enumTypes[0] 93} 94 95func (x Subscription_DeliveryConfig_DeliveryRequirement) Number() protoreflect.EnumNumber { 96 return protoreflect.EnumNumber(x) 97} 98 99// Deprecated: Use Subscription_DeliveryConfig_DeliveryRequirement.Descriptor instead. 100func (Subscription_DeliveryConfig_DeliveryRequirement) EnumDescriptor() ([]byte, []int) { 101 return file_google_cloud_pubsublite_v1_common_proto_rawDescGZIP(), []int{5, 0, 0} 102} 103 104// The values associated with a key of an attribute. 105type AttributeValues struct { 106 state protoimpl.MessageState 107 sizeCache protoimpl.SizeCache 108 unknownFields protoimpl.UnknownFields 109 110 // The list of values associated with a key. 111 Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` 112} 113 114func (x *AttributeValues) Reset() { 115 *x = AttributeValues{} 116 if protoimpl.UnsafeEnabled { 117 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[0] 118 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 119 ms.StoreMessageInfo(mi) 120 } 121} 122 123func (x *AttributeValues) String() string { 124 return protoimpl.X.MessageStringOf(x) 125} 126 127func (*AttributeValues) ProtoMessage() {} 128 129func (x *AttributeValues) ProtoReflect() protoreflect.Message { 130 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[0] 131 if protoimpl.UnsafeEnabled && x != nil { 132 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 133 if ms.LoadMessageInfo() == nil { 134 ms.StoreMessageInfo(mi) 135 } 136 return ms 137 } 138 return mi.MessageOf(x) 139} 140 141// Deprecated: Use AttributeValues.ProtoReflect.Descriptor instead. 142func (*AttributeValues) Descriptor() ([]byte, []int) { 143 return file_google_cloud_pubsublite_v1_common_proto_rawDescGZIP(), []int{0} 144} 145 146func (x *AttributeValues) GetValues() [][]byte { 147 if x != nil { 148 return x.Values 149 } 150 return nil 151} 152 153// A message that is published by publishers and delivered to subscribers. 154type PubSubMessage struct { 155 state protoimpl.MessageState 156 sizeCache protoimpl.SizeCache 157 unknownFields protoimpl.UnknownFields 158 159 // The key used for routing messages to partitions or for compaction (e.g., 160 // keep the last N messages per key). If the key is empty, the message is 161 // routed to an arbitrary partition. 162 Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` 163 // The payload of the message. 164 Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` 165 // Optional attributes that can be used for message metadata/headers. 166 Attributes map[string]*AttributeValues `protobuf:"bytes,3,rep,name=attributes,proto3" json:"attributes,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` 167 // An optional, user-specified event time. 168 EventTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"` 169} 170 171func (x *PubSubMessage) Reset() { 172 *x = PubSubMessage{} 173 if protoimpl.UnsafeEnabled { 174 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[1] 175 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 176 ms.StoreMessageInfo(mi) 177 } 178} 179 180func (x *PubSubMessage) String() string { 181 return protoimpl.X.MessageStringOf(x) 182} 183 184func (*PubSubMessage) ProtoMessage() {} 185 186func (x *PubSubMessage) ProtoReflect() protoreflect.Message { 187 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[1] 188 if protoimpl.UnsafeEnabled && x != nil { 189 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 190 if ms.LoadMessageInfo() == nil { 191 ms.StoreMessageInfo(mi) 192 } 193 return ms 194 } 195 return mi.MessageOf(x) 196} 197 198// Deprecated: Use PubSubMessage.ProtoReflect.Descriptor instead. 199func (*PubSubMessage) Descriptor() ([]byte, []int) { 200 return file_google_cloud_pubsublite_v1_common_proto_rawDescGZIP(), []int{1} 201} 202 203func (x *PubSubMessage) GetKey() []byte { 204 if x != nil { 205 return x.Key 206 } 207 return nil 208} 209 210func (x *PubSubMessage) GetData() []byte { 211 if x != nil { 212 return x.Data 213 } 214 return nil 215} 216 217func (x *PubSubMessage) GetAttributes() map[string]*AttributeValues { 218 if x != nil { 219 return x.Attributes 220 } 221 return nil 222} 223 224func (x *PubSubMessage) GetEventTime() *timestamppb.Timestamp { 225 if x != nil { 226 return x.EventTime 227 } 228 return nil 229} 230 231// A cursor that describes the position of a message within a topic partition. 232type Cursor struct { 233 state protoimpl.MessageState 234 sizeCache protoimpl.SizeCache 235 unknownFields protoimpl.UnknownFields 236 237 // The offset of a message within a topic partition. Must be greater than or 238 // equal 0. 239 Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` 240} 241 242func (x *Cursor) Reset() { 243 *x = Cursor{} 244 if protoimpl.UnsafeEnabled { 245 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[2] 246 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 247 ms.StoreMessageInfo(mi) 248 } 249} 250 251func (x *Cursor) String() string { 252 return protoimpl.X.MessageStringOf(x) 253} 254 255func (*Cursor) ProtoMessage() {} 256 257func (x *Cursor) ProtoReflect() protoreflect.Message { 258 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[2] 259 if protoimpl.UnsafeEnabled && x != nil { 260 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 261 if ms.LoadMessageInfo() == nil { 262 ms.StoreMessageInfo(mi) 263 } 264 return ms 265 } 266 return mi.MessageOf(x) 267} 268 269// Deprecated: Use Cursor.ProtoReflect.Descriptor instead. 270func (*Cursor) Descriptor() ([]byte, []int) { 271 return file_google_cloud_pubsublite_v1_common_proto_rawDescGZIP(), []int{2} 272} 273 274func (x *Cursor) GetOffset() int64 { 275 if x != nil { 276 return x.Offset 277 } 278 return 0 279} 280 281// A message that has been stored and sequenced by the Pub/Sub Lite system. 282type SequencedMessage struct { 283 state protoimpl.MessageState 284 sizeCache protoimpl.SizeCache 285 unknownFields protoimpl.UnknownFields 286 287 // The position of a message within the partition where it is stored. 288 Cursor *Cursor `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"` 289 // The time when the message was received by the server when it was first 290 // published. 291 PublishTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=publish_time,json=publishTime,proto3" json:"publish_time,omitempty"` 292 // The user message. 293 Message *PubSubMessage `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` 294 // The size in bytes of this message for flow control and quota purposes. 295 SizeBytes int64 `protobuf:"varint,4,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"` 296} 297 298func (x *SequencedMessage) Reset() { 299 *x = SequencedMessage{} 300 if protoimpl.UnsafeEnabled { 301 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[3] 302 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 303 ms.StoreMessageInfo(mi) 304 } 305} 306 307func (x *SequencedMessage) String() string { 308 return protoimpl.X.MessageStringOf(x) 309} 310 311func (*SequencedMessage) ProtoMessage() {} 312 313func (x *SequencedMessage) ProtoReflect() protoreflect.Message { 314 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[3] 315 if protoimpl.UnsafeEnabled && x != nil { 316 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 317 if ms.LoadMessageInfo() == nil { 318 ms.StoreMessageInfo(mi) 319 } 320 return ms 321 } 322 return mi.MessageOf(x) 323} 324 325// Deprecated: Use SequencedMessage.ProtoReflect.Descriptor instead. 326func (*SequencedMessage) Descriptor() ([]byte, []int) { 327 return file_google_cloud_pubsublite_v1_common_proto_rawDescGZIP(), []int{3} 328} 329 330func (x *SequencedMessage) GetCursor() *Cursor { 331 if x != nil { 332 return x.Cursor 333 } 334 return nil 335} 336 337func (x *SequencedMessage) GetPublishTime() *timestamppb.Timestamp { 338 if x != nil { 339 return x.PublishTime 340 } 341 return nil 342} 343 344func (x *SequencedMessage) GetMessage() *PubSubMessage { 345 if x != nil { 346 return x.Message 347 } 348 return nil 349} 350 351func (x *SequencedMessage) GetSizeBytes() int64 { 352 if x != nil { 353 return x.SizeBytes 354 } 355 return 0 356} 357 358// Metadata about a topic resource. 359type Topic struct { 360 state protoimpl.MessageState 361 sizeCache protoimpl.SizeCache 362 unknownFields protoimpl.UnknownFields 363 364 // The name of the topic. 365 // Structured like: 366 // projects/{project_number}/locations/{location}/topics/{topic_id} 367 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 368 // The settings for this topic's partitions. 369 PartitionConfig *Topic_PartitionConfig `protobuf:"bytes,2,opt,name=partition_config,json=partitionConfig,proto3" json:"partition_config,omitempty"` 370 // The settings for this topic's message retention. 371 RetentionConfig *Topic_RetentionConfig `protobuf:"bytes,3,opt,name=retention_config,json=retentionConfig,proto3" json:"retention_config,omitempty"` 372} 373 374func (x *Topic) Reset() { 375 *x = Topic{} 376 if protoimpl.UnsafeEnabled { 377 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[4] 378 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 379 ms.StoreMessageInfo(mi) 380 } 381} 382 383func (x *Topic) String() string { 384 return protoimpl.X.MessageStringOf(x) 385} 386 387func (*Topic) ProtoMessage() {} 388 389func (x *Topic) ProtoReflect() protoreflect.Message { 390 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[4] 391 if protoimpl.UnsafeEnabled && x != nil { 392 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 393 if ms.LoadMessageInfo() == nil { 394 ms.StoreMessageInfo(mi) 395 } 396 return ms 397 } 398 return mi.MessageOf(x) 399} 400 401// Deprecated: Use Topic.ProtoReflect.Descriptor instead. 402func (*Topic) Descriptor() ([]byte, []int) { 403 return file_google_cloud_pubsublite_v1_common_proto_rawDescGZIP(), []int{4} 404} 405 406func (x *Topic) GetName() string { 407 if x != nil { 408 return x.Name 409 } 410 return "" 411} 412 413func (x *Topic) GetPartitionConfig() *Topic_PartitionConfig { 414 if x != nil { 415 return x.PartitionConfig 416 } 417 return nil 418} 419 420func (x *Topic) GetRetentionConfig() *Topic_RetentionConfig { 421 if x != nil { 422 return x.RetentionConfig 423 } 424 return nil 425} 426 427// Metadata about a subscription resource. 428type Subscription struct { 429 state protoimpl.MessageState 430 sizeCache protoimpl.SizeCache 431 unknownFields protoimpl.UnknownFields 432 433 // The name of the subscription. 434 // Structured like: 435 // projects/{project_number}/locations/{location}/subscriptions/{subscription_id} 436 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 437 // The name of the topic this subscription is attached to. 438 // Structured like: 439 // projects/{project_number}/locations/{location}/topics/{topic_id} 440 Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` 441 // The settings for this subscription's message delivery. 442 DeliveryConfig *Subscription_DeliveryConfig `protobuf:"bytes,3,opt,name=delivery_config,json=deliveryConfig,proto3" json:"delivery_config,omitempty"` 443} 444 445func (x *Subscription) Reset() { 446 *x = Subscription{} 447 if protoimpl.UnsafeEnabled { 448 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[5] 449 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 450 ms.StoreMessageInfo(mi) 451 } 452} 453 454func (x *Subscription) String() string { 455 return protoimpl.X.MessageStringOf(x) 456} 457 458func (*Subscription) ProtoMessage() {} 459 460func (x *Subscription) ProtoReflect() protoreflect.Message { 461 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[5] 462 if protoimpl.UnsafeEnabled && x != nil { 463 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 464 if ms.LoadMessageInfo() == nil { 465 ms.StoreMessageInfo(mi) 466 } 467 return ms 468 } 469 return mi.MessageOf(x) 470} 471 472// Deprecated: Use Subscription.ProtoReflect.Descriptor instead. 473func (*Subscription) Descriptor() ([]byte, []int) { 474 return file_google_cloud_pubsublite_v1_common_proto_rawDescGZIP(), []int{5} 475} 476 477func (x *Subscription) GetName() string { 478 if x != nil { 479 return x.Name 480 } 481 return "" 482} 483 484func (x *Subscription) GetTopic() string { 485 if x != nil { 486 return x.Topic 487 } 488 return "" 489} 490 491func (x *Subscription) GetDeliveryConfig() *Subscription_DeliveryConfig { 492 if x != nil { 493 return x.DeliveryConfig 494 } 495 return nil 496} 497 498// A target publish or event time. Can be used for seeking to or retrieving the 499// corresponding cursor. 500type TimeTarget struct { 501 state protoimpl.MessageState 502 sizeCache protoimpl.SizeCache 503 unknownFields protoimpl.UnknownFields 504 505 // The type of message time to query. 506 // 507 // Types that are assignable to Time: 508 // *TimeTarget_PublishTime 509 // *TimeTarget_EventTime 510 Time isTimeTarget_Time `protobuf_oneof:"time"` 511} 512 513func (x *TimeTarget) Reset() { 514 *x = TimeTarget{} 515 if protoimpl.UnsafeEnabled { 516 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[6] 517 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 518 ms.StoreMessageInfo(mi) 519 } 520} 521 522func (x *TimeTarget) String() string { 523 return protoimpl.X.MessageStringOf(x) 524} 525 526func (*TimeTarget) ProtoMessage() {} 527 528func (x *TimeTarget) ProtoReflect() protoreflect.Message { 529 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[6] 530 if protoimpl.UnsafeEnabled && x != nil { 531 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 532 if ms.LoadMessageInfo() == nil { 533 ms.StoreMessageInfo(mi) 534 } 535 return ms 536 } 537 return mi.MessageOf(x) 538} 539 540// Deprecated: Use TimeTarget.ProtoReflect.Descriptor instead. 541func (*TimeTarget) Descriptor() ([]byte, []int) { 542 return file_google_cloud_pubsublite_v1_common_proto_rawDescGZIP(), []int{6} 543} 544 545func (m *TimeTarget) GetTime() isTimeTarget_Time { 546 if m != nil { 547 return m.Time 548 } 549 return nil 550} 551 552func (x *TimeTarget) GetPublishTime() *timestamppb.Timestamp { 553 if x, ok := x.GetTime().(*TimeTarget_PublishTime); ok { 554 return x.PublishTime 555 } 556 return nil 557} 558 559func (x *TimeTarget) GetEventTime() *timestamppb.Timestamp { 560 if x, ok := x.GetTime().(*TimeTarget_EventTime); ok { 561 return x.EventTime 562 } 563 return nil 564} 565 566type isTimeTarget_Time interface { 567 isTimeTarget_Time() 568} 569 570type TimeTarget_PublishTime struct { 571 // Request the cursor of the first message with publish time greater than or 572 // equal to `publish_time`. All messages thereafter are guaranteed to have 573 // publish times >= `publish_time`. 574 PublishTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=publish_time,json=publishTime,proto3,oneof"` 575} 576 577type TimeTarget_EventTime struct { 578 // Request the cursor of the first message with event time greater than or 579 // equal to `event_time`. If messages are missing an event time, the publish 580 // time is used as a fallback. As event times are user supplied, subsequent 581 // messages may have event times less than `event_time` and should be 582 // filtered by the client, if necessary. 583 EventTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=event_time,json=eventTime,proto3,oneof"` 584} 585 586func (*TimeTarget_PublishTime) isTimeTarget_Time() {} 587 588func (*TimeTarget_EventTime) isTimeTarget_Time() {} 589 590// The settings for a topic's partitions. 591type Topic_PartitionConfig struct { 592 state protoimpl.MessageState 593 sizeCache protoimpl.SizeCache 594 unknownFields protoimpl.UnknownFields 595 596 // The number of partitions in the topic. Must be at least 1. 597 // 598 // Once a topic has been created the number of partitions can be increased 599 // but not decreased. Message ordering is not guaranteed across a topic 600 // resize. For more information see 601 // https://cloud.google.com/pubsub/lite/docs/topics#scaling_capacity 602 Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` 603 // The throughput dimension of this topic. 604 // 605 // Types that are assignable to Dimension: 606 // *Topic_PartitionConfig_Scale 607 // *Topic_PartitionConfig_Capacity_ 608 Dimension isTopic_PartitionConfig_Dimension `protobuf_oneof:"dimension"` 609} 610 611func (x *Topic_PartitionConfig) Reset() { 612 *x = Topic_PartitionConfig{} 613 if protoimpl.UnsafeEnabled { 614 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[8] 615 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 616 ms.StoreMessageInfo(mi) 617 } 618} 619 620func (x *Topic_PartitionConfig) String() string { 621 return protoimpl.X.MessageStringOf(x) 622} 623 624func (*Topic_PartitionConfig) ProtoMessage() {} 625 626func (x *Topic_PartitionConfig) ProtoReflect() protoreflect.Message { 627 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[8] 628 if protoimpl.UnsafeEnabled && x != nil { 629 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 630 if ms.LoadMessageInfo() == nil { 631 ms.StoreMessageInfo(mi) 632 } 633 return ms 634 } 635 return mi.MessageOf(x) 636} 637 638// Deprecated: Use Topic_PartitionConfig.ProtoReflect.Descriptor instead. 639func (*Topic_PartitionConfig) Descriptor() ([]byte, []int) { 640 return file_google_cloud_pubsublite_v1_common_proto_rawDescGZIP(), []int{4, 0} 641} 642 643func (x *Topic_PartitionConfig) GetCount() int64 { 644 if x != nil { 645 return x.Count 646 } 647 return 0 648} 649 650func (m *Topic_PartitionConfig) GetDimension() isTopic_PartitionConfig_Dimension { 651 if m != nil { 652 return m.Dimension 653 } 654 return nil 655} 656 657// Deprecated: Do not use. 658func (x *Topic_PartitionConfig) GetScale() int32 { 659 if x, ok := x.GetDimension().(*Topic_PartitionConfig_Scale); ok { 660 return x.Scale 661 } 662 return 0 663} 664 665func (x *Topic_PartitionConfig) GetCapacity() *Topic_PartitionConfig_Capacity { 666 if x, ok := x.GetDimension().(*Topic_PartitionConfig_Capacity_); ok { 667 return x.Capacity 668 } 669 return nil 670} 671 672type isTopic_PartitionConfig_Dimension interface { 673 isTopic_PartitionConfig_Dimension() 674} 675 676type Topic_PartitionConfig_Scale struct { 677 // DEPRECATED: Use capacity instead which can express a superset of 678 // configurations. 679 // 680 // Every partition in the topic is allocated throughput equivalent to 681 // `scale` times the standard partition throughput (4 MiB/s). This is also 682 // reflected in the cost of this topic; a topic with `scale` of 2 and 683 // count of 10 is charged for 20 partitions. This value must be in the 684 // range [1,4]. 685 // 686 // Deprecated: Do not use. 687 Scale int32 `protobuf:"varint,2,opt,name=scale,proto3,oneof"` 688} 689 690type Topic_PartitionConfig_Capacity_ struct { 691 // The capacity configuration. 692 Capacity *Topic_PartitionConfig_Capacity `protobuf:"bytes,3,opt,name=capacity,proto3,oneof"` 693} 694 695func (*Topic_PartitionConfig_Scale) isTopic_PartitionConfig_Dimension() {} 696 697func (*Topic_PartitionConfig_Capacity_) isTopic_PartitionConfig_Dimension() {} 698 699// The settings for a topic's message retention. 700type Topic_RetentionConfig struct { 701 state protoimpl.MessageState 702 sizeCache protoimpl.SizeCache 703 unknownFields protoimpl.UnknownFields 704 705 // The provisioned storage, in bytes, per partition. If the number of bytes 706 // stored in any of the topic's partitions grows beyond this value, older 707 // messages will be dropped to make room for newer ones, regardless of the 708 // value of `period`. 709 PerPartitionBytes int64 `protobuf:"varint,1,opt,name=per_partition_bytes,json=perPartitionBytes,proto3" json:"per_partition_bytes,omitempty"` 710 // How long a published message is retained. If unset, messages will be 711 // retained as long as the bytes retained for each partition is below 712 // `per_partition_bytes`. 713 Period *durationpb.Duration `protobuf:"bytes,2,opt,name=period,proto3" json:"period,omitempty"` 714} 715 716func (x *Topic_RetentionConfig) Reset() { 717 *x = Topic_RetentionConfig{} 718 if protoimpl.UnsafeEnabled { 719 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[9] 720 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 721 ms.StoreMessageInfo(mi) 722 } 723} 724 725func (x *Topic_RetentionConfig) String() string { 726 return protoimpl.X.MessageStringOf(x) 727} 728 729func (*Topic_RetentionConfig) ProtoMessage() {} 730 731func (x *Topic_RetentionConfig) ProtoReflect() protoreflect.Message { 732 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[9] 733 if protoimpl.UnsafeEnabled && x != nil { 734 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 735 if ms.LoadMessageInfo() == nil { 736 ms.StoreMessageInfo(mi) 737 } 738 return ms 739 } 740 return mi.MessageOf(x) 741} 742 743// Deprecated: Use Topic_RetentionConfig.ProtoReflect.Descriptor instead. 744func (*Topic_RetentionConfig) Descriptor() ([]byte, []int) { 745 return file_google_cloud_pubsublite_v1_common_proto_rawDescGZIP(), []int{4, 1} 746} 747 748func (x *Topic_RetentionConfig) GetPerPartitionBytes() int64 { 749 if x != nil { 750 return x.PerPartitionBytes 751 } 752 return 0 753} 754 755func (x *Topic_RetentionConfig) GetPeriod() *durationpb.Duration { 756 if x != nil { 757 return x.Period 758 } 759 return nil 760} 761 762// The throughput capacity configuration for each partition. 763type Topic_PartitionConfig_Capacity struct { 764 state protoimpl.MessageState 765 sizeCache protoimpl.SizeCache 766 unknownFields protoimpl.UnknownFields 767 768 // Publish throughput capacity per partition in MiB/s. 769 // Must be >= 4 and <= 16. 770 PublishMibPerSec int32 `protobuf:"varint,1,opt,name=publish_mib_per_sec,json=publishMibPerSec,proto3" json:"publish_mib_per_sec,omitempty"` 771 // Subscribe throughput capacity per partition in MiB/s. 772 // Must be >= 4 and <= 32. 773 SubscribeMibPerSec int32 `protobuf:"varint,2,opt,name=subscribe_mib_per_sec,json=subscribeMibPerSec,proto3" json:"subscribe_mib_per_sec,omitempty"` 774} 775 776func (x *Topic_PartitionConfig_Capacity) Reset() { 777 *x = Topic_PartitionConfig_Capacity{} 778 if protoimpl.UnsafeEnabled { 779 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[10] 780 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 781 ms.StoreMessageInfo(mi) 782 } 783} 784 785func (x *Topic_PartitionConfig_Capacity) String() string { 786 return protoimpl.X.MessageStringOf(x) 787} 788 789func (*Topic_PartitionConfig_Capacity) ProtoMessage() {} 790 791func (x *Topic_PartitionConfig_Capacity) ProtoReflect() protoreflect.Message { 792 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[10] 793 if protoimpl.UnsafeEnabled && x != nil { 794 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 795 if ms.LoadMessageInfo() == nil { 796 ms.StoreMessageInfo(mi) 797 } 798 return ms 799 } 800 return mi.MessageOf(x) 801} 802 803// Deprecated: Use Topic_PartitionConfig_Capacity.ProtoReflect.Descriptor instead. 804func (*Topic_PartitionConfig_Capacity) Descriptor() ([]byte, []int) { 805 return file_google_cloud_pubsublite_v1_common_proto_rawDescGZIP(), []int{4, 0, 0} 806} 807 808func (x *Topic_PartitionConfig_Capacity) GetPublishMibPerSec() int32 { 809 if x != nil { 810 return x.PublishMibPerSec 811 } 812 return 0 813} 814 815func (x *Topic_PartitionConfig_Capacity) GetSubscribeMibPerSec() int32 { 816 if x != nil { 817 return x.SubscribeMibPerSec 818 } 819 return 0 820} 821 822// The settings for a subscription's message delivery. 823type Subscription_DeliveryConfig struct { 824 state protoimpl.MessageState 825 sizeCache protoimpl.SizeCache 826 unknownFields protoimpl.UnknownFields 827 828 // The DeliveryRequirement for this subscription. 829 DeliveryRequirement Subscription_DeliveryConfig_DeliveryRequirement `protobuf:"varint,3,opt,name=delivery_requirement,json=deliveryRequirement,proto3,enum=google.cloud.pubsublite.v1.Subscription_DeliveryConfig_DeliveryRequirement" json:"delivery_requirement,omitempty"` 830} 831 832func (x *Subscription_DeliveryConfig) Reset() { 833 *x = Subscription_DeliveryConfig{} 834 if protoimpl.UnsafeEnabled { 835 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[11] 836 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 837 ms.StoreMessageInfo(mi) 838 } 839} 840 841func (x *Subscription_DeliveryConfig) String() string { 842 return protoimpl.X.MessageStringOf(x) 843} 844 845func (*Subscription_DeliveryConfig) ProtoMessage() {} 846 847func (x *Subscription_DeliveryConfig) ProtoReflect() protoreflect.Message { 848 mi := &file_google_cloud_pubsublite_v1_common_proto_msgTypes[11] 849 if protoimpl.UnsafeEnabled && x != nil { 850 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 851 if ms.LoadMessageInfo() == nil { 852 ms.StoreMessageInfo(mi) 853 } 854 return ms 855 } 856 return mi.MessageOf(x) 857} 858 859// Deprecated: Use Subscription_DeliveryConfig.ProtoReflect.Descriptor instead. 860func (*Subscription_DeliveryConfig) Descriptor() ([]byte, []int) { 861 return file_google_cloud_pubsublite_v1_common_proto_rawDescGZIP(), []int{5, 0} 862} 863 864func (x *Subscription_DeliveryConfig) GetDeliveryRequirement() Subscription_DeliveryConfig_DeliveryRequirement { 865 if x != nil { 866 return x.DeliveryRequirement 867 } 868 return Subscription_DeliveryConfig_DELIVERY_REQUIREMENT_UNSPECIFIED 869} 870 871var File_google_cloud_pubsublite_v1_common_proto protoreflect.FileDescriptor 872 873var file_google_cloud_pubsublite_v1_common_proto_rawDesc = []byte{ 874 0x0a, 0x27, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x70, 875 0x75, 0x62, 0x73, 0x75, 0x62, 0x6c, 0x69, 0x74, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x63, 0x6f, 0x6d, 876 0x6d, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1a, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 877 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x6c, 0x69, 878 0x74, 0x65, 0x2e, 0x76, 0x31, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 879 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 880 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 881 0x66, 0x2f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 882 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 883 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 884 0x6f, 0x22, 0x29, 0x0a, 0x0f, 0x41, 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x56, 0x61, 885 0x6c, 0x75, 0x65, 0x73, 0x12, 0x16, 0x0a, 0x06, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x01, 886 0x20, 0x03, 0x28, 0x0c, 0x52, 0x06, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x22, 0xb7, 0x02, 0x0a, 887 0x0d, 0x50, 0x75, 0x62, 0x53, 0x75, 0x62, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x10, 888 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x03, 0x6b, 0x65, 0x79, 889 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 890 0x64, 0x61, 0x74, 0x61, 0x12, 0x59, 0x0a, 0x0a, 0x61, 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 891 0x65, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x39, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 892 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x6c, 0x69, 893 0x74, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x75, 0x62, 0x53, 0x75, 0x62, 0x4d, 0x65, 0x73, 0x73, 894 0x61, 0x67, 0x65, 0x2e, 0x41, 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x73, 0x45, 0x6e, 895 0x74, 0x72, 0x79, 0x52, 0x0a, 0x61, 0x74, 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x73, 0x12, 896 0x39, 0x0a, 0x0a, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 897 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 898 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 899 0x09, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x1a, 0x6a, 0x0a, 0x0f, 0x41, 0x74, 900 0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 901 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 902 0x41, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2b, 903 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x70, 0x75, 904 0x62, 0x73, 0x75, 0x62, 0x6c, 0x69, 0x74, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x74, 0x74, 0x72, 905 0x69, 0x62, 0x75, 0x74, 0x65, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x52, 0x05, 0x76, 0x61, 0x6c, 906 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x20, 0x0a, 0x06, 0x43, 0x75, 0x72, 0x73, 0x6f, 0x72, 907 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 908 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x22, 0xf1, 0x01, 0x0a, 0x10, 0x53, 0x65, 0x71, 909 0x75, 0x65, 0x6e, 0x63, 0x65, 0x64, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x3a, 0x0a, 910 0x06, 0x63, 0x75, 0x72, 0x73, 0x6f, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x22, 0x2e, 911 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x70, 0x75, 0x62, 912 0x73, 0x75, 0x62, 0x6c, 0x69, 0x74, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x75, 0x72, 0x73, 0x6f, 913 0x72, 0x52, 0x06, 0x63, 0x75, 0x72, 0x73, 0x6f, 0x72, 0x12, 0x3d, 0x0a, 0x0c, 0x70, 0x75, 0x62, 914 0x6c, 0x69, 0x73, 0x68, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 915 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 916 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0b, 0x70, 0x75, 0x62, 917 0x6c, 0x69, 0x73, 0x68, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x43, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 918 0x61, 0x67, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 919 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x6c, 920 0x69, 0x74, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x75, 0x62, 0x53, 0x75, 0x62, 0x4d, 0x65, 0x73, 921 0x73, 0x61, 0x67, 0x65, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x1d, 0x0a, 922 0x0a, 0x73, 0x69, 0x7a, 0x65, 0x5f, 0x62, 0x79, 0x74, 0x65, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 923 0x03, 0x52, 0x09, 0x73, 0x69, 0x7a, 0x65, 0x42, 0x79, 0x74, 0x65, 0x73, 0x22, 0xc6, 0x05, 0x0a, 924 0x05, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 925 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x5c, 0x0a, 0x10, 0x70, 0x61, 926 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x02, 927 0x20, 0x01, 0x28, 0x0b, 0x32, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 928 0x6f, 0x75, 0x64, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x6c, 0x69, 0x74, 0x65, 0x2e, 0x76, 929 0x31, 0x2e, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 930 0x6e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x0f, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 931 0x6f, 0x6e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x5c, 0x0a, 0x10, 0x72, 0x65, 0x74, 0x65, 932 0x6e, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x03, 0x20, 0x01, 933 0x28, 0x0b, 0x32, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 934 0x64, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x6c, 0x69, 0x74, 0x65, 0x2e, 0x76, 0x31, 0x2e, 935 0x54, 0x6f, 0x70, 0x69, 0x63, 0x2e, 0x52, 0x65, 0x74, 0x65, 0x6e, 0x74, 0x69, 0x6f, 0x6e, 0x43, 936 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x0f, 0x72, 0x65, 0x74, 0x65, 0x6e, 0x74, 0x69, 0x6f, 0x6e, 937 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x1a, 0x98, 0x02, 0x0a, 0x0f, 0x50, 0x61, 0x72, 0x74, 0x69, 938 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x14, 0x0a, 0x05, 0x63, 0x6f, 939 0x75, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x05, 0x63, 0x6f, 0x75, 0x6e, 0x74, 940 0x12, 0x1a, 0x0a, 0x05, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x42, 941 0x02, 0x18, 0x01, 0x48, 0x00, 0x52, 0x05, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x12, 0x58, 0x0a, 0x08, 942 0x63, 0x61, 0x70, 0x61, 0x63, 0x69, 0x74, 0x79, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3a, 943 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x70, 0x75, 944 0x62, 0x73, 0x75, 0x62, 0x6c, 0x69, 0x74, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x6f, 0x70, 0x69, 945 0x63, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 946 0x67, 0x2e, 0x43, 0x61, 0x70, 0x61, 0x63, 0x69, 0x74, 0x79, 0x48, 0x00, 0x52, 0x08, 0x63, 0x61, 947 0x70, 0x61, 0x63, 0x69, 0x74, 0x79, 0x1a, 0x6c, 0x0a, 0x08, 0x43, 0x61, 0x70, 0x61, 0x63, 0x69, 948 0x74, 0x79, 0x12, 0x2d, 0x0a, 0x13, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x5f, 0x6d, 0x69, 949 0x62, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x73, 0x65, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 950 0x10, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x4d, 0x69, 0x62, 0x50, 0x65, 0x72, 0x53, 0x65, 951 0x63, 0x12, 0x31, 0x0a, 0x15, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x5f, 0x6d, 952 0x69, 0x62, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x73, 0x65, 0x63, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 953 0x52, 0x12, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x4d, 0x69, 0x62, 0x50, 0x65, 954 0x72, 0x53, 0x65, 0x63, 0x42, 0x0b, 0x0a, 0x09, 0x64, 0x69, 0x6d, 0x65, 0x6e, 0x73, 0x69, 0x6f, 955 0x6e, 0x1a, 0x74, 0x0a, 0x0f, 0x52, 0x65, 0x74, 0x65, 0x6e, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, 956 0x6e, 0x66, 0x69, 0x67, 0x12, 0x2e, 0x0a, 0x13, 0x70, 0x65, 0x72, 0x5f, 0x70, 0x61, 0x72, 0x74, 957 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x62, 0x79, 0x74, 0x65, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 958 0x03, 0x52, 0x11, 0x70, 0x65, 0x72, 0x50, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x42, 959 0x79, 0x74, 0x65, 0x73, 0x12, 0x31, 0x0a, 0x06, 0x70, 0x65, 0x72, 0x69, 0x6f, 0x64, 0x18, 0x02, 960 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 961 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 962 0x06, 0x70, 0x65, 0x72, 0x69, 0x6f, 0x64, 0x3a, 0x5c, 0xea, 0x41, 0x59, 0x0a, 0x1f, 0x70, 0x75, 963 0x62, 0x73, 0x75, 0x62, 0x6c, 0x69, 0x74, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 964 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x36, 0x70, 965 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 966 0x7d, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 0x6f, 0x63, 967 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x73, 0x2f, 0x7b, 0x74, 968 0x6f, 0x70, 0x69, 0x63, 0x7d, 0x22, 0xb6, 0x04, 0x0a, 0x0c, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 969 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 970 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x3a, 0x0a, 0x05, 0x74, 0x6f, 971 0x70, 0x69, 0x63, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x24, 0xfa, 0x41, 0x21, 0x0a, 0x1f, 972 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x6c, 0x69, 0x74, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 973 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x6f, 0x70, 0x69, 0x63, 0x52, 974 0x05, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x12, 0x60, 0x0a, 0x0f, 0x64, 0x65, 0x6c, 0x69, 0x76, 0x65, 975 0x72, 0x79, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 976 0x37, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x70, 977 0x75, 0x62, 0x73, 0x75, 0x62, 0x6c, 0x69, 0x74, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x75, 0x62, 978 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x44, 0x65, 0x6c, 0x69, 0x76, 0x65, 979 0x72, 0x79, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x0e, 0x64, 0x65, 0x6c, 0x69, 0x76, 0x65, 980 0x72, 0x79, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x1a, 0x80, 0x02, 0x0a, 0x0e, 0x44, 0x65, 0x6c, 981 0x69, 0x76, 0x65, 0x72, 0x79, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x7e, 0x0a, 0x14, 0x64, 982 0x65, 0x6c, 0x69, 0x76, 0x65, 0x72, 0x79, 0x5f, 0x72, 0x65, 0x71, 0x75, 0x69, 0x72, 0x65, 0x6d, 983 0x65, 0x6e, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x4b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 984 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x6c, 985 0x69, 0x74, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 986 0x69, 0x6f, 0x6e, 0x2e, 0x44, 0x65, 0x6c, 0x69, 0x76, 0x65, 0x72, 0x79, 0x43, 0x6f, 0x6e, 0x66, 987 0x69, 0x67, 0x2e, 0x44, 0x65, 0x6c, 0x69, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x69, 988 0x72, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x52, 0x13, 0x64, 0x65, 0x6c, 0x69, 0x76, 0x65, 0x72, 0x79, 989 0x52, 0x65, 0x71, 0x75, 0x69, 0x72, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x22, 0x6e, 0x0a, 0x13, 0x44, 990 0x65, 0x6c, 0x69, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x69, 0x72, 0x65, 0x6d, 0x65, 991 0x6e, 0x74, 0x12, 0x24, 0x0a, 0x20, 0x44, 0x45, 0x4c, 0x49, 0x56, 0x45, 0x52, 0x59, 0x5f, 0x52, 992 0x45, 0x51, 0x55, 0x49, 0x52, 0x45, 0x4d, 0x45, 0x4e, 0x54, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 993 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x17, 0x0a, 0x13, 0x44, 0x45, 0x4c, 0x49, 994 0x56, 0x45, 0x52, 0x5f, 0x49, 0x4d, 0x4d, 0x45, 0x44, 0x49, 0x41, 0x54, 0x45, 0x4c, 0x59, 0x10, 995 0x01, 0x12, 0x18, 0x0a, 0x14, 0x44, 0x45, 0x4c, 0x49, 0x56, 0x45, 0x52, 0x5f, 0x41, 0x46, 0x54, 996 0x45, 0x52, 0x5f, 0x53, 0x54, 0x4f, 0x52, 0x45, 0x44, 0x10, 0x02, 0x3a, 0x71, 0xea, 0x41, 0x6e, 997 0x0a, 0x26, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x6c, 0x69, 0x74, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 998 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x53, 0x75, 0x62, 0x73, 999 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x44, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 1000 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f, 0x6c, 0x6f, 0x63, 1001 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 1002 0x7d, 0x2f, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 1003 0x7b, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x22, 0x92, 1004 0x01, 0x0a, 0x0a, 0x54, 0x69, 0x6d, 0x65, 0x54, 0x61, 0x72, 0x67, 0x65, 0x74, 0x12, 0x3f, 0x0a, 1005 0x0c, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x01, 0x20, 1006 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 1007 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x48, 1008 0x00, 0x52, 0x0b, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x3b, 1009 0x0a, 0x0a, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 1010 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 1011 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x48, 0x00, 1012 0x52, 0x09, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x42, 0x06, 0x0a, 0x04, 0x74, 1013 0x69, 0x6d, 0x65, 0x42, 0xd5, 0x01, 0x0a, 0x21, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 1014 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x6c, 1015 0x69, 0x74, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x42, 0x0b, 0x43, 0x6f, 0x6d, 0x6d, 0x6f, 1016 0x6e, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x44, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 1017 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 1018 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 1019 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x6c, 0x69, 0x74, 0x65, 1020 0x2f, 0x76, 0x31, 0x3b, 0x70, 0x75, 0x62, 0x73, 0x75, 0x62, 0x6c, 0x69, 0x74, 0x65, 0xf8, 0x01, 1021 0x01, 0xaa, 0x02, 0x1a, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 1022 0x2e, 0x50, 0x75, 0x62, 0x53, 0x75, 0x62, 0x4c, 0x69, 0x74, 0x65, 0x2e, 0x56, 0x31, 0xca, 0x02, 1023 0x1a, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x5c, 0x50, 0x75, 1024 0x62, 0x53, 0x75, 0x62, 0x4c, 0x69, 0x74, 0x65, 0x5c, 0x56, 0x31, 0xea, 0x02, 0x1d, 0x47, 0x6f, 1025 0x6f, 0x67, 0x6c, 0x65, 0x3a, 0x3a, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x3a, 0x3a, 0x50, 0x75, 0x62, 1026 0x53, 0x75, 0x62, 0x4c, 0x69, 0x74, 0x65, 0x3a, 0x3a, 0x56, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 1027 0x74, 0x6f, 0x33, 1028} 1029 1030var ( 1031 file_google_cloud_pubsublite_v1_common_proto_rawDescOnce sync.Once 1032 file_google_cloud_pubsublite_v1_common_proto_rawDescData = file_google_cloud_pubsublite_v1_common_proto_rawDesc 1033) 1034 1035func file_google_cloud_pubsublite_v1_common_proto_rawDescGZIP() []byte { 1036 file_google_cloud_pubsublite_v1_common_proto_rawDescOnce.Do(func() { 1037 file_google_cloud_pubsublite_v1_common_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_pubsublite_v1_common_proto_rawDescData) 1038 }) 1039 return file_google_cloud_pubsublite_v1_common_proto_rawDescData 1040} 1041 1042var file_google_cloud_pubsublite_v1_common_proto_enumTypes = make([]protoimpl.EnumInfo, 1) 1043var file_google_cloud_pubsublite_v1_common_proto_msgTypes = make([]protoimpl.MessageInfo, 12) 1044var file_google_cloud_pubsublite_v1_common_proto_goTypes = []interface{}{ 1045 (Subscription_DeliveryConfig_DeliveryRequirement)(0), // 0: google.cloud.pubsublite.v1.Subscription.DeliveryConfig.DeliveryRequirement 1046 (*AttributeValues)(nil), // 1: google.cloud.pubsublite.v1.AttributeValues 1047 (*PubSubMessage)(nil), // 2: google.cloud.pubsublite.v1.PubSubMessage 1048 (*Cursor)(nil), // 3: google.cloud.pubsublite.v1.Cursor 1049 (*SequencedMessage)(nil), // 4: google.cloud.pubsublite.v1.SequencedMessage 1050 (*Topic)(nil), // 5: google.cloud.pubsublite.v1.Topic 1051 (*Subscription)(nil), // 6: google.cloud.pubsublite.v1.Subscription 1052 (*TimeTarget)(nil), // 7: google.cloud.pubsublite.v1.TimeTarget 1053 nil, // 8: google.cloud.pubsublite.v1.PubSubMessage.AttributesEntry 1054 (*Topic_PartitionConfig)(nil), // 9: google.cloud.pubsublite.v1.Topic.PartitionConfig 1055 (*Topic_RetentionConfig)(nil), // 10: google.cloud.pubsublite.v1.Topic.RetentionConfig 1056 (*Topic_PartitionConfig_Capacity)(nil), // 11: google.cloud.pubsublite.v1.Topic.PartitionConfig.Capacity 1057 (*Subscription_DeliveryConfig)(nil), // 12: google.cloud.pubsublite.v1.Subscription.DeliveryConfig 1058 (*timestamppb.Timestamp)(nil), // 13: google.protobuf.Timestamp 1059 (*durationpb.Duration)(nil), // 14: google.protobuf.Duration 1060} 1061var file_google_cloud_pubsublite_v1_common_proto_depIdxs = []int32{ 1062 8, // 0: google.cloud.pubsublite.v1.PubSubMessage.attributes:type_name -> google.cloud.pubsublite.v1.PubSubMessage.AttributesEntry 1063 13, // 1: google.cloud.pubsublite.v1.PubSubMessage.event_time:type_name -> google.protobuf.Timestamp 1064 3, // 2: google.cloud.pubsublite.v1.SequencedMessage.cursor:type_name -> google.cloud.pubsublite.v1.Cursor 1065 13, // 3: google.cloud.pubsublite.v1.SequencedMessage.publish_time:type_name -> google.protobuf.Timestamp 1066 2, // 4: google.cloud.pubsublite.v1.SequencedMessage.message:type_name -> google.cloud.pubsublite.v1.PubSubMessage 1067 9, // 5: google.cloud.pubsublite.v1.Topic.partition_config:type_name -> google.cloud.pubsublite.v1.Topic.PartitionConfig 1068 10, // 6: google.cloud.pubsublite.v1.Topic.retention_config:type_name -> google.cloud.pubsublite.v1.Topic.RetentionConfig 1069 12, // 7: google.cloud.pubsublite.v1.Subscription.delivery_config:type_name -> google.cloud.pubsublite.v1.Subscription.DeliveryConfig 1070 13, // 8: google.cloud.pubsublite.v1.TimeTarget.publish_time:type_name -> google.protobuf.Timestamp 1071 13, // 9: google.cloud.pubsublite.v1.TimeTarget.event_time:type_name -> google.protobuf.Timestamp 1072 1, // 10: google.cloud.pubsublite.v1.PubSubMessage.AttributesEntry.value:type_name -> google.cloud.pubsublite.v1.AttributeValues 1073 11, // 11: google.cloud.pubsublite.v1.Topic.PartitionConfig.capacity:type_name -> google.cloud.pubsublite.v1.Topic.PartitionConfig.Capacity 1074 14, // 12: google.cloud.pubsublite.v1.Topic.RetentionConfig.period:type_name -> google.protobuf.Duration 1075 0, // 13: google.cloud.pubsublite.v1.Subscription.DeliveryConfig.delivery_requirement:type_name -> google.cloud.pubsublite.v1.Subscription.DeliveryConfig.DeliveryRequirement 1076 14, // [14:14] is the sub-list for method output_type 1077 14, // [14:14] is the sub-list for method input_type 1078 14, // [14:14] is the sub-list for extension type_name 1079 14, // [14:14] is the sub-list for extension extendee 1080 0, // [0:14] is the sub-list for field type_name 1081} 1082 1083func init() { file_google_cloud_pubsublite_v1_common_proto_init() } 1084func file_google_cloud_pubsublite_v1_common_proto_init() { 1085 if File_google_cloud_pubsublite_v1_common_proto != nil { 1086 return 1087 } 1088 if !protoimpl.UnsafeEnabled { 1089 file_google_cloud_pubsublite_v1_common_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 1090 switch v := v.(*AttributeValues); i { 1091 case 0: 1092 return &v.state 1093 case 1: 1094 return &v.sizeCache 1095 case 2: 1096 return &v.unknownFields 1097 default: 1098 return nil 1099 } 1100 } 1101 file_google_cloud_pubsublite_v1_common_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 1102 switch v := v.(*PubSubMessage); i { 1103 case 0: 1104 return &v.state 1105 case 1: 1106 return &v.sizeCache 1107 case 2: 1108 return &v.unknownFields 1109 default: 1110 return nil 1111 } 1112 } 1113 file_google_cloud_pubsublite_v1_common_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 1114 switch v := v.(*Cursor); i { 1115 case 0: 1116 return &v.state 1117 case 1: 1118 return &v.sizeCache 1119 case 2: 1120 return &v.unknownFields 1121 default: 1122 return nil 1123 } 1124 } 1125 file_google_cloud_pubsublite_v1_common_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 1126 switch v := v.(*SequencedMessage); i { 1127 case 0: 1128 return &v.state 1129 case 1: 1130 return &v.sizeCache 1131 case 2: 1132 return &v.unknownFields 1133 default: 1134 return nil 1135 } 1136 } 1137 file_google_cloud_pubsublite_v1_common_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { 1138 switch v := v.(*Topic); i { 1139 case 0: 1140 return &v.state 1141 case 1: 1142 return &v.sizeCache 1143 case 2: 1144 return &v.unknownFields 1145 default: 1146 return nil 1147 } 1148 } 1149 file_google_cloud_pubsublite_v1_common_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { 1150 switch v := v.(*Subscription); i { 1151 case 0: 1152 return &v.state 1153 case 1: 1154 return &v.sizeCache 1155 case 2: 1156 return &v.unknownFields 1157 default: 1158 return nil 1159 } 1160 } 1161 file_google_cloud_pubsublite_v1_common_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { 1162 switch v := v.(*TimeTarget); i { 1163 case 0: 1164 return &v.state 1165 case 1: 1166 return &v.sizeCache 1167 case 2: 1168 return &v.unknownFields 1169 default: 1170 return nil 1171 } 1172 } 1173 file_google_cloud_pubsublite_v1_common_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { 1174 switch v := v.(*Topic_PartitionConfig); i { 1175 case 0: 1176 return &v.state 1177 case 1: 1178 return &v.sizeCache 1179 case 2: 1180 return &v.unknownFields 1181 default: 1182 return nil 1183 } 1184 } 1185 file_google_cloud_pubsublite_v1_common_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { 1186 switch v := v.(*Topic_RetentionConfig); i { 1187 case 0: 1188 return &v.state 1189 case 1: 1190 return &v.sizeCache 1191 case 2: 1192 return &v.unknownFields 1193 default: 1194 return nil 1195 } 1196 } 1197 file_google_cloud_pubsublite_v1_common_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { 1198 switch v := v.(*Topic_PartitionConfig_Capacity); i { 1199 case 0: 1200 return &v.state 1201 case 1: 1202 return &v.sizeCache 1203 case 2: 1204 return &v.unknownFields 1205 default: 1206 return nil 1207 } 1208 } 1209 file_google_cloud_pubsublite_v1_common_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { 1210 switch v := v.(*Subscription_DeliveryConfig); i { 1211 case 0: 1212 return &v.state 1213 case 1: 1214 return &v.sizeCache 1215 case 2: 1216 return &v.unknownFields 1217 default: 1218 return nil 1219 } 1220 } 1221 } 1222 file_google_cloud_pubsublite_v1_common_proto_msgTypes[6].OneofWrappers = []interface{}{ 1223 (*TimeTarget_PublishTime)(nil), 1224 (*TimeTarget_EventTime)(nil), 1225 } 1226 file_google_cloud_pubsublite_v1_common_proto_msgTypes[8].OneofWrappers = []interface{}{ 1227 (*Topic_PartitionConfig_Scale)(nil), 1228 (*Topic_PartitionConfig_Capacity_)(nil), 1229 } 1230 type x struct{} 1231 out := protoimpl.TypeBuilder{ 1232 File: protoimpl.DescBuilder{ 1233 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 1234 RawDescriptor: file_google_cloud_pubsublite_v1_common_proto_rawDesc, 1235 NumEnums: 1, 1236 NumMessages: 12, 1237 NumExtensions: 0, 1238 NumServices: 0, 1239 }, 1240 GoTypes: file_google_cloud_pubsublite_v1_common_proto_goTypes, 1241 DependencyIndexes: file_google_cloud_pubsublite_v1_common_proto_depIdxs, 1242 EnumInfos: file_google_cloud_pubsublite_v1_common_proto_enumTypes, 1243 MessageInfos: file_google_cloud_pubsublite_v1_common_proto_msgTypes, 1244 }.Build() 1245 File_google_cloud_pubsublite_v1_common_proto = out.File 1246 file_google_cloud_pubsublite_v1_common_proto_rawDesc = nil 1247 file_google_cloud_pubsublite_v1_common_proto_goTypes = nil 1248 file_google_cloud_pubsublite_v1_common_proto_depIdxs = nil 1249} 1250