in sdk-java/src/main/java/com/spotify/confidence/TelemetryClientInterceptor.java [18:33]
public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) {
return new ForwardingClientCall.SimpleForwardingClientCall<>(
next.newCall(method, callOptions)) {
@Override
public void start(Listener<RespT> responseListener, Metadata headers) {
if (telemetry != null) {
final Monitoring telemetrySnapshot = telemetry.getSnapshot();
final String base64Telemetry =
Base64.getEncoder().encodeToString(telemetrySnapshot.toByteArray());
headers.put(HEADER_KEY, base64Telemetry);
}
super.start(responseListener, headers);
}
};
}