rpc

package

v0.0.0-...-2c29f98 Latest Latest Go to latest Published: May 7, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func GetBackoffDurationForAttempts(numAttempts int64, maxRetryTime time.Duration) (time.Duration, bool)

func GetBlock(cl *probeClient.ChainClient, height int64) (*coretypes.ResultBlock, error)

GetBlockTimestamp

func GetBlockResult(client URIClient, height int64) (*ctypes.ResultBlockResults, error)

func GetBlockResultWithRetry(client URIClient, height int64, retryMaxAttempts int64, retryMaxWaitSeconds uint64) (*ctypes.ResultBlockResults, error)

func GetEarliestAndLatestBlockHeights(cl *probeClient.ChainClient) (int64, int64, error)

func GetLatestBlockHeight(cl *probeClient.ChainClient) (int64, error)

func GetLatestBlockHeightWithRetry(cl *probeClient.ChainClient, retryMaxAttempts int64, retryMaxWaitSeconds uint64) (int64, error)

func GetTxsByBlockHeight(cl *probeClient.ChainClient, height int64) (*txTypes.GetTxsEventResponse, error)

GetTxsByBlockHeight makes a request to the Cosmos RPC API and returns all the transactions for a specific block

func IsCatchingUp(cl *probeClient.ChainClient) (bool, error)

IsCatchingUp true if the node is catching up to the chain, false otherwise

type URIClient struct {
	Address    string
	Client     *http.Client
	AuthHeader string
}

func (c *URIClient) DoBlockResults(ctx context.Context, height *int64) (*ctypes.ResultBlockResults, error)

func (c *URIClient) DoHTTPGet(ctx context.Context, method string, params map[string]interface{}, result interface{}) (interface{}, error)