utils

Documentation

Index

• Constants
• func CreateSha256Checksum(input []byte) (hash string)
• func DecompressBundleFromStorageProvider(bundle types.FinalizedBundle, data []byte) ([]byte, error)
• func DecompressGzip(input []byte) ([]byte, error)
• func GetDataFromFinalizedBundle(bundle types.FinalizedBundle) ([]byte, error)
• func GetFinalizedBundleById(restEndpoint string, poolId int64, bundleId int64) (*types.FinalizedBundle, error)
• func GetFinalizedBundlesPage(restEndpoint string, poolId int64, paginationLimit int64, paginationKey string, ...) ([]types.FinalizedBundle, string, error)
• func GetFinalizedBundlesPageWithOffset(restEndpoint string, poolId int64, paginationLimit, paginationOffset int64, ...) ([]types.FinalizedBundle, string, error)
• func GetFromUrl(url string) (data []byte, err error)
• func GetPool(restEndpoint string, poolId int64) (*types.PoolResponse, error)
• func GetUserConfirmationInput() (bool, error)
• func GetVersion() string
• func IsUpgradeHeight(homePath string, height int64) bool
• func ParseSnapshotFromKey(key string) (height int64, chunkIndex int64, err error)
• func RetrieveDataFromStorageProvider(bundle types.FinalizedBundle) ([]byte, error)

Constants

const (
	ChainIdMainnet  = "kyve-1"
	ChainIdKaon     = "kaon-1"
	ChainIdKorellia = "korellia-2"

	RestEndpointMainnet  = "https://api.kyve.network"
	RestEndpointKaon     = "https://api.kaon.kyve.network"
	RestEndpointKorellia = "https://api.korellia.kyve.network"

	RestEndpointArweave      = "https://arweave.net"
	RestEndpointBundlr       = "https://arweave.net"
	RestEndpointKYVEStorage  = "https://storage.kyve.network"
	RestEndpointTurboStorage = "https://arweave.net"
)

const (
	RuntimeTendermint      = "@kyvejs/tendermint"
	RuntimeTendermintBsync = "@kyvejs/tendermint-bsync"
	RuntimeTendermintSsync = "@kyvejs/tendermint-ssync"
)

const (
	EngineTendermintV34   = "TENDERMINT-V34"
	EngineCelestiaCoreV34 = "CELESTIA-CORE-V34"
	EngineCometBFTV37     = "COMETBFT-V37"
	EngineCometBFTV38     = "COMETBFT-V38"
)

const (
	DefaultChainId            = ChainIdMainnet
	DefaultRpcServerPort      = 7777
	DefaultSnapshotServerPort = 7878
)

const (
	BundlesPageLimit            = 1000
	BlockBuffer                 = 300
	PruningInterval             = 100
	SnapshotPruningAheadFactor  = 3
	SnapshotPruningWindowFactor = 6
	BackoffMaxRetries           = 10
	RequestTimeoutMS            = 100
	RequestBlocksTimeoutMS      = 250
)

const (
	DefaultRegistryURL = "https://raw.githubusercontent.com/KYVENetwork/source-registry/main/.github/registry.yml"
)

Functions

func CreateSha256Checksum

func CreateSha256Checksum(input []byte) (hash string)

func DecompressBundleFromStorageProvider

func DecompressBundleFromStorageProvider(bundle types.FinalizedBundle, data []byte) ([]byte, error)

func DecompressGzip

func DecompressGzip(input []byte) ([]byte, error)

func GetDataFromFinalizedBundle

func GetDataFromFinalizedBundle(bundle types.FinalizedBundle) ([]byte, error)

GetDataFromFinalizedBundle downloads the data from the provided bundle, verify if the checksum on the KYVE chain matches and finally decompresses it before returning

func GetFinalizedBundleById

func GetFinalizedBundleById(restEndpoint string, poolId int64, bundleId int64) (*types.FinalizedBundle, error)

func GetFinalizedBundlesPage

func GetFinalizedBundlesPage(restEndpoint string, poolId int64, paginationLimit int64, paginationKey string, reverse bool) ([]types.FinalizedBundle, string, error)

func GetFinalizedBundlesPageWithOffset

func GetFinalizedBundlesPageWithOffset(restEndpoint string, poolId int64, paginationLimit, paginationOffset int64, paginationKey string, reverse bool) ([]types.FinalizedBundle, string, error)

func GetFromUrl

func GetFromUrl(url string) (data []byte, err error)

GetFromUrl tries to fetch data from url with exponential backoff, we usually always want a request to succeed so it is implemented by default

func GetPool

func GetPool(restEndpoint string, poolId int64) (*types.PoolResponse, error)

func GetUserConfirmationInput

func GetUserConfirmationInput() (bool, error)

func GetVersion

func GetVersion() string

func IsUpgradeHeight

func IsUpgradeHeight(homePath string, height int64) bool

func ParseSnapshotFromKey

func ParseSnapshotFromKey(key string) (height int64, chunkIndex int64, err error)

func RetrieveDataFromStorageProvider

func RetrieveDataFromStorageProvider(bundle types.FinalizedBundle) ([]byte, error)