config

Documentation

Index

• Variables
• func GetConfig(config interface{}, path string) error
• func GetLoggerFor(ctx string) *log.Entry
• func InitLogger(level string, format string)
• func LoadHederaFees(tokens parser.Tokens) (res struct{ ... })
• type Bridge
  • func NewBridge(bridge parser.Bridge) *Bridge
  • func (b Bridge) LoadStaticMinAmountsForWrappedFungibleTokens(parsedBridge parser.Bridge, assetsService service.Assets)
  • func (b *Bridge) Update(from *Bridge)
• type BridgeEvm
• type BridgeHedera
• type Clients
• type CoinGecko
• type CoinMarketCap
• type Config
  • func LoadConfig() (*Config, *parser.Bridge, error)
• type Database
• type Evm
• type GCEFormatter
  • func NewGCEFormatter(withSourceInfo bool) *GCEFormatter
  • func (f *GCEFormatter) Format(entry *logrus.Entry) ([]byte, error)
• type Hedera
  • func (h *Hedera) DefaultOrConfig(cfg *parser.Hedera) *Hedera
• type HederaToken
  • func NewHederaTokenFromToken(token parser.Token) HederaToken
• type MirrorNode
  • func (m *MirrorNode) DefaultOrConfig(cfg *parser.MirrorNode) *MirrorNode
• type Monitoring
• type Node
  • func New(node parser.Node) Node
• type Operator
• type Recovery
• type RetryPolicy
  • func (r *RetryPolicy) DefaultOrConfig(cfg *parser.RetryPolicy) *RetryPolicy
• type Token

Variables

var (
	ErrSkipNotFound = errors.New("could not find skips for log level")
)

Functions

func GetConfig

func GetConfig(config interface{}, path string) error

func GetLoggerFor

func GetLoggerFor(ctx string) *log.Entry

GetLoggerFor returns a logger defined with a context

func InitLogger

func InitLogger(level string, format string)

InitLogger sets the initial configuration of the used logger

func LoadHederaFees

func LoadHederaFees(tokens parser.Tokens) (res struct {
	FungiblePercentages map[string]int64
	ConstantNftFees     map[string]int64
	DynamicNftFees      map[string]decimal.Decimal
})

Types

type Bridge

type Bridge struct {
	TopicId           string
	Hedera            *BridgeHedera
	EVMs              map[uint64]BridgeEvm
	CoinMarketCapIds  map[uint64]map[string]string
	CoinGeckoIds      map[uint64]map[string]string
	MinAmounts        map[uint64]map[string]*big.Int
	MonitoredAccounts map[string]string
}

func NewBridge

func NewBridge(bridge parser.Bridge) *Bridge

func (Bridge) LoadStaticMinAmountsForWrappedFungibleTokens

func (b Bridge) LoadStaticMinAmountsForWrappedFungibleTokens(parsedBridge parser.Bridge, assetsService service.Assets)

func (*Bridge) Update

func (b *Bridge) Update(from *Bridge)

type BridgeEvm

type BridgeEvm struct {
	RouterContractAddress string
	Tokens                map[string]Token
}

type BridgeHedera

type BridgeHedera struct {
	BridgeAccount   string
	PayerAccount    string
	Members         []string
	Tokens          map[string]HederaToken
	FeePercentages  map[string]int64
	NftConstantFees map[string]int64
	NftDynamicFees  map[string]decimal.Decimal
}

type Clients

type Clients struct {
	Evm           map[uint64]Evm
	Hedera        Hedera
	MirrorNode    MirrorNode
	CoinGecko     CoinGecko
	CoinMarketCap CoinMarketCap
}

type CoinGecko

type CoinGecko struct {
	ApiAddress string
}

type CoinMarketCap

type CoinMarketCap struct {
	ApiKey     string
	ApiAddress string
}

type Config

type Config struct {
	Node   Node
	Bridge *Bridge
}

func LoadConfig

func LoadConfig() (*Config, *parser.Bridge, error)

type Database

type Database struct {
	Host     string
	Name     string
	Password string
	Port     string
	Username string
}

type Evm

type Evm struct {
	BlockConfirmations uint64
	NodeUrl            string
	PrivateKey         string
	StartBlock         int64
	PollingInterval    time.Duration
	MaxLogsBlocks      int64
}

type GCEFormatter

type GCEFormatter struct {
	// contains filtered or unexported fields
}

func NewGCEFormatter

func NewGCEFormatter(withSourceInfo bool) *GCEFormatter

func (*GCEFormatter) Format

func (f *GCEFormatter) Format(entry *logrus.Entry) ([]byte, error)

type Hedera

type Hedera struct {
	Operator       Operator
	Network        string
	Rpc            map[string]hedera.AccountID
	StartTimestamp int64
	MaxRetry       int
}

func (*Hedera) DefaultOrConfig

func (h *Hedera) DefaultOrConfig(cfg *parser.Hedera) *Hedera

type HederaToken

type HederaToken struct {
	Fee               int64
	FeePercentage     int64
	MinFeeAmountInUsd string
	MinAmount         *big.Int
	Networks          map[uint64]string
	ReleaseTimestamp  uint64
}

func NewHederaTokenFromToken

func NewHederaTokenFromToken(token parser.Token) HederaToken

type MirrorNode

type MirrorNode struct {
	ClientAddress     string
	ApiAddress        string
	PollingInterval   time.Duration
	QueryMaxLimit     int64
	QueryDefaultLimit int64
	RetryPolicy       RetryPolicy
	RequestTimeout    int
}

func (*MirrorNode) DefaultOrConfig

func (m *MirrorNode) DefaultOrConfig(cfg *parser.MirrorNode) *MirrorNode

type Monitoring

type Monitoring struct {
	Enable           bool
	DashboardPolling time.Duration
}

type Node

type Node struct {
	Database   Database
	Clients    Clients
	LogLevel   string
	LogFormat  string
	Port       string
	Validator  bool
	Monitoring Monitoring
}

func New

func New(node parser.Node) Node

type Operator

type Operator struct {
	AccountId  string
	PrivateKey string
}

type Recovery

type Recovery struct {
	StartTimestamp int64
	StartBlock     int64
}

type RetryPolicy

type RetryPolicy struct {
	MaxRetry  int
	MinWait   int
	MaxWait   int
	MaxJitter int
}

func (*RetryPolicy) DefaultOrConfig

func (r *RetryPolicy) DefaultOrConfig(cfg *parser.RetryPolicy) *RetryPolicy

type Token

type Token struct {
	MinFeeAmountInUsd *big.Int
	Networks          map[uint64]string
	ReleaseTimestamp  uint64
}