/dports/devel/py-moto/moto-2.2.16/tests/test_kinesis/ |
H A D | test_kinesis.py | 147 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 D | test_kinesis_boto3.py | 14 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 D | test_firehose_destination_types.py | 16 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 D | test_firehose_tags.py | 18 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 D | test_firehose_put.py | 27 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 D | test_firehose.py | 39 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 D | filename_util.c | 31 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 D | kinesis_stream.py | 204 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 D | responses.py | 17 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 D | models.py | 141 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 D | kinesis_stream.py | 305 '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 D | test_kinesisvideo.py | 11 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 D | handler.py | 211 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 D | client.py | 151 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 D | models.py | 19 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 D | responses.py | 15 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 D | layer1.py | 71 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 D | layer1.py | 71 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 D | layer1.py | 71 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 D | layer1.py | 71 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 D | boto_kinesis.py | 81 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 D | test_kinesisvideoarchivedmedia.py | 13 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 D | responses.py | 14 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 D | models.py | 17 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 D | modulemd-module.h | 116 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)
|