Function pushMetric

lib/utapi/utilities.js:253–348

* Call the Utapi Client `pushMetric` method with the associated parameters * @param {string} action - the metric action to push a metric for * @param {object} log - werelogs logger * @param {object} metricObj - the object containing the relevant data for * pushing metrics in Utapi * @param {str

(action, log, metricObj)

 * filtered out and not pushed to utapi.
 */
function pushMetric(action, log, metricObj) {
    const {
        bucket,
        keys,
        versionId,
        byteLength,
        newByteLength,
        oldByteLength,
        numberOfObjects,
        authInfo,
        canonicalID,
        location,
        isDelete,
        removedDeleteMarkers,
    } = metricObj;

    if (utapiVersion === 2) {
        const incomingBytes = action === 'getObject' ? 0 : newByteLength;
        let sizeDelta = incomingBytes;
        if (Number.isInteger(oldByteLength) && Number.isInteger(newByteLength)) {
            sizeDelta = newByteLength - oldByteLength;
            // Include oldByteLength in conditional so we don't end up with `-0`
        } else if (action === 'completeMultipartUpload' && !versionId && oldByteLength) {
            // If this is a non-versioned bucket we need to decrement
            // the sizeDelta added by uploadPart when completeMPU is called.
            sizeDelta = -oldByteLength;
        } else if (action === 'abortMultipartUpload' && byteLength) {
            sizeDelta = -byteLength;
        } else if (action === 'putDeleteMarkerObject' && byteLength) {
            sizeDelta = -byteLength;
        }

        let objectDelta = isDelete ? -numberOfObjects : numberOfObjects;
        // putDeleteMarkerObject does not pass numberOfObjects
        if ((action === 'putDeleteMarkerObject' && byteLength === null)
            || action === 'replicateDelete'
            || action === 'replicateObject') {
            objectDelta = 1;
        } else if (action === 'multiObjectDelete') {
            objectDelta = -(numberOfObjects + removedDeleteMarkers);
        }

        const utapiObj = {
            operationId: action,
            bucket,
            location,
            objectDelta,
            sizeDelta: isDelete ? -byteLength : sizeDelta,
            incomingBytes,
            outgoingBytes: action === 'getObject' ? newByteLength : 0,
        };

        // Any operation from lifecycle that does not change object count or size is dropped
        const isLifecycle = _config.lifecycleRoleName
            && authInfo && authInfo.arn.endsWith(`:assumed-role/${_config.lifecycleRoleName}/backbeat-lifecycle`);
        if (isLifecycle && !objectDelta && !sizeDelta) {
            log.trace('ignoring pushMetric from lifecycle service user', { action, bucket, keys });
            return undefined;