pub async fn create_table_monitor( &self, table_name: String, ) -> Result<CreateTableMonitorResponse, KineticaError>
Create a table monitor that will watch for and queue any records added
Creates a monitor that watches for a single table modification event type (insert, update, or delete) on a particular table (identified by table_name) and forwards event notifications to subscribers via ZMQ. After this call completes, subscribe to the returned topic_id on the ZMQ table monitor port (default 9002). Each time an operation of the given type on the table completes, a multipart message is published for that topic; the first part contains only the topic ID, and each subsequent part contains one binary-encoded Avro object that corresponds to the event and can be decoded using type_schema. The monitor will continue to run (regardless of whether or not there are any subscribers) until deactivated with /clear/tablemonitor.
For more information on table monitors, see Table Monitors.
table_name- Name of the table to monitor, in [schema_name.]table_name format, using standard name resolution rules.
pub async fn create_table_monitor_with_opts( &self, table_name: String, options: CreateTableMonitorRequestOptions, ) -> Result<CreateTableMonitorResponse, KineticaError>
Create a table monitor that will watch for and queue any records added
Creates a monitor that watches for a single table modification event type (insert, update, or delete) on a particular table (identified by table_name) and forwards event notifications to subscribers via ZMQ. After this call completes, subscribe to the returned topic_id on the ZMQ table monitor port (default 9002). Each time an operation of the given type on the table completes, a multipart message is published for that topic; the first part contains only the topic ID, and each subsequent part contains one binary-encoded Avro object that corresponds to the event and can be decoded using type_schema. The monitor will continue to run (regardless of whether or not there are any subscribers) until deactivated with /clear/tablemonitor.
For more information on table monitors, see Table Monitors.
table_name- Name of the table to monitor, in [schema_name.]table_name format, using standard name resolution rules.options- The optional parameters; any left unset take the server’s defaults.
pub async fn create_table_monitor_raw( &self, request: &CreateTableMonitorRequest, ) -> Result<CreateTableMonitorResponse, KineticaError>
Sends a pre-built CreateTableMonitorRequest to the /create/tablemonitor endpoint.
pub async fn create_table_monitor_from_url( &self, url: &str, request: &CreateTableMonitorRequest, ) -> Result<CreateTableMonitorResponse, KineticaError>
Sends a pre-built CreateTableMonitorRequest to a specific worker URL, bypassing HA head-node selection. Used for multi-head access.