utils

Documentation

Index

• Constants
• func GetGovernanceView(backend *ledger.Ledger) (*governance.GovernanceView, error)
• type GovCache
• type GovNodeInfo
  • func GetPeersConfig(backend *ledger.Ledger, view uint32) ([]*GovNodeInfo, uint32, error)
• type GovNodeLedgerResolver
  • func NewGovNodeResolver(db *ledger.Ledger) *GovNodeLedgerResolver
  • func (self *GovNodeLedgerResolver) GetNodeRoleAndView(pubKey string) (NodeRole, uint32)
  • func (self *GovNodeLedgerResolver) IsGovNode(pubKey string) bool
  • func (self *GovNodeLedgerResolver) IsGovNodePubKey(key keypair.PublicKey) bool
• type GovNodeMockResolver
  • func NewGovNodeMockResolver(gov []string) *GovNodeMockResolver
  • func (self *GovNodeMockResolver) GetNodeRoleAndView(key string) (NodeRole, uint32)
  • func (self *GovNodeMockResolver) IsGovNode(key string) bool
  • func (self *GovNodeMockResolver) IsGovNodePubKey(key keypair.PublicKey) bool
• type GovNodeResolver
• type HostsCache
• type HostsResolver
  • func NewHostsResolver(hosts []string) (*HostsResolver, []string)
  • func (self *HostsResolver) GetHostAddrs() []string
• type NodeRole
• type Parker
  • func NewParker() *Parker
  • func (self *Parker) ParkTimeout(d time.Duration)
  • func (self *Parker) Unpark()

Constants

const (
	SyncNode      NodeRole = iota
	CandidateNode          = iota
	ConsensusNode          = iota
)

const GovNodeCacheTime = time.Minute * 10

const HostsResolverCacheTime = time.Minute * 10

Functions

func GetGovernanceView

func GetGovernanceView(backend *ledger.Ledger) (*governance.GovernanceView, error)

Types

type GovCache

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

type GovNodeInfo

type GovNodeInfo struct {
	ConsNode bool
	*config.VBFTPeerStakeInfo
}

func GetPeersConfig

func GetPeersConfig(backend *ledger.Ledger, view uint32) ([]*GovNodeInfo, uint32, error)

type GovNodeLedgerResolver

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

func NewGovNodeResolver

func NewGovNodeResolver(db *ledger.Ledger) *GovNodeLedgerResolver

func (*GovNodeLedgerResolver) GetNodeRoleAndView

func (self *GovNodeLedgerResolver) GetNodeRoleAndView(pubKey string) (NodeRole, uint32)

func (*GovNodeLedgerResolver) IsGovNode

func (self *GovNodeLedgerResolver) IsGovNode(pubKey string) bool

func (*GovNodeLedgerResolver) IsGovNodePubKey

func (self *GovNodeLedgerResolver) IsGovNodePubKey(key keypair.PublicKey) bool

type GovNodeMockResolver

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

func NewGovNodeMockResolver

func NewGovNodeMockResolver(gov []string) *GovNodeMockResolver

func (*GovNodeMockResolver) GetNodeRoleAndView

func (self *GovNodeMockResolver) GetNodeRoleAndView(key string) (NodeRole, uint32)

func (*GovNodeMockResolver) IsGovNode

func (self *GovNodeMockResolver) IsGovNode(key string) bool

func (*GovNodeMockResolver) IsGovNodePubKey

func (self *GovNodeMockResolver) IsGovNodePubKey(key keypair.PublicKey) bool

type GovNodeResolver

type GovNodeResolver interface {
	IsGovNodePubKey(key keypair.PublicKey) bool
	IsGovNode(key string) bool
	GetNodeRoleAndView(key string) (NodeRole, uint32)
}

type HostsCache

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

type HostsResolver

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

host resolver with cache

func NewHostsResolver

func NewHostsResolver(hosts []string) (*HostsResolver, []string)

func (*HostsResolver) GetHostAddrs

func (self *HostsResolver) GetHostAddrs() []string

type NodeRole

type NodeRole byte

type Parker

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

func NewParker

func NewParker() *Parker

func (*Parker) ParkTimeout

func (self *Parker) ParkTimeout(d time.Duration)

func (*Parker) Unpark

func (self *Parker) Unpark()