Skip to content

Commit cd4491a

Browse files
committed
Add counter telemetry(WIP)
Signed-off-by: Rohit Dandamudi <[email protected]>
1 parent c28929f commit cd4491a

File tree

5 files changed

+16
-0
lines changed

5 files changed

+16
-0
lines changed

Cargo.lock

Lines changed: 1 addition & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

crates/key-value/Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@ tokio = { version = "1", features = ["macros", "sync", "rt"] }
1313
spin-app = { path = "../app" }
1414
spin-core = { path = "../core" }
1515
spin-world = { path = "../world" }
16+
spin-telemetry = { path = "../telemetry" }
1617
table = { path = "../table" }
1718
tracing = { workspace = true }
1819
lru = "0.9.0"

crates/key-value/src/lib.rs

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -98,6 +98,9 @@ impl key_value::HostStore for KeyValueDispatch {
9898
store: Resource<key_value::Store>,
9999
key: String,
100100
) -> Result<Result<Option<Vec<u8>>, Error>> {
101+
// Log key value host component get feature
102+
spin_telemetry::counter!(spin.key_value_get = 1, key = key);
103+
101104
let store = self.get_store(store)?;
102105
Ok(store.get(&key).await)
103106
}
@@ -108,6 +111,9 @@ impl key_value::HostStore for KeyValueDispatch {
108111
key: String,
109112
value: Vec<u8>,
110113
) -> Result<Result<(), Error>> {
114+
// Log key value host component set feature
115+
spin_telemetry::counter!(spin.key_value_set = 1, key = key);
116+
111117
let store = self.get_store(store)?;
112118
Ok(store.set(&key, &value).await)
113119
}

crates/llm-remote-http/src/lib.rs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,13 @@ impl RemoteHttpLlmEngine {
7070
);
7171
spin_telemetry::inject_trace_context(&mut headers);
7272

73+
// capturing llm host component metrics
74+
spin_telemetry::counter!(
75+
spin.llm_infer = 1,
76+
model_name = model,
77+
prompt_given = prompt
78+
);
79+
7380
let inference_options = InferRequestBodyParams {
7481
max_tokens: params.max_tokens,
7582
repeat_penalty: params.repeat_penalty,

examples/spin-timer/Cargo.lock

Lines changed: 1 addition & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)