scheduler

Documentation

Index

• Constants
• type ConsulInfo
• type Scheduler
  • func New(adaptors map[account.ChainType]adaptors.IBlockchainAdaptor, ...) (*Scheduler, error)
  • func (scheduler *Scheduler) HandleBlock(height int64, store *storage.Storage, isSync bool, isConsul bool) error

Constants

const (
	CalculateScoreInterval = 200
	OracleCount            = 5
)

Types

type ConsulInfo

type ConsulInfo struct {
	ConsulIndex int
	TotalCount  int
	IsConsul    bool
}

type Scheduler

type Scheduler struct {
	Adaptors map[account.ChainType]adaptors.IBlockchainAdaptor
	Ledger   *account.LedgerValidator
	// contains filtered or unexported fields
}

func New

func New(adaptors map[account.ChainType]adaptors.IBlockchainAdaptor, ledger *account.LedgerValidator, localHost string, ctx context.Context) (*Scheduler, error)

func (*Scheduler) HandleBlock

func (scheduler *Scheduler) HandleBlock(height int64, store *storage.Storage, isSync bool, isConsul bool) error