pub trait ChannelTxnT: GraphTxnT {
    type Channel: Sync + Send;
    type Changeset;
    type RevChangeset;
    type ChangesetCursor;
    type RevchangesetCursor;
    type States;
    type Tags;
    type TagsCursor;

Show 25 methods // Required methods fn name<'a>(&self, channel: &'a Self::Channel) -> &'a str; fn id<'a>(&self, c: &'a Self::Channel) -> Option<&'a RemoteId>; fn graph<'a>(&self, channel: &'a Self::Channel) -> &'a Self::Graph; fn apply_counter(&self, channel: &Self::Channel) -> u64; fn last_modified(&self, channel: &Self::Channel) -> u64; fn changes<'a>(&self, channel: &'a Self::Channel) -> &'a Self::Changeset; fn rev_changes<'a>( &self, channel: &'a Self::Channel ) -> &'a Self::RevChangeset; fn tags<'a>(&self, channel: &'a Self::Channel) -> &'a Self::Tags; fn states<'a>(&self, channel: &'a Self::Channel) -> &'a Self::States; fn get_changeset( &self, channel: &Self::Changeset, c: &ChangeId ) -> Result<Option<&L64>, TxnErr<Self::GraphError>>; fn get_revchangeset( &self, channel: &Self::RevChangeset, c: &L64 ) -> Result<Option<&Pair<ChangeId, SerializedMerkle>>, TxnErr<Self::GraphError>>; fn cursor_changeset<'txn>( &'txn self, channel: &Self::Changeset, pos: Option<ChangeId> ) -> Result<Cursor<Self, &'txn Self, Self::ChangesetCursor, ChangeId, L64>, TxnErr<Self::GraphError>>; fn cursor_changeset_next( &self, cursor: &mut Self::ChangesetCursor ) -> Result<Option<(&ChangeId, &L64)>, TxnErr<Self::GraphError>>; fn cursor_changeset_prev( &self, cursor: &mut Self::ChangesetCursor ) -> Result<Option<(&ChangeId, &L64)>, TxnErr<Self::GraphError>>; fn cursor_revchangeset_ref<RT: Deref<Target = Self>>( txn: RT, channel: &Self::RevChangeset, pos: Option<L64> ) -> Result<Cursor<Self, RT, Self::RevchangesetCursor, L64, Pair<ChangeId, SerializedMerkle>>, TxnErr<Self::GraphError>>; fn rev_cursor_revchangeset<'txn>( &'txn self, channel: &Self::RevChangeset, pos: Option<L64> ) -> Result<RevCursor<Self, &'txn Self, Self::RevchangesetCursor, L64, Pair<ChangeId, SerializedMerkle>>, TxnErr<Self::GraphError>>; fn cursor_revchangeset_next( &self, cursor: &mut Self::RevchangesetCursor ) -> Result<Option<(&L64, &Pair<ChangeId, SerializedMerkle>)>, TxnErr<Self::GraphError>>; fn cursor_revchangeset_prev( &self, cursor: &mut Self::RevchangesetCursor ) -> Result<Option<(&L64, &Pair<ChangeId, SerializedMerkle>)>, TxnErr<Self::GraphError>>; fn channel_has_state( &self, channel: &Self::States, hash: &SerializedMerkle ) -> Result<Option<L64>, TxnErr<Self::GraphError>>; fn is_tagged( &self, tags: &Self::Tags, t: u64 ) -> Result<bool, TxnErr<Self::GraphError>>; fn cursor_tags<'txn>( &'txn self, channel: &Self::Tags, pos: Option<L64> ) -> Result<Cursor<Self, &'txn Self, Self::TagsCursor, L64, Pair<SerializedMerkle, SerializedMerkle>>, TxnErr<Self::GraphError>>; fn cursor_tags_next( &self, cursor: &mut Self::TagsCursor ) -> Result<Option<(&L64, &Pair<SerializedMerkle, SerializedMerkle>)>, TxnErr<Self::GraphError>>; fn cursor_tags_prev( &self, cursor: &mut Self::TagsCursor ) -> Result<Option<(&L64, &Pair<SerializedMerkle, SerializedMerkle>)>, TxnErr<Self::GraphError>>; fn iter_tags( &self, channel: &Self::Tags, from: u64 ) -> Result<Cursor<Self, &Self, Self::TagsCursor, L64, Pair<SerializedMerkle, SerializedMerkle>>, TxnErr<Self::GraphError>>; fn rev_iter_tags( &self, channel: &Self::Tags, from: Option<u64> ) -> Result<RevCursor<Self, &Self, Self::TagsCursor, L64, Pair<SerializedMerkle, SerializedMerkle>>, TxnErr<Self::GraphError>>;
}

Required Associated Types§

Required Methods§

source

fn name<'a>(&self, channel: &'a Self::Channel) -> &'a str

source

fn id<'a>(&self, c: &'a Self::Channel) -> Option<&'a RemoteId>

source

fn graph<'a>(&self, channel: &'a Self::Channel) -> &'a Self::Graph

source

fn apply_counter(&self, channel: &Self::Channel) -> u64

source

fn last_modified(&self, channel: &Self::Channel) -> u64

source

fn changes<'a>(&self, channel: &'a Self::Channel) -> &'a Self::Changeset

source

fn rev_changes<'a>(&self, channel: &'a Self::Channel) -> &'a Self::RevChangeset

source

fn tags<'a>(&self, channel: &'a Self::Channel) -> &'a Self::Tags

source

fn states<'a>(&self, channel: &'a Self::Channel) -> &'a Self::States

source

fn get_changeset( &self, channel: &Self::Changeset, c: &ChangeId ) -> Result<Option<&L64>, TxnErr<Self::GraphError>>

source

fn get_revchangeset( &self, channel: &Self::RevChangeset, c: &L64 ) -> Result<Option<&Pair<ChangeId, SerializedMerkle>>, TxnErr<Self::GraphError>>

source

fn cursor_changeset<'txn>( &'txn self, channel: &Self::Changeset, pos: Option<ChangeId> ) -> Result<Cursor<Self, &'txn Self, Self::ChangesetCursor, ChangeId, L64>, TxnErr<Self::GraphError>>

source

fn cursor_changeset_next( &self, cursor: &mut Self::ChangesetCursor ) -> Result<Option<(&ChangeId, &L64)>, TxnErr<Self::GraphError>>

source

fn cursor_changeset_prev( &self, cursor: &mut Self::ChangesetCursor ) -> Result<Option<(&ChangeId, &L64)>, TxnErr<Self::GraphError>>

source

fn cursor_revchangeset_ref<RT: Deref<Target = Self>>( txn: RT, channel: &Self::RevChangeset, pos: Option<L64> ) -> Result<Cursor<Self, RT, Self::RevchangesetCursor, L64, Pair<ChangeId, SerializedMerkle>>, TxnErr<Self::GraphError>>

source

fn rev_cursor_revchangeset<'txn>( &'txn self, channel: &Self::RevChangeset, pos: Option<L64> ) -> Result<RevCursor<Self, &'txn Self, Self::RevchangesetCursor, L64, Pair<ChangeId, SerializedMerkle>>, TxnErr<Self::GraphError>>

source

fn cursor_revchangeset_next( &self, cursor: &mut Self::RevchangesetCursor ) -> Result<Option<(&L64, &Pair<ChangeId, SerializedMerkle>)>, TxnErr<Self::GraphError>>

source

fn cursor_revchangeset_prev( &self, cursor: &mut Self::RevchangesetCursor ) -> Result<Option<(&L64, &Pair<ChangeId, SerializedMerkle>)>, TxnErr<Self::GraphError>>

source

fn channel_has_state( &self, channel: &Self::States, hash: &SerializedMerkle ) -> Result<Option<L64>, TxnErr<Self::GraphError>>

source

fn is_tagged( &self, tags: &Self::Tags, t: u64 ) -> Result<bool, TxnErr<Self::GraphError>>

source

fn cursor_tags<'txn>( &'txn self, channel: &Self::Tags, pos: Option<L64> ) -> Result<Cursor<Self, &'txn Self, Self::TagsCursor, L64, Pair<SerializedMerkle, SerializedMerkle>>, TxnErr<Self::GraphError>>

source

fn cursor_tags_next( &self, cursor: &mut Self::TagsCursor ) -> Result<Option<(&L64, &Pair<SerializedMerkle, SerializedMerkle>)>, TxnErr<Self::GraphError>>

source

fn cursor_tags_prev( &self, cursor: &mut Self::TagsCursor ) -> Result<Option<(&L64, &Pair<SerializedMerkle, SerializedMerkle>)>, TxnErr<Self::GraphError>>

source

fn iter_tags( &self, channel: &Self::Tags, from: u64 ) -> Result<Cursor<Self, &Self, Self::TagsCursor, L64, Pair<SerializedMerkle, SerializedMerkle>>, TxnErr<Self::GraphError>>

source

fn rev_iter_tags( &self, channel: &Self::Tags, from: Option<u64> ) -> Result<RevCursor<Self, &Self, Self::TagsCursor, L64, Pair<SerializedMerkle, SerializedMerkle>>, TxnErr<Self::GraphError>>

Implementors§

source§

impl ChannelTxnT for TagTxn

§

type Channel = DbOffsets

§

type Changeset = u64

§

type RevChangeset = u64

§

type Tags = u64

§

type States = u64

§

type ChangesetCursor = Cursor<ChangeId, L64, Page<ChangeId, L64>>

§

type RevchangesetCursor = Cursor<L64, Pair<ChangeId, SerializedMerkle>, Page<L64, Pair<ChangeId, SerializedMerkle>>>

§

type TagsCursor = Cursor<L64, Pair<SerializedMerkle, SerializedMerkle>, Page<L64, Pair<SerializedMerkle, SerializedMerkle>>>

source§

impl<T> ChannelTxnT for WithTag<T>

source§

impl<T: LoadPage<Error = Error> + RootPage> ChannelTxnT for GenericTxn<T>

§

type Channel = Channel

§

type Changeset = Db_<ChangeId, L64, Page<ChangeId, L64>>

§

type RevChangeset = Db_<L64, Pair<ChangeId, SerializedMerkle>, Page<L64, Pair<ChangeId, SerializedMerkle>>>

§

type ChangesetCursor = Cursor<ChangeId, L64, Page<ChangeId, L64>>

§

type RevchangesetCursor = Cursor<L64, Pair<ChangeId, SerializedMerkle>, Page<L64, Pair<ChangeId, SerializedMerkle>>>

§

type States = Db_<SerializedMerkle, L64, Page<SerializedMerkle, L64>>

§

type Tags = Db_<L64, Pair<SerializedMerkle, SerializedMerkle>, Page<L64, Pair<SerializedMerkle, SerializedMerkle>>>

§

type TagsCursor = Cursor<L64, Pair<SerializedMerkle, SerializedMerkle>, Page<L64, Pair<SerializedMerkle, SerializedMerkle>>>