configuration

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 10, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	Kafka       KafkaConfig
	Tendermint  TendermintConfig
	Ethereum    EthereumConfig
	PStakeDenom string
	CoinType    uint32
	PStakeHome  string
}

func NewConfig

func NewConfig() Config

type EthereumConfig

type EthereumConfig struct {
	EthAccountPrivateKey *ecdsa.PrivateKey
	EthGasLimit          uint64
	EthereumEndpoint     string
	EthereumSleepTime    int // seconds
	EthereumStartHeight  int64
}

func NewEthereumConfig

func NewEthereumConfig() EthereumConfig

type KafkaConfig

type KafkaConfig struct {
	// Brokers: List of brokers to run kafka cluster
	Brokers      []string
	TopicDetail  sarama.TopicDetail
	ToEth        TopicConsumer
	ToTendermint TopicConsumer
	// start the first unbond
	EthUnbondStartTime time.Duration
	// Time for each unbonding transactions 3 days => input nano-seconds 259200000000000
	EthUnbondCycleTime time.Duration
}

func NewKafkaConfig

func NewKafkaConfig() KafkaConfig

type TendermintConfig

type TendermintConfig struct {
	PStakeAddress         sdkTypes.AccAddress
	Validators            []sdkTypes.ValAddress
	RelayerTimeout        string
	TendermintSleepTime   int //seconds
	TendermintStartHeight int64
}

func NewTendermintConfig

func NewTendermintConfig() TendermintConfig

type TopicConsumer

type TopicConsumer struct {
	MinBatchSize int
	MaxBatchSize int
	Ticker       time.Duration
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL