Home
last modified time | relevance | path

Searched refs:pubsub (Results 1 – 25 of 5301) sorted by relevance

12345678910>>...213

/dports/databases/redisjson/RedisJSON-2.0.6/tests/pytest/
H A Dtest_keyspace_notifications.py19 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 Dsamples.cc46 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 Dsamples.cc50 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 Dpubsub_advanced.scs21 <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 Dpubsub_multi_items.scs19 <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 Dquery_pubsub.t20 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 Dpubsub_test.go32 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 Dpubsub_test.go32 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 Dpubsub_test.go38 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 Dpubsub_test.go38 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 Dpubsub_test.go38 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 Dpubsub_test.go38 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 Dpubsub_test.go38 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 Dtopic_admin_connection.cc46 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 Dsubscription_admin_connection.cc33 : 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 Dtopic_admin_connection.cc45 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 Dsubscription_admin_connection.h32 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 Dsubscription_admin_connection.cc32 : 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 Dpubsub_test.go29 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 Dpubsub_test.go38 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 Dsubscriber_stub.h46 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 Dmock_subscriber_stub.h40 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 Dsubscriber_logging.cc25 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 Dsubscriber_stub.h45 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 Dexample_test.go28 _, 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 …]

12345678910>>...213