1 /* 2 * Copyright 2020 Google LLC 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * https://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 // Generated by the protocol buffer compiler. DO NOT EDIT! 17 // source: google/cloud/scheduler/v1/target.proto 18 19 package com.google.cloud.scheduler.v1; 20 21 /** 22 * 23 * 24 * <pre> 25 * Pub/Sub target. The job will be delivered by publishing a message to 26 * the given Pub/Sub topic. 27 * </pre> 28 * 29 * Protobuf type {@code google.cloud.scheduler.v1.PubsubTarget} 30 */ 31 public final class PubsubTarget extends com.google.protobuf.GeneratedMessageV3 32 implements 33 // @@protoc_insertion_point(message_implements:google.cloud.scheduler.v1.PubsubTarget) 34 PubsubTargetOrBuilder { 35 private static final long serialVersionUID = 0L; 36 // Use PubsubTarget.newBuilder() to construct. PubsubTarget(com.google.protobuf.GeneratedMessageV3.Builder<?> builder)37 private PubsubTarget(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { 38 super(builder); 39 } 40 PubsubTarget()41 private PubsubTarget() { 42 topicName_ = ""; 43 data_ = com.google.protobuf.ByteString.EMPTY; 44 } 45 46 @java.lang.Override 47 @SuppressWarnings({"unused"}) newInstance(UnusedPrivateParameter unused)48 protected java.lang.Object newInstance(UnusedPrivateParameter unused) { 49 return new PubsubTarget(); 50 } 51 52 @java.lang.Override getUnknownFields()53 public final com.google.protobuf.UnknownFieldSet getUnknownFields() { 54 return this.unknownFields; 55 } 56 getDescriptor()57 public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() { 58 return com.google.cloud.scheduler.v1.TargetProto 59 .internal_static_google_cloud_scheduler_v1_PubsubTarget_descriptor; 60 } 61 62 @SuppressWarnings({"rawtypes"}) 63 @java.lang.Override internalGetMapField(int number)64 protected com.google.protobuf.MapField internalGetMapField(int number) { 65 switch (number) { 66 case 4: 67 return internalGetAttributes(); 68 default: 69 throw new RuntimeException("Invalid map field number: " + number); 70 } 71 } 72 73 @java.lang.Override 74 protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()75 internalGetFieldAccessorTable() { 76 return com.google.cloud.scheduler.v1.TargetProto 77 .internal_static_google_cloud_scheduler_v1_PubsubTarget_fieldAccessorTable 78 .ensureFieldAccessorsInitialized( 79 com.google.cloud.scheduler.v1.PubsubTarget.class, 80 com.google.cloud.scheduler.v1.PubsubTarget.Builder.class); 81 } 82 83 public static final int TOPIC_NAME_FIELD_NUMBER = 1; 84 85 @SuppressWarnings("serial") 86 private volatile java.lang.Object topicName_ = ""; 87 /** 88 * 89 * 90 * <pre> 91 * Required. The name of the Cloud Pub/Sub topic to which messages will 92 * be published when a job is delivered. The topic name must be in the 93 * same format as required by Pub/Sub's 94 * [PublishRequest.name](https://cloud.google.com/pubsub/docs/reference/rpc/google.pubsub.v1#publishrequest), 95 * for example `projects/PROJECT_ID/topics/TOPIC_ID`. 96 * The topic must be in the same project as the Cloud Scheduler job. 97 * </pre> 98 * 99 * <code>string topic_name = 1 [(.google.api.resource_reference) = { ... }</code> 100 * 101 * @return The topicName. 102 */ 103 @java.lang.Override getTopicName()104 public java.lang.String getTopicName() { 105 java.lang.Object ref = topicName_; 106 if (ref instanceof java.lang.String) { 107 return (java.lang.String) ref; 108 } else { 109 com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref; 110 java.lang.String s = bs.toStringUtf8(); 111 topicName_ = s; 112 return s; 113 } 114 } 115 /** 116 * 117 * 118 * <pre> 119 * Required. The name of the Cloud Pub/Sub topic to which messages will 120 * be published when a job is delivered. The topic name must be in the 121 * same format as required by Pub/Sub's 122 * [PublishRequest.name](https://cloud.google.com/pubsub/docs/reference/rpc/google.pubsub.v1#publishrequest), 123 * for example `projects/PROJECT_ID/topics/TOPIC_ID`. 124 * The topic must be in the same project as the Cloud Scheduler job. 125 * </pre> 126 * 127 * <code>string topic_name = 1 [(.google.api.resource_reference) = { ... }</code> 128 * 129 * @return The bytes for topicName. 130 */ 131 @java.lang.Override getTopicNameBytes()132 public com.google.protobuf.ByteString getTopicNameBytes() { 133 java.lang.Object ref = topicName_; 134 if (ref instanceof java.lang.String) { 135 com.google.protobuf.ByteString b = 136 com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref); 137 topicName_ = b; 138 return b; 139 } else { 140 return (com.google.protobuf.ByteString) ref; 141 } 142 } 143 144 public static final int DATA_FIELD_NUMBER = 3; 145 private com.google.protobuf.ByteString data_ = com.google.protobuf.ByteString.EMPTY; 146 /** 147 * 148 * 149 * <pre> 150 * The message payload for PubsubMessage. 151 * Pubsub message must contain either non-empty data, or at least one 152 * attribute. 153 * </pre> 154 * 155 * <code>bytes data = 3;</code> 156 * 157 * @return The data. 158 */ 159 @java.lang.Override getData()160 public com.google.protobuf.ByteString getData() { 161 return data_; 162 } 163 164 public static final int ATTRIBUTES_FIELD_NUMBER = 4; 165 166 private static final class AttributesDefaultEntryHolder { 167 static final com.google.protobuf.MapEntry<java.lang.String, java.lang.String> defaultEntry = 168 com.google.protobuf.MapEntry.<java.lang.String, java.lang.String>newDefaultInstance( 169 com.google.cloud.scheduler.v1.TargetProto 170 .internal_static_google_cloud_scheduler_v1_PubsubTarget_AttributesEntry_descriptor, 171 com.google.protobuf.WireFormat.FieldType.STRING, 172 "", 173 com.google.protobuf.WireFormat.FieldType.STRING, 174 ""); 175 } 176 177 @SuppressWarnings("serial") 178 private com.google.protobuf.MapField<java.lang.String, java.lang.String> attributes_; 179 internalGetAttributes()180 private com.google.protobuf.MapField<java.lang.String, java.lang.String> internalGetAttributes() { 181 if (attributes_ == null) { 182 return com.google.protobuf.MapField.emptyMapField(AttributesDefaultEntryHolder.defaultEntry); 183 } 184 return attributes_; 185 } 186 getAttributesCount()187 public int getAttributesCount() { 188 return internalGetAttributes().getMap().size(); 189 } 190 /** 191 * 192 * 193 * <pre> 194 * Attributes for PubsubMessage. 195 * Pubsub message must contain either non-empty data, or at least one 196 * attribute. 197 * </pre> 198 * 199 * <code>map<string, string> attributes = 4;</code> 200 */ 201 @java.lang.Override containsAttributes(java.lang.String key)202 public boolean containsAttributes(java.lang.String key) { 203 if (key == null) { 204 throw new NullPointerException("map key"); 205 } 206 return internalGetAttributes().getMap().containsKey(key); 207 } 208 /** Use {@link #getAttributesMap()} instead. */ 209 @java.lang.Override 210 @java.lang.Deprecated getAttributes()211 public java.util.Map<java.lang.String, java.lang.String> getAttributes() { 212 return getAttributesMap(); 213 } 214 /** 215 * 216 * 217 * <pre> 218 * Attributes for PubsubMessage. 219 * Pubsub message must contain either non-empty data, or at least one 220 * attribute. 221 * </pre> 222 * 223 * <code>map<string, string> attributes = 4;</code> 224 */ 225 @java.lang.Override getAttributesMap()226 public java.util.Map<java.lang.String, java.lang.String> getAttributesMap() { 227 return internalGetAttributes().getMap(); 228 } 229 /** 230 * 231 * 232 * <pre> 233 * Attributes for PubsubMessage. 234 * Pubsub message must contain either non-empty data, or at least one 235 * attribute. 236 * </pre> 237 * 238 * <code>map<string, string> attributes = 4;</code> 239 */ 240 @java.lang.Override getAttributesOrDefault( java.lang.String key, java.lang.String defaultValue)241 public /* nullable */ java.lang.String getAttributesOrDefault( 242 java.lang.String key, 243 /* nullable */ 244 java.lang.String defaultValue) { 245 if (key == null) { 246 throw new NullPointerException("map key"); 247 } 248 java.util.Map<java.lang.String, java.lang.String> map = internalGetAttributes().getMap(); 249 return map.containsKey(key) ? map.get(key) : defaultValue; 250 } 251 /** 252 * 253 * 254 * <pre> 255 * Attributes for PubsubMessage. 256 * Pubsub message must contain either non-empty data, or at least one 257 * attribute. 258 * </pre> 259 * 260 * <code>map<string, string> attributes = 4;</code> 261 */ 262 @java.lang.Override getAttributesOrThrow(java.lang.String key)263 public java.lang.String getAttributesOrThrow(java.lang.String key) { 264 if (key == null) { 265 throw new NullPointerException("map key"); 266 } 267 java.util.Map<java.lang.String, java.lang.String> map = internalGetAttributes().getMap(); 268 if (!map.containsKey(key)) { 269 throw new java.lang.IllegalArgumentException(); 270 } 271 return map.get(key); 272 } 273 274 private byte memoizedIsInitialized = -1; 275 276 @java.lang.Override isInitialized()277 public final boolean isInitialized() { 278 byte isInitialized = memoizedIsInitialized; 279 if (isInitialized == 1) return true; 280 if (isInitialized == 0) return false; 281 282 memoizedIsInitialized = 1; 283 return true; 284 } 285 286 @java.lang.Override writeTo(com.google.protobuf.CodedOutputStream output)287 public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException { 288 if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(topicName_)) { 289 com.google.protobuf.GeneratedMessageV3.writeString(output, 1, topicName_); 290 } 291 if (!data_.isEmpty()) { 292 output.writeBytes(3, data_); 293 } 294 com.google.protobuf.GeneratedMessageV3.serializeStringMapTo( 295 output, internalGetAttributes(), AttributesDefaultEntryHolder.defaultEntry, 4); 296 getUnknownFields().writeTo(output); 297 } 298 299 @java.lang.Override getSerializedSize()300 public int getSerializedSize() { 301 int size = memoizedSize; 302 if (size != -1) return size; 303 304 size = 0; 305 if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(topicName_)) { 306 size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, topicName_); 307 } 308 if (!data_.isEmpty()) { 309 size += com.google.protobuf.CodedOutputStream.computeBytesSize(3, data_); 310 } 311 for (java.util.Map.Entry<java.lang.String, java.lang.String> entry : 312 internalGetAttributes().getMap().entrySet()) { 313 com.google.protobuf.MapEntry<java.lang.String, java.lang.String> attributes__ = 314 AttributesDefaultEntryHolder.defaultEntry 315 .newBuilderForType() 316 .setKey(entry.getKey()) 317 .setValue(entry.getValue()) 318 .build(); 319 size += com.google.protobuf.CodedOutputStream.computeMessageSize(4, attributes__); 320 } 321 size += getUnknownFields().getSerializedSize(); 322 memoizedSize = size; 323 return size; 324 } 325 326 @java.lang.Override equals(final java.lang.Object obj)327 public boolean equals(final java.lang.Object obj) { 328 if (obj == this) { 329 return true; 330 } 331 if (!(obj instanceof com.google.cloud.scheduler.v1.PubsubTarget)) { 332 return super.equals(obj); 333 } 334 com.google.cloud.scheduler.v1.PubsubTarget other = 335 (com.google.cloud.scheduler.v1.PubsubTarget) obj; 336 337 if (!getTopicName().equals(other.getTopicName())) return false; 338 if (!getData().equals(other.getData())) return false; 339 if (!internalGetAttributes().equals(other.internalGetAttributes())) return false; 340 if (!getUnknownFields().equals(other.getUnknownFields())) return false; 341 return true; 342 } 343 344 @java.lang.Override hashCode()345 public int hashCode() { 346 if (memoizedHashCode != 0) { 347 return memoizedHashCode; 348 } 349 int hash = 41; 350 hash = (19 * hash) + getDescriptor().hashCode(); 351 hash = (37 * hash) + TOPIC_NAME_FIELD_NUMBER; 352 hash = (53 * hash) + getTopicName().hashCode(); 353 hash = (37 * hash) + DATA_FIELD_NUMBER; 354 hash = (53 * hash) + getData().hashCode(); 355 if (!internalGetAttributes().getMap().isEmpty()) { 356 hash = (37 * hash) + ATTRIBUTES_FIELD_NUMBER; 357 hash = (53 * hash) + internalGetAttributes().hashCode(); 358 } 359 hash = (29 * hash) + getUnknownFields().hashCode(); 360 memoizedHashCode = hash; 361 return hash; 362 } 363 parseFrom(java.nio.ByteBuffer data)364 public static com.google.cloud.scheduler.v1.PubsubTarget parseFrom(java.nio.ByteBuffer data) 365 throws com.google.protobuf.InvalidProtocolBufferException { 366 return PARSER.parseFrom(data); 367 } 368 parseFrom( java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)369 public static com.google.cloud.scheduler.v1.PubsubTarget parseFrom( 370 java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) 371 throws com.google.protobuf.InvalidProtocolBufferException { 372 return PARSER.parseFrom(data, extensionRegistry); 373 } 374 parseFrom( com.google.protobuf.ByteString data)375 public static com.google.cloud.scheduler.v1.PubsubTarget parseFrom( 376 com.google.protobuf.ByteString data) 377 throws com.google.protobuf.InvalidProtocolBufferException { 378 return PARSER.parseFrom(data); 379 } 380 parseFrom( com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)381 public static com.google.cloud.scheduler.v1.PubsubTarget parseFrom( 382 com.google.protobuf.ByteString data, 383 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 384 throws com.google.protobuf.InvalidProtocolBufferException { 385 return PARSER.parseFrom(data, extensionRegistry); 386 } 387 parseFrom(byte[] data)388 public static com.google.cloud.scheduler.v1.PubsubTarget parseFrom(byte[] data) 389 throws com.google.protobuf.InvalidProtocolBufferException { 390 return PARSER.parseFrom(data); 391 } 392 parseFrom( byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)393 public static com.google.cloud.scheduler.v1.PubsubTarget parseFrom( 394 byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) 395 throws com.google.protobuf.InvalidProtocolBufferException { 396 return PARSER.parseFrom(data, extensionRegistry); 397 } 398 parseFrom(java.io.InputStream input)399 public static com.google.cloud.scheduler.v1.PubsubTarget parseFrom(java.io.InputStream input) 400 throws java.io.IOException { 401 return com.google.protobuf.GeneratedMessageV3.parseWithIOException(PARSER, input); 402 } 403 parseFrom( java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)404 public static com.google.cloud.scheduler.v1.PubsubTarget parseFrom( 405 java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) 406 throws java.io.IOException { 407 return com.google.protobuf.GeneratedMessageV3.parseWithIOException( 408 PARSER, input, extensionRegistry); 409 } 410 parseDelimitedFrom( java.io.InputStream input)411 public static com.google.cloud.scheduler.v1.PubsubTarget parseDelimitedFrom( 412 java.io.InputStream input) throws java.io.IOException { 413 return com.google.protobuf.GeneratedMessageV3.parseDelimitedWithIOException(PARSER, input); 414 } 415 parseDelimitedFrom( java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)416 public static com.google.cloud.scheduler.v1.PubsubTarget parseDelimitedFrom( 417 java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) 418 throws java.io.IOException { 419 return com.google.protobuf.GeneratedMessageV3.parseDelimitedWithIOException( 420 PARSER, input, extensionRegistry); 421 } 422 parseFrom( com.google.protobuf.CodedInputStream input)423 public static com.google.cloud.scheduler.v1.PubsubTarget parseFrom( 424 com.google.protobuf.CodedInputStream input) throws java.io.IOException { 425 return com.google.protobuf.GeneratedMessageV3.parseWithIOException(PARSER, input); 426 } 427 parseFrom( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)428 public static com.google.cloud.scheduler.v1.PubsubTarget parseFrom( 429 com.google.protobuf.CodedInputStream input, 430 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 431 throws java.io.IOException { 432 return com.google.protobuf.GeneratedMessageV3.parseWithIOException( 433 PARSER, input, extensionRegistry); 434 } 435 436 @java.lang.Override newBuilderForType()437 public Builder newBuilderForType() { 438 return newBuilder(); 439 } 440 newBuilder()441 public static Builder newBuilder() { 442 return DEFAULT_INSTANCE.toBuilder(); 443 } 444 newBuilder(com.google.cloud.scheduler.v1.PubsubTarget prototype)445 public static Builder newBuilder(com.google.cloud.scheduler.v1.PubsubTarget prototype) { 446 return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); 447 } 448 449 @java.lang.Override toBuilder()450 public Builder toBuilder() { 451 return this == DEFAULT_INSTANCE ? new Builder() : new Builder().mergeFrom(this); 452 } 453 454 @java.lang.Override newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)455 protected Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { 456 Builder builder = new Builder(parent); 457 return builder; 458 } 459 /** 460 * 461 * 462 * <pre> 463 * Pub/Sub target. The job will be delivered by publishing a message to 464 * the given Pub/Sub topic. 465 * </pre> 466 * 467 * Protobuf type {@code google.cloud.scheduler.v1.PubsubTarget} 468 */ 469 public static final class Builder extends com.google.protobuf.GeneratedMessageV3.Builder<Builder> 470 implements 471 // @@protoc_insertion_point(builder_implements:google.cloud.scheduler.v1.PubsubTarget) 472 com.google.cloud.scheduler.v1.PubsubTargetOrBuilder { getDescriptor()473 public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() { 474 return com.google.cloud.scheduler.v1.TargetProto 475 .internal_static_google_cloud_scheduler_v1_PubsubTarget_descriptor; 476 } 477 478 @SuppressWarnings({"rawtypes"}) internalGetMapField(int number)479 protected com.google.protobuf.MapField internalGetMapField(int number) { 480 switch (number) { 481 case 4: 482 return internalGetAttributes(); 483 default: 484 throw new RuntimeException("Invalid map field number: " + number); 485 } 486 } 487 488 @SuppressWarnings({"rawtypes"}) internalGetMutableMapField(int number)489 protected com.google.protobuf.MapField internalGetMutableMapField(int number) { 490 switch (number) { 491 case 4: 492 return internalGetMutableAttributes(); 493 default: 494 throw new RuntimeException("Invalid map field number: " + number); 495 } 496 } 497 498 @java.lang.Override 499 protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()500 internalGetFieldAccessorTable() { 501 return com.google.cloud.scheduler.v1.TargetProto 502 .internal_static_google_cloud_scheduler_v1_PubsubTarget_fieldAccessorTable 503 .ensureFieldAccessorsInitialized( 504 com.google.cloud.scheduler.v1.PubsubTarget.class, 505 com.google.cloud.scheduler.v1.PubsubTarget.Builder.class); 506 } 507 508 // Construct using com.google.cloud.scheduler.v1.PubsubTarget.newBuilder() Builder()509 private Builder() {} 510 Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)511 private Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { 512 super(parent); 513 } 514 515 @java.lang.Override clear()516 public Builder clear() { 517 super.clear(); 518 bitField0_ = 0; 519 topicName_ = ""; 520 data_ = com.google.protobuf.ByteString.EMPTY; 521 internalGetMutableAttributes().clear(); 522 return this; 523 } 524 525 @java.lang.Override getDescriptorForType()526 public com.google.protobuf.Descriptors.Descriptor getDescriptorForType() { 527 return com.google.cloud.scheduler.v1.TargetProto 528 .internal_static_google_cloud_scheduler_v1_PubsubTarget_descriptor; 529 } 530 531 @java.lang.Override getDefaultInstanceForType()532 public com.google.cloud.scheduler.v1.PubsubTarget getDefaultInstanceForType() { 533 return com.google.cloud.scheduler.v1.PubsubTarget.getDefaultInstance(); 534 } 535 536 @java.lang.Override build()537 public com.google.cloud.scheduler.v1.PubsubTarget build() { 538 com.google.cloud.scheduler.v1.PubsubTarget result = buildPartial(); 539 if (!result.isInitialized()) { 540 throw newUninitializedMessageException(result); 541 } 542 return result; 543 } 544 545 @java.lang.Override buildPartial()546 public com.google.cloud.scheduler.v1.PubsubTarget buildPartial() { 547 com.google.cloud.scheduler.v1.PubsubTarget result = 548 new com.google.cloud.scheduler.v1.PubsubTarget(this); 549 if (bitField0_ != 0) { 550 buildPartial0(result); 551 } 552 onBuilt(); 553 return result; 554 } 555 buildPartial0(com.google.cloud.scheduler.v1.PubsubTarget result)556 private void buildPartial0(com.google.cloud.scheduler.v1.PubsubTarget result) { 557 int from_bitField0_ = bitField0_; 558 if (((from_bitField0_ & 0x00000001) != 0)) { 559 result.topicName_ = topicName_; 560 } 561 if (((from_bitField0_ & 0x00000002) != 0)) { 562 result.data_ = data_; 563 } 564 if (((from_bitField0_ & 0x00000004) != 0)) { 565 result.attributes_ = internalGetAttributes(); 566 result.attributes_.makeImmutable(); 567 } 568 } 569 570 @java.lang.Override clone()571 public Builder clone() { 572 return super.clone(); 573 } 574 575 @java.lang.Override setField( com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value)576 public Builder setField( 577 com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) { 578 return super.setField(field, value); 579 } 580 581 @java.lang.Override clearField(com.google.protobuf.Descriptors.FieldDescriptor field)582 public Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) { 583 return super.clearField(field); 584 } 585 586 @java.lang.Override clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)587 public Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) { 588 return super.clearOneof(oneof); 589 } 590 591 @java.lang.Override setRepeatedField( com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value)592 public Builder setRepeatedField( 593 com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value) { 594 return super.setRepeatedField(field, index, value); 595 } 596 597 @java.lang.Override addRepeatedField( com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value)598 public Builder addRepeatedField( 599 com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) { 600 return super.addRepeatedField(field, value); 601 } 602 603 @java.lang.Override mergeFrom(com.google.protobuf.Message other)604 public Builder mergeFrom(com.google.protobuf.Message other) { 605 if (other instanceof com.google.cloud.scheduler.v1.PubsubTarget) { 606 return mergeFrom((com.google.cloud.scheduler.v1.PubsubTarget) other); 607 } else { 608 super.mergeFrom(other); 609 return this; 610 } 611 } 612 mergeFrom(com.google.cloud.scheduler.v1.PubsubTarget other)613 public Builder mergeFrom(com.google.cloud.scheduler.v1.PubsubTarget other) { 614 if (other == com.google.cloud.scheduler.v1.PubsubTarget.getDefaultInstance()) return this; 615 if (!other.getTopicName().isEmpty()) { 616 topicName_ = other.topicName_; 617 bitField0_ |= 0x00000001; 618 onChanged(); 619 } 620 if (other.getData() != com.google.protobuf.ByteString.EMPTY) { 621 setData(other.getData()); 622 } 623 internalGetMutableAttributes().mergeFrom(other.internalGetAttributes()); 624 bitField0_ |= 0x00000004; 625 this.mergeUnknownFields(other.getUnknownFields()); 626 onChanged(); 627 return this; 628 } 629 630 @java.lang.Override isInitialized()631 public final boolean isInitialized() { 632 return true; 633 } 634 635 @java.lang.Override mergeFrom( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)636 public Builder mergeFrom( 637 com.google.protobuf.CodedInputStream input, 638 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 639 throws java.io.IOException { 640 if (extensionRegistry == null) { 641 throw new java.lang.NullPointerException(); 642 } 643 try { 644 boolean done = false; 645 while (!done) { 646 int tag = input.readTag(); 647 switch (tag) { 648 case 0: 649 done = true; 650 break; 651 case 10: 652 { 653 topicName_ = input.readStringRequireUtf8(); 654 bitField0_ |= 0x00000001; 655 break; 656 } // case 10 657 case 26: 658 { 659 data_ = input.readBytes(); 660 bitField0_ |= 0x00000002; 661 break; 662 } // case 26 663 case 34: 664 { 665 com.google.protobuf.MapEntry<java.lang.String, java.lang.String> attributes__ = 666 input.readMessage( 667 AttributesDefaultEntryHolder.defaultEntry.getParserForType(), 668 extensionRegistry); 669 internalGetMutableAttributes() 670 .getMutableMap() 671 .put(attributes__.getKey(), attributes__.getValue()); 672 bitField0_ |= 0x00000004; 673 break; 674 } // case 34 675 default: 676 { 677 if (!super.parseUnknownField(input, extensionRegistry, tag)) { 678 done = true; // was an endgroup tag 679 } 680 break; 681 } // default: 682 } // switch (tag) 683 } // while (!done) 684 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 685 throw e.unwrapIOException(); 686 } finally { 687 onChanged(); 688 } // finally 689 return this; 690 } 691 692 private int bitField0_; 693 694 private java.lang.Object topicName_ = ""; 695 /** 696 * 697 * 698 * <pre> 699 * Required. The name of the Cloud Pub/Sub topic to which messages will 700 * be published when a job is delivered. The topic name must be in the 701 * same format as required by Pub/Sub's 702 * [PublishRequest.name](https://cloud.google.com/pubsub/docs/reference/rpc/google.pubsub.v1#publishrequest), 703 * for example `projects/PROJECT_ID/topics/TOPIC_ID`. 704 * The topic must be in the same project as the Cloud Scheduler job. 705 * </pre> 706 * 707 * <code>string topic_name = 1 [(.google.api.resource_reference) = { ... }</code> 708 * 709 * @return The topicName. 710 */ getTopicName()711 public java.lang.String getTopicName() { 712 java.lang.Object ref = topicName_; 713 if (!(ref instanceof java.lang.String)) { 714 com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref; 715 java.lang.String s = bs.toStringUtf8(); 716 topicName_ = s; 717 return s; 718 } else { 719 return (java.lang.String) ref; 720 } 721 } 722 /** 723 * 724 * 725 * <pre> 726 * Required. The name of the Cloud Pub/Sub topic to which messages will 727 * be published when a job is delivered. The topic name must be in the 728 * same format as required by Pub/Sub's 729 * [PublishRequest.name](https://cloud.google.com/pubsub/docs/reference/rpc/google.pubsub.v1#publishrequest), 730 * for example `projects/PROJECT_ID/topics/TOPIC_ID`. 731 * The topic must be in the same project as the Cloud Scheduler job. 732 * </pre> 733 * 734 * <code>string topic_name = 1 [(.google.api.resource_reference) = { ... }</code> 735 * 736 * @return The bytes for topicName. 737 */ getTopicNameBytes()738 public com.google.protobuf.ByteString getTopicNameBytes() { 739 java.lang.Object ref = topicName_; 740 if (ref instanceof String) { 741 com.google.protobuf.ByteString b = 742 com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref); 743 topicName_ = b; 744 return b; 745 } else { 746 return (com.google.protobuf.ByteString) ref; 747 } 748 } 749 /** 750 * 751 * 752 * <pre> 753 * Required. The name of the Cloud Pub/Sub topic to which messages will 754 * be published when a job is delivered. The topic name must be in the 755 * same format as required by Pub/Sub's 756 * [PublishRequest.name](https://cloud.google.com/pubsub/docs/reference/rpc/google.pubsub.v1#publishrequest), 757 * for example `projects/PROJECT_ID/topics/TOPIC_ID`. 758 * The topic must be in the same project as the Cloud Scheduler job. 759 * </pre> 760 * 761 * <code>string topic_name = 1 [(.google.api.resource_reference) = { ... }</code> 762 * 763 * @param value The topicName to set. 764 * @return This builder for chaining. 765 */ setTopicName(java.lang.String value)766 public Builder setTopicName(java.lang.String value) { 767 if (value == null) { 768 throw new NullPointerException(); 769 } 770 topicName_ = value; 771 bitField0_ |= 0x00000001; 772 onChanged(); 773 return this; 774 } 775 /** 776 * 777 * 778 * <pre> 779 * Required. The name of the Cloud Pub/Sub topic to which messages will 780 * be published when a job is delivered. The topic name must be in the 781 * same format as required by Pub/Sub's 782 * [PublishRequest.name](https://cloud.google.com/pubsub/docs/reference/rpc/google.pubsub.v1#publishrequest), 783 * for example `projects/PROJECT_ID/topics/TOPIC_ID`. 784 * The topic must be in the same project as the Cloud Scheduler job. 785 * </pre> 786 * 787 * <code>string topic_name = 1 [(.google.api.resource_reference) = { ... }</code> 788 * 789 * @return This builder for chaining. 790 */ clearTopicName()791 public Builder clearTopicName() { 792 topicName_ = getDefaultInstance().getTopicName(); 793 bitField0_ = (bitField0_ & ~0x00000001); 794 onChanged(); 795 return this; 796 } 797 /** 798 * 799 * 800 * <pre> 801 * Required. The name of the Cloud Pub/Sub topic to which messages will 802 * be published when a job is delivered. The topic name must be in the 803 * same format as required by Pub/Sub's 804 * [PublishRequest.name](https://cloud.google.com/pubsub/docs/reference/rpc/google.pubsub.v1#publishrequest), 805 * for example `projects/PROJECT_ID/topics/TOPIC_ID`. 806 * The topic must be in the same project as the Cloud Scheduler job. 807 * </pre> 808 * 809 * <code>string topic_name = 1 [(.google.api.resource_reference) = { ... }</code> 810 * 811 * @param value The bytes for topicName to set. 812 * @return This builder for chaining. 813 */ setTopicNameBytes(com.google.protobuf.ByteString value)814 public Builder setTopicNameBytes(com.google.protobuf.ByteString value) { 815 if (value == null) { 816 throw new NullPointerException(); 817 } 818 checkByteStringIsUtf8(value); 819 topicName_ = value; 820 bitField0_ |= 0x00000001; 821 onChanged(); 822 return this; 823 } 824 825 private com.google.protobuf.ByteString data_ = com.google.protobuf.ByteString.EMPTY; 826 /** 827 * 828 * 829 * <pre> 830 * The message payload for PubsubMessage. 831 * Pubsub message must contain either non-empty data, or at least one 832 * attribute. 833 * </pre> 834 * 835 * <code>bytes data = 3;</code> 836 * 837 * @return The data. 838 */ 839 @java.lang.Override getData()840 public com.google.protobuf.ByteString getData() { 841 return data_; 842 } 843 /** 844 * 845 * 846 * <pre> 847 * The message payload for PubsubMessage. 848 * Pubsub message must contain either non-empty data, or at least one 849 * attribute. 850 * </pre> 851 * 852 * <code>bytes data = 3;</code> 853 * 854 * @param value The data to set. 855 * @return This builder for chaining. 856 */ setData(com.google.protobuf.ByteString value)857 public Builder setData(com.google.protobuf.ByteString value) { 858 if (value == null) { 859 throw new NullPointerException(); 860 } 861 data_ = value; 862 bitField0_ |= 0x00000002; 863 onChanged(); 864 return this; 865 } 866 /** 867 * 868 * 869 * <pre> 870 * The message payload for PubsubMessage. 871 * Pubsub message must contain either non-empty data, or at least one 872 * attribute. 873 * </pre> 874 * 875 * <code>bytes data = 3;</code> 876 * 877 * @return This builder for chaining. 878 */ clearData()879 public Builder clearData() { 880 bitField0_ = (bitField0_ & ~0x00000002); 881 data_ = getDefaultInstance().getData(); 882 onChanged(); 883 return this; 884 } 885 886 private com.google.protobuf.MapField<java.lang.String, java.lang.String> attributes_; 887 888 private com.google.protobuf.MapField<java.lang.String, java.lang.String> internalGetAttributes()889 internalGetAttributes() { 890 if (attributes_ == null) { 891 return com.google.protobuf.MapField.emptyMapField( 892 AttributesDefaultEntryHolder.defaultEntry); 893 } 894 return attributes_; 895 } 896 897 private com.google.protobuf.MapField<java.lang.String, java.lang.String> internalGetMutableAttributes()898 internalGetMutableAttributes() { 899 if (attributes_ == null) { 900 attributes_ = 901 com.google.protobuf.MapField.newMapField(AttributesDefaultEntryHolder.defaultEntry); 902 } 903 if (!attributes_.isMutable()) { 904 attributes_ = attributes_.copy(); 905 } 906 bitField0_ |= 0x00000004; 907 onChanged(); 908 return attributes_; 909 } 910 getAttributesCount()911 public int getAttributesCount() { 912 return internalGetAttributes().getMap().size(); 913 } 914 /** 915 * 916 * 917 * <pre> 918 * Attributes for PubsubMessage. 919 * Pubsub message must contain either non-empty data, or at least one 920 * attribute. 921 * </pre> 922 * 923 * <code>map<string, string> attributes = 4;</code> 924 */ 925 @java.lang.Override containsAttributes(java.lang.String key)926 public boolean containsAttributes(java.lang.String key) { 927 if (key == null) { 928 throw new NullPointerException("map key"); 929 } 930 return internalGetAttributes().getMap().containsKey(key); 931 } 932 /** Use {@link #getAttributesMap()} instead. */ 933 @java.lang.Override 934 @java.lang.Deprecated getAttributes()935 public java.util.Map<java.lang.String, java.lang.String> getAttributes() { 936 return getAttributesMap(); 937 } 938 /** 939 * 940 * 941 * <pre> 942 * Attributes for PubsubMessage. 943 * Pubsub message must contain either non-empty data, or at least one 944 * attribute. 945 * </pre> 946 * 947 * <code>map<string, string> attributes = 4;</code> 948 */ 949 @java.lang.Override getAttributesMap()950 public java.util.Map<java.lang.String, java.lang.String> getAttributesMap() { 951 return internalGetAttributes().getMap(); 952 } 953 /** 954 * 955 * 956 * <pre> 957 * Attributes for PubsubMessage. 958 * Pubsub message must contain either non-empty data, or at least one 959 * attribute. 960 * </pre> 961 * 962 * <code>map<string, string> attributes = 4;</code> 963 */ 964 @java.lang.Override getAttributesOrDefault( java.lang.String key, java.lang.String defaultValue)965 public /* nullable */ java.lang.String getAttributesOrDefault( 966 java.lang.String key, 967 /* nullable */ 968 java.lang.String defaultValue) { 969 if (key == null) { 970 throw new NullPointerException("map key"); 971 } 972 java.util.Map<java.lang.String, java.lang.String> map = internalGetAttributes().getMap(); 973 return map.containsKey(key) ? map.get(key) : defaultValue; 974 } 975 /** 976 * 977 * 978 * <pre> 979 * Attributes for PubsubMessage. 980 * Pubsub message must contain either non-empty data, or at least one 981 * attribute. 982 * </pre> 983 * 984 * <code>map<string, string> attributes = 4;</code> 985 */ 986 @java.lang.Override getAttributesOrThrow(java.lang.String key)987 public java.lang.String getAttributesOrThrow(java.lang.String key) { 988 if (key == null) { 989 throw new NullPointerException("map key"); 990 } 991 java.util.Map<java.lang.String, java.lang.String> map = internalGetAttributes().getMap(); 992 if (!map.containsKey(key)) { 993 throw new java.lang.IllegalArgumentException(); 994 } 995 return map.get(key); 996 } 997 clearAttributes()998 public Builder clearAttributes() { 999 bitField0_ = (bitField0_ & ~0x00000004); 1000 internalGetMutableAttributes().getMutableMap().clear(); 1001 return this; 1002 } 1003 /** 1004 * 1005 * 1006 * <pre> 1007 * Attributes for PubsubMessage. 1008 * Pubsub message must contain either non-empty data, or at least one 1009 * attribute. 1010 * </pre> 1011 * 1012 * <code>map<string, string> attributes = 4;</code> 1013 */ removeAttributes(java.lang.String key)1014 public Builder removeAttributes(java.lang.String key) { 1015 if (key == null) { 1016 throw new NullPointerException("map key"); 1017 } 1018 internalGetMutableAttributes().getMutableMap().remove(key); 1019 return this; 1020 } 1021 /** Use alternate mutation accessors instead. */ 1022 @java.lang.Deprecated getMutableAttributes()1023 public java.util.Map<java.lang.String, java.lang.String> getMutableAttributes() { 1024 bitField0_ |= 0x00000004; 1025 return internalGetMutableAttributes().getMutableMap(); 1026 } 1027 /** 1028 * 1029 * 1030 * <pre> 1031 * Attributes for PubsubMessage. 1032 * Pubsub message must contain either non-empty data, or at least one 1033 * attribute. 1034 * </pre> 1035 * 1036 * <code>map<string, string> attributes = 4;</code> 1037 */ putAttributes(java.lang.String key, java.lang.String value)1038 public Builder putAttributes(java.lang.String key, java.lang.String value) { 1039 if (key == null) { 1040 throw new NullPointerException("map key"); 1041 } 1042 if (value == null) { 1043 throw new NullPointerException("map value"); 1044 } 1045 internalGetMutableAttributes().getMutableMap().put(key, value); 1046 bitField0_ |= 0x00000004; 1047 return this; 1048 } 1049 /** 1050 * 1051 * 1052 * <pre> 1053 * Attributes for PubsubMessage. 1054 * Pubsub message must contain either non-empty data, or at least one 1055 * attribute. 1056 * </pre> 1057 * 1058 * <code>map<string, string> attributes = 4;</code> 1059 */ putAllAttributes(java.util.Map<java.lang.String, java.lang.String> values)1060 public Builder putAllAttributes(java.util.Map<java.lang.String, java.lang.String> values) { 1061 internalGetMutableAttributes().getMutableMap().putAll(values); 1062 bitField0_ |= 0x00000004; 1063 return this; 1064 } 1065 1066 @java.lang.Override setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields)1067 public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) { 1068 return super.setUnknownFields(unknownFields); 1069 } 1070 1071 @java.lang.Override mergeUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields)1072 public final Builder mergeUnknownFields( 1073 final com.google.protobuf.UnknownFieldSet unknownFields) { 1074 return super.mergeUnknownFields(unknownFields); 1075 } 1076 1077 // @@protoc_insertion_point(builder_scope:google.cloud.scheduler.v1.PubsubTarget) 1078 } 1079 1080 // @@protoc_insertion_point(class_scope:google.cloud.scheduler.v1.PubsubTarget) 1081 private static final com.google.cloud.scheduler.v1.PubsubTarget DEFAULT_INSTANCE; 1082 1083 static { 1084 DEFAULT_INSTANCE = new com.google.cloud.scheduler.v1.PubsubTarget(); 1085 } 1086 getDefaultInstance()1087 public static com.google.cloud.scheduler.v1.PubsubTarget getDefaultInstance() { 1088 return DEFAULT_INSTANCE; 1089 } 1090 1091 private static final com.google.protobuf.Parser<PubsubTarget> PARSER = 1092 new com.google.protobuf.AbstractParser<PubsubTarget>() { 1093 @java.lang.Override 1094 public PubsubTarget parsePartialFrom( 1095 com.google.protobuf.CodedInputStream input, 1096 com.google.protobuf.ExtensionRegistryLite extensionRegistry) 1097 throws com.google.protobuf.InvalidProtocolBufferException { 1098 Builder builder = newBuilder(); 1099 try { 1100 builder.mergeFrom(input, extensionRegistry); 1101 } catch (com.google.protobuf.InvalidProtocolBufferException e) { 1102 throw e.setUnfinishedMessage(builder.buildPartial()); 1103 } catch (com.google.protobuf.UninitializedMessageException e) { 1104 throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial()); 1105 } catch (java.io.IOException e) { 1106 throw new com.google.protobuf.InvalidProtocolBufferException(e) 1107 .setUnfinishedMessage(builder.buildPartial()); 1108 } 1109 return builder.buildPartial(); 1110 } 1111 }; 1112 parser()1113 public static com.google.protobuf.Parser<PubsubTarget> parser() { 1114 return PARSER; 1115 } 1116 1117 @java.lang.Override getParserForType()1118 public com.google.protobuf.Parser<PubsubTarget> getParserForType() { 1119 return PARSER; 1120 } 1121 1122 @java.lang.Override getDefaultInstanceForType()1123 public com.google.cloud.scheduler.v1.PubsubTarget getDefaultInstanceForType() { 1124 return DEFAULT_INSTANCE; 1125 } 1126 } 1127