Documentation ¶
Index ¶
- type CrossChain
- type CrossPool
- type CrossStore
- type Peer
- type SortedTxByBlockNum
- type Sync
- func (s *Sync) DeliverCrossTransactions(pid string, ctxList []*cc.CrossTransactionWithSignatures) error
- func (s *Sync) DeliverPending(pid string, pending []*cc.CrossTransaction) error
- func (s *Sync) RegisterPeer(id string, peer Peer) error
- func (s *Sync) Synchronise(id string, height *big.Int) error
- func (s *Sync) SynchronisePending(id string) error
- func (s *Sync) Terminate()
- func (s *Sync) UnregisterPeer(id string) error
- type SyncMode
- type SyncPendingReq
- type SyncPendingResp
- type SyncReq
- type SyncResp
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CrossChain ¶
type CrossChain interface { CanAcceptTxs() bool RequireSignatures() int GetConfirmedTransactionNumberOnChain(trigger.Transaction) uint64 }
type CrossStore ¶
type CrossStore interface { Height() uint64 Writes([]*cc.CrossTransactionWithSignatures, bool) error }
type SortedTxByBlockNum ¶
type SortedTxByBlockNum []*core.CrossTransactionWithSignatures
func (SortedTxByBlockNum) LastNumber ¶
func (s SortedTxByBlockNum) LastNumber() uint64
func (SortedTxByBlockNum) Len ¶
func (s SortedTxByBlockNum) Len() int
func (SortedTxByBlockNum) Less ¶
func (s SortedTxByBlockNum) Less(i, j int) bool
func (SortedTxByBlockNum) Swap ¶
func (s SortedTxByBlockNum) Swap(i, j int)
type Sync ¶
type Sync struct {
// contains filtered or unexported fields
}
func New ¶
func New(chainID *big.Int, pool CrossPool, store CrossStore, chain CrossChain, mode SyncMode) *Sync
func (*Sync) DeliverCrossTransactions ¶
func (s *Sync) DeliverCrossTransactions(pid string, ctxList []*cc.CrossTransactionWithSignatures) error
func (*Sync) DeliverPending ¶
func (s *Sync) DeliverPending(pid string, pending []*cc.CrossTransaction) error
func (*Sync) SynchronisePending ¶
func (*Sync) UnregisterPeer ¶
type SyncPendingReq ¶
type SyncPendingResp ¶
Click to show internal directories.
Click to hide internal directories.