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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
Click to show internal directories.
Click to hide internal directories.