Skip to main content

sink_object_exists

risingwave_meta::manager::exactly_once_util

Function sink_object_exists 

Source 
async fn sink_object_exists<C: ConnectionTrait>(
    db: &C,
    sink_id: SinkId,
) -> Result<bool, DbErr>