sync

Documentation

Overview

Package sync ...

Index

• Constants
• func HandleRequest(body []byte) error
• type TxReceipts
  • func NewSyncTxReceipts(db dbm.DB) *TxReceipts
  • func StartSyncTxReceipt(cfg *relayerTypes.SyncTxReceiptConfig, db dbm.DB) *TxReceipts
  • func (syncTx *TxReceipts) GetNextValidTxReceipts(height int64) (*types.TxReceipts4SubscribePerBlk, error)
  • func (syncTx *TxReceipts) GetTxReceipts(height int64) (*types.TxReceipts4SubscribePerBlk, error)
  • func (syncTx *TxReceipts) LoadLastBlockHeight() (int64, error)
  • func (syncTx *TxReceipts) SaveAndSyncTxs2Relayer()
  • func (syncTx *TxReceipts) Stop()

Constants

const (
	SeqTypeAdd = int32(1)
	SeqTypeDel = int32(2)
)

SeqType

Functions

func HandleRequest

func HandleRequest(body []byte) error

HandleRequest ...

Types

type TxReceipts

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

TxReceipts ...

func NewSyncTxReceipts

func NewSyncTxReceipts(db dbm.DB) *TxReceipts

NewSyncTxReceipts ...

func StartSyncTxReceipt

func StartSyncTxReceipt(cfg *relayerTypes.SyncTxReceiptConfig, db dbm.DB) *TxReceipts

StartSyncTxReceipt ...

func (*TxReceipts) GetNextValidTxReceipts

func (syncTx *TxReceipts) GetNextValidTxReceipts(height int64) (*types.TxReceipts4SubscribePerBlk, error)

GetNextValidTxReceipts ...

func (*TxReceipts) GetTxReceipts

func (syncTx *TxReceipts) GetTxReceipts(height int64) (*types.TxReceipts4SubscribePerBlk, error)

GetTxReceipts ...

func (*TxReceipts) LoadLastBlockHeight

func (syncTx *TxReceipts) LoadLastBlockHeight() (int64, error)

LoadLastBlockHeight ...

func (*TxReceipts) SaveAndSyncTxs2Relayer

func (syncTx *TxReceipts) SaveAndSyncTxs2Relayer()

SaveAndSyncTxs2Relayer save block to db

func (*TxReceipts) Stop

func (syncTx *TxReceipts) Stop()

Stop ...