crosschaintx

Documentation

Index

• func InitCrossChainManager() error
• func InitCrossChainManagerMock() error
• type CrossChainTxManager
  • func (c *CrossChainTxManager) BuildCrossChainInfoFromBeginCrossChainRequest(beginCrossChainRequest *relay_chain.BeginCrossChainRequest) *common.CrossChainInfo
  • func (c *CrossChainTxManager) GetCrossChainInfo(crossChainId string) (*common.CrossChainInfo, error)
  • func (c *CrossChainTxManager) GetCrossChainInfoByRange(startCrossChainId, stopCrossChainId string) ([]*common.CrossChainInfo, error)
  • func (c *CrossChainTxManager) GetCrossChainNum() (uint64, error)
  • func (c *CrossChainTxManager) GetNotEndCrossChainIdList() ([]*common.CrossChainInfo, error)
  • func (c *CrossChainTxManager) NewCrossChainInfo(crossChainInfo *common.CrossChainInfo) (string, error)
  • func (c *CrossChainTxManager) Recover()

Functions

func InitCrossChainManager

func InitCrossChainManager() error

InitCrossChainManager 初始化跨链管理模块

@return error

func InitCrossChainManagerMock

func InitCrossChainManagerMock() error

InitCrossChainManagerMock 初始化跨链管理模块

@return error

Types

type CrossChainTxManager

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

CrossChainTxManager 跨链管理结构体

var CrossChainTxV1 *CrossChainTxManager

CrossChainTxV1 跨链管理全局变量

func (*CrossChainTxManager) BuildCrossChainInfoFromBeginCrossChainRequest

func (c *CrossChainTxManager) BuildCrossChainInfoFromBeginCrossChainRequest(
	beginCrossChainRequest *relay_chain.BeginCrossChainRequest) *common.CrossChainInfo

BuildCrossChainInfoFromBeginCrossChainRequest 通过跨链请求信息生成新的跨链信息

@receiver c
@param beginCrossChainRequest
@return *common.CrossChainInfo

func (*CrossChainTxManager) GetCrossChainInfo

func (c *CrossChainTxManager) GetCrossChainInfo(crossChainId string) (*common.CrossChainInfo, error)

GetCrossChainInfo 获取跨链信息

@receiver c
@param crossChainId
@return *common.CrossChainInfo
@return error

func (*CrossChainTxManager) GetCrossChainInfoByRange

func (c *CrossChainTxManager) GetCrossChainInfoByRange(
	startCrossChainId, stopCrossChainId string) ([]*common.CrossChainInfo, error)

GetCrossChainInfoByRange 获取跨链信息列表

@receiver c
@param startCrossChainId
@param stopCrossChainId
@return []*common.CrossChainInfo
@return error

func (*CrossChainTxManager) GetCrossChainNum

func (c *CrossChainTxManager) GetCrossChainNum() (uint64, error)

GetCrossChainNum 获取跨链信息个数

@receiver c
@return uint64
@return error

func (*CrossChainTxManager) GetNotEndCrossChainIdList

func (c *CrossChainTxManager) GetNotEndCrossChainIdList() ([]*common.CrossChainInfo, error)

GetNotEndCrossChainIdList 获取未结束的跨链id

@receiver c
@return []*common.CrossChainInfo
@return error

func (*CrossChainTxManager) NewCrossChainInfo

func (c *CrossChainTxManager) NewCrossChainInfo(crossChainInfo *common.CrossChainInfo) (string, error)

NewCrossChainInfo 生成心的跨链信息

@receiver c
@param crossChainInfo
@return string
@return error

func (*CrossChainTxManager) Recover

func (c *CrossChainTxManager) Recover()

Recover 断电恢复

@receiver c