police

Documentation

Index

• func GetPolicePassphrase() string
• func SetPolicePassphrase(passphrase string)
• type Backend
• type HeaderWithHeight
  • func (match *HeaderWithHeight) BlockHash() common.Hash
  • func (match *HeaderWithHeight) BlockNum() uint64
• type Lamp
• type Officer
  • func New(elephant Backend, eth Lamp) *Officer
  • func (self *Officer) IsBusying() bool
  • func (self *Officer) PushWork(work *Work)
  • func (self *Officer) SetEtherbase(coinbase common.Address)
  • func (self *Officer) Start(coinbase common.Address)
  • func (self *Officer) Stop()
  • func (self *Officer) Work() chan<- *Work
• type Result
• type Work

Functions

func GetPolicePassphrase

func GetPolicePassphrase() string

func SetPolicePassphrase

func SetPolicePassphrase(passphrase string)

Types

type Backend

type Backend interface {
	GetEleHeaderByNumber(number uint64) *types_elephant.Header
	GetEleHeadersFromPeer(from uint64, amount int, shardingID uint16, lampNum uint64) ([]*types_elephant.Header, error)
	SignVerifyResult(data []byte, passphrase string) ([]byte, error)
	BroadcastPoliceVerify(result *Result)
	DeliverVerifiedResult(result *Result)
}

Backend wraps all methods required for verifying.

type HeaderWithHeight

type HeaderWithHeight struct {
	ShardingID  uint16
	LampBase    *common.Hash
	Header      *common.Hash
	BlockNumber uint64

	PreviousHeaders []*common.Hash // Hashes of the verified headers from last to this one
}

func (*HeaderWithHeight) BlockHash

func (match *HeaderWithHeight) BlockHash() common.Hash

func (*HeaderWithHeight) BlockNum

func (match *HeaderWithHeight) BlockNum() uint64

type Lamp

type Lamp interface {
	GetValidHeadersByBlockNum(blockNum uint64) map[uint16]*types.VerifiedValid
	CurrEleSealersBlockNum() rpc.BlockNumber
}

Lamp wraps all methods required for verifying.

type Officer

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

officer is the main object which takes care of applying messages to the new state

func New

func New(elephant Backend, eth Lamp) *Officer

func (*Officer) IsBusying

func (self *Officer) IsBusying() bool

func (self *Officer) SetReturnCh(ch chan<- *Result) { self.returnCh = ch }

func (*Officer) PushWork

func (self *Officer) PushWork(work *Work)

func (*Officer) SetEtherbase

func (self *Officer) SetEtherbase(coinbase common.Address)

func (*Officer) Start

func (self *Officer) Start(coinbase common.Address)

func (*Officer) Stop

func (self *Officer) Stop()

func (*Officer) Work

func (self *Officer) Work() chan<- *Work

type Result

type Result struct {
	Match *HeaderWithHeight // the sharding header's hash matching with the tx root hash fetched from the liaison
	Sign  string
}

type Work

type Work struct {
	ShardingTxBatch *types_elephant.ShardingTxBatch
}

Work is the officer task that shall be verified