util

Documentation

Index

• Constants
• func AppendPrefix(signerPubKey []byte) []byte
• func CalculateTaskDelay(cliCtx cliContext.CLIContext) (bool, time.Duration)
• func CloseBridgeDBInstance()
• func CreateURLWithQuery(uri string, param map[string]interface{}) (string, error)
• func GetAccount(cliCtx cliContext.CLIContext, address types.HeimdallAddress) (account authTypes.Account, err error)
• func GetBridgeDBInstance(filePath string) *leveldb.DB
• func GetBufferedCheckpoint(cliCtx cliContext.CLIContext) (*hmtypes.Checkpoint, error)
• func GetChainmanagerParams(cliCtx cliContext.CLIContext) (*chainManagerTypes.Params, error)
• func GetCheckpointParams(cliCtx cliContext.CLIContext) (*checkpointTypes.Params, error)
• func GetlastestCheckpoint(cliCtx cliContext.CLIContext) (*hmtypes.Checkpoint, error)
• func IsCatchingUp(cliCtx cliContext.CLIContext) bool
• func IsCurrentProposer(cliCtx cliContext.CLIContext) (bool, error)
• func IsEventSender(cliCtx cliContext.CLIContext, validatorID uint64) bool
• func IsInProposerList(cliCtx cliContext.CLIContext, count uint64) (bool, error)
• func IsProposer(cliCtx cliContext.CLIContext) (bool, error)
• func Logger() log.Logger
• func WaitForOneEvent(tx tmTypes.Tx, client *httpClient.HTTP) (tmTypes.TMEventData, error)
• type NoopLogger
  • func (NoopLogger) Fatal(...interface{})
  • func (NoopLogger) Fatalf(string, ...interface{})
  • func (NoopLogger) Fatalln(...interface{})
  • func (NoopLogger) Panic(...interface{})
  • func (NoopLogger) Panicf(string, ...interface{})
  • func (NoopLogger) Panicln(...interface{})
  • func (NoopLogger) Print(...interface{})
  • func (NoopLogger) Printf(string, ...interface{})
  • func (NoopLogger) Println(...interface{})

Constants

const (
	AccountDetailsURL       = "/auth/accounts/%v"
	LastNoAckURL            = "/checkpoints/last-no-ack"
	CheckpointParamsURL     = "/checkpoints/params"
	ChainManagerParamsURL   = "/chainmanager/params"
	ProposersURL            = "/staking/proposer/%v"
	BufferedCheckpointURL   = "/checkpoints/buffer"
	LatestCheckpointURL     = "/checkpoints/latest"
	CurrentProposerURL      = "/staking/current-proposer"
	LatestSpanURL           = "/bor/latest-span"
	NextSpanInfoURL         = "/bor/prepare-next-span"
	NextSpanSeedURL         = "/bor/next-span-seed"
	DividendAccountRootURL  = "/topup/dividend-account-root"
	ValidatorURL            = "/staking/validator/%v"
	CurrentValidatorSetURL  = "staking/validator-set"
	StakingTxStatusURL      = "/staking/isoldtx"
	TopupTxStatusURL        = "/topup/isoldtx"
	ClerkTxStatusURL        = "/clerk/isoldtx"
	LatestSlashInfoBytesURL = "/slashing/latest_slash_info_bytes"
	TickSlashInfoListURL    = "/slashing/tick_slash_infos"
	SlashingTxStatusURL     = "/slashing/isoldtx"
	SlashingTickCountURL    = "/slashing/tick-count"

	TransactionTimeout      = 1 * time.Minute
	CommitTimeout           = 2 * time.Minute
	TaskDelayBetweenEachVal = 6 * time.Second
	RetryTaskDelay          = 12 * time.Second

	BridgeDBFlag = "bridge-db"
)

Functions

func AppendPrefix

func AppendPrefix(signerPubKey []byte) []byte

AppendPrefix returns publickey in uncompressed format

func CalculateTaskDelay

func CalculateTaskDelay(cliCtx cliContext.CLIContext) (bool, time.Duration)

CalculateTaskDelay calculates delay required for current validator to propose the tx It solves for multiple validators sending same transaction.

func CloseBridgeDBInstance

func CloseBridgeDBInstance()

CloseBridgeDBInstance closes bridge-db instance

func CreateURLWithQuery

func CreateURLWithQuery(uri string, param map[string]interface{}) (string, error)

CreateURLWithQuery receives the uri and parameters in key value form it will return the new url with the given query from the parameter

func GetAccount

func GetAccount(cliCtx cliContext.CLIContext, address types.HeimdallAddress) (account authTypes.Account, err error)

GetAccount returns heimdall auth account

func GetBridgeDBInstance

func GetBridgeDBInstance(filePath string) *leveldb.DB

GetBridgeDBInstance get sington object for bridge-db

func GetBufferedCheckpoint

func GetBufferedCheckpoint(cliCtx cliContext.CLIContext) (*hmtypes.Checkpoint, error)

GetBufferedCheckpoint return checkpoint from bueffer

func GetChainmanagerParams

func GetChainmanagerParams(cliCtx cliContext.CLIContext) (*chainManagerTypes.Params, error)

GetChainmanagerParams return chain manager params

func GetCheckpointParams

func GetCheckpointParams(cliCtx cliContext.CLIContext) (*checkpointTypes.Params, error)

GetCheckpointParams return params

func GetlastestCheckpoint

func GetlastestCheckpoint(cliCtx cliContext.CLIContext) (*hmtypes.Checkpoint, error)

GetlastestCheckpoint return last successful checkpoint

func IsCatchingUp

func IsCatchingUp(cliCtx cliContext.CLIContext) bool

IsCatchingUp checks if the heimdall node you are connected to is fully synced or not returns true when synced

func IsCurrentProposer

func IsCurrentProposer(cliCtx cliContext.CLIContext) (bool, error)

IsCurrentProposer checks if we are current proposer

func IsEventSender

func IsEventSender(cliCtx cliContext.CLIContext, validatorID uint64) bool

IsEventSender check if we are the EventSender

func IsInProposerList

func IsInProposerList(cliCtx cliContext.CLIContext, count uint64) (bool, error)

IsInProposerList checks if we are in current proposer

func IsProposer

func IsProposer(cliCtx cliContext.CLIContext) (bool, error)

IsProposer checks if we are proposer

func Logger

func Logger() log.Logger

Logger returns logger singleton instance

func WaitForOneEvent

func WaitForOneEvent(tx tmTypes.Tx, client *httpClient.HTTP) (tmTypes.TMEventData, error)

WaitForOneEvent subscribes to a websocket event for the given event time and returns upon receiving it one time, or when the timeout duration has expired.

This handles subscribing and unsubscribing under the hood

Types

type NoopLogger

type NoopLogger struct{}

NoopLogger no operational logger

func (NoopLogger) Fatal

func (NoopLogger) Fatal(...interface{})

func (NoopLogger) Fatalf

func (NoopLogger) Fatalf(string, ...interface{})

func (NoopLogger) Fatalln

func (NoopLogger) Fatalln(...interface{})

func (NoopLogger) Panic

func (NoopLogger) Panic(...interface{})

func (NoopLogger) Panicf

func (NoopLogger) Panicf(string, ...interface{})

func (NoopLogger) Panicln

func (NoopLogger) Panicln(...interface{})

func (NoopLogger) Print

func (NoopLogger) Print(...interface{})

func (NoopLogger) Printf

func (NoopLogger) Printf(string, ...interface{})

func (NoopLogger) Println

func (NoopLogger) Println(...interface{})