syncer

package

v0.0.6 Latest Latest Go to latest Published: Sep 25, 2019 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/QOSGroup/qmoon

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type COSMOS
type QOS
type QOSStakingValidator
type QSC
type StakingValidator
type Syncer
- func NewSyncer(node *service.Node) Syncer

Constants ¶

View Source

const (
	SyncConsensusStateDuration = time.Second * 2
	SyncPeerDuration           = time.Second * 30
	SyncValidator              = time.Second * 2
)

View Source

const (
	SyncLocked   = "1"
	SyncUnlocked = "0"
)

View Source

const (
	LockTypeBlock          = "block"
	LockTypeConsensusState = "consensus_state"
	LockTypePeer           = "peer"
	LockTypeValidator      = "validator"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type COSMOS ¶

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

func (COSMOS) BlockLoop ¶

func (s COSMOS) BlockLoop(ctx context.Context) error

BlockLoop 同步块

func (COSMOS) ConsensusStateLoop ¶

func (s COSMOS) ConsensusStateLoop(ctx context.Context) error

func (COSMOS) Lock ¶

func (s COSMOS) Lock(key string) bool

SyncLock 同步时锁定，同一个时间只会有一个同步协程

func (COSMOS) PeerLoop ¶

func (s COSMOS) PeerLoop(ctx context.Context) error

func (COSMOS) RpcPeers ¶

func (s COSMOS) RpcPeers(ctx context.Context) error

func (COSMOS) Unlock ¶

func (s COSMOS) Unlock(key string) bool

func (COSMOS) Validator ¶

func (s COSMOS) Validator(height int64, t time.Time) error

type QOS ¶

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

func (QOS) BlockLoop ¶

func (s QOS) BlockLoop(ctx context.Context) error

BlockLoop 同步块

func (QOS) ConsensusStateLoop ¶

func (s QOS) ConsensusStateLoop(ctx context.Context) error

func (QOS) Lock ¶

func (s QOS) Lock(key string) bool

SyncLock 同步时锁定，同一个时间只会有一个同步协程

func (QOS) PeerLoop ¶

func (s QOS) PeerLoop(ctx context.Context) error

func (QOS) RpcPeers ¶

func (s QOS) RpcPeers(ctx context.Context) error

func (QOS) Unlock ¶

func (s QOS) Unlock(key string) bool

func (QOS) Validator ¶

func (s QOS) Validator(height int64, t time.Time) error

type QOSStakingValidator ¶

type QOSStakingValidator struct {
	Commission struct {
		MaxChangeRate string `json:"max_change_rate"`
		MaxRate       string `json:"max_rate"`
		Rate          string `json:"rate"`
		UpdateTime    string `json:"update_time"`
	} `json:"commission"`
	ConsensusPubkey string `json:"consensus_pubkey"`
	DelegatorShares string `json:"delegator_shares"`
	Description     struct {
		Details string `json:"details"`
		Logo    string `json:"logo"`
		Moniker string `json:"moniker"`
		Website string `json:"website"`
	} `json:"description"`
	Jailed            bool   `json:"jailed"`
	MinSelfDelegation string `json:"min_self_delegation"`
	OperatorAddress   string `json:"operator_address"`
	Status            int    `json:"status"`
	Tokens            string `json:"tokens"`
	UnbondingHeight   string `json:"unbonding_height"`
	UnbondingTime     string `json:"unbonding_time"`
}

QOSStakingValidator struct

type QSC ¶

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

func (QSC) BlockLoop ¶

func (s QSC) BlockLoop(ctx context.Context) error

BlockLoop 同步块

func (QSC) ConsensusStateLoop ¶

func (s QSC) ConsensusStateLoop(ctx context.Context) error

func (QSC) Lock ¶

func (s QSC) Lock(key string) bool

SyncLock 同步时锁定，同一个时间只会有一个同步协程

func (QSC) PeerLoop ¶

func (s QSC) PeerLoop(ctx context.Context) error

func (QSC) RpcPeers ¶

func (s QSC) RpcPeers(ctx context.Context) error

func (QSC) Unlock ¶

func (s QSC) Unlock(key string) bool

func (QSC) Validator ¶

func (s QSC) Validator(height int64, t time.Time) error

type StakingValidator ¶

type StakingValidator struct {
	Commission struct {
		MaxChangeRate string `json:"max_change_rate"`
		MaxRate       string `json:"max_rate"`
		Rate          string `json:"rate"`
		UpdateTime    string `json:"update_time"`
	} `json:"commission"`
	ConsPubKey      string `json:"consensus_pubkey"`
	DelegatorShares string `json:"delegator_shares"`
	Description     struct {
		Details  string `json:"details"`
		Identity string `json:"identity"`
		Moniker  string `json:"moniker"`
		Website  string `json:"website"`
	} `json:"description"`
	Jailed                  bool   `json:"jailed"`
	MinSelfDelegation       string `json:"min_self_delegation"`
	OperatorAddress         string `json:"operator_address"`
	Status                  int    `json:"status"`
	Tokens                  string `json:"tokens"`
	UnbondingHeight         string `json:"unbonding_height"`
	UnbondingCompletionTime string `json:"unbonding_time"`
}

type Syncer ¶

type Syncer interface {
	Validator(height int64, t time.Time) error
	BlockLoop(ctx context.Context) error
	ConsensusStateLoop(ctx context.Context) error
	RpcPeers(ctx context.Context) error

	Lock(key string) bool
	Unlock(key string) bool
}

Syncer

func NewSyncer ¶

func NewSyncer(node *service.Node) Syncer

Source Files ¶

View all Source files

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