gf_web3_monitor_lib

Documentation

Index

• func Event__process_from_sqs(p_queue_info *GF_queue_info, p_ctx context.Context, ...)
• func InitHandlers(p_get_hosts_fn func(context.Context, *gf_eth_core.GF_runtime) []string, ...) *gf_core.GFerror
• func InitService(pHTTPmux *http.ServeMux, pConfig *gf_eth_core.GF_config, ...)
• func Run_service(p_runtime *gf_eth_core.GF_runtime)
• type GF_queue_info
  • func Event__init_queue(p_queue_name_str string, p_metrics *gf_eth_core.GF_metrics) (*GF_queue_info, error)

Functions

func Event__process_from_sqs

func Event__process_from_sqs(p_queue_info *GF_queue_info,
	p_ctx context.Context,
	p_metrics *gf_eth_core.GF_metrics,
	p_runtime *gf_eth_core.GF_runtime)

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

func InitHandlers

func InitHandlers(p_get_hosts_fn func(context.Context, *gf_eth_core.GF_runtime) []string,
	p_indexer_cmds_ch gf_eth_indexer.GF_indexer_ch,
	p_indexer_job_updates_new_consumer_ch gf_eth_indexer.GF_job_update_new_consumer_ch,
	p_metrics *gf_eth_core.GF_metrics,
	pRuntime *gf_eth_core.GF_runtime) *gf_core.GFerror

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

func InitService

func InitService(pHTTPmux *http.ServeMux,
	pConfig *gf_eth_core.GF_config,
	pRuntimeSys *gf_core.RuntimeSys)

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

func Run_service

func Run_service(p_runtime *gf_eth_core.GF_runtime)

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

Types

type GF_queue_info

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

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

func Event__init_queue

func Event__init_queue(p_queue_name_str string,
	p_metrics *gf_eth_core.GF_metrics) (*GF_queue_info, error)

------------------------------------------------- INIT_QUEUE