Expand description
a runtime to watch for new points from other processes or threads
Modules
- (rust only) lk_watch takes the callback PktHandler which are quick to impl with cb and try_cb. Other languages should use their own function syntax as argument to lk_watch. *
Structs
- The linkspace runtime.
- miscellaneous information about the runtime
Functions
- get the first result from the database matching the query.
- Run callback for every match for the query in the database. Break early if the callback returns true. returns number of matches if return from break return is -1*Number of matches If break => number of matches If no break ( cb only returned false ) => -1 * Number of matches
- todo
- read a single packet directly without copying when possible. *
- get LkInfo of a linkspace runtime
- iterate over all active (Qid,Query)
- open a linkspace runtime.
- process the log of new packets and trigger callbacks. Updates the reader to the latest state.
- continuously process callbacks until:
- save a packet. Returns true if new and false if its old.
- save multiple packets at once - returns the number of new packets written
- returns the range [incusive,exclusive) of recv stamps used to save new packets. total_new = r.1-r.0
- close lk_watch watches based on the query id ‘:qid:example’ in the query.
- Registers the query under its ‘qid’ ( .e.g. set by lk_query_parse(q,“:qid:myqid”) ) Before returning, calls cb for every packet in the database. The absolute return value is the number of times the callback was called. A positive value means the callback finished already.
- lk_watch with a custom log tracing::Span The span will be entered on every callback. If you do not care for structured options you can use vspan
lk_watch2(.. , .. ,.. , vspan("my function"))
- See lk_watch2