Module linkspace::runtime

source ·
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"))