order

Documentation

Index

• type Config
  • func GenerateConfig(opts ...Option) (*Config, error)
• type Option
  • func WithApplied(height uint64) Option
  • func WithDigest(digest string) Option
  • func WithGetAccountNonceFunc(f func(address *types.Address) uint64) Option
  • func WithGetBlockByHeightFunc(f func(height uint64) (*pb.Block, error)) Option
  • func WithGetChainMetaFunc(f func() *pb.ChainMeta) Option
  • func WithID(id uint64) Option
  • func WithIsNew(isNew bool) Option
  • func WithLogger(logger logrus.FieldLogger) Option
  • func WithNodes(nodes map[uint64]*pb.VpInfo) Option
  • func WithPeerManager(peerMgr peermgr.PeerManager) Option
  • func WithPluginPath(path string) Option
  • func WithPrivKey(privKey crypto.PrivateKey) Option
  • func WithRepoRoot(path string) Option
  • func WithStoragePath(path string) Option
• type Order
• type ReqLookUp
  • func NewReqLookUp(storage storage.Storage, logger logrus.FieldLogger) (*ReqLookUp, error)
  • func (r *ReqLookUp) Add(key []byte)
  • func (r *ReqLookUp) Build() error
  • func (r *ReqLookUp) LookUp(key []byte) bool

Types

type Config

type Config struct {
	ID               uint64
	IsNew            bool
	RepoRoot         string
	StoragePath      string
	PluginPath       string
	PeerMgr          peermgr.PeerManager
	PrivKey          crypto.PrivateKey
	Logger           logrus.FieldLogger
	Nodes            map[uint64]*pb.VpInfo
	Applied          uint64
	Digest           string
	GetChainMetaFunc func() *pb.ChainMeta
	GetBlockByHeight func(height uint64) (*pb.Block, error)
	GetAccountNonce  func(address *types.Address) uint64
}

func GenerateConfig

func GenerateConfig(opts ...Option) (*Config, error)

type Option

type Option func(*Config)

func WithApplied

func WithApplied(height uint64) Option

func WithDigest

func WithDigest(digest string) Option

func WithGetAccountNonceFunc

func WithGetAccountNonceFunc(f func(address *types.Address) uint64) Option

func WithGetBlockByHeightFunc

func WithGetBlockByHeightFunc(f func(height uint64) (*pb.Block, error)) Option

func WithGetChainMetaFunc

func WithGetChainMetaFunc(f func() *pb.ChainMeta) Option

func WithID

func WithID(id uint64) Option

func WithIsNew

func WithIsNew(isNew bool) Option

func WithLogger

func WithLogger(logger logrus.FieldLogger) Option

func WithNodes

func WithNodes(nodes map[uint64]*pb.VpInfo) Option

func WithPeerManager

func WithPeerManager(peerMgr peermgr.PeerManager) Option

func WithPluginPath

func WithPluginPath(path string) Option

func WithPrivKey

func WithPrivKey(privKey crypto.PrivateKey) Option

func WithRepoRoot

func WithRepoRoot(path string) Option

func WithStoragePath

func WithStoragePath(path string) Option

type Order

type Order interface {
	// Start the order service.
	Start() error

	// Stop means frees the resources which were allocated for this service.
	Stop()

	// Prepare means send transaction to the consensus engine
	Prepare(tx pb.Transaction) error

	// Commit recv blocks form Order and commit it by order
	Commit() chan *pb.CommitEvent

	// Step send msg to the consensus engine
	Step(msg []byte) error

	// Ready means whether order has finished electing leader
	Ready() error

	// ReportState means block was persisted and report it to the consensus engine
	ReportState(height uint64, blockHash *types.Hash, txHashList []*types.Hash)

	// Quorum means minimum number of nodes in the cluster that can work
	Quorum() uint64

	// GetPendingNonce will return the latest pending nonce of a given account
	GetPendingNonceByAccount(account string) uint64

	GetPendingTxByHash(hash *types.Hash) pb.Transaction

	// DelNode sends a delete vp request by given id.
	DelNode(delID uint64) error

	SubscribeTxEvent(events chan<- pb.Transactions) event.Subscription
}

type ReqLookUp

type ReqLookUp struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewReqLookUp

func NewReqLookUp(storage storage.Storage, logger logrus.FieldLogger) (*ReqLookUp, error)

func (*ReqLookUp) Add

func (r *ReqLookUp) Add(key []byte)

func (*ReqLookUp) Build

func (r *ReqLookUp) Build() error

func (*ReqLookUp) LookUp

func (r *ReqLookUp) LookUp(key []byte) bool