Versions in this module Expand all Collapse all v0 v0.1.1 Oct 8, 2021 v0.1.0 Oct 8, 2021 Changes in this version + const DefaultMaxConnections + var HomePath = "" + func BindFlagsLoadViper(cmd *cobra.Command, _ []string) error + func ConvertValidatorAddressToBech32String(address types.Address) string + func ConvertValidatorPubKeyToBech32String(pubKey tmcrypto.PubKey) (string, error) + func DefaultConfigSetup(cfg Config, sdkConfig *sdk.Config) + func GetConfigFilePath() string + func Write(cfg Config, path string) error + type Block struct + Hash string + Height int64 + ProposerAddress string + Timestamp time.Time + TotalGas uint64 + TxNum int + func NewBlock(height int64, hash string, txNum int, totalGas uint64, proposerAddress string, ...) *Block + func NewBlockFromTmBlock(blk *tmctypes.ResultBlock, totalGas uint64) *Block + type CobraCmdFunc func(cmd *cobra.Command, args []string) error + func ConcatCobraCmdFuncs(fs ...CobraCmdFunc) CobraCmdFunc + type CommitSig struct + Height int64 + ProposerPriority int64 + Timestamp time.Time + ValidatorAddress string + VotingPower int64 + func NewCommitSig(validatorAddress string, votingPower, proposerPriority, height int64, ...) *CommitSig + type Config interface + GetCosmosConfig func() CosmosConfig + GetDatabaseConfig func() DatabaseConfig + GetGrpcConfig func() GrpcConfig + GetLoggingConfig func() LoggingConfig + GetParsingConfig func() ParsingConfig + GetPruningConfig func() PruningConfig + GetRPCConfig func() RPCConfig + GetTelemetryConfig func() TelemetryConfig + var Cfg Config + var HTTPProtocols = regexp.MustCompile("https?://") + func DefaultConfigParser(configData []byte) (Config, error) + func NewConfig(rpcConfig RPCConfig, grpConfig GrpcConfig, cosmosConfig CosmosConfig, ...) Config + func Read(configPath string, parser ConfigParser) (Config, error) + type ConfigParser = func(fileContents []byte) (Config, error) + type CosmosConfig interface + GetModules func() []string + GetPrefix func() string + func DefaultCosmosConfig() CosmosConfig + func NewCosmosConfig(prefix string, modules []string) CosmosConfig + type DatabaseConfig interface + GetHost func() string + GetMaxIdleConnections func() int + GetMaxOpenConnections func() int + GetName func() string + GetPassword func() string + GetPort func() int64 + GetSSLMode func() string + GetSchema func() string + GetUser func() string + func DefaultDatabaseConfig() DatabaseConfig + func NewDatabaseConfig(name, host string, port int64, user string, password string, sslMode string, ...) DatabaseConfig + type EncodingConfigBuilder func() params.EncodingConfig + type GrpcConfig interface + GetAddress func() string + IsInsecure func() bool + func DefaultGrpcConfig() GrpcConfig + func NewGrpcConfig(address string, insecure bool) GrpcConfig + type HeightQueue chan int64 + func NewQueue(size int) HeightQueue + type LoggingConfig interface + GetLogFormat func() string + GetLogLevel func() string + func DefaultLoggingConfig() LoggingConfig + func NewLoggingConfig(level, format string) LoggingConfig + type Message struct + Addresses []string + Index int + TxHash string + Type string + Value string + func NewMessage(txHash string, index int, msgType string, value string, addresses []string) *Message + type ParsingConfig interface + GetGenesisFilePath func() string + GetStartHeight func() int64 + GetWorkers func() int64 + ShouldParseGenesis func() bool + ShouldParseNewBlocks func() bool + ShouldParseOldBlocks func() bool + UseFastSync func() bool + func DefaultParsingConfig() ParsingConfig + func NewParsingConfig(workers int64, parseNewBlocks, parseOldBlocks bool, parseGenesis bool, ...) ParsingConfig + type PruningConfig interface + GetInterval func() int64 + GetKeepEvery func() int64 + GetKeepRecent func() int64 + func DefaultPruningConfig() PruningConfig + func NewPruningConfig(keepRecent, keepEvery, interval int64) PruningConfig + type RPCConfig interface + GetAddress func() string + GetClientName func() string + GetMaxConnections func() int + func DefaultRPCConfig() RPCConfig + func NewRPCConfig(clientName, address string, maxConnections int) RPCConfig + type SdkConfigSetup func(config Config, sdkConfig *sdk.Config) + type TelemetryConfig interface + GetPort func() uint + IsEnabled func() bool + func DefaultTelemetryConfig() TelemetryConfig + func NewTelemetryConfig(enabled bool, port uint) TelemetryConfig + type Tx struct + func NewTx(txResponse *sdk.TxResponse, tx *tx.Tx) (*Tx, error) + func (tx Tx) FindAttributeByKey(event sdk.StringEvent, attrKey string) (string, error) + func (tx Tx) FindEventByType(index int, eventType string) (sdk.StringEvent, error) + func (tx Tx) Successful() bool + type Validator struct + ConsAddr string + ConsPubKey string + func NewValidator(consAddr string, consPubKey string) *Validator