gf_eth_indexer

package
v0.0.0-...-225a141 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 25, 2022 License: GPL-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Client__new_consumer

func Client__new_consumer(p_job_id_str GF_indexer_job_id,
	p_indexer_job_updates_new_consumer_ch GF_job_update_new_consumer_ch,
	p_ctx context.Context) (GF_job_updates_ch, GF_job_err_ch, GF_job_complete_ch)

------------------------------------------------- CLIENT__NEW_CONSUMER

func Client_http__index_job_updates

func Client_http__index_job_updates(p_job_id_str GF_indexer_job_id,
	p_job_updates_ch chan (map[string]interface{}),
	p_host_port_str string,
	p_ctx context.Context,
	p_runtime_sys *gf_core.Runtime_sys) *gf_core.GF_error

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

func Init

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

func Init_handlers

func Init_handlers(p_indexer_cmds_ch GF_indexer_ch,
	p_indexer_job_updates_new_consumer_ch GF_job_update_new_consumer_ch,
	p_metrics *gf_eth_core.GF_metrics,
	p_runtime *gf_eth_core.GF_runtime)

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

func Updates__consume_stream

func Updates__consume_stream(p_job_id_str GF_indexer_job_id,
	p_ctx context.Context,
	p_aws_client *sqs.Client,
	p_runtime *gf_eth_core.GF_runtime) (GF_job_updates_ch, GF_job_err_ch, GF_job_complete_ch)

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

func Updates__init_stream

func Updates__init_stream(p_job_id_str GF_indexer_job_id,
	p_ctx context.Context,
	p_sqs_client *sqs.Client,
	p_runtime *gf_eth_core.GF_runtime) (*gf_aws.GF_SQS_queue, *gf_core.GF_error)

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

Types

type GF_indexer_ch

type GF_indexer_ch chan (GF_indexer_cmd)

type GF_indexer_cmd

type GF_indexer_cmd struct {
	Block_start_uint uint64
	Block_end_uint   uint64
	Response_ch      chan (GF_indexer_job_id)
	Response_err_ch  chan (gf_core.GF_error)
}

type GF_indexer_job_id

type GF_indexer_job_id string

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

func Client__index_block_range

func Client__index_block_range(p_block_start_uint uint64,
	p_block_end_uint uint64,
	p_indexer_cmds_ch chan (GF_indexer_cmd)) (GF_indexer_job_id, *gf_core.GF_error)

------------------------------------------------- CLIENT__INDEX_BLOCK_RANGE

func Client_http__index_block_range

func Client_http__index_block_range(p_block_start_uint uint64,
	p_block_end_uint uint64,
	p_host_port_str string,
	p_ctx context.Context,
	p_runtime_sys *gf_core.Runtime_sys) (GF_indexer_job_id, *gf_core.GF_error)

------------------------------------------------- HTTP -------------------------------------------------

type GF_job_complete_ch

type GF_job_complete_ch chan (bool)

type GF_job_err_ch

type GF_job_err_ch chan (gf_core.GF_error)

type GF_job_update

type GF_job_update struct {
	Block_num_indexed_int uint64 `json:"block_num_indexed_int"`
	Txs_num_indexed_int   uint64 `json:"txs_num_indexed_int"`
}

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

type GF_job_update_new_consumer

type GF_job_update_new_consumer struct {
	Job_id_str  GF_indexer_job_id
	Response_ch chan (GF_job_update_new_consumer_response)
	// contains filtered or unexported fields
}

type GF_job_update_new_consumer_ch

type GF_job_update_new_consumer_ch chan (GF_job_update_new_consumer)

type GF_job_update_new_consumer_response

type GF_job_update_new_consumer_response struct {
	Job_updates_ch  GF_job_updates_ch
	Job_err_ch      GF_job_err_ch
	Job_complete_ch GF_job_complete_ch
}

type GF_job_updates_ch

type GF_job_updates_ch chan (GF_job_update)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL