/dports/databases/redisjson/RedisJSON-2.0.6/tests/pytest/ |
H A D | test_keyspace_notifications.py | 19 pubsub = r.pubsub() 20 pubsub.psubscribe('__key*') 55 env.assertEqual(None, pubsub.get_message()) 58 env.assertEqual(None, pubsub.get_message()) 66 pubsub = r.pubsub() 67 pubsub.psubscribe('__key*') 98 env.assertEqual(None, pubsub.get_message()) 127 pubsub = r.pubsub() 128 pubsub.psubscribe('__key*') 153 pubsub = r.pubsub() [all …]
|
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/pubsub/samples/ |
H A D | samples.cc | 46 namespace pubsub = google::cloud::pubsub; in CreateTopic() 69 namespace pubsub = google::cloud::pubsub; in GetTopic() 86 namespace pubsub = google::cloud::pubsub; in UpdateTopic() 105 namespace pubsub = google::cloud::pubsub; in ListTopics() 124 namespace pubsub = google::cloud::pubsub; in DeleteTopic() 145 namespace pubsub = google::cloud::pubsub; in DetachSubscription() 162 namespace pubsub = google::cloud::pubsub; in ListTopicSubscriptions() 180 namespace pubsub = google::cloud::pubsub; in ListTopicSnapshots() 198 namespace pubsub = google::cloud::pubsub; in CreateSubscription() 221 namespace pubsub = google::cloud::pubsub; in CreatePushSubscription() [all …]
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/pubsub/samples/ |
H A D | samples.cc | 50 namespace pubsub = google::cloud::pubsub; in CreateTopic() 73 namespace pubsub = google::cloud::pubsub; in GetTopic() 90 namespace pubsub = google::cloud::pubsub; in UpdateTopic() 109 namespace pubsub = google::cloud::pubsub; in ListTopics() 128 namespace pubsub = google::cloud::pubsub; in DeleteTopic() 149 namespace pubsub = google::cloud::pubsub; in DetachSubscription() 166 namespace pubsub = google::cloud::pubsub; in ListTopicSubscriptions() 184 namespace pubsub = google::cloud::pubsub; in ListTopicSnapshots() 202 namespace pubsub = google::cloud::pubsub; in CreateSubscription() 225 namespace pubsub = google::cloud::pubsub; in CreateFilteredSubscription() [all …]
|
/dports/net-im/prosody/prosody-0.11.13/spec/scansion/ |
H A D | pubsub_advanced.scs | 21 <pubsub xmlns="http://jabber.org/protocol/pubsub"> 23 </pubsub> 37 <pubsub xmlns='http://jabber.org/protocol/pubsub'> 39 </pubsub> 47 <pubsub xmlns="http://jabber.org/protocol/pubsub"> 49 </pubsub> 63 <pubsub xmlns="http://jabber.org/protocol/pubsub"> 65 </pubsub> 73 <pubsub xmlns="http://jabber.org/protocol/pubsub"> 75 </pubsub> [all …]
|
H A D | pubsub_multi_items.scs | 19 <pubsub xmlns="http://jabber.org/protocol/pubsub"> 21 </pubsub> 29 <pubsub xmlns="http://jabber.org/protocol/pubsub#owner"> 31 </pubsub> 105 </pubsub> 110 <pubsub xmlns="http://jabber.org/protocol/pubsub"> 116 </pubsub> 121 <pubsub xmlns="http://jabber.org/protocol/pubsub"> 130 <pubsub xmlns="http://jabber.org/protocol/pubsub"> 141 <pubsub xmlns="http://jabber.org/protocol/pubsub"> [all …]
|
/dports/net-im/p5-Net-Jabber/Net-Jabber-2.0/t/ |
H A D | query_pubsub.t | 20 is( $query1->GetXML(), "<pubsub xmlns='http://jabber.org/protocol/pubsub'/>", "GetXML()" ); 96 is( $query2->GetXML(), "<pubsub xmlns='http://jabber.org/protocol/pubsub'><configure node='node1'/>… 130 is( $query3->GetXML(), "<pubsub xmlns='http://jabber.org/protocol/pubsub'><create/></pubsub>", "Get… 134 is( $query3->GetXML(), "<pubsub xmlns='http://jabber.org/protocol/pubsub'><create node='node1'/></p… 170 is( $query4->GetXML(), "<pubsub xmlns='http://jabber.org/protocol/pubsub'><delete node='node1'/></p… 204 is( $query5->GetXML(), "<pubsub xmlns='http://jabber.org/protocol/pubsub'><entities/></pubsub>", "G… 327 is( $query7->GetXML(), "<pubsub xmlns='http://jabber.org/protocol/pubsub'><items max_items='max1' n… 385 is( $query8->GetXML(), "<pubsub xmlns='http://jabber.org/protocol/pubsub'><item id='id1'><test/></i… 464 is( $query10->GetXML(), "<pubsub xmlns='http://jabber.org/protocol/pubsub'><publish node='node1'/><… 521 is( $query11->GetXML(), "<pubsub xmlns='http://jabber.org/protocol/pubsub'><purge node='node1'/></p… [all …]
|
/dports/multimedia/livego/livego-0.0.15/vendor/github.com/go-redis/redis/v7/ |
H A D | pubsub_test.go | 32 defer pubsub.Close() 39 defer pubsub.Close() 90 defer pubsub.Close() 107 defer pubsub.Close() 124 defer pubsub.Close() 133 defer pubsub.Close() 209 defer pubsub.Close() 225 defer pubsub.Close() 241 defer pubsub.Close() 270 defer pubsub.Close() [all …]
|
/dports/www/pomerium/pomerium-0.8.3/vendor/github.com/go-redis/redis/v7/ |
H A D | pubsub_test.go | 32 defer pubsub.Close() 39 defer pubsub.Close() 90 defer pubsub.Close() 107 defer pubsub.Close() 124 defer pubsub.Close() 133 defer pubsub.Close() 209 defer pubsub.Close() 225 defer pubsub.Close() 241 defer pubsub.Close() 270 defer pubsub.Close() [all …]
|
/dports/net/storj/storj-1.45.3/vendor/github.com/go-redis/redis/v8/ |
H A D | pubsub_test.go | 38 defer pubsub.Close() 45 defer pubsub.Close() 96 defer pubsub.Close() 113 defer pubsub.Close() 130 defer pubsub.Close() 139 defer pubsub.Close() 215 defer pubsub.Close() 231 defer pubsub.Close() 247 defer pubsub.Close() 276 defer pubsub.Close() [all …]
|
/dports/security/vuls/vuls-0.13.7/vendor/github.com/go-redis/redis/v8/ |
H A D | pubsub_test.go | 38 defer pubsub.Close() 45 defer pubsub.Close() 96 defer pubsub.Close() 113 defer pubsub.Close() 130 defer pubsub.Close() 139 defer pubsub.Close() 215 defer pubsub.Close() 231 defer pubsub.Close() 247 defer pubsub.Close() 276 defer pubsub.Close() [all …]
|
/dports/security/go-cve-dictionary/go-cve-dictionary-0.5.5/vendor/github.com/go-redis/redis/v8/ |
H A D | pubsub_test.go | 38 defer pubsub.Close() 45 defer pubsub.Close() 96 defer pubsub.Close() 113 defer pubsub.Close() 130 defer pubsub.Close() 139 defer pubsub.Close() 215 defer pubsub.Close() 231 defer pubsub.Close() 247 defer pubsub.Close() 276 defer pubsub.Close() [all …]
|
/dports/games/automuteus/automuteus-6.15.2/vendor/github.com/go-redis/redis/v8/ |
H A D | pubsub_test.go | 38 defer pubsub.Close() 45 defer pubsub.Close() 96 defer pubsub.Close() 113 defer pubsub.Close() 130 defer pubsub.Close() 139 defer pubsub.Close() 215 defer pubsub.Close() 231 defer pubsub.Close() 247 defer pubsub.Close() 276 defer pubsub.Close() [all …]
|
/dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/github.com/go-redis/redis/v8/ |
H A D | pubsub_test.go | 38 defer pubsub.Close() 45 defer pubsub.Close() 96 defer pubsub.Close() 113 defer pubsub.Close() 130 defer pubsub.Close() 139 defer pubsub.Close() 215 defer pubsub.Close() 231 defer pubsub.Close() 247 defer pubsub.Close() 276 defer pubsub.Close() [all …]
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/pubsub/ |
H A D | topic_admin_connection.cc | 46 StatusOr<google::pubsub::v1::Topic> CreateTopic( in CreateTopic() 52 google::pubsub::v1::Topic const& request) { in CreateTopic() 59 google::pubsub::v1::GetTopicRequest request; in GetTopic() 71 StatusOr<google::pubsub::v1::Topic> UpdateTopic( in UpdateTopic() 84 google::pubsub::v1::ListTopicsRequest request; in ListTopics() 108 std::vector<google::pubsub::v1::Topic> items; in ListTopics() 118 google::pubsub::v1::DeleteTopicRequest request; in DeleteTopic() 181 pubsub::ListTopicSnapshotsRange ListTopicSnapshots( in ListTopicSnapshots() 224 pubsub::ConnectionOptions const& options, in MakeTopicAdminConnection() 241 namespace pubsub { namespace [all …]
|
H A D | subscription_admin_connection.cc | 33 : public pubsub::SubscriptionAdminConnection { 59 google::pubsub::v1::GetSubscriptionRequest request; in GetSubscription() 83 pubsub::ListSubscriptionsRange ListSubscriptions( in ListSubscriptions() 159 google::pubsub::v1::GetSnapshotRequest request; in GetSnapshot() 251 pubsub::ConnectionOptions const& options, in MakeSubscriptionAdminConnection() 269 namespace pubsub { namespace 286 StatusOr<google::pubsub::v1::Subscription> 292 StatusOr<google::pubsub::v1::Subscription> 298 StatusOr<google::pubsub::v1::Subscription> 319 StatusOr<google::pubsub::v1::Snapshot> [all …]
|
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/pubsub/ |
H A D | topic_admin_connection.cc | 45 StatusOr<google::pubsub::v1::Topic> CreateTopic( in CreateTopic() 57 google::pubsub::v1::GetTopicRequest request; in GetTopic() 68 StatusOr<google::pubsub::v1::Topic> UpdateTopic( in UpdateTopic() 80 google::pubsub::v1::ListTopicsRequest request; in ListTopics() 101 return pubsub::ListTopicsRange( in ListTopics() 114 google::pubsub::v1::DeleteTopicRequest request; in DeleteTopic() 163 return pubsub::ListTopicSubscriptionsRange( in ListTopicSubscriptions() 175 pubsub::ListTopicSnapshotsRange ListTopicSnapshots( in ListTopicSnapshots() 198 return pubsub::ListTopicSnapshotsRange( in ListTopicSnapshots() 218 pubsub::ConnectionOptions const& options, in MakeTopicAdminConnection() [all …]
|
H A D | subscription_admin_connection.h | 32 namespace pubsub { 45 google::pubsub::v1::Subscription, 46 google::pubsub::v1::ListSubscriptionsRequest, 47 google::pubsub::v1::ListSubscriptionsResponse>; 59 google::pubsub::v1::Snapshot, google::pubsub::v1::ListSnapshotsRequest, 60 google::pubsub::v1::ListSnapshotsResponse>; 91 google::pubsub::v1::Subscription subscription; 121 google::pubsub::v1::CreateSnapshotRequest request; 146 google::pubsub::v1::SeekRequest request; 221 std::shared_ptr<pubsub::SubscriptionAdminConnection> [all …]
|
H A D | subscription_admin_connection.cc | 32 : public pubsub::SubscriptionAdminConnection { 57 google::pubsub::v1::GetSubscriptionRequest request; in GetSubscription() 79 pubsub::ListSubscriptionsRange ListSubscriptions( in ListSubscriptions() 103 return pubsub::ListSubscriptionsRange( in ListSubscriptions() 149 StatusOr<google::pubsub::v1::Snapshot> GetSnapshot( in GetSnapshot() 151 google::pubsub::v1::GetSnapshotRequest request; in GetSnapshot() 163 google::pubsub::v1::ListSnapshotsRequest request; in ListSnapshots() 185 return pubsub::ListSnapshotsRange( in ListSnapshots() 237 std::shared_ptr<pubsub::SubscriptionAdminConnection> 239 pubsub::ConnectionOptions const& options, in MakeSubscriptionAdminConnection() [all …]
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/go-redis/redis/ |
H A D | pubsub_test.go | 29 defer pubsub.Close() 80 defer pubsub.Close() 97 defer pubsub.Close() 114 defer pubsub.Close() 123 defer pubsub.Close() 199 defer pubsub.Close() 215 defer pubsub.Close() 231 defer pubsub.Close() 262 defer pubsub.Close() 299 defer pubsub.Close() [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/go-redis/redis/v8/ |
H A D | pubsub_test.go | 38 defer pubsub.Close() 45 defer pubsub.Close() 96 defer pubsub.Close() 113 defer pubsub.Close() 130 defer pubsub.Close() 139 defer pubsub.Close() 215 defer pubsub.Close() 231 defer pubsub.Close() 247 defer pubsub.Close() 276 defer pubsub.Close() [all …]
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/pubsub/internal/ |
H A D | subscriber_stub.h | 46 google::pubsub::v1::Subscription const& request) = 0; 59 virtual StatusOr<google::pubsub::v1::ListSubscriptionsResponse> 75 google::pubsub::v1::StreamingPullRequest, 76 google::pubsub::v1::StreamingPullResponse>; 84 virtual StatusOr<google::pubsub::v1::Snapshot> CreateSnapshot( 89 virtual StatusOr<google::pubsub::v1::Snapshot> GetSnapshot( 91 google::pubsub::v1::GetSnapshotRequest const& request) = 0; 99 virtual StatusOr<google::pubsub::v1::Snapshot> UpdateSnapshot( 109 virtual StatusOr<google::pubsub::v1::SeekResponse> Seek( 111 google::pubsub::v1::SeekRequest const& request) = 0; [all …]
|
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/pubsub/testing/ |
H A D | mock_subscriber_stub.h | 40 google::pubsub::v1::GetSubscriptionRequest const&), 67 google::pubsub::v1::PullRequest const&), 73 google::pubsub::v1::AcknowledgeRequest const&), 84 google::pubsub::v1::CreateSnapshotRequest const&), 87 MOCK_METHOD(StatusOr<google::pubsub::v1::Snapshot>, GetSnapshot, 89 google::pubsub::v1::GetSnapshotRequest const&), 92 MOCK_METHOD(StatusOr<google::pubsub::v1::ListSnapshotsResponse>, 95 google::pubsub::v1::ListSnapshotsRequest const&), 100 google::pubsub::v1::UpdateSnapshotRequest const&), 105 google::pubsub::v1::DeleteSnapshotRequest const&), [all …]
|
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/pubsub/internal/ |
H A D | subscriber_logging.cc | 25 StatusOr<google::pubsub::v1::Subscription> 28 google::pubsub::v1::Subscription const& request) { in CreateSubscription() 31 google::pubsub::v1::Subscription const& request) { in CreateSubscription() 39 google::pubsub::v1::GetSubscriptionRequest const& request) { in GetSubscription() 48 StatusOr<google::pubsub::v1::Subscription> 60 StatusOr<google::pubsub::v1::ListSubscriptionsResponse> 97 google::pubsub::v1::PullRequest const& request) { in AsyncPull() 110 google::pubsub::v1::AcknowledgeRequest const& request) { in AsyncAcknowledge() 144 StatusOr<google::pubsub::v1::ListSnapshotsResponse> 158 google::pubsub::v1::GetSnapshotRequest const& request) { in GetSnapshot() [all …]
|
H A D | subscriber_stub.h | 45 google::pubsub::v1::Subscription const& request) = 0; 58 virtual StatusOr<google::pubsub::v1::ListSubscriptionsResponse> 77 google::pubsub::v1::PullRequest const& request) = 0; 83 google::pubsub::v1::AcknowledgeRequest const& request) = 0; 92 virtual StatusOr<google::pubsub::v1::Snapshot> CreateSnapshot( 97 virtual StatusOr<google::pubsub::v1::Snapshot> GetSnapshot( 99 google::pubsub::v1::GetSnapshotRequest const& request) = 0; 107 virtual StatusOr<google::pubsub::v1::Snapshot> UpdateSnapshot( 117 virtual StatusOr<google::pubsub::v1::SeekResponse> Seek( 119 google::pubsub::v1::SeekRequest const& request) = 0; [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/pubsub/ |
H A D | example_test.go | 28 _, err := pubsub.NewClient(ctx, "project-id") 38 client, err := pubsub.NewClient(ctx, "project-id") 54 client, err := pubsub.NewClient(ctx, "project-id") 60 topicConfig := &pubsub.TopicConfig{ 62 MessageStoragePolicy: pubsub.MessageStoragePolicy{ 77 client, err := pubsub.NewClient(ctx, "project-id") 87 client, err := pubsub.NewClient(ctx, "project-id") 177 var results []*pubsub.PublishResult 178 r := topic.Publish(ctx, &pubsub.Message{ 379 PushConfig: &pubsub.PushConfig{ [all …]
|