4EKtWYNH

1var Minio = require('minio');
2var settings = require('./minio.json');
3var uuid = require('uuid');
4var async = require('async');
5
6var minioClients = [];
7for (var i = 0; i < settings.public_ips.length; i++) {
8    minioClients.push(new Minio.Client({
9        endPoint: settings.public_ips[i],
10        port: 9000,
11        secure: false,
12        accessKey: settings.access_key,
13        secretKey: settings.secret_key
14    }));
15}
16let file = '/root/randomfile';
17
18minioClients[0].makeBucket('test', 'us-east-1', (err) => {
19    if (err) {
20        console.log("error creating the bucket", err);
21    }
22    async.map(minioClients, (client, callback) => {
23
24        if (err) {
25            console.log("error creating the bucket", err);
26        }
27        async.timesLimit(100, 5, (n, callback) => {
28            var uuidStr = uuid.v4()
29            client.fPutObject('test', uuidStr, file, 'application/octet-stream', (err) => {
30                if (err) {
31                    process.stdout.write('E');
32                    //console.log(err);
33                } else {
34                    process.stdout.write('.');
35                    var size = 0;
36                    client.getObject('test', uuidStr, function(err, dataS) {
37                        if (err) {
38                            return console.log(err);
39                        }
40                        dataS.on('data', function(chunk) {
41                                size += chunk.length
42                        })
43                        dataS.on('end', function() {
44                                console.log('End. Total size = ' + size)
45                        })
46                        dataS.on('error', function(err) {
47                                console.log(err)
48                        })
49                    });
50                }
51                callback();
52            });
53        }, (err) => {
54            if (err) {
55                console.log(err);
56            }
57            return callback();
58        });
59
60    }, (err) => {
61        console.log(err);
62    });
63});