query

Documentation

Index

• func BeJsonRpcQueryWithRetry[T any](qSvc BeJsonRpcQueryService, ...) (res T, duration time.Duration, err error)
• type BeJsonRpcQueryService
  • func NewBeJsonRpcQueryService(chainId string, logger logging.Logger) BeJsonRpcQueryService

Functions

func BeJsonRpcQueryWithRetry

func BeJsonRpcQueryWithRetry[T any](
	qSvc BeJsonRpcQueryService,
	f func(BeJsonRpcQueryService) (T, time.Duration, error),
	retryOption ...querytypes.RetryOption,
) (res T, duration time.Duration, err error)

Types

type BeJsonRpcQueryService

type BeJsonRpcQueryService interface {
	SetQueryEndpoint(url string)

	GetQueryEndpoint() string

	// BeGetChainInfo is `be_getChainInfo`
	BeGetChainInfo() (res *querytypes.ResponseBeGetChainInfo, duration time.Duration, err error)

	// BeGetLatestBlockNumber is `be_getLatestBlockNumber`
	BeGetLatestBlockNumber() (res *querytypes.ResponseBeGetLatestBlockNumber, duration time.Duration, err error)

	// BeTransactionsInBlockRange is `be_getTransactionsInBlockRange`
	BeTransactionsInBlockRange(from, to int64) (res *querytypes.TransformedResponseBeTransactionsInBlockRange, duration time.Duration, err error)
}

func NewBeJsonRpcQueryService

func NewBeJsonRpcQueryService(chainId string, logger logging.Logger) BeJsonRpcQueryService

NewBeJsonRpcQueryService initialize and returns a BeJsonRpcQueryService instance