Enum Chain

Source
pub enum Chain<State, Txn, FE, T> {
    Block(BlockChain<State, Txn, FE, T>),
    Sync(SyncChain<State, Txn, FE, T>),
}
Expand description

A data structure responsible for maintaining the integrity of a mutable subject.

Variants§

§

Block(BlockChain<State, Txn, FE, T>)

§

Sync(SyncChain<State, Txn, FE, T>)

Trait Implementations§

Source§

impl<State, T> AsyncHash for Chain<State, State::Txn, State::FE, T>
where State: StateInstance, State::FE: AsType<ChainBlock> + for<'a> FileSave<'a> + ThreadSafe, T: AsyncHash + Send + Sync,

Source§

fn hash<'life0, 'async_trait>( &'life0 self, txn_id: TxnId, ) -> Pin<Box<dyn Future<Output = TCResult<Output<Sha256>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Compute the hash of this state as of a given TxnId
Source§

impl<State, T> ChainInstance<State, T> for Chain<State, State::Txn, State::FE, T>
where State: StateInstance, State::FE: for<'a> FileSave<'a> + CacheBlock, T: Persist<State::FE, Txn = State::Txn> + Route<State> + Debug, Collection<State::Txn, State::FE>: TryCastFrom<State>, Scalar: TryCastFrom<State>,

Source§

fn append_delete(&self, txn_id: TxnId, key: Value) -> TCResult<()>

Append the given DELETE op to the latest block in this Chain.
Source§

fn append_put(&self, txn: State::Txn, key: Value, value: State) -> TCResult<()>

Append the given PUT op to the latest block in this Chain.
Source§

fn subject(&self) -> &T

Borrow the subject of this Chain.
Source§

impl<State, Txn, FE, T> Clone for Chain<State, Txn, FE, T>
where T: Clone,

Source§

fn clone(&self) -> Self

Returns a copy of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

impl<State, T> CopyFrom<<State as StateInstance>::FE, Chain<State, <State as StateInstance>::Txn, <State as StateInstance>::FE, T>> for Chain<State, State::Txn, State::FE, T>
where State: StateInstance, State::FE: CacheBlock + for<'a> FileSave<'a>, T: Persist<State::FE, Txn = State::Txn> + Route<State> + Debug,

Source§

fn copy_from<'life0, 'async_trait>( txn: &'life0 State::Txn, store: Dir<State::FE>, instance: Self, ) -> Pin<Box<dyn Future<Output = TCResult<Self>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Copy a new instance of Self from an existing instance.
Source§

impl<State, Txn, FE, T> Debug for Chain<State, Txn, FE, T>

Source§

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

Formats the value using the given formatter. Read more
Source§

impl<State, Txn, FE, T> From<BlockChain<State, Txn, FE, T>> for Chain<State, Txn, FE, T>

Source§

fn from(chain: BlockChain<State, Txn, FE, T>) -> Self

Converts to this type from the input type.
Source§

impl<State, T> FromStream for Chain<State, State::Txn, State::FE, T>
where State: StateInstance + FromStream<Context = State::Txn> + From<Collection<State::Txn, State::FE>> + From<Scalar>, State::FE: CacheBlock + for<'a> FileSave<'a>, T: Route<State> + FromStream<Context = State::Txn> + Debug, (Bytes, Map<Tuple<State>>): TryCastFrom<State>, Collection<State::Txn, State::FE>: TryCastFrom<State>, Scalar: TryCastFrom<State>, Value: TryCastFrom<State>, (Value,): TryCastFrom<State>, (Value, State): TryCastFrom<State>,

Source§

type Context = <State as StateInstance>::Txn

The decoding context of this type, useful in situations where the stream to be decoded may be too large to hold in main memory. Read more
Source§

fn from_stream<'life0, 'async_trait, D>( txn: State::Txn, decoder: &'life0 mut D, ) -> Pin<Box<dyn Future<Output = Result<Self, D::Error>> + Send + 'async_trait>>
where D: 'async_trait + Decoder, Self: 'async_trait, 'life0: 'async_trait,

Parse this value using the given Decoder.
Source§

impl<State, Txn, FE, T> Instance for Chain<State, Txn, FE, T>
where State: Send + Sync, Txn: Send + Sync, FE: Send + Sync, T: Send + Sync,

Source§

type Class = ChainType

The Class type of this instance
Source§

fn class(&self) -> Self::Class

Returns the [Class] of this instance.
Source§

impl<'en, State, T> IntoView<'en, <State as StateInstance>::FE> for Chain<State, State::Txn, State::FE, T>
where State: StateInstance, T: IntoView<'en, State::FE, Txn = State::Txn> + Send + Sync + 'en, BlockChain<State, State::Txn, State::FE, T>: IntoView<'en, State::FE, View = (T::View, SeqStream<TCResult<(Bytes, MapStream<TxnId, TCResult<SeqStream<TCResult<MutationView<'en>>, TCBoxTryStream<'en, MutationView<'en>>>>, TCBoxStream<'en, (TxnId, TCResult<SeqStream<TCResult<MutationView<'en>>, TCBoxTryStream<'en, MutationView<'en>>>>)>>)>, TCBoxTryStream<'en, (Bytes, MapStream<TxnId, TCResult<SeqStream<TCResult<MutationView<'en>>, TCBoxTryStream<'en, MutationView<'en>>>>, TCBoxStream<'en, (TxnId, TCResult<SeqStream<TCResult<MutationView<'en>>, TCBoxTryStream<'en, MutationView<'en>>>>)>>)>>), Txn = State::Txn> + Send + Sync, SyncChain<State, State::Txn, State::FE, T>: IntoView<'en, State::FE, View = T::View, Txn = State::Txn> + Send + Sync,

Source§

type Txn = <State as StateInstance>::Txn

The type of Transaction which this state supports
Source§

type View = ChainView<'en, <T as IntoView<'en, <State as StateInstance>::FE>>::View>

The type of encodable view returned by into_view
Source§

fn into_view<'async_trait>( self, txn: Self::Txn, ) -> Pin<Box<dyn Future<Output = TCResult<Self::View>> + Send + 'async_trait>>
where Self: 'async_trait,

Return a View which can be encoded with en::IntoStream.
Source§

impl<State, T> Persist<<State as StateInstance>::FE> for Chain<State, State::Txn, State::FE, T>
where State: StateInstance, State::FE: CacheBlock + for<'a> FileSave<'a>, T: Persist<State::FE, Txn = State::Txn> + Route<State> + Debug,

Source§

type Txn = <State as StateInstance>::Txn

Source§

type Schema = (ChainType, <T as Persist<<State as StateInstance>::FE>>::Schema)

Source§

fn create<'async_trait>( txn_id: TxnId, schema: Self::Schema, store: Dir<State::FE>, ) -> Pin<Box<dyn Future<Output = TCResult<Self>> + Send + 'async_trait>>
where Self: 'async_trait,

Create a new instance of Self from an empty Store.
Source§

fn load<'async_trait>( txn_id: TxnId, schema: Self::Schema, store: Dir<State::FE>, ) -> Pin<Box<dyn Future<Output = TCResult<Self>> + Send + 'async_trait>>
where Self: 'async_trait,

Load a saved instance of Self from persistent storage. Should only be invoked at startup time.
Source§

fn dir(&self) -> Inner<State::FE>

Access the filesystem directory backing this persistent data structure.
Source§

fn load_or_create<'async_trait>( txn_id: TxnId, schema: Self::Schema, store: Dir<FE>, ) -> Pin<Box<dyn Future<Output = Result<Self, TCError>> + Send + 'async_trait>>
where Self: Send + 'async_trait,

Load a saved instance of Self from persistent storage if present, or create a new one.
Source§

impl<State, T> Recover<<State as StateInstance>::FE> for Chain<State, State::Txn, State::FE, T>
where State: StateInstance + From<Collection<State::Txn, State::FE>> + From<Scalar>, State::FE: CacheBlock + for<'a> FileSave<'a>, T: Route<State> + Debug + Send + Sync, Collection<State::Txn, State::FE>: TryCastFrom<State>, Scalar: TryCastFrom<State>,

Source§

type Txn = <State as StateInstance>::Txn

Source§

fn recover<'life0, 'life1, 'async_trait>( &'life0 self, txn: &'life1 State::Txn, ) -> Pin<Box<dyn Future<Output = TCResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Recover this state after loading, in case the last transaction failed or was interrupted.
Source§

impl<State> Replicate<<State as StateInstance>::Txn> for Chain<State, State::Txn, State::FE, CollectionBase<State::Txn, State::FE>>
where State: StateInstance + From<Collection<State::Txn, State::FE>> + From<Scalar>, State::FE: CacheBlock, Collection<State::Txn, State::FE>: TryCastFrom<State>, CollectionBase<State::Txn, State::FE>: Route<State> + TryCastFrom<State>, Scalar: TryCastFrom<State>, BlockChain<State, State::Txn, State::FE, CollectionBase<State::Txn, State::FE>>: TryCastFrom<State>, SyncChain<State, State::Txn, State::FE, CollectionBase<State::Txn, State::FE>>: TryCastFrom<State>,

Source§

fn replicate<'life0, 'life1, 'async_trait>( &'life0 self, txn: &'life1 State::Txn, source: Link, ) -> Pin<Box<dyn Future<Output = TCResult<Output<Sha256>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update the state of this replica from the given source.
Source§

impl<State, T> Route<State> for Chain<State, State::Txn, State::FE, T>
where State: StateInstance, T: Persist<State::FE, Txn = State::Txn> + Route<State> + Clone + Debug, Self: ChainInstance<State, T>,

Source§

fn route<'a>( &'a self, path: &'a [PathSegment], ) -> Option<Box<dyn Handler<'a, State> + 'a>>

Source§

impl<State, T> Transact for Chain<State, State::Txn, State::FE, T>
where State: StateInstance, State::FE: CacheBlock + for<'a> FileSave<'a>, T: Persist<State::FE, Txn = State::Txn> + Route<State> + Transact + Debug,

Source§

type Commit = <T as Transact>::Commit

A guard which blocks concurrent commits
Source§

fn commit<'life0, 'async_trait>( &'life0 self, txn_id: TxnId, ) -> Pin<Box<dyn Future<Output = Self::Commit> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Commit this transaction.
Source§

fn rollback<'life0, 'life1, 'async_trait>( &'life0 self, txn_id: &'life1 TxnId, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Roll back this transaction.
Source§

fn finalize<'life0, 'life1, 'async_trait>( &'life0 self, txn_id: &'life1 TxnId, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete any version data specific to this transaction.

Auto Trait Implementations§

§

impl<State, Txn, FE, T> Freeze for Chain<State, Txn, FE, T>
where T: Freeze,

§

impl<State, Txn, FE, T> !RefUnwindSafe for Chain<State, Txn, FE, T>

§

impl<State, Txn, FE, T> Send for Chain<State, Txn, FE, T>
where T: Send, State: Send, Txn: Send, FE: Send + Sync,

§

impl<State, Txn, FE, T> Sync for Chain<State, Txn, FE, T>
where T: Sync, State: Sync, Txn: Sync, FE: Send + Sync,

§

impl<State, Txn, FE, T> Unpin for Chain<State, Txn, FE, T>
where T: Unpin, State: Unpin, Txn: Unpin,

§

impl<State, Txn, FE, T> !UnwindSafe for Chain<State, Txn, FE, T>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<F, T> CastFrom<F> for T
where T: From<F>,

Source§

fn cast_from(f: F) -> T

Cast an instance of T into an instance of Self.
Source§

impl<T, F> CastInto<F> for T
where F: CastFrom<T>,

Source§

fn cast_into(self) -> F

Cast an instance of Self into an instance of T.
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<'en, T> FileLoad for T
where T: FromStream<Context = ()> + Send + Sync + 'static,

Source§

fn load<'life0, 'async_trait>( _path: &'life0 Path, file: File, _metadata: Metadata, ) -> Pin<Box<dyn Future<Output = Result<T, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, T: 'async_trait,

Load this state from the given file.
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<F> Match for F

Source§

fn matches<T>(&self) -> bool
where T: TryCastFrom<Self>,

Returns true if self can be cast into the target type T.
Source§

impl<State, T> Public<State> for T
where State: StateInstance, T: Route<State> + Debug,

Source§

fn get<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, txn: &'life1 <State as StateInstance>::Txn, path: &'life2 [Id], key: Value, ) -> Pin<Box<dyn Future<Output = Result<State, TCError>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, T: 'async_trait,

Source§

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, txn: &'life1 <State as StateInstance>::Txn, path: &'life2 [Id], key: Value, value: State, ) -> Pin<Box<dyn Future<Output = Result<(), TCError>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, T: 'async_trait,

Source§

fn post<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, txn: &'life1 <State as StateInstance>::Txn, path: &'life2 [Id], params: Map<State>, ) -> Pin<Box<dyn Future<Output = Result<State, TCError>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, T: 'async_trait,

Source§

fn delete<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, txn: &'life1 <State as StateInstance>::Txn, path: &'life2 [Id], key: Value, ) -> Pin<Box<dyn Future<Output = Result<(), TCError>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, T: 'async_trait,

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<State, T> ToState<State> for T
where State: StateInstance, T: Clone + Into<State>,

Source§

fn to_state(&self) -> State

Source§

impl<F, T> TryCastFrom<F> for T
where T: CastFrom<F>,

Source§

fn can_cast_from(_: &F) -> bool

Test if value can be cast into Self.
Source§

fn opt_cast_from(f: F) -> Option<T>

Returns Some(Self) if the source value can be cast into Self, otherwise None.
Source§

fn try_cast_from<Err, OnErr>(value: T, on_err: OnErr) -> Result<Self, Err>
where OnErr: FnOnce(&T) -> Err,

Returns Ok(Self) if the source value can be cast into Self, otherwise calls on_err.
Source§

impl<F, T> TryCastInto<T> for F
where T: TryCastFrom<F>,

Source§

fn can_cast_into(&self) -> bool

Test if self can be cast into T.
Source§

fn opt_cast_into(self) -> Option<T>

Returns Some(T) if self can be cast into T, otherwise None.
Source§

fn try_cast_into<Err, OnErr>(self, on_err: OnErr) -> Result<T, Err>
where OnErr: FnOnce(&Self) -> Err,

Returns Ok(T) if self can be cast into T, otherwise calls on_err.
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> ThreadSafe for T
where T: Send + Sync + 'static,