primary

Documentation

Index

• type BlockData
  • func NewBlockData(storageSnapshot snapshot.StorageSnapshot, snapshotTime logical.Time) *BlockData
  • func (block *BlockData) LatestSnapshot() timestampedSnapshotTree
  • func (block *BlockData) NewCachingSnapshotReadTransactionData(parameters state.StateParameters) *TransactionData
  • func (block *BlockData) NewSnapshotReadTransactionData(parameters state.StateParameters) *TransactionData
  • func (block *BlockData) NewTransactionData(executionTime logical.Time, parameters state.StateParameters) (*TransactionData, error)
• type TransactionData
  • func (txn *TransactionData) Commit() (*snapshot.ExecutionSnapshot, error)
  • func (txn *TransactionData) Finalize() error
  • func (txn *TransactionData) SnapshotTime() logical.Time
  • func (txn *TransactionData) Validate() error

Types

type BlockData

type BlockData struct {
	// contains filtered or unexported fields
}

BlockData is a rudimentary in-memory MVCC database for storing (RegisterID, RegisterValue) pairs for a particular block. The database enforces atomicity, consistency, and isolation, but not durability (The transactions are made durable by the block computer using aggregated execution snapshots).

func NewBlockData

func NewBlockData(
	storageSnapshot snapshot.StorageSnapshot,
	snapshotTime logical.Time,
) *BlockData

Note: storageSnapshot must be thread safe.

func (*BlockData) LatestSnapshot

func (block *BlockData) LatestSnapshot() timestampedSnapshotTree

func (*BlockData) NewCachingSnapshotReadTransactionData

func (block *BlockData) NewCachingSnapshotReadTransactionData(
	parameters state.StateParameters,
) *TransactionData

func (*BlockData) NewSnapshotReadTransactionData

func (block *BlockData) NewSnapshotReadTransactionData(
	parameters state.StateParameters,
) *TransactionData

func (*BlockData) NewTransactionData

func (block *BlockData) NewTransactionData(
	executionTime logical.Time,
	parameters state.StateParameters,
) (
	*TransactionData,
	error,
)

type TransactionData

type TransactionData struct {
	state.NestedTransactionPreparer
	// contains filtered or unexported fields
}

func (*TransactionData) Commit

func (txn *TransactionData) Commit() (
	*snapshot.ExecutionSnapshot,
	error,
)

func (*TransactionData) Finalize

func (txn *TransactionData) Finalize() error

func (*TransactionData) SnapshotTime

func (txn *TransactionData) SnapshotTime() logical.Time

func (*TransactionData) Validate

func (txn *TransactionData) Validate() error