gf_eth_blocks

Documentation

Index

• func DB__get_count(p_metrics *gf_eth_core.GF_metrics, p_runtime *gf_eth_core.GF_runtime) (int64, *gf_core.GF_error)
• func DB__write_bulk(p_gf_blocks_lst []*GF_eth__block__int, p_ctx context.Context, ...) *gf_core.GF_error
• func Get__txs_pipeline(p_block *types.Block, p_eth_rpc_client *ethclient.Client, ...) ([]*gf_eth_tx.GF_eth__tx, []*gf_core.GF_error)
• func Get_from_workers__pipeline(p_block_uint uint64, ...) (map[string]*GF_eth__block__int, map[string]*gf_eth_core.GF_eth__miner__int, ...)
• func Index__pipeline(p_block_uint uint64, ...) (uint64, *gf_core.GF_error)
• func Init_continuous_metrics(p_metrics *gf_eth_core.GF_metrics, p_runtime *gf_eth_core.GF_runtime)
• type GF_eth__block__int
  • func Get__pipeline(p_block_num_uint uint64, p_eth_rpc_client *ethclient.Client, ...) (*GF_eth__block__int, *gf_core.GF_error)
  • func Get_block__from_worker_inspector(p_block_uint uint64, p_host_port_str string, p_ctx context.Context, ...) (*GF_eth__block__int, *gf_core.GF_error)

Functions

func DB__get_count

func DB__get_count(p_metrics *gf_eth_core.GF_metrics,
	p_runtime *gf_eth_core.GF_runtime) (int64, *gf_core.GF_error)

------------------------------------------------- BLOCKS__DB__GET_COUNT

func DB__write_bulk

func DB__write_bulk(p_gf_blocks_lst []*GF_eth__block__int,
	p_ctx context.Context,
	p_metrics *gf_eth_core.GF_metrics,
	p_runtime *gf_eth_core.GF_runtime) *gf_core.GF_error

------------------------------------------------- BLOCKS__DB__WRITE_BULK

func Get__txs_pipeline

func Get__txs_pipeline(p_block *types.Block,
	p_eth_rpc_client *ethclient.Client,
	p_ctx context.Context,
	p_py_plugins *gf_eth_core.GF_py_plugins,
	p_runtime_sys *gf_core.Runtime_sys) ([]*gf_eth_tx.GF_eth__tx, []*gf_core.GF_error)

-------------------------------------------------

func Get_from_workers__pipeline

func Get_from_workers__pipeline(p_block_uint uint64,
	p_get_worker_hosts_fn func(context.Context, *gf_eth_core.GF_runtime) []string,
	p_abis_defs_map map[string]*gf_eth_contract.GF_eth__abi,
	p_ctx context.Context,
	p_metrics *gf_eth_core.GF_metrics,
	p_runtime *gf_eth_core.GF_runtime) (map[string]*GF_eth__block__int, map[string]*gf_eth_core.GF_eth__miner__int, *gf_core.GF_error)

-------------------------------------------------

func Index__pipeline

func Index__pipeline(p_block_uint uint64,
	p_get_worker_hosts_fn func(context.Context, *gf_eth_core.GF_runtime) []string,
	p_abis_defs_map map[string]*gf_eth_contract.GF_eth__abi,
	p_ctx context.Context,
	p_metrics *gf_eth_core.GF_metrics,
	p_runtime *gf_eth_core.GF_runtime) (uint64, *gf_core.GF_error)

-------------------------------------------------

func Init_continuous_metrics

func Init_continuous_metrics(p_metrics *gf_eth_core.GF_metrics,
	p_runtime *gf_eth_core.GF_runtime)

Types

type GF_eth__block__int

type GF_eth__block__int struct {
	DB_id                 string  `mapstructure:"db_id"                 json:"db_id"                 bson:"_id"`
	Creation_time__unix_f float64 `mapstructure:"creation_time__unix_f" json:"creation_time__unix_f" bson:"creation_time__unix_f"`

	Hash_str          string `mapstructure:"hash_str"          json:"hash_str"          bson:"hash_str"`
	Parent_hash_str   string `mapstructure:"parent_hash_str"   json:"parent_hash_str"   bson:"parent_hash_str"`
	Block_num_uint    uint64 `mapstructure:"block_num_int"     json:"block_num_int"     bson:"block_num_uint"`
	Gas_used_uint     uint64 `mapstructure:"gas_used_uint"     json:"gas_used_uint"     bson:"gas_used_uint"`
	Gas_limit_uint    uint64 `mapstructure:"gas_limit_uint"    json:"gas_limit_uint"    bson:"gas_limit_uint"`
	Coinbase_addr_str string `mapstructure:"coinbase_addr_str" json:"coinbase_addr_str" bson:"coinbase_addr_str"`

	// txs_lst       - not stored in DB. blocks are stored in their own table/collection, separate from TX's themselves (which are in their own).
	// tx_hashes_lst - these are stored in the DB, and used to lookup TX's that are in their own collection.
	Txs_lst        []*gf_eth_tx.GF_eth__tx `mapstructure:"txs_lst"           json:"txs_lst"            bson:"-"`
	Txs_hashes_lst []string                `mapstructure:"txs_hashes_lst"    json:"txs_hashes_lst"     bson:"txs_hashes_lst"`

	Time_uint uint64 `mapstructure:"time_int" json:"time_uint"`
}

------------------------------------------------- BLOCK__INTERNAL - internal representation of the block, with fields

that are not visible to the external public users.

func Get__pipeline

func Get__pipeline(p_block_num_uint uint64,
	p_eth_rpc_client *ethclient.Client,
	p_ctx context.Context,
	p_py_plugins *gf_eth_core.GF_py_plugins,
	p_runtime_sys *gf_core.Runtime_sys) (*GF_eth__block__int, *gf_core.GF_error)

------------------------------------------------- GET_BLOCK__PIPELINE

func Get_block__from_worker_inspector

func Get_block__from_worker_inspector(p_block_uint uint64,
	p_host_port_str string,
	p_ctx context.Context,
	p_runtime_sys *gf_core.Runtime_sys) (*GF_eth__block__int, *gf_core.GF_error)

------------------------------------------------- GET_BLOCK__FROM_WORKER_INSPECTOR