Struct mz_storage_client::controller::collection_mgmt::CollectionManager

pub struct CollectionManager {
    collections: Arc<Mutex<BTreeSet<GlobalId>>>,
    tx: Sender<(GlobalId, Vec<(Row, Diff)>)>,
}

Fields

collections: Arc<Mutex<BTreeSet<GlobalId>>>

tx: Sender<(GlobalId, Vec<(Row, Diff)>)>

Implementations

impl CollectionManager

The CollectionManager provides two complementary functions:

• Providing an API to append values to a registered set of collections. For this usecase:
  • The CollectionManager expects to be the only writer.
  • Appending to a closed collection panics
• Automatically advancing the timestamp of managed collections every second. For this usecase:
  • The CollectionManager handles contention by permitting and ignoring errors.
  • Closed collections will not panic if they continue receiving these requests.

pub(super) fn new<T: Timestamp + Lattice + Codec64 + From<EpochMillis> + TimestampManipulation>(
    write_handle: PersistWriteWorker<T>,
    now: NowFn
) -> CollectionManager

pub(super) async fn register_collection(&self, id: GlobalId)

Registers the collection as one that CollectionManager will:

• Automatically advance the upper of every second
• Accept appends for. However, note that when appending, the CollectionManager expects to be the only writer.

pub(super) async fn append_to_collection(
    &self,
    id: GlobalId,
    updates: Vec<(Row, Diff)>
)

Appends updates to the collection correlated with id.

Panics

• If id does not belong to managed collections.
• If there is contention to write to the collection identified by id.
• If the collection closed.

Trait Implementations

impl Clone for CollectionManager

fn clone(&self) -> CollectionManager

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CollectionManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.