Home
last modified time | relevance | path

Searched refs:stream_name (Results 1 – 25 of 2434) sorted by relevance

12345678910>>...98

/dports/devel/py-moto/moto-2.2.16/tests/test_kinesis/
H A Dtest_kinesis.py147 stream_name = "my_stream"
166 stream_name = "mystream"
186 stream_name = "my_stream"
198 stream_name = "mystream"
219 stream_name = "my_stream"
280 stream_name = "my_stream"
340 stream_name = "my_stream"
414 stream_name = "my_stream"
489 stream_name = "my_stream"
573 stream_name = "my_stream"
[all …]
H A Dtest_kinesis_boto3.py14 stream_name = "my_stream"
16 client.create_stream(StreamName=stream_name, ShardCount=5)
44 stream_name = "my_stream"
46 conn.create_stream(StreamName=stream_name, ShardCount=2)
77 stream_name = "my_stream"
78 client.create_stream(StreamName=stream_name, ShardCount=10)
81 shard_list = client.list_shards(StreamName=stream_name)
228 stream_name = "my-stream"
229 client.create_stream(StreamName=stream_name, ShardCount=2)
233 StreamName=stream_name,
[all …]
/dports/devel/py-moto/moto-2.2.16/tests/test_firehose/
H A Dtest_firehose_destination_types.py16 DeliveryStreamName=stream_name,
30 "DatabaseName": stream_name,
44 DeliveryStreamName=stream_name,
70 DeliveryStreamName=stream_name,
96 DeliveryStreamName=stream_name,
121 stream_name = f"stream_{get_random_hex(6)}"
134 "DeliveryStreamName": stream_name,
177 stream_name = f"stream_{get_random_hex(6)}"
190 "DeliveryStreamName": stream_name,
257 "DeliveryStreamName": stream_name,
[all …]
H A Dtest_firehose_tags.py18 stream_name = f"test_list_tags_{get_random_hex(6)}"
25 DeliveryStreamName=stream_name,
32 DeliveryStreamName=stream_name, Limit=1
39 DeliveryStreamName=stream_name, Limit=number_of_tags
46 DeliveryStreamName=stream_name, ExclusiveStartTagKey="30_k"
63 DeliveryStreamName=stream_name, ExclusiveStartTagKey="foo"
82 stream_name = f"test_tags_{get_random_hex(6)}"
84 DeliveryStreamName=stream_name,
104 DeliveryStreamName=stream_name,
143 stream_name = f"test_untag_{get_random_hex(6)}"
[all …]
H A Dtest_firehose_put.py27 stream_name = f"test_put_record_{get_random_hex(6)}"
28 create_redshift_delivery_stream(client, stream_name)
30 DeliveryStreamName=stream_name, Record={"Data": "some test data"}
44 stream_name = f"test_put_record_{get_random_hex(6)}"
45 create_redshift_delivery_stream(client, stream_name)
66 stream_name = f"test_put_record_{get_random_hex(6)}"
68 DeliveryStreamName=stream_name,
86 stream_name = f"test_put_record_{get_random_hex(6)}"
88 DeliveryStreamName=stream_name,
122 stream_name = f"test_put_record_{get_random_hex(6)}"
[all …]
H A Dtest_firehose.py39 DeliveryStreamName=stream_name,
51 DeliveryStreamName=stream_name,
71 DeliveryStreamName=stream_name,
222 DeliveryStreamName=stream_name,
267 DeliveryStreamName=stream_name,
301 DeliveryStreamName=stream_name,
337 DeliveryStreamName=stream_name,
468 DeliveryStreamName=stream_name,
476 DeliveryStreamName=stream_name,
492 DeliveryStreamName=stream_name,
[all …]
/dports/net/samba412/samba-4.12.15/source3/lib/
H A Dfilename_util.c31 if (smb_fname->stream_name) { in get_full_smb_filename()
55 const char *stream_name, in synthetic_smb_fname() argument
63 smb_fname_loc.stream_name = discard_const_p(char, stream_name); in synthetic_smb_fname()
97 char *stream_name = NULL; in synthetic_smb_fname_split() local
114 &stream_name); in synthetic_smb_fname_split()
121 TALLOC_FREE(stream_name); in synthetic_smb_fname_split()
190 if (in->stream_name) { in cp_smb_filename()
198 if (in->stream_name != NULL) { in cp_smb_filename()
229 out->stream_name); in cp_smb_filename()
245 if (smb_fname->stream_name) { in assert_valid_stream_smb_fname()
[all …]
/dports/sysutils/ansible/ansible-4.7.0/ansible_collections/community/aws/plugins/modules/
H A Dkinesis_stream.py204 def get_tags(client, stream_name): argument
221 'StreamName': stream_name,
235 def find_stream(client, stream_name): argument
251 'StreamName': stream_name,
416 get_tags(client, stream_name)
475 'StreamName': stream_name
531 'StreamName': stream_name
589 'StreamName': stream_name
647 'StreamName': stream_name,
1053 'StreamName': stream_name
[all …]
/dports/devel/py-moto/moto-2.2.16/moto/kinesis/
H A Dresponses.py17 stream_name = self.parameters.get("StreamName")
26 stream_name = self.parameters.get("StreamName")
32 stream_name = self.parameters.get("StreamName")
58 stream_name = self.parameters.get("StreamName")
59 self.kinesis_backend.delete_stream(stream_name)
63 stream_name = self.parameters.get("StreamName")
70 stream_name,
105 stream_name,
147 stream_name=stream_name, limit=max, next_token=next_token
158 stream_name, retention_period_hours
[all …]
H A Dmodels.py141 self.stream_name = stream_name
177 stream_name=self.stream_name,
336 return self.stream_name
353 if stream_name in self.streams:
356 self.streams[stream_name] = stream
360 if stream_name in self.streams:
371 def delete_stream(self, stream_name): argument
372 if stream_name in self.streams:
378 stream_name, argument
394 stream_name,
[all …]
/dports/sysutils/ansible2/ansible-2.9.27/lib/ansible/modules/cloud/amazon/
H A Dkinesis_stream.py305 'StreamName': stream_name,
347 'StreamName': stream_name,
472 params = {'StreamName': stream_name}
638 'StreamName': stream_name
694 'StreamName': stream_name
752 'StreamName': stream_name
810 'StreamName': stream_name,
962 .format(stream_name)
1060 .format(stream_name)
1215 'StreamName': stream_name
[all …]
/dports/devel/py-moto/moto-2.2.16/tests/test_kinesisvideo/
H A Dtest_kinesisvideo.py11 stream_name = "my-stream"
16 res.should.have.key("StreamARN").which.should.contain(stream_name)
22 stream_name = "my-stream"
25 client.create_stream(StreamName=stream_name, DeviceName=device_name)
35 stream_name = "my-stream"
39 res.should.have.key("StreamARN").which.should.contain(stream_name)
47 res = client.describe_stream(StreamName=stream_name)
76 stream_name = "my-stream"
93 stream_name = "my-stream"
111 stream_name = "my-stream"
[all …]
/dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/replication/tcp/
H A Dhandler.py211 stream_name: _StreamCommandQueue() for stream_name in self._streams
223 (stream_name,): len(queue)
246 stream_name = cmd.stream_name
287 stream_name: str,
429 stream_name = cmd.stream_name
463 stream_name,
479 stream = self._streams[stream_name]
491 stream_name,
536 streams.discard(stream_name)
552 stream_name,
[all …]
H A Dclient.py151 if stream_name == TypingStream.NAME:
156 elif stream_name == PushRulesStream.NAME:
164 elif stream_name == ReceiptsStream.NAME:
171 elif stream_name == ToDeviceStream.NAME:
175 elif stream_name == DeviceListsStream.NAME:
182 elif stream_name == GroupServerStream.NAME:
186 elif stream_name == PushersStream.NAME:
192 elif stream_name == EventsStream.NAME:
362 if stream_name == "federation":
367 elif stream_name == ReceiptsStream.NAME:
[all …]
/dports/devel/py-moto/moto-2.2.16/moto/kinesisvideo/
H A Dmodels.py19 stream_name, argument
26 self.stream_name = stream_name
36 self.region_name, ACCOUNT_ID, self.stream_name
55 "StreamName": self.stream_name,
80 stream_name, argument
86 streams = [_ for _ in self.streams.values() if _.stream_name == stream_name]
94 stream_name,
103 def _get_stream(self, stream_name, stream_arn): argument
104 if stream_name:
105 streams = [_ for _ in self.streams.values() if _.stream_name == stream_name]
[all …]
H A Dresponses.py15 stream_name = self._get_param("StreamName")
22 stream_name=stream_name,
31 stream_name = self._get_param("StreamName")
34 stream_name=stream_name, stream_arn=stream_arn,
58 stream_name = self._get_param("StreamName")
62 stream_name=stream_name, stream_arn=stream_arn, api_name=api_name,
/dports/net/google-cloud-sdk/google-cloud-sdk/platform/gsutil/gslib/vendored/boto/boto/kinesis/
H A Dlayer1.py71 def add_tags_to_stream(self, stream_name, tags): argument
91 def create_stream(self, stream_name, shard_count): argument
159 'StreamName': stream_name,
165 def delete_stream(self, stream_name): argument
195 params = {'StreamName': stream_name, }
241 params = {'StreamName': stream_name, }
419 'StreamName': stream_name,
487 params = {'StreamName': stream_name, }
556 'StreamName': stream_name,
651 'StreamName': stream_name,
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/catapult/third_party/gsutil/gslib/vendored/boto/boto/kinesis/
H A Dlayer1.py71 def add_tags_to_stream(self, stream_name, tags): argument
91 def create_stream(self, stream_name, shard_count): argument
159 'StreamName': stream_name,
165 def delete_stream(self, stream_name): argument
195 params = {'StreamName': stream_name, }
241 params = {'StreamName': stream_name, }
419 'StreamName': stream_name,
487 params = {'StreamName': stream_name, }
556 'StreamName': stream_name,
651 'StreamName': stream_name,
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/depot_tools/external_bin/gsutil/gsutil_4.28/gsutil/third_party/boto/boto/kinesis/
H A Dlayer1.py71 def add_tags_to_stream(self, stream_name, tags): argument
91 def create_stream(self, stream_name, shard_count): argument
159 'StreamName': stream_name,
165 def delete_stream(self, stream_name): argument
195 params = {'StreamName': stream_name, }
241 params = {'StreamName': stream_name, }
419 'StreamName': stream_name,
487 params = {'StreamName': stream_name, }
556 'StreamName': stream_name,
651 'StreamName': stream_name,
[all …]
/dports/devel/py-boto/boto-2.49.0/boto/kinesis/
H A Dlayer1.py71 def add_tags_to_stream(self, stream_name, tags): argument
91 def create_stream(self, stream_name, shard_count): argument
159 'StreamName': stream_name,
165 def delete_stream(self, stream_name): argument
195 params = {'StreamName': stream_name, }
241 params = {'StreamName': stream_name, }
419 'StreamName': stream_name,
487 params = {'StreamName': stream_name, }
556 'StreamName': stream_name,
651 'StreamName': stream_name,
[all …]
/dports/sysutils/py-salt/salt-3004.1/salt/modules/
H A Dboto_kinesis.py81 def _get_basic_stream(stream_name, conn):
107 stream = _get_basic_stream(stream_name, conn)["result"]
115 StreamName=stream_name,
176 stream = _get_basic_stream(stream_name, conn)
240 StreamName=stream_name,
264 StreamName=stream_name,
288 StreamName=stream_name,
313 StreamName=stream_name,
378 stream_name,
475 StreamName=stream_name,
[all …]
/dports/devel/py-moto/moto-2.2.16/tests/test_kinesisvideoarchivedmedia/
H A Dtest_kinesisvideoarchivedmedia.py13 stream_name = "my-stream"
14 kvs_client.create_stream(StreamName=stream_name)
17 res = kvs_client.get_data_endpoint(StreamName=stream_name, APIName=api_name)
25 res = client.get_hls_streaming_session_url(StreamName=stream_name,)
37 stream_name = "my-stream"
38 kvs_client.create_stream(StreamName=stream_name)
41 res = kvs_client.get_data_endpoint(StreamName=stream_name, APIName=api_name)
49 res = client.get_dash_streaming_session_url(StreamName=stream_name,)
61 stream_name = "my-stream"
62 kvs_client.create_stream(StreamName=stream_name)
[all …]
/dports/devel/py-moto/moto-2.2.16/moto/kinesisvideoarchivedmedia/
H A Dresponses.py14 stream_name = self._get_param("StreamName")
26 stream_name=stream_name,
39 stream_name = self._get_param("StreamName")
48 stream_name=stream_name,
60 stream_name = self._get_param("StreamName")
64 stream_name=stream_name,
H A Dmodels.py17 def _get_streaming_url(self, stream_name, stream_arn, api_name): argument
19 stream_name, stream_arn
33 stream_name, argument
45 url = self._get_streaming_url(stream_name, stream_arn, api_name)
50 stream_name, argument
61 url = self._get_streaming_url(stream_name, stream_arn, api_name)
64 def get_clip(self, stream_name, stream_arn, clip_fragment_selector): argument
65 kinesisvideo_backends[self.region_name]._get_stream(stream_name, stream_arn)
/dports/misc/libmodulemd/modulemd-2.13.0/modulemd/include/modulemd-2.0/
H A Dmodulemd-module.h116 const gchar *stream_name);
134 const gchar *stream_name,
161 const gchar *stream_name,
192 const gchar *stream_name,
239 const gchar *stream_name,
264 const gchar *stream_name,
280 #define modulemd_module_remove_streams_by_name(self, stream_name) \ argument
281 modulemd_module_remove_streams_by_NSVCA (self, stream_name, 0, NULL, NULL)

12345678910>>...98