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" )
Variables ¶
This section is empty.
Functions ¶
func AppendPrefix ¶
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 ¶
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 ¶
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 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{})
Source Files