Skip to content

Commit

Permalink
chore: Inject k8s pod name and uid
Browse files Browse the repository at this point in the history
Injected as env vars and picked up as part of the otel resource for
resource association.
  • Loading branch information
spalladino committed Dec 11, 2024
1 parent 98ba747 commit 84a3673
Show file tree
Hide file tree
Showing 15 changed files with 101 additions and 13 deletions.
16 changes: 16 additions & 0 deletions spartan/aztec-network/templates/boot-node.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -94,6 +94,14 @@ spec:
value: "{{ .Values.aztec.epochDuration }}"
- name: AZTEC_EPOCH_PROOF_CLAIM_WINDOW_IN_L2_SLOTS
value: "{{ .Values.aztec.epochProofClaimWindow }}"
- name: K8S_POD_UID
valueFrom:
fieldRef:
fieldPath: metadata.uid
- name: K8S_POD_NAME
valueFrom:
fieldRef:
fieldPath: metadata.name
{{- end }}
containers:
- name: boot-node
Expand Down Expand Up @@ -142,6 +150,14 @@ spec:
valueFrom:
fieldRef:
fieldPath: status.podIP
- name: K8S_POD_UID
valueFrom:
fieldRef:
fieldPath: metadata.uid
- name: K8S_POD_NAME
valueFrom:
fieldRef:
fieldPath: metadata.name
- name: AZTEC_PORT
value: "{{ .Values.bootNode.service.nodePort }}"
- name: LOG_LEVEL
Expand Down
8 changes: 8 additions & 0 deletions spartan/aztec-network/templates/deploy-l1-verifier.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -74,6 +74,14 @@ spec:
done || { echo "All L1 verifier deploy attempts failed." >&2; exit 1; }
echo "L1 verifier deployed"
env:
- name: K8S_POD_UID
valueFrom:
fieldRef:
fieldPath: metadata.uid
- name: K8S_POD_NAME
valueFrom:
fieldRef:
fieldPath: metadata.name
- name: NODE_NO_WARNINGS
value: "1"
- name: LOG_LEVEL
Expand Down
8 changes: 8 additions & 0 deletions spartan/aztec-network/templates/prover-agent.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -80,6 +80,14 @@ spec:
source /shared/config/service-addresses && \
node --no-warnings /usr/src/yarn-project/aztec/dest/bin/index.js start --prover-agent
env:
- name: K8S_POD_UID
valueFrom:
fieldRef:
fieldPath: metadata.uid
- name: K8S_POD_NAME
valueFrom:
fieldRef:
fieldPath: metadata.name
- name: AZTEC_PORT
value: "{{ .Values.proverAgent.service.nodePort }}"
- name: LOG_LEVEL
Expand Down
8 changes: 8 additions & 0 deletions spartan/aztec-network/templates/prover-broker.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -62,6 +62,14 @@ spec:
source /shared/config/service-addresses && \
node --no-warnings /usr/src/yarn-project/aztec/dest/bin/index.js start --prover-broker
env:
- name: K8S_POD_UID
valueFrom:
fieldRef:
fieldPath: metadata.uid
- name: K8S_POD_NAME
valueFrom:
fieldRef:
fieldPath: metadata.name
- name: AZTEC_PORT
value: "{{ .Values.proverBroker.service.nodePort }}"
- name: LOG_LEVEL
Expand Down
8 changes: 8 additions & 0 deletions spartan/aztec-network/templates/prover-node.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -107,6 +107,14 @@ spec:
- name: config
mountPath: /shared/config
env:
- name: K8S_POD_UID
valueFrom:
fieldRef:
fieldPath: metadata.uid
- name: K8S_POD_NAME
valueFrom:
fieldRef:
fieldPath: metadata.name
- name: POD_IP
valueFrom:
fieldRef:
Expand Down
8 changes: 8 additions & 0 deletions spartan/aztec-network/templates/pxe.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -81,6 +81,14 @@ spec:
echo "AZTEC_NODE_URL=${AZTEC_NODE_URL}"
node --no-warnings /usr/src/yarn-project/aztec/dest/bin/index.js start --pxe
env:
- name: K8S_POD_UID
valueFrom:
fieldRef:
fieldPath: metadata.uid
- name: K8S_POD_NAME
valueFrom:
fieldRef:
fieldPath: metadata.name
- name: AZTEC_PORT
value: "{{ .Values.pxe.service.nodePort }}"
- name: LOG_JSON
Expand Down
8 changes: 8 additions & 0 deletions spartan/aztec-network/templates/setup-l2-contracts.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,14 @@ spec:
node --no-warnings /usr/src/yarn-project/aztec/dest/bin/index.js setup-protocol-contracts --skipProofWait --l1-chain-id {{ .Values.ethereum.chainId }}
echo "L2 contracts initialized"
env:
- name: K8S_POD_UID
valueFrom:
fieldRef:
fieldPath: metadata.uid
- name: K8S_POD_NAME
valueFrom:
fieldRef:
fieldPath: metadata.name
- name: TELEMETRY
value: "{{ .Values.telemetry.enabled }}"
- name: LOG_LEVEL
Expand Down
8 changes: 8 additions & 0 deletions spartan/aztec-network/templates/transaction-bot.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,14 @@ spec:
echo "AZTEC_NODE_URL=${AZTEC_NODE_URL}"
node --no-warnings /usr/src/yarn-project/aztec/dest/bin/index.js start --pxe --bot
env:
- name: K8S_POD_UID
valueFrom:
fieldRef:
fieldPath: metadata.uid
- name: K8S_POD_NAME
valueFrom:
fieldRef:
fieldPath: metadata.name
- name: AZTEC_PORT
value: "{{ .Values.bot.service.nodePort }}"
- name: LOG_JSON
Expand Down
8 changes: 8 additions & 0 deletions spartan/aztec-network/templates/validator.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -144,6 +144,14 @@ spec:
- name: validator-data
mountPath: {{ .Values.validator.dataDir }}
env:
- name: K8S_POD_UID
valueFrom:
fieldRef:
fieldPath: metadata.uid
- name: K8S_POD_NAME
valueFrom:
fieldRef:
fieldPath: metadata.name
- name: POD_IP
valueFrom:
fieldRef:
Expand Down
4 changes: 3 additions & 1 deletion yarn-project/foundation/src/config/env_var.ts
Original file line number Diff line number Diff line change
Expand Up @@ -184,4 +184,6 @@ export type EnvVar =
| 'L1_TX_MONITOR_MAX_ATTEMPTS'
| 'L1_TX_MONITOR_CHECK_INTERVAL_MS'
| 'L1_TX_MONITOR_STALL_TIME_MS'
| 'L1_TX_MONITOR_TX_TIMEOUT_MS';
| 'L1_TX_MONITOR_TX_TIMEOUT_MS'
| 'K8S_POD_NAME'
| 'K8S_POD_UID';
2 changes: 1 addition & 1 deletion yarn-project/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -85,4 +85,4 @@
"@noir-lang/noir_js": "file:../noir/packages/noir_js",
"jest-runner@^29.7.0": "patch:jest-runner@npm%3A29.7.0#./.yarn/patches/jest-runner-npm-29.7.0-3bc9f82b58.patch"
}
}
}
3 changes: 3 additions & 0 deletions yarn-project/telemetry-client/src/aztec_resource_detector.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
import { type DetectorSync, type IResource, Resource } from '@opentelemetry/resources';
import { ATTR_K8S_POD_NAME, ATTR_K8S_POD_UID } from '@opentelemetry/semantic-conventions/incubating';

import { NETWORK_NAME } from './attributes.js';
import { getConfigEnvVars } from './config.js';
Expand All @@ -12,6 +13,8 @@ class AztecDetector implements DetectorSync {

return new Resource({
[NETWORK_NAME]: config.networkName,
[ATTR_K8S_POD_UID]: config.k8sPodUid,
[ATTR_K8S_POD_NAME]: config.k8sPodName,
});
}
}
Expand Down
10 changes: 10 additions & 0 deletions yarn-project/telemetry-client/src/config.ts
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,8 @@ export interface TelemetryClientConfig {
networkName: string;
otelCollectIntervalMs: number;
otelExportTimeoutMs: number;
k8sPodUid?: string;
k8sPodName?: string;
}

export const telemetryClientConfigMappings: ConfigMappingsType<TelemetryClientConfig> = {
Expand Down Expand Up @@ -48,6 +50,14 @@ export const telemetryClientConfigMappings: ConfigMappingsType<TelemetryClientCo
defaultValue: 30000, // Default extracted from otel client
parseEnv: (val: string) => parseInt(val),
},
k8sPodUid: {
env: 'K8S_POD_UID',
description: 'The UID of the Kubernetes pod (injected automatically by k8s)',
},
k8sPodName: {
env: 'K8S_POD_NAME',
description: 'The name of the Kubernetes pod (injected automatically by k8s)',
},
};

export function getConfigEnvVars(): TelemetryClientConfig {
Expand Down
3 changes: 3 additions & 0 deletions yarn-project/telemetry-client/src/otel_logger_provider.ts
Original file line number Diff line number Diff line change
Expand Up @@ -30,5 +30,8 @@ export async function registerOtelLoggerProvider(resource?: IResource, otelLogsU
);

otelLogs.setGlobalLoggerProvider(loggerProvider);

console.log('LOGGING TRASH');
loggerProvider.getLogger('test').emit({ body: 'Test log', severityNumber: 33 } as any);
return loggerProvider;
}
12 changes: 1 addition & 11 deletions yarn-project/telemetry-client/src/otel_resource.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@
import { awsEc2Detector, awsEcsDetector } from '@opentelemetry/resource-detector-aws';
import {
type IResource,
detectResourcesSync,
Expand All @@ -11,17 +10,8 @@ import {
import { aztecDetector } from './aztec_resource_detector.js';

export async function getOtelResource(): Promise<IResource> {
// TODO(palla/log): Do we really need *all* this info?
const resource = detectResourcesSync({
detectors: [
osDetectorSync,
envDetectorSync,
processDetectorSync,
serviceInstanceIdDetectorSync,
awsEc2Detector,
awsEcsDetector,
aztecDetector,
],
detectors: [osDetectorSync, envDetectorSync, processDetectorSync, serviceInstanceIdDetectorSync, aztecDetector],
});

if (resource.asyncAttributesPending) {
Expand Down

0 comments on commit 84a3673

Please sign in to comment.