gf_web3_lib

Documentation

Index

• func EventProcessFromSQS(pQueueInfo *GFqueueInfo, pCtx context.Context, ...)
• func InitHandlers(pGetHostsFun func(context.Context, *gf_eth_core.GF_runtime) []string, ...) *gf_core.GFerror
• func InitService(pAuthSubsystemTypeStr string, pKeyServer *gf_identity_core.GFkeyServerInfo, ...)
• func RunService(pRuntime *gf_eth_core.GF_runtime)
• type GFqueueInfo
  • func Event__init_queue(p_queue_name_str string, pMetrics *gf_eth_core.GF_metrics) (*GFqueueInfo, error)

Functions

func EventProcessFromSQS

func EventProcessFromSQS(pQueueInfo *GFqueueInfo,
	pCtx context.Context,
	pMetrics *gf_eth_core.GF_metrics,
	pRuntime *gf_eth_core.GF_runtime)

func InitHandlers

func InitHandlers(pGetHostsFun func(context.Context, *gf_eth_core.GF_runtime) []string,
	pIndexerCmdsCh gf_eth_indexer.GF_indexer_ch,
	pIndexerJobUpdatesNewConsumerCh gf_eth_indexer.GF_job_update_new_consumer_ch,
	pMetrics *gf_eth_core.GF_metrics,
	pRuntime *gf_eth_core.GF_runtime) *gf_core.GFerror

func InitService

func InitService(pAuthSubsystemTypeStr string,
	pKeyServer *gf_identity_core.GFkeyServerInfo,
	pHTTPmux *http.ServeMux,
	pConfig *gf_eth_core.GF_config,
	pImagesJobsMngrCh chan gf_images_jobs_core.JobMsg,
	pRuntimeSys *gf_core.RuntimeSys)

func RunService

func RunService(pRuntime *gf_eth_core.GF_runtime)

Types

type GFqueueInfo

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

func Event__init_queue

func Event__init_queue(p_queue_name_str string,
	pMetrics *gf_eth_core.GF_metrics) (*GFqueueInfo, error)