golden hour
/home/doctorbruno/public_html/pgmed.org/wp-content/plugins/backupbuddy/destinations/_s3lib3/Aws
⬆️ Go Up
Upload
File/Folder
Size
Actions
Acm
-
Del
OK
Api
-
Del
OK
ApplicationAutoScaling
-
Del
OK
ApplicationDiscoveryService
-
Del
OK
AutoScaling
-
Del
OK
AwsClient.php
11.34 KB
Del
OK
AwsClientInterface.php
5.4 KB
Del
OK
AwsClientTrait.php
2.49 KB
Del
OK
CacheInterface.php
755 B
Del
OK
ClientResolver.php
26.63 KB
Del
OK
CloudHsm
-
Del
OK
CloudTrail
-
Del
OK
CodeCommit
-
Del
OK
CodePipeline
-
Del
OK
CognitoIdentity
-
Del
OK
CognitoIdentityProvider
-
Del
OK
CognitoSync
-
Del
OK
Command.php
1.3 KB
Del
OK
CommandInterface.php
946 B
Del
OK
CommandPool.php
4.91 KB
Del
OK
ConfigService
-
Del
OK
Credentials
-
Del
OK
DataPipeline
-
Del
OK
DatabaseMigrationService
-
Del
OK
DeviceFarm
-
Del
OK
DirectConnect
-
Del
OK
DirectoryService
-
Del
OK
DoctrineCacheAdapter.php
989 B
Del
OK
Ecr
-
Del
OK
Ecs
-
Del
OK
Efs
-
Del
OK
Emr
-
Del
OK
Endpoint
-
Del
OK
Exception
-
Del
OK
GameLift
-
Del
OK
Handler
-
Del
OK
HandlerList.php
12.43 KB
Del
OK
HasDataTrait.php
1.11 KB
Del
OK
HashInterface.php
531 B
Del
OK
HashingStream.php
1.53 KB
Del
OK
History.php
3.81 KB
Del
OK
Iam
-
Del
OK
ImportExport
-
Del
OK
Inspector
-
Del
OK
Iot
-
Del
OK
IotDataPlane
-
Del
OK
JsonCompiler.php
478 B
Del
OK
Kinesis
-
Del
OK
KinesisAnalytics
-
Del
OK
Kms
-
Del
OK
LruArrayCache.php
2.06 KB
Del
OK
MachineLearning
-
Del
OK
MarketplaceCommerceAnalytics
-
Del
OK
MarketplaceMetering
-
Del
OK
Middleware.php
12.8 KB
Del
OK
MockHandler.php
3.6 KB
Del
OK
MultiRegionClient.php
7.42 KB
Del
OK
Multipart
-
Del
OK
OpsWorks
-
Del
OK
PhpHash.php
1.78 KB
Del
OK
PsrCacheAdapter.php
742 B
Del
OK
Redshift
-
Del
OK
Result.php
1.08 KB
Del
OK
ResultInterface.php
1.34 KB
Del
OK
ResultPaginator.php
5.08 KB
Del
OK
RetryMiddleware.php
6.17 KB
Del
OK
S3
-
Del
OK
Sdk.php
14.59 KB
Del
OK
ServiceCatalog
-
Del
OK
Signature
-
Del
OK
SnowBall
-
Del
OK
Ssm
-
Del
OK
StorageGateway
-
Del
OK
Sts
-
Del
OK
Support
-
Del
OK
Swf
-
Del
OK
TraceMiddleware.php
10.41 KB
Del
OK
Waf
-
Del
OK
Waiter.php
8.44 KB
Del
OK
WorkSpaces
-
Del
OK
WrappedHttpHandler.php
6.88 KB
Del
OK
data
-
Del
OK
functions.php
9.54 KB
Del
OK
index.php
27 B
Del
OK
Edit: CommandPool.php
<?php namespace Aws; use GuzzleHttp\Promise\PromisorInterface; use GuzzleHttp\Promise\EachPromise; /** * Sends and iterator of commands concurrently using a capped pool size. * * The pool will read command objects from an iterator until it is cancelled or * until the iterator is consumed. */ class CommandPool implements PromisorInterface { /** @var EachPromise */ private $each; /** * The CommandPool constructor accepts a hash of configuration options: * * - concurrency: (callable|int) Maximum number of commands to execute * concurrently. Provide a function to resize the pool dynamically. The * function will be provided the current number of pending requests and * is expected to return an integer representing the new pool size limit. * - before: (callable) function to invoke before sending each command. The * before function accepts the command and the key of the iterator of the * command. You can mutate the command as needed in the before function * before sending the command. * - fulfilled: (callable) Function to invoke when a promise is fulfilled. * The function is provided the result object, id of the iterator that the * result came from, and the aggregate promise that can be resolved/rejected * if you need to short-circuit the pool. * - rejected: (callable) Function to invoke when a promise is rejected. * The function is provided an AwsException object, id of the iterator that * the exception came from, and the aggregate promise that can be * resolved/rejected if you need to short-circuit the pool. * * @param AwsClientInterface $client Client used to execute commands. * @param array|\Iterator $commands Iterable that yields commands. * @param array $config Associative array of options. */ public function __construct( AwsClientInterface $client, $commands, array $config = [] ) { if (!isset($config['concurrency'])) { $config['concurrency'] = 25; } $before = $this->getBefore($config); $mapFn = function ($commands) use ($client, $before) { foreach ($commands as $key => $command) { if (!($command instanceof CommandInterface)) { throw new \InvalidArgumentException('Each value yielded by ' . 'the iterator must be an Aws\CommandInterface.'); } if ($before) { $before($command, $key); } yield $client->executeAsync($command); } }; $this->each = new EachPromise($mapFn($commands), $config); } /** * @return \GuzzleHttp\Promise\PromiseInterface */ public function promise() { return $this->each->promise(); } /** * Executes a pool synchronously and aggregates the results of the pool * into an indexed array in the same order as the passed in array. * * @param AwsClientInterface $client Client used to execute commands. * @param mixed $commands Iterable that yields commands. * @param array $config Configuration options. * * @return array * @see \Aws\CommandPool::__construct for available configuration options. */ public static function batch( AwsClientInterface $client, $commands, array $config = [] ) { $results = []; self::cmpCallback($config, 'fulfilled', $results); self::cmpCallback($config, 'rejected', $results); return (new self($client, $commands, $config)) ->promise() ->then(static function () use (&$results) { ksort($results); return $results; }) ->wait(); } /** * @return callable */ private function getBefore(array $config) { if (!isset($config['before'])) { return null; } if (is_callable($config['before'])) { return $config['before']; } throw new \InvalidArgumentException('before must be callable'); } /** * Adds an onFulfilled or onRejected callback that aggregates results into * an array. If a callback is already present, it is replaced with the * composed function. * * @param array $config * @param $name * @param array $results */ private static function cmpCallback(array &$config, $name, array &$results) { if (!isset($config[$name])) { $config[$name] = function ($v, $k) use (&$results) { $results[$k] = $v; }; } else { $currentFn = $config[$name]; $config[$name] = function ($v, $k) use (&$results, $currentFn) { $currentFn($v, $k); $results[$k] = $v; }; } } }
Save