Struct FlowNameManager

pub struct FlowNameManager {
    kv_backend: KvBackendRef,
}

The manager of FlowNameKey.

Fields

kv_backend: KvBackendRef

Implementations

impl FlowNameManager

pub fn new(kv_backend: KvBackendRef) -> Self

Returns a new FlowNameManager.

pub async fn get( &self, catalog: &str, flow: &str, ) -> Result<Option<FlowNameValue>>

Returns the FlowNameValue of specified catalog.flow.

pub async fn flow_names( &self, catalog: &str, ) -> BoxStream<'static, Result<(String, FlowNameValue)>>

Return all flows’ names and ids

pub async fn exists(&self, catalog: &str, flow: &str) -> Result<bool>

Returns true if the flow exists.

pub fn build_create_txn( &self, catalog_name: &str, flow_name: &str, flow_id: FlowId, ) -> Result<(Txn, impl FnOnce(&mut TxnOpGetResponseSet) -> Result<Option<DeserializedValueWithBytes<FlowNameValue>>>)>

Builds a create flow name transaction. It’s expected that the __flow/name/{catalog}/{flow_name} wasn’t occupied. Otherwise, the transaction will retrieve existing value.

pub fn build_update_txn( &self, catalog_name: &str, flow_name: &str, flow_id: FlowId, ) -> Result<(Txn, impl FnOnce(&mut TxnOpGetResponseSet) -> Result<Option<DeserializedValueWithBytes<FlowNameValue>>>)>

Builds a update flow name transaction. Which doesn’t change either the name or id, just checking if they are the same. It’s expected that the __flow/name/{catalog}/{flow_name} IS already occupied, and both flow name and flow id is the same. Otherwise, the transaction will retrieve existing value(and fail).