relaycross

Documentation

Index

• type RelayCrossManager
  • func NewRelayCrossManager(log protocol.Logger) *RelayCrossManager
  • func (r *RelayCrossManager) GetMethod(methodName string) common.ContractFunc
• type RelayCrossRuntime
  • func (r *RelayCrossRuntime) DeleteErrorCrossChainTxList(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, error)
  • func (r *RelayCrossRuntime) GetCrossChainInfo(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, error)
  • func (r *RelayCrossRuntime) GetCrossChainInfoByRange(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, error)
  • func (r *RelayCrossRuntime) GetCrossChainNum(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, error)
  • func (r *RelayCrossRuntime) GetGateway(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, error)
  • func (r *RelayCrossRuntime) GetGatewayByRange(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, error)
  • func (r *RelayCrossRuntime) GetGatewayNum(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, error)
  • func (r *RelayCrossRuntime) GetNotEndCrossChainIdList(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, error)
  • func (r *RelayCrossRuntime) SaveCrossChainInfo(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, []*pbcommon.ContractEvent, error)
  • func (r *RelayCrossRuntime) SaveGateway(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, error)
  • func (r *RelayCrossRuntime) UpdateCrossChainConfirm(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, []*pbcommon.ContractEvent, error)
  • func (r *RelayCrossRuntime) UpdateCrossChainResult(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, []*pbcommon.ContractEvent, error)
  • func (r *RelayCrossRuntime) UpdateCrossChainTry(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, []*pbcommon.ContractEvent, error)
  • func (r *RelayCrossRuntime) UpdateGateway(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, error)
  • func (r *RelayCrossRuntime) UpdateSrcGatewayConfirm(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, []*pbcommon.ContractEvent, error)

Types

type RelayCrossManager

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

RelayCrossManager 提供中继跨链管理

func NewRelayCrossManager

func NewRelayCrossManager(log protocol.Logger) *RelayCrossManager

NewRelayCrossManager create a new RelayCrossManager instance @param log @return *ContractManager

func (*RelayCrossManager) GetMethod

func (r *RelayCrossManager) GetMethod(methodName string) common.ContractFunc

GetMethod get register method by name @receiver r @param methodName @return common.ContractFunc

type RelayCrossRuntime

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

RelayCrossRuntime 提供中继跨链管理功能

func (*RelayCrossRuntime) DeleteErrorCrossChainTxList

func (r *RelayCrossRuntime) DeleteErrorCrossChainTxList(ctx protocol.TxSimContext,
	params map[string][]byte) ([]byte, error)

DeleteErrorCrossChainTxList 删除错误的跨链id

@receiver r
@param ctx
@param params
@return []byte
@return error

func (*RelayCrossRuntime) GetCrossChainInfo

func (r *RelayCrossRuntime) GetCrossChainInfo(ctx protocol.TxSimContext,
	params map[string][]byte) ([]byte, error)

GetCrossChainInfo 获取跨链交易

@receiver r
@param ctx
@param params
@return []byte
@return error

func (*RelayCrossRuntime) GetCrossChainInfoByRange

func (r *RelayCrossRuntime) GetCrossChainInfoByRange(ctx protocol.TxSimContext,
	params map[string][]byte) ([]byte, error)

GetCrossChainInfoByRange 批量获取跨链交易

@receiver r
@param ctx
@param params
@return []byte
@return error

func (*RelayCrossRuntime) GetCrossChainNum

func (r *RelayCrossRuntime) GetCrossChainNum(ctx protocol.TxSimContext,
	params map[string][]byte) ([]byte, error)

GetCrossChainNum 获取跨链交易个数

@receiver r
@param ctx
@param params
@return []byte
@return error

func (*RelayCrossRuntime) GetGateway

func (r *RelayCrossRuntime) GetGateway(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, error)

GetGateway 获取gateway

@receiver r
@param ctx
@param params
@return []byte
@return error

func (*RelayCrossRuntime) GetGatewayByRange

func (r *RelayCrossRuntime) GetGatewayByRange(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, error)

GetGatewayByRange 批量获取gateway

@receiver r
@param ctx
@param params
@return []byte
@return error

func (*RelayCrossRuntime) GetGatewayNum

func (r *RelayCrossRuntime) GetGatewayNum(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, error)

GetGatewayNum 获取gateway个数

@receiver r
@param ctx
@param params
@return []byte
@return error

func (*RelayCrossRuntime) GetNotEndCrossChainIdList

func (r *RelayCrossRuntime) GetNotEndCrossChainIdList(ctx protocol.TxSimContext,
	params map[string][]byte) ([]byte, error)

GetNotEndCrossChainIdList 获取未完成的跨链交易id

@receiver r
@param ctx
@param params
@return []byte
@return error

func (*RelayCrossRuntime) SaveCrossChainInfo

func (r *RelayCrossRuntime) SaveCrossChainInfo(ctx protocol.TxSimContext,
	params map[string][]byte) ([]byte, []*pbcommon.ContractEvent, error)

SaveCrossChainInfo 保存跨链交易

@receiver r
@param ctx
@param params
@return []byte
@return []*pbcommon.ContractEvent
@return error

func (*RelayCrossRuntime) SaveGateway

func (r *RelayCrossRuntime) SaveGateway(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, error)

SaveGateway 保存gateway

@receiver r
@param ctx
@param params
@return []byte
@return error

func (*RelayCrossRuntime) UpdateCrossChainConfirm

func (r *RelayCrossRuntime) UpdateCrossChainConfirm(ctx protocol.TxSimContext,
	params map[string][]byte) ([]byte, []*pbcommon.ContractEvent, error)

UpdateCrossChainConfirm 更新目标网关的confirm信息

@receiver r
@param ctx
@param params
@return []byte
@return []*pbcommon.ContractEvent
@return error

func (*RelayCrossRuntime) UpdateCrossChainResult

func (r *RelayCrossRuntime) UpdateCrossChainResult(ctx protocol.TxSimContext,
	params map[string][]byte) ([]byte, []*pbcommon.ContractEvent, error)

UpdateCrossChainResult 更新跨链结果

@receiver r
@param ctx
@param params
@return []byte
@return []*pbcommon.ContractEvent
@return error

func (*RelayCrossRuntime) UpdateCrossChainTry

func (r *RelayCrossRuntime) UpdateCrossChainTry(ctx protocol.TxSimContext,
	params map[string][]byte) ([]byte, []*pbcommon.ContractEvent, error)

UpdateCrossChainTry 更新cross chain try 信息

@receiver r
@param ctx
@param params
@return []byte
@return []*pbcommon.ContractEvent
@return error

func (*RelayCrossRuntime) UpdateGateway

func (r *RelayCrossRuntime) UpdateGateway(ctx protocol.TxSimContext, params map[string][]byte) ([]byte, error)

UpdateGateway 更新gateway

@receiver r
@param ctx
@param params
@return []byte
@return error

func (*RelayCrossRuntime) UpdateSrcGatewayConfirm

func (r *RelayCrossRuntime) UpdateSrcGatewayConfirm(ctx protocol.TxSimContext,
	params map[string][]byte) ([]byte, []*pbcommon.ContractEvent, error)

UpdateSrcGatewayConfirm 更新源网关的confirm信息

@receiver r
@param ctx
@param params
@return []byte
@return []*pbcommon.ContractEvent
@return error