common

Documentation

Index

• Constants
• func DecodeTransaction(tx models.Transaction) (functionSig string, params any, err error)
• func FormatFloat(f float64) string
• func GetYieldIntervalEnd(pbft_count uint64, block_num *uint64, interval uint64) uint64
• func MakeThreadPool() pool.Pool
• func ParseBool(s string) (v bool)
• func ParseInt(s string) (v int64)
• func ParseStringToBigInt(v string) *big.Int
• func ParseToString(item any) (result any, err error)
• func ParseUInt(s string) (v uint64)
• func ProcessTransaction(trx *models.Transaction) (err error)
• type CallData
• type ChainConfig
  • func DefaultChainConfig() *ChainConfig
• type Config
  • func DefaultConfig() *Config
  • func (c *Config) IsEligible(stake *big.Int) bool
• type Task
  • func MakeTask[P any](f func(P) error, params P, err *error) *Task[P]
  • func (t *Task[P]) Run()
• type TaskWithResult
  • func MakeTaskWithResult[P, R any](f func(P) (R, error), params P, result *R, err *error) *TaskWithResult[P, R]
  • func (t *TaskWithResult[P, R]) Run()

Constants

const DposContractAddress = "0x00000000000000000000000000000000000000fe"

Functions

func DecodeTransaction

func DecodeTransaction(tx models.Transaction) (functionSig string, params any, err error)

func FormatFloat

func FormatFloat(f float64) string

func GetYieldIntervalEnd

func GetYieldIntervalEnd(pbft_count uint64, block_num *uint64, interval uint64) uint64

func MakeThreadPool

func MakeThreadPool() pool.Pool

isn't creating threads, but limiting goroutines count. Mostly used for RPC and db related tasks

func ParseBool

func ParseBool(s string) (v bool)

func ParseInt

func ParseInt(s string) (v int64)

func ParseStringToBigInt

func ParseStringToBigInt(v string) *big.Int

func ParseToString

func ParseToString(item any) (result any, err error)

func ParseUInt

func ParseUInt(s string) (v uint64)

func ProcessTransaction

func ProcessTransaction(trx *models.Transaction) (err error)

Types

type CallData

type CallData struct {
	Name   string `json:"name"`
	Params any    `json:"params"`
}

type ChainConfig

type ChainConfig struct {
	CommitteeSize               *big.Int
	BlocksPerYear               *big.Int
	YieldPercentage             *big.Int
	DagProposersReward          *big.Int
	MaxBlockAuthorReward        *big.Int
	EligibilityBalanceThreshold *big.Int
}

func DefaultChainConfig

func DefaultChainConfig() *ChainConfig

type Config

type Config struct {
	Chain                         *ChainConfig
	TotalYieldSavingInterval      uint64
	ValidatorsYieldSavingInterval uint64
}

func DefaultConfig

func DefaultConfig() *Config

func (*Config) IsEligible

func (c *Config) IsEligible(stake *big.Int) bool

type Task

type Task[P any] struct {
	// contains filtered or unexported fields
}

func MakeTask

func MakeTask[P any](f func(P) error, params P, err *error) *Task[P]

func (*Task[P]) Run

func (t *Task[P]) Run()

type TaskWithResult

type TaskWithResult[P, R any] struct {
	// contains filtered or unexported fields
}

func MakeTaskWithResult

func MakeTaskWithResult[P, R any](f func(P) (R, error), params P, result *R, err *error) *TaskWithResult[P, R]

func (*TaskWithResult[P, R]) Run

func (t *TaskWithResult[P, R]) Run()