875c7f9b91
- Add full Telegram bot functionality with Z.AI API integration
- Implement 4 tools: Bash, FileEdit, WebSearch, Git
- Add 3 agents: Code Reviewer, Architect, DevOps Engineer
- Add 6 skills for common coding tasks
- Add systemd service file for 24/7 operation
- Add nginx configuration for HTTPS webhook
- Add comprehensive documentation
- Implement WebSocket server for real-time updates
- Add logging system with Winston
- Add environment validation
🤖 zCode CLI X - Agentic coder with Z.AI + Telegram integration
77 lines
2.7 KiB
JavaScript
77 lines
2.7 KiB
JavaScript
/*
|
|
* Copyright The OpenTelemetry Authors
|
|
* SPDX-License-Identifier: Apache-2.0
|
|
*/
|
|
import { AggregatorKind } from './types';
|
|
import { millisToHrTime, hrTimeToMicroseconds } from '@opentelemetry/core';
|
|
import { DataPointType } from '../export/MetricData';
|
|
export class LastValueAccumulation {
|
|
startTime;
|
|
_current;
|
|
sampleTime;
|
|
constructor(startTime, current = 0, sampleTime = [0, 0]) {
|
|
this.startTime = startTime;
|
|
this._current = current;
|
|
this.sampleTime = sampleTime;
|
|
}
|
|
record(value) {
|
|
this._current = value;
|
|
this.sampleTime = millisToHrTime(Date.now());
|
|
}
|
|
setStartTime(startTime) {
|
|
this.startTime = startTime;
|
|
}
|
|
toPointValue() {
|
|
return this._current;
|
|
}
|
|
}
|
|
/** Basic aggregator which calculates a LastValue from individual measurements. */
|
|
export class LastValueAggregator {
|
|
kind = AggregatorKind.LAST_VALUE;
|
|
createAccumulation(startTime) {
|
|
return new LastValueAccumulation(startTime);
|
|
}
|
|
/**
|
|
* Returns the result of the merge of the given accumulations.
|
|
*
|
|
* Return the newly captured (delta) accumulation for LastValueAggregator.
|
|
*/
|
|
merge(previous, delta) {
|
|
// nanoseconds may lose precisions.
|
|
const latestAccumulation = hrTimeToMicroseconds(delta.sampleTime) >=
|
|
hrTimeToMicroseconds(previous.sampleTime)
|
|
? delta
|
|
: previous;
|
|
return new LastValueAccumulation(previous.startTime, latestAccumulation.toPointValue(), latestAccumulation.sampleTime);
|
|
}
|
|
/**
|
|
* Returns a new DELTA aggregation by comparing two cumulative measurements.
|
|
*
|
|
* A delta aggregation is not meaningful to LastValueAggregator, just return
|
|
* the newly captured (delta) accumulation for LastValueAggregator.
|
|
*/
|
|
diff(previous, current) {
|
|
// nanoseconds may lose precisions.
|
|
const latestAccumulation = hrTimeToMicroseconds(current.sampleTime) >=
|
|
hrTimeToMicroseconds(previous.sampleTime)
|
|
? current
|
|
: previous;
|
|
return new LastValueAccumulation(current.startTime, latestAccumulation.toPointValue(), latestAccumulation.sampleTime);
|
|
}
|
|
toMetricData(descriptor, aggregationTemporality, accumulationByAttributes, endTime) {
|
|
return {
|
|
descriptor,
|
|
aggregationTemporality,
|
|
dataPointType: DataPointType.GAUGE,
|
|
dataPoints: accumulationByAttributes.map(([attributes, accumulation]) => {
|
|
return {
|
|
attributes,
|
|
startTime: accumulation.startTime,
|
|
endTime,
|
|
value: accumulation.toPointValue(),
|
|
};
|
|
}),
|
|
};
|
|
}
|
|
}
|
|
//# sourceMappingURL=LastValue.js.map
|