Struct mz_storage_client::controller::CollectionDescription

pub struct CollectionDescription<T> {
    pub desc: RelationDesc,
    pub data_source: DataSource,
    pub since: Option<Antichain<T>>,
    pub status_collection_id: Option<GlobalId>,
}

Describes a request to create a source.

Fields

desc: RelationDesc

The schema of this collection

data_source: DataSource

The source of this collection’s data.

since: Option<Antichain<T>>

An optional frontier to which the collection’s since should be advanced.

status_collection_id: Option<GlobalId>

A GlobalId to use for this collection to use for the status collection. Used to keep track of source status/error information.

Implementations

impl<T> CollectionDescription<T>

fn get_storage_dependencies(&self) -> Vec<GlobalId>

Returns IDs for all storage objects that this CollectionDescription depends on.

TODO: @sean: This is where the remap shard would slot in.

Trait Implementations

impl<T: Clone> Clone for CollectionDescription<T>

fn clone(&self) -> CollectionDescription<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for CollectionDescription<T>

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

Formats the value using the given formatter.

impl<T> From<RelationDesc> for CollectionDescription<T>

fn from(desc: RelationDesc) -> Self

Converts to this type from the input type.

impl<T: PartialEq> PartialEq<CollectionDescription<T>> for CollectionDescription<T>

fn eq(&self, other: &CollectionDescription<T>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<T: Eq> Eq for CollectionDescription<T>

impl<T> StructuralEq for CollectionDescription<T>

impl<T> StructuralPartialEq for CollectionDescription<T>