package octez-shell-libs

  1. Overview
  2. Docs
Octez shell libraries

Install 

dune-project
 Dependency

www.tezos.com Readme Edit opam file Versions (5)

Authors

  1. T
    Tezos devteam

Maintainers

  1. C
    contact@tezos.com

Sources

tezos-18.1.tar.gz
sha256=aa2f5bc99cc4ca2217c52a1af2a2cdfd3b383208cb859ca2e79ca0903396ca1d
sha512=d68bb3eb615e3dcccc845fddfc9901c95b3c6dc8e105e39522ce97637b1308a7fa7aa1d271351d5933febd7476b2819e1694f31198f1f0919681f1f9cc97cb3a

doc/octez-shell-libs.shell/Tezos_shell/Distributed_db/index.html

Module Tezos_shell.Distributed_dbSource

Tezos Shell - High-level API for the Gossip network and local storage.

It provides functions to query *static* resources such as blocks headers, operations, and functions to access dynamic resources such as heads and chains.

Several chains (mainchain, testchain, ...) can be managed independently. First a chain is activated using activate, which provides a chain_db from which it is possible to access resources. Eventually the chain is deactivated using deactivate.

Static resources are accessible via "Requester" modules (Block_header, Operation, Operations, Protocol). These modules act as read-through caches in front of the local storage State and the p2p layer. They centralize concurrent requests, and cache results in memory. They don't update State directly.

For instance, from a block_header hash, one can fetch the actual block header using Block_header.fetch, then the block operations with Operations.fetch.

Sourcetype t
Sourcetype db = t
Sourceval create : Tezos_store.Store.t -> p2p -> t
Sourceval store : db -> Tezos_store.Store.t
Sourceval shutdown : t -> unit Lwt.t

Network database

Sourcetype chain_db

An instance of the distributed DB for a given chain

Sourceval activate : t -> Tezos_store.Store.Chain.t -> P2p_reader.callback -> chain_db

The first call to activate t chain callbacks activates chain, creates a chain_db and sends a Get_current_branch chain_id message to all neighbors, where chain_id is the identifier of chain. This informs the neighbors that this node expects notifications for new heads/mempools. The given callbacks are given to the P2p_reader for each peer:

  • notify_branch peer locator is called when the P2p_reader receives the message Current_branch (chain, locator) from peer peer.
  • notify_head peer head is called when the P2p_reader receives the message Current_head (chain, head, mempool) from peer peer.
  • Disconnection peer is called when the P2p_reader receives the message Deactivate chain from peer peer or when the P2p_reader associated to peer is shutdown.

Subsequent calls simply return the existing chain_db.

Sourceval get_chain : t -> Tezos_base.TzPervasives.Chain_id.t -> chain_db option

Look for the database of an active chain.

Sourceval deactivate : chain_db -> unit Lwt.t

deactivate chain_db sends a Deactivate chain_id message to all active neighbors for this chain. This notifies them that this node isn't interested in messages for this chain

Sourceval disconnect : chain_db -> Tezos_base.P2p_peer.Id.t -> unit Lwt.t

Kick a given peer.

Sourceval greylist : chain_db -> Tezos_base.P2p_peer.Id.t -> unit Lwt.t

Greylist a given peer.

Various accessors.

Sourceval chain_store : chain_db -> Tezos_store.Store.chain_store
Sourceval db : chain_db -> db

Return the peer id of the node

Sending messages

Sourcemodule Request : sig ... end
Sourcemodule Advertise : sig ... end

Block index

Sourcemodule Block_header : sig ... end

Index of block headers.

Sourcemodule Operations : Tezos_requester.Requester.REQUESTER with type t := chain_db and type key = Tezos_base.TzPervasives.Block_hash.t * int and type value = Tezos_base.Operation.t list and type param := Tezos_base.TzPervasives.Operation_list_list_hash.t

Index of all the operations of a given block (per validation pass).

Sourceval commit_block : chain_db -> Tezos_base.TzPervasives.Block_hash.t -> Block_header.t -> Tezos_base.Operation.t list list -> Tezos_validation.Block_validation.result -> Tezos_store.Store.Block.t option Tezos_base.TzPervasives.tzresult Lwt.t

Store on disk all the data associated to a valid block.

Sourceval commit_invalid_block : chain_db -> Tezos_base.TzPervasives.Block_hash.t -> Block_header.t -> Tezos_base.TzPervasives.Error_monad.error list -> unit Tezos_base.TzPervasives.tzresult Lwt.t

Store on disk all the data associated to an invalid block.

Operations index

Sourceval inject_operation : chain_db -> Tezos_base.TzPervasives.Operation_hash.t -> Tezos_base.Operation.t -> bool Lwt.t

Inject a new operation in the local index (memory only).

Sourceval inject_prechecked_block : chain_db -> Tezos_base.TzPervasives.Block_hash.t -> Block_header.t -> Tezos_base.Operation.t Tezos_base.TzPervasives.trace Tezos_base.TzPervasives.trace -> unit Tezos_base.TzPervasives.tzresult Lwt.t

Inject a prechecked block in the precheck_blocks memory table. This is to ensure the data availability of the operations once the block has been prechecked and advertised to our peers.

No need to remove the data explicitely of the precheck_blocks memory table. The table is handled as an LRU cache.

Sourcemodule Operation : Tezos_requester.Requester.REQUESTER with type t := chain_db and type key := Tezos_base.TzPervasives.Operation_hash.t and type value := Tezos_base.Operation.t and type param := unit

Index of operations (for the mempool).

Protocol index

Sourcemodule Protocol : sig ... end

Index of protocol sources.

Sourceval commit_protocol : db -> Tezos_base.TzPervasives.Protocol_hash.t -> Protocol.t -> bool Tezos_base.TzPervasives.tzresult Lwt.t

Store on disk protocol sources.