Package com.amazonaws.services.kinesis.metrics.interfaces

Examples of com.amazonaws.services.kinesis.metrics.interfaces.IMetricsScope.addDimension()

171
172
173
174
175
176
177
178
179
180
181
            Map<String, T> takenLeases = leaseTaker.takeLeases();

            leaseRenewer.addLeasesToRenew(takenLeases.values());
            success = true;
        } finally {
            scope.addDimension(WORKER_IDENTIFIER_METRIC, getWorkerIdentifier());
            MetricsHelper.addSuccessAndLatency(startTime, success);
            MetricsHelper.endScope();
        }
    }
View Full Code Here
192
193
194
195
196
197
198
199
200
201
202
        try {
            leaseRenewer.renewLeases();
            success = true;
        } finally {
            scope.addDimension(WORKER_IDENTIFIER_METRIC, getWorkerIdentifier());
            MetricsHelper.addSuccessAndLatency(startTime, success);
            MetricsHelper.endScope();
        }
    }
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
    public static IMetricsScope startScope(IMetricsFactory factory, String operation) {
        IMetricsScope result = currentScope.get();
        if (result == null) {
            result = factory.createMetrics();
            if (operation != null) {
                result.addDimension(OPERATION_DIMENSION_NAME, operation);
            }
            currentScope.set(result);
            referenceCount.set(1);
        } else {
            referenceCount.set(referenceCount.get() + 1);
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
        IMetricsScope scope = getMetricsScope();

        String realPrefix = prefix == null ? "" : prefix + SEP;
       
        if (shardId != null) {
            scope.addDimension("ShardId", shardId);
        }

        scope.addData(realPrefix + MetricsHelper.SUCCESS, success ? 1 : 0, StandardUnit.Count);
        scope.addData(realPrefix + MetricsHelper.TIME,
                System.currentTimeMillis() - startTimeMillis,
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
    // CHECKSTYLE:OFF CyclomaticComplexity
    @Override
    public TaskResult call() {
        long startTimeMillis = System.currentTimeMillis();
        IMetricsScope scope = MetricsHelper.getMetricsScope();
        scope.addDimension("ShardId", shardInfo.getShardId());
        scope.addData(RECORDS_PROCESSED_METRIC, 0, StandardUnit.Count);
        scope.addData(DATA_BYTES_PROCESSED_METRIC, 0, StandardUnit.Bytes);

        Exception exception = null;
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
    // CHECKSTYLE:OFF CyclomaticComplexity
    @Override
    public TaskResult call() {
        long startTimeMillis = System.currentTimeMillis();
        IMetricsScope scope = MetricsHelper.getMetricsScope();
        scope.addDimension("ShardId", shardInfo.getShardId());
        scope.addData(RECORDS_PROCESSED_METRIC, 0, StandardUnit.Count);
        scope.addData(DATA_BYTES_PROCESSED_METRIC, 0, StandardUnit.Bytes);

        Exception exception = null;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.