| /aosp_15_r20/external/sdk-platform-java/test/integration/goldens/pubsub/src/com/google/cloud/pubsub/v1/ |
| H A D | TopicAdminClientTest.java | 268 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in publishTest() local
292 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in publishExceptionTest() local
307 String topic = "topic110546223"; in publishTest2() local
331 String topic = "topic110546223"; in publishExceptionTest2() local
354 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in getTopicTest() local
376 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in getTopicExceptionTest() local
398 String topic = "topic110546223"; in getTopicTest2() local
420 String topic = "topic110546223"; in getTopicExceptionTest2() local
526 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in listTopicSubscriptionsTest() local
553 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in listTopicSubscriptionsExceptionTest() local
[all …]
|
| H A D | TopicAdminClient.java | 394 public final PublishResponse publish(TopicName topic, List<PubsubMessage> messages) { in publish()
427 public final PublishResponse publish(String topic, List<PubsubMessage> messages) { in publish()
512 public final Topic getTopic(TopicName topic) { in getTopic()
540 public final Topic getTopic(String topic) { in getTopic()
786 public final ListTopicSubscriptionsPagedResponse listTopicSubscriptions(TopicName topic) { in listTopicSubscriptions()
818 public final ListTopicSubscriptionsPagedResponse listTopicSubscriptions(String topic) { in listTopicSubscriptions()
957 public final ListTopicSnapshotsPagedResponse listTopicSnapshots(TopicName topic) { in listTopicSnapshots()
992 public final ListTopicSnapshotsPagedResponse listTopicSnapshots(String topic) { in listTopicSnapshots()
1138 public final void deleteTopic(TopicName topic) { in deleteTopic()
1169 public final void deleteTopic(String topic) { in deleteTopic()
|
| H A D | SubscriptionAdminClientTest.java | 161 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in createSubscriptionTest() local
190 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in createSubscriptionExceptionTest() local
224 String topic = "topic110546223"; in createSubscriptionTest2() local
253 String topic = "topic110546223"; in createSubscriptionExceptionTest2() local
287 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in createSubscriptionTest3() local
316 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in createSubscriptionExceptionTest3() local
350 String topic = "topic110546223"; in createSubscriptionTest4() local
379 String topic = "topic110546223"; in createSubscriptionExceptionTest4() local
|
| /aosp_15_r20/packages/modules/AdServices/adservices/tests/unittest/service-core/topics/src/com/android/adservices/service/topics/ |
| D | EncryptionManagerTest.java | 128 Topic topic = Topic.create(/* topic */ 5, /* taxonomyVersion */ 6L, /* modelVersion */ 7L); in testEncryption_success() local
163 Topic topic = Topic.create(/* topic */ 5, /* taxonomyVersion */ 6L, /* modelVersion */ 7L); in testEncryption_verifyLatestKeys() local
180 Topic topic = Topic.create(/* topic */ 5, /* taxonomyVersion */ 6L, /* modelVersion */ 7L); in testEncryption_useTestingKeys() local
201 Topic topic = Topic.create(/* topic */ 5, /* taxonomyVersion */ 6L, /* modelVersion */ 7L); in testEncryption_missingKeys() local
221 Topic topic = Topic.create(/* topic */ 5, /* taxonomyVersion */ 6L, /* modelVersion */ 7L); in testEncryption_incompatibleKeys() local
235 Topic topic = Topic.create(/* topic */ 5, /* taxonomyVersion */ 6L, /* modelVersion */ 7L); in testEncryption_missingEnrollmentData() local
250 Topic topic = Topic.create(/* topic */ 5, /* taxonomyVersion */ 6L, /* modelVersion */ 7L); in testEncryption_missingEnrollmentId() local
263 Topic topic = Topic.create(/* topic */ 5, /* taxonomyVersion */ 6L, /* modelVersion */ 7L); in testEncryption_missingSdkName() local
276 Topic topic = Topic.create(/* topic */ 5, /* taxonomyVersion */ 6L, /* modelVersion */ 7L); in testEncryption_nullSdkName() local
319 Topic topic = Topic.create(/* topic */ 5, /* taxonomyVersion */ 6L, /* modelVersion */ 7L); in testEncryption_keyDecodingFailure() local
[all …]
|
| D | HpkeEncrypterTest.java | 53 Topic topic = Topic.create(/* topic */ 5, /* taxonomyVersion */ 6L, /* modelVersion */ 7L); in testEncryption_success() local
81 Topic topic = Topic.create(/* topic */ 5, /* taxonomyVersion */ 6L, /* modelVersion */ 7L); in testEncryption_invalidKeyLength_returnsEmpty() local
106 Topic topic = Topic.create(/* topic */ 5, /* taxonomyVersion */ 6L, /* modelVersion */ 7L); in testEncryption_nullPublicKey_throwsException() local
116 Topic topic = Topic.create(/* topic */ 5, /* taxonomyVersion */ 6L, /* modelVersion */ 7L); in testEncryption_nullContextInfo_throwsException() local
126 private byte[] generateTopicsPlainText(Topic topic) { in generateTopicsPlainText()
|
| D | AppUpdateManagerTest.java | 878 Topic topic = topics[(int) (currentEpochId - 1 - epochId)]; in testAssignTopicsToSdkForAppInstallation() local
906 Topic topic = topics[(int) (currentEpochId - 1 - epochId)]; in testAssignTopicsToSdkForAppInstallation() local
936 Topic topic = topics[(int) (currentEpochId - 1 - epochId)]; in testAssignTopicsToSdkForAppInstallation_NonSdk() local
957 Topic topic = Topic.create(/* topic */ 1, TAXONOMY_VERSION, MODEL_VERSION); in testAssignTopicsToSdkForAppInstallation_unsatisfiedApp() local
1007 Topic topic = Topic.create(/* topic */ 1, TAXONOMY_VERSION, MODEL_VERSION); in testAssignTopicsToSdkForAppInstallation_unsatisfiedSdk() local
|
| /aosp_15_r20/external/sdk-platform-java/test/integration/goldens/pubsub/src/com/google/pubsub/v1/ |
| H A D | TopicName.java | 41 private final String topic; field in TopicName
83 public static TopicName of(String project, String topic) { in of()
88 public static TopicName ofProjectTopicName(String project, String topic) { in ofProjectTopicName()
97 public static String format(String project, String topic) { in format()
102 public static String formatProjectTopicName(String project, String topic) { in formatProjectTopicName()
201 private String topic; field in TopicName.Builder
218 public Builder setTopic(String topic) { in setTopic()
|
| /aosp_15_r20/external/google-cloud-java/java-notification/src/main/java/com/google/cloud/notification/ |
| H A D | NotificationInfo.java | 63 private final ProjectTopicName topic; field in NotificationInfo
74 private ProjectTopicName topic; field in NotificationInfo.Builder
82 Builder(ProjectTopicName topic) { in Builder()
107 public Builder setTopic(ProjectTopicName topic) { in setTopic()
260 public static NotificationInfo of(ProjectTopicName topic) { in of()
267 public static Builder newBuilder(ProjectTopicName topic) { in newBuilder()
|
| /aosp_15_r20/external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt/ |
| H A D | MqttMessage.java | 11 private String topic; field in MqttMessage
33 …public MqttMessage(String topic, byte[] payload, QualityOfService qos, boolean retain, boolean dup… in MqttMessage()
54 public MqttMessage(String topic, byte[] payload, QualityOfService qos, boolean retain) { in MqttMessage()
67 public MqttMessage(String topic, byte[] payload, QualityOfService qos) { in MqttMessage()
77 public MqttMessage(String topic, byte[] payload) { in MqttMessage()
|
| H A D | MqttClientConnection.java | 51 void deliver(String topic, byte[] payload, boolean dup, int qos, boolean retain) { in deliver()
350 …public CompletableFuture<Integer> subscribe(String topic, QualityOfService qos, Consumer<MqttMessa… in subscribe()
378 public CompletableFuture<Integer> subscribe(String topic, QualityOfService qos) { in subscribe()
398 public CompletableFuture<Integer> unsubscribe(String topic) { in unsubscribe()
487 … private static native short mqttClientConnectionSubscribe(long connection, String topic, int qos, in mqttClientConnectionSubscribe()
493 …private static native short mqttClientConnectionUnsubscribe(long connection, String topic, AsyncCa… in mqttClientConnectionUnsubscribe()
495 …private static native short mqttClientConnectionPublish(long connection, String topic, int qos, bo… in mqttClientConnectionPublish()
498 …private static native boolean mqttClientConnectionSetWill(long connection, String topic, int qos, … in mqttClientConnectionSetWill()
|
| /aosp_15_r20/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/data/topics/ |
| D | TopicsDao.java | 208 Topic topic = Topic.create(topicId, taxonomyVersion, modelVersion); in retrieveAppClassificationTopics() local
565 Topic topic = entry.getKey(); in persistCallerCanLearnTopics() local
669 Topic topic = Topic.create(topicId, taxonomyVersion, modelVersion); in retrieveCallerCanLearnTopicsMap() local
864 Topic topic = Topic.create(topicId, taxonomyVersion, modelVersion); in retrieveReturnedTopics() local
875 topicsMap.get(cursorEpochId).put(Pair.create(app, sdk), topic); in retrieveReturnedTopics() local
967 EncryptedTopic topic = in retrieveReturnedEncryptedTopics() local
970 encryptedTopicsMap.get(cursorEpochId).put(Pair.create(app, sdk), topic); in retrieveReturnedEncryptedTopics() local
982 public void recordBlockedTopic(Topic topic) { in recordBlockedTopic()
1002 private ContentValues getContentValuesForBlockedTopic(Topic topic) { in getContentValuesForBlockedTopic()
1016 public void removeBlockedTopic(Topic topic) { in removeBlockedTopic()
[all …]
|
| D | Topic.java | 77 int topic, in create()
98 int topic, in create()
114 public abstract Builder setTopic(int topic); in setTopic()
161 Topic topic = (Topic) object; in equals() local
|
| D | CombinedTopic.java | 49 public static CombinedTopic create(Topic topic, EncryptedTopic encryptedTopic) { in create()
68 public abstract CombinedTopic.Builder setTopic(Topic topic); in setTopic()
|
| /aosp_15_r20/packages/modules/AdServices/adservices/tests/cts/endtoends/topics/src/com/android/adservices/tests/cts/topics/ |
| D | TopicsManagerTest.java | 209 Topic topic = sdk5Result.getTopics().get(0); in testTopicsManager_testOnDeviceKillSwitch_shouldUsePrecomputedList() local
278 Topic topic = sdk1Result.getTopics().get(0); in testTopicsManager_runDefaultClassifier() local
363 Topic topic = sdk3Result.getTopics().get(0); in testTopicsManager_runOnDeviceClassifier() local
444 Topic topic = sdk4Result.getTopics().get(0); in testTopicsManager_runPrecomputedClassifier() local
517 Topic topic = sdk6Result.getTopics().get(0); in testTopicsManager_runPrecomputedClassifier_encryptedTopics() local
|
| /aosp_15_r20/out/soong/.intermediates/packages/modules/AdServices/adservices/service-core/adservices-service-core/android_common_apex30/javac/anno/com/android/adservices/data/topics/ |
| D | AutoValue_CombinedTopic.java | 8 private final Topic topic; field in AutoValue_CombinedTopic
13 Topic topic, in AutoValue_CombinedTopic()
30 private Topic topic; field in AutoValue_CombinedTopic.Builder
35 public CombinedTopic.Builder setTopic(Topic topic) { in setTopic()
|
| D | AutoValue_Topic.java | 8 private final int topic; field in AutoValue_Topic
17 int topic, in AutoValue_Topic()
58 private int topic; field in AutoValue_Topic.Builder
66 public Topic.Builder setTopic(int topic) { in setTopic()
|
| /aosp_15_r20/out/soong/.intermediates/packages/modules/AdServices/adservices/service-core/adservices-service-core/android_common_apex33/javac/anno/com/android/adservices/data/topics/ |
| D | AutoValue_CombinedTopic.java | 8 private final Topic topic; field in AutoValue_CombinedTopic
13 Topic topic, in AutoValue_CombinedTopic()
30 private Topic topic; field in AutoValue_CombinedTopic.Builder
35 public CombinedTopic.Builder setTopic(Topic topic) { in setTopic()
|
| D | AutoValue_Topic.java | 8 private final int topic; field in AutoValue_Topic
17 int topic, in AutoValue_Topic()
58 private int topic; field in AutoValue_Topic.Builder
66 public Topic.Builder setTopic(int topic) { in setTopic()
|
| /aosp_15_r20/external/googleapis/google/pubsub/v1beta2/ |
| H A D | pubsub.proto | 137 string topic = 1; field
143 string topic = 1; field
184 string topic = 1; field
209 string topic = 1; field
220 string topic = 2; field
|
| /aosp_15_r20/packages/modules/AdServices/adservices/tests/unittest/service-core/appsearch/src/com/android/adservices/service/appsearch/ |
| D | AppSearchTopicsConsentDaoTest.java | 152 Topic topic = Topic.create(5, 6L, 7L); in testAddTopic_null() local
169 Topic topic = Topic.create(5, 6L, 7L); in testAddTopic() local
190 Topic topic = Topic.create(5, 6L, 7L); in testRemoveTopic_notExists() local
211 Topic topic = Topic.create(0, 1L, 11L); in testRemoveTopic() local
|
| /aosp_15_r20/external/googleapis/google/cloud/pubsublite/v1/ |
| H A D | topic_stats.proto | 78 string topic = 1 [ field
119 string topic = 1 [ field
140 string topic = 1 [ field
|
| /aosp_15_r20/external/googleapis/google/pubsub/v1/ |
| H A D | pubsub.proto | 364 string topic = 1 [ field
373 Topic topic = 1 [(google.api.field_behavior) = REQUIRED]; field
388 string topic = 1 [ field
439 string topic = 1 [ field
474 string topic = 1 [ field
503 string topic = 1 [ field
|
| /aosp_15_r20/external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt5/packets/ |
| H A D | PublishPacket.java | 23 private String topic; field in PublishPacket
286 private String topic; field in PublishPacket.PublishPacketBuilder
343 public PublishPacketBuilder withTopic(String topic) { in withTopic()
|
| /aosp_15_r20/external/aws-crt-java/src/native/ |
| H A D | mqtt_connection.c | 770 const struct aws_byte_cursor *topic, in s_on_ack()
804 const struct aws_byte_cursor *topic, in s_on_subscription_delivered()
879 struct aws_byte_cursor topic = aws_jni_byte_cursor_from_jstring_acquire(env, jni_topic); in Java_software_amazon_awssdk_crt_mqtt_MqttClientConnection_mqttClientConnectionSubscribe() local
985 struct aws_byte_cursor topic = aws_jni_byte_cursor_from_jstring_acquire(env, jni_topic); in Java_software_amazon_awssdk_crt_mqtt_MqttClientConnection_mqttClientConnectionUnsubscribe() local
1037 struct aws_byte_cursor topic = aws_jni_byte_cursor_from_jstring_acquire(env, jni_topic); in Java_software_amazon_awssdk_crt_mqtt_MqttClientConnection_mqttClientConnectionPublish() local
1093 struct aws_byte_cursor topic = aws_jni_byte_cursor_from_jstring_acquire(env, jni_topic); in Java_software_amazon_awssdk_crt_mqtt_MqttClientConnection_mqttClientConnectionSetWill() local
|
| /aosp_15_r20/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/cobalt/ |
| D | TopicsCobaltLogger.java | 72 public void logTopicOccurrence(Topic topic) { in logTopicOccurrence()
81 public void logTopicOccurrences(Topic topic, int count) { in logTopicOccurrences()
|