diff options
| author | 童宗振 <[email protected]> | 2024-04-16 09:57:09 +0000 |
|---|---|---|
| committer | 童宗振 <[email protected]> | 2024-04-16 09:57:09 +0000 |
| commit | 134ef8b0b14ef76c6c0fec7e998196b19e73722a (patch) | |
| tree | 4d77704cce1a6d6ad03be51441021392e8448296 /include/job_ctx.h | |
| parent | 1f413abebc4c2b8b7b6457a717a9d9d7c6b74ae7 (diff) | |
Adjust file path
Diffstat (limited to 'include/job_ctx.h')
| -rw-r--r-- | include/job_ctx.h | 21 |
1 files changed, 21 insertions, 0 deletions
diff --git a/include/job_ctx.h b/include/job_ctx.h new file mode 100644 index 0000000..6ce69f4 --- /dev/null +++ b/include/job_ctx.h @@ -0,0 +1,21 @@ +#pragma once +#include "marsio.h" +#include <uuid/uuid.h> + +struct dp_trace_telemetry_desc +{ + uuid_t uuid; + char job_name[128]; + struct dp_trace_job_desc job_desc; +}; + +void job_rule_apply(struct dp_trace_job_desc desc[], unsigned int nr_desc, uint8_t role); +int job_id_to_index(job_bitmap_t job_id); +job_bitmap_t index_to_job_id(unsigned int index); +int is_job_id_used(job_bitmap_t job_id); +uint8_t job_id_role_get(job_bitmap_t job_id); + +void telemetry_job_add_cb(const char * table_name, int table_id, const char * key, const char * table_line, void ** ad, + long argl, void * argp); +void telemetry_job_del_cb(int table_id, void ** ad, long argl, void * argp); +void telemetry_job_uuid_get(job_bitmap_t job_id, unsigned char * uu);
\ No newline at end of file |
