Source
pub async fn drop_datasink( &self, name: String, ) -> Result<DropDatasinkResponse, KineticaError>
Drop an existing data sink
Drops an existing data sink.
By default, if any table monitors use this sink as a destination, the request will be blocked unless option clear_table_monitors is true.
name- Name of the data sink to be dropped. Must be an existing data sink.
Source
pub async fn drop_datasink_with_opts( &self, name: String, options: DropDatasinkRequestOptions, ) -> Result<DropDatasinkResponse, KineticaError>
Drop an existing data sink
Drops an existing data sink.
By default, if any table monitors use this sink as a destination, the request will be blocked unless option clear_table_monitors is true.
name- Name of the data sink to be dropped. Must be an existing data sink.options- The optional parameters; any left unset take the server’s defaults.
Source
pub async fn drop_datasink_raw( &self, request: &DropDatasinkRequest, ) -> Result<DropDatasinkResponse, KineticaError>
Sends a pre-built DropDatasinkRequest to the /drop/datasink endpoint.
Source
pub async fn drop_datasink_from_url( &self, url: &str, request: &DropDatasinkRequest, ) -> Result<DropDatasinkResponse, KineticaError>
Sends a pre-built DropDatasinkRequest to a specific worker URL, bypassing HA head-node selection. Used for multi-head access.