handler

Documentation

Index

• type PriAsyEthHandler
  • func NewPriAsyEthHandler(cfg *config.Config, db *db.Ldb) *PriAsyEthHandler
  • func (this *PriAsyEthHandler) Close()
  • func (this *PriAsyEthHandler) Start()
• type PriSynEthHandler
  • func InitPriSynEthHandler(sinkAddrStr string, cfg config.EthCfg) (*PriSynEthHandler, error)
  • func (p *PriSynEthHandler) HashAvailable(hashStr string) (bool, error)
  • func (p *PriSynEthHandler) TxExists(hashStr, txHashStr string) (bool, error)

Types

type PriAsyEthHandler

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

异步处理

func NewPriAsyEthHandler

func NewPriAsyEthHandler(cfg *config.Config, db *db.Ldb) *PriAsyEthHandler

func (*PriAsyEthHandler) Close

func (this *PriAsyEthHandler) Close()

关闭私链操作处理

func (*PriAsyEthHandler) Start

func (this *PriAsyEthHandler) Start()

上私链操作

type PriSynEthHandler

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

同步处理

var PriSynEth *PriSynEthHandler

func InitPriSynEthHandler

func InitPriSynEthHandler(sinkAddrStr string, cfg config.EthCfg) (*PriSynEthHandler, error)

func (*PriSynEthHandler) HashAvailable

func (p *PriSynEthHandler) HashAvailable(hashStr string) (bool, error)

hash是否有效

func (*PriSynEthHandler) TxExists

func (p *PriSynEthHandler) TxExists(hashStr, txHashStr string) (bool, error)

申请是否成功