Struct WorkTable

pub struct WorkTable<Row, PrimaryKey, AvailableTypes = (), SecondaryIndexes = (), LockType = (), PkGen = <PrimaryKey as TablePrimaryKey>::Generator, PkNodeType = Vec<Pair<PrimaryKey, Link>>, const DATA_LENGTH: usize = INNER_PAGE_SIZE>
where
    PrimaryKey: Clone + Ord + Send + 'static + Hash,
    Row: StorableRow,
    PkNodeType: NodeLike<Pair<PrimaryKey, Link>> + Send + 'static,
{
    pub data: DataPages<Row, DATA_LENGTH>,
    pub pk_map: IndexMap<PrimaryKey, Link, PkNodeType>,
    pub indexes: SecondaryIndexes,
    pub pk_gen: PkGen,
    pub lock_map: LockMap<LockType, PrimaryKey>,
    pub table_name: &'static str,
    pub pk_phantom: PhantomData<PrimaryKey>,
    pub types_phantom: PhantomData<AvailableTypes>,
}

Fields

data: DataPages<Row, DATA_LENGTH>

pk_map: IndexMap<PrimaryKey, Link, PkNodeType>

indexes: SecondaryIndexes

pk_gen: PkGen

lock_map: LockMap<LockType, PrimaryKey>

table_name: &'static str

pk_phantom: PhantomData<PrimaryKey>

types_phantom: PhantomData<AvailableTypes>

Implementations

impl<Row, PrimaryKey, AvailableTypes, SecondaryIndexes, LockType, PkGen, PkNodeType, const DATA_LENGTH: usize> WorkTable<Row, PrimaryKey, AvailableTypes, SecondaryIndexes, LockType, PkGen, PkNodeType, DATA_LENGTH>

where Row: TableRow<PrimaryKey> + StorableRow, PrimaryKey: Clone + Ord + Send + TablePrimaryKey + Hash, PkNodeType: NodeLike<Pair<PrimaryKey, Link>> + Send + 'static, <Row as StorableRow>::WrappedRow: RowWrapper<Row>,

pub fn get_next_pk(&self) -> PrimaryKey

where PkGen: PrimaryKeyGenerator<PrimaryKey>,

pub fn select(&self, pk: PrimaryKey) -> Option<Row>

where LockType: 'static, Row: Archive + for<'a> Serialize<Strategy<Serializer<AlignedVec, ArenaHandle<'a>, Share>, Error>>, <<Row as StorableRow>::WrappedRow as Archive>::Archived: Deserialize<<Row as StorableRow>::WrappedRow, HighDeserializer<Error>>,

Selects Row from table identified with provided primary key. Returns None if no value presented.

pub fn insert(&self, row: Row) -> Result<PrimaryKey, WorkTableError>

where Row: Archive + Clone + for<'a> Serialize<Strategy<Serializer<AlignedVec, ArenaHandle<'a>, Share>, Error>>, <Row as StorableRow>::WrappedRow: Archive + for<'a> Serialize<Strategy<Serializer<AlignedVec, ArenaHandle<'a>, Share>, Error>>, PrimaryKey: Clone, AvailableTypes: 'static, SecondaryIndexes: TableSecondaryIndex<Row, AvailableTypes>, LockType: 'static,

pub fn insert_cdc<SecondaryEvents>( &self, row: Row, ) -> Result<(PrimaryKey, Operation<<PkGen as PrimaryKeyGeneratorState>::State, PrimaryKey, SecondaryEvents>), WorkTableError>

where Row: Archive + Clone + for<'a> Serialize<Strategy<Serializer<AlignedVec, ArenaHandle<'a>, Share>, Error>>, <Row as StorableRow>::WrappedRow: Archive + for<'a> Serialize<Strategy<Serializer<AlignedVec, ArenaHandle<'a>, Share>, Error>>, PrimaryKey: Clone, SecondaryIndexes: TableSecondaryIndex<Row, AvailableTypes> + TableSecondaryIndexCdc<Row, AvailableTypes, SecondaryEvents>, PkGen: PrimaryKeyGeneratorState,

Trait Implementations

impl<Row, PrimaryKey, AvailableTypes: Debug, SecondaryIndexes: Debug, LockType: Debug, PkGen: Debug, PkNodeType, const DATA_LENGTH: usize> Debug for WorkTable<Row, PrimaryKey, AvailableTypes, SecondaryIndexes, LockType, PkGen, PkNodeType, DATA_LENGTH>

where PrimaryKey: Clone + Ord + Send + 'static + Hash + Debug, Row: StorableRow + Debug, PkNodeType: NodeLike<Pair<PrimaryKey, Link>> + Send + 'static + Debug,

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

Formats the value using the given formatter.

impl<Row, PrimaryKey, AvailableTypes, SecondaryIndexes, LockType, PkGen, PkNodeType, const DATA_LENGTH: usize> Default for WorkTable<Row, PrimaryKey, AvailableTypes, SecondaryIndexes, LockType, PkGen, PkNodeType, DATA_LENGTH>

where PrimaryKey: Clone + Ord + Send + TablePrimaryKey + Hash, SecondaryIndexes: Default, PkGen: Default, PkNodeType: NodeLike<Pair<PrimaryKey, Link>> + Send + 'static, Row: StorableRow, <Row as StorableRow>::WrappedRow: RowWrapper<Row>,

fn default() -> Self

Returns the “default value” for a type.