gf_eth_indexer

Documentation

Index

• func Client__new_consumer(p_job_id_str GF_indexer_job_id, ...) (GF_job_updates_ch, GF_job_err_ch, GF_job_complete_ch)
• func Client_http__index_job_updates(p_job_id_str GF_indexer_job_id, p_job_updates_ch chan (map[string]interface{}), ...) *gf_core.GF_error
• func Init(p_get_worker_hosts_fn gf_eth_worker.Get_worker_hosts_fn, ...) (GF_indexer_ch, GF_job_update_new_consumer_ch, *gf_core.GF_error)
• func Init_handlers(p_indexer_cmds_ch GF_indexer_ch, ...)
• func Updates__consume_stream(p_job_id_str GF_indexer_job_id, p_ctx context.Context, ...) (GF_job_updates_ch, GF_job_err_ch, GF_job_complete_ch)
• func Updates__init_stream(p_job_id_str GF_indexer_job_id, p_ctx context.Context, ...) (*gf_aws.GF_SQS_queue, *gf_core.GF_error)
• type GF_indexer_ch
• type GF_indexer_cmd
• type GF_indexer_job_id
  • func Client__index_block_range(p_block_start_uint uint64, p_block_end_uint uint64, ...) (GF_indexer_job_id, *gf_core.GF_error)
  • func Client_http__index_block_range(p_block_start_uint uint64, p_block_end_uint uint64, p_host_port_str string, ...) (GF_indexer_job_id, *gf_core.GF_error)
• type GF_job_complete_ch
• type GF_job_err_ch
• type GF_job_update
• type GF_job_update_new_consumer
• type GF_job_update_new_consumer_ch
• type GF_job_update_new_consumer_response
• type GF_job_updates_ch

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(p_get_worker_hosts_fn gf_eth_worker.Get_worker_hosts_fn,
	p_metrics *gf_eth_core.GF_metrics,
	p_runtime *gf_eth_core.GF_runtime) (GF_indexer_ch, GF_job_update_new_consumer_ch, *gf_core.GF_error)

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

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)