Module state_table

Module state_table 

Source

Macrosยง

dispatch_value_indices ๐Ÿ”’
insane_mode_discard_point ๐Ÿ”’
This macro is used to mark a point where we want to randomly discard the operation and early return, only in insane mode.

Structsยง

StateTableBuilder
StateTableInner
StateTableInner is the interface accessing relational data in KV(StateStore) with row-based encoding.
StateTablePostCommit
A callback struct returned from StateTableInner::commit.
StateTableRowStore ๐Ÿ”’
Extract the logic of StateTableRowStore from StateTable, which serves a similar functionality as a BTreeMap<TableKey<Bytes>, OwnedRow>, and provides method to read (get and iter) over serialized key (or key range) and returns OwnedRow, and write (insert, delete, update) on (TableKey<Bytes>, OwnedRow).

Enumsยง

StateTableOpConsistencyLevel

Traitsยง

FromVnodeBytes
KeyedRowStream
PkRowStream
RowStream

Functionsยง

consistent_old_value_op ๐Ÿ”’
deserialize_keyed_row_stream ๐Ÿ”’
end_range_to_memcomparable ๐Ÿ”’
fill_non_output_indices ๐Ÿ”’
prefix_and_sub_range_to_memcomparable ๐Ÿ”’
prefix_range_to_memcomparable
start_range_to_memcomparable ๐Ÿ”’

Type Aliasesยง

ReplicatedStateTable
ReplicatedStateTable is meant to replicate upstream shared buffer. Used for ArrangementBackfill executor.
StateTable
StateTable will use BasicSerde as default