risingwave_storage::hummock::utils

Function do_insert_sanity_check

source
pub(crate) async fn do_insert_sanity_check(
    key: &TableKey<Bytes>,
    value: &Bytes,
    inner: &impl StateStoreRead,
    epoch: u64,
    table_id: TableId,
    table_option: TableOption,
    op_consistency_level: &OpConsistencyLevel,
) -> StorageResult<()>
Expand description

Make sure the key to insert should not exist in storage.