Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Add C and Python API for LDMS Schema info access #1448

Merged
merged 3 commits into from
Sep 26, 2024
Merged

Add C and Python API for LDMS Schema info access #1448

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
be4a762
Fix `char *` conversion in ldms.pyx
narategithub Mar 25, 2024
779d9a1
Fix flags check for `LDMS_V_RECORD_TYPE` in `ldms_schema_metric_add_t…
narategithub Mar 28, 2024
89e17af
Add C and Python APIs for Schema and Record Definition info access
narategithub Mar 28, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
42 changes: 39 additions & 3 deletions ldms/python/ldms.pxd
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -258,6 +258,12 @@ cdef extern from "ldms_rail.h" nogil:
__RAIL_UNLIMITED
RAIL_UNLIMITED "__RAIL_UNLIMITED"

cdef extern from "ldms_core.h" nogil:
cpdef enum :
LDMS_MDESC_F_DATA
LDMS_MDESC_F_META
LDMS_MDESC_F_RECORD

cdef extern from "ldms.h" nogil:
struct ldms_xprt:
pass
Expand Down Expand Up @@ -574,10 +580,22 @@ cdef extern from "ldms.h" nogil:
float ldms_metric_array_get_float(ldms_set_t s, int i, int idx)
double ldms_metric_array_get_double(ldms_set_t s, int i, int idx)

struct ldms_record:
pass # opaque
ctypedef ldms_record *ldms_record_t

# --- set schema --- #
struct ldms_schema_s:
pass
ctypedef ldms_schema_s *ldms_schema_t
struct ldms_metric_template_s:
const char *name
int flags
ldms_value_type type
const char *unit
uint32_t len
ldms_record_t rec_def
ctypedef ldms_metric_template_s *ldms_metric_template_t
ldms_schema_t ldms_schema_new(const char *schema_name)
void ldms_schema_delete(ldms_schema_t schema)
int ldms_schema_metric_count_get(ldms_schema_t schema)
Expand All @@ -586,12 +604,25 @@ cdef extern from "ldms.h" nogil:
const ldms_schema_t schema)
int ldms_schema_metric_add(ldms_schema_t s, const char *name,
ldms_value_type t)
int ldms_schema_metric_add_with_unit(ldms_schema_t s, const char *name,
const char *unit, ldms_value_type type);
int ldms_schema_meta_add(ldms_schema_t s, const char *name,
ldms_value_type t)
int ldms_schema_meta_add_with_unit(ldms_schema_t s, const char *name,
const char *unit, ldms_value_type t);
int ldms_schema_metric_array_add(ldms_schema_t s, const char *name,
ldms_value_type t, uint32_t count)
int ldms_schema_metric_array_add_with_unit(ldms_schema_t s, const char *name,
const char *unit, ldms_value_type t, uint32_t count);
int ldms_schema_meta_array_add(ldms_schema_t s, const char *name,
ldms_value_type t, uint32_t count)
int ldms_schema_meta_array_add_with_unit(ldms_schema_t s, const char *name,
const char *unit, ldms_value_type t, uint32_t count);

int ldms_schema_metric_template_get(ldms_schema_t schema, int mid,
ldms_metric_template_s *out);
int ldms_schema_bulk_template_get(ldms_schema_t schema, int len,
ldms_metric_template_s out[])

# --- schema hash / digest --- #
ctypedef unsigned char *ldms_digest_t
Expand Down Expand Up @@ -646,9 +677,6 @@ cdef extern from "ldms.h" nogil:
int ldms_list_purge(ldms_set_t s, ldms_mval_t lh)

# --- record related functions --- #
struct ldms_record:
pass # opaque
ctypedef ldms_record *ldms_record_t
ldms_record_t ldms_record_create(const char *name)
int ldms_record_metric_add(ldms_record_t rec_def, const char *name,
const char *unit, ldms_value_type type,
Expand All @@ -661,13 +689,15 @@ cdef extern from "ldms.h" nogil:
# --- record instance functions --- #
int ldms_list_append_record(ldms_set_t set, ldms_mval_t lh, ldms_mval_t rec_inst)
ldms_mval_t ldms_record_alloc(ldms_set_t set, int metric_id)
int ldms_record_type_get(ldms_mval_t rec_inst)
int ldms_record_card(ldms_mval_t rec_inst)
int ldms_record_metric_find(ldms_mval_t rec_inst, const char *name)
ldms_mval_t ldms_record_metric_get(ldms_mval_t rec_inst, int metric_id)
const char *ldms_record_metric_name_get(ldms_mval_t rec_inst, int metric_id)
const char *ldms_record_metric_unit_get(ldms_mval_t rec_inst, int metric_id)
ldms_value_type ldms_record_metric_type_get(ldms_mval_t rec_inst,
int metric_id, size_t *count)
int ldms_metric_flags_get(ldms_set_t s, int i)
void ldms_record_metric_set(ldms_mval_t rec_inst, int metric_id,
ldms_mval_t val)
void ldms_record_metric_array_set(ldms_mval_t rec_inst, int metric_id,
Expand Down Expand Up @@ -722,6 +752,12 @@ cdef extern from "ldms.h" nogil:
ldms_mval_t ldms_record_array_get_inst(ldms_mval_t rec_array, int idx);
int ldms_record_array_len(ldms_mval_t rec_array)

int ldms_record_metric_template_get(ldms_record_t record, int mid,
ldms_metric_template_s *out)
int ldms_record_bulk_template_get(ldms_record_t record, int len,
ldms_metric_template_s out[])
const char * ldms_record_name_get(ldms_record_t record)

# --- ldms_stream --- #
struct ldms_stream_client_s:
pass # opaque
Expand Down
Loading
Loading