otel.h

Go to the documentation of this file.

#pragma once
#include <ascii-chat/asciichat_errno.h>
#include <stdarg.h>
#include <stdbool.h>
#include <ascii-chat/stats/stats.h>
typedef enum {
#define ASCII_OTEL_OPERATION(id, name, realtime) ASCII_OTEL_##id,
#include <ascii-chat/otel_operations.def>
#undef ASCII_OTEL_OPERATION
  ASCII_OTEL_OPERATION_COUNT
} ascii_otel_operation_t;
typedef enum {
#define ASCII_OTEL_METRIC(id, name, type, unit) ASCII_OTEL_METRIC_##id,
#include <ascii-chat/otel_metrics.def>
#undef ASCII_OTEL_METRIC
  ASCII_OTEL_METRIC_COUNT
} ascii_otel_metric_t;
#ifndef __EMSCRIPTEN__
#include <gotel/gotel.h>
typedef struct ascii_otel_scope {
  gotel_scope_t scope;
  bool retained;
  struct ascii_otel_scope *previous;
} ascii_otel_scope_t;
asciichat_error_t ascii_otel_init(const char *mode, int argc, char **argv);
void ascii_otel_shutdown(void);
bool ascii_otel_enabled(void);
const char *ascii_otel_current_operation(void);
void ascii_otel_metric(ascii_otel_metric_t metric, double value);
void ascii_otel_stats_attach(stats_scope_t *scope);
ascii_otel_metric_t ascii_otel_stats_metric(stats_record_kind_t kind, unsigned id);
void ascii_otel_ui_usage(const char *screen, const char *event, uint64_t duration_ns);
void ascii_otel_call_session_used(const char *session_string);
void ascii_otel_packet(ascii_otel_scope_t *scope, uint16_t type, size_t payload_size, const char *action,
                       int transport);
void ascii_otel_exit(int code);
void ascii_otel_frame_rejected(const char *validator, const char *reason, size_t bytes, uint32_t width, uint32_t height,
                               asciichat_error_t code);
gotel_context_t ascii_otel_context(void);
void ascii_otel_scope_int(ascii_otel_scope_t *scope, const char *key, int64_t value);
void ascii_otel_scope_string(ascii_otel_scope_t *scope, const char *key, const char *value);
void ascii_otel_scope_parent(ascii_otel_scope_t *scope, ascii_otel_operation_t operation,
                             const gotel_context_t *parent);
void ascii_otel_scope_begin(ascii_otel_scope_t *scope, ascii_otel_operation_t operation);
void ascii_otel_scope_end(ascii_otel_scope_t *scope);
void ascii_otel_log(int level, const char *file, int line, const char *function, const char *format, va_list args);
void ascii_otel_error(const char *message);
void ascii_otel_error_code(asciichat_error_t code, const char *message);
ascii_otel_operation_t ascii_otel_failure_operation(asciichat_error_t code, const char *origin);
double ascii_otel_pipeline_age(uint64_t now, uint64_t capture, uint64_t progress, bool expected);
// Stages: capture=0 (expected bits: display=1, encode=2), display=1, encode=2, stop=3.
void ascii_otel_pipeline_progress(unsigned stage, unsigned expected);
void ascii_otel_http(ascii_otel_scope_t *scope, const char *hostname, const char *path);
void ascii_otel_http_status(ascii_otel_scope_t *scope, int status);
void ascii_otel_sqlite(sqlite3 *db, const gotel_query_t *queries, size_t count);
void ascii_otel_sqlite_catalog(sqlite3 *db, const gotel_query_catalog_t *catalog);

int ascii_otel_sqlite_prepare(sqlite3 *db, const char *sql, sqlite3_stmt **statement);
 
#define ASCII_OTEL_ATTR_STRING(key, value) ascii_otel_scope_string(&otel_scope, key, value)
#define ASCII_OTEL_ATTR_INT(key, value) ascii_otel_scope_int(&otel_scope, key, value)
#define ASCII_OTEL_PACKET(type, size, action, transport) ascii_otel_packet(&otel_scope, type, size, action, transport)
#define ASCII_OTEL_SCOPE_PARENT(id, parent)                                                                            \
  ascii_otel_scope_t otel_scope __attribute__((cleanup(ascii_otel_scope_end))) = {0};                                  \
  ascii_otel_scope_parent(&otel_scope, ASCII_OTEL_##id, parent)
#define ASCII_OTEL_SCOPE(id)                                                                                           \
  ascii_otel_scope_t otel_scope __attribute__((cleanup(ascii_otel_scope_end))) = {0};                                  \
  ascii_otel_scope_begin(&otel_scope, ASCII_OTEL_##id)
#else
#define ASCII_OTEL_ATTR_STRING(key, value) ((void)(key), (void)(value))
#define ASCII_OTEL_ATTR_INT(key, value) ((void)(key), (void)(value))
#define ASCII_OTEL_PACKET(type, size, action, transport) ((void)0)
#define ascii_otel_frame_rejected(validator, reason, bytes, width, height, code)                                       \
  ((void)(validator), (void)(reason), (void)(bytes), (void)(width), (void)(height), (void)(code))
#define ascii_otel_pipeline_progress(stage, expected) ((void)(stage), (void)(expected))
#define ascii_otel_ui_usage(screen, event, duration_ns) ((void)(screen), (void)(event), (void)(duration_ns))
#define ascii_otel_sqlite_prepare(db, sql, statement) sqlite3_prepare_v2(db, sql, -1, statement, NULL)
#define ascii_otel_enabled() false
#define ascii_otel_current_operation() ""
#define ascii_otel_call_session_used(session_string) ((void)(session_string))
#define ascii_otel_metric(metric, value) ((void)(metric), (void)(value))
#define ascii_otel_stats_attach(scope) ((void)(scope))
#define ASCII_OTEL_SCOPE_PARENT(id, parent) ((void)0)
#define ASCII_OTEL_SCOPE(id) ((void)0)
#endif
 
// Test executables may link the ordinary library; never initialize its exporter.
#if !defined(ASCIICHAT_OTEL_IMPLEMENTATION) && (defined(TESTING) || defined(CRITERION_TEST) || defined(__CRITERION__))
#define ascii_otel_init(mode, argc, argv) ((void)(mode), (void)(argc), (void)(argv), ASCIICHAT_OK)
#endif