request

Documentation

Index

• func InitRequestManager() error
• func InitRequestManagerMock() error
• type Request
• type RequestManager
  • func (r *RequestManager) BeginCrossChain(eventInfo *event.EventInfo)
  • func (r *RequestManager) GatewayRegister(objectPath string) error
  • func (r *RequestManager) GatewayUpdate(objectPath string) error
  • func (r *RequestManager) InitSpvContracta(version, path, runtimeType, kvJsonStr, chainRid string) error
  • func (r *RequestManager) SyncBlockHeader(blockHeader *chainmaker_common.BlockHeader, chainRid string)
  • func (r *RequestManager) UpdateSpvContract(version, path, runtimeType, kvJsonStr, chainRid string) error

Functions

func InitRequestManager

func InitRequestManager() error

InitRequestManager 初始化request

@return error

func InitRequestManagerMock

func InitRequestManagerMock() error

InitRequestManagerMock 初始化request模块

@return error

Types

type Request

type Request interface {
	BeginCrossChain(req *relay_chain.BeginCrossChainRequest) (*relay_chain.BeginCrossChainResponse, error)
	SyncBlockHeader(req *relay_chain.SyncBlockHeaderRequest) (*relay_chain.SyncBlockHeaderResponse, error)
	InitSpvContract(req *relay_chain.InitContractRequest) (*relay_chain.InitContractResponse, error)
	UpdateSpvContract(req *relay_chain.UpdateContractRequest) (*relay_chain.UpdateContractResponse, error)
}

Request 请求接口

type RequestManager

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

RequestManager 请求管理结构体

var RequestV1 *RequestManager

RequestV1 rquest模块对象

func (*RequestManager) BeginCrossChain

func (r *RequestManager) BeginCrossChain(eventInfo *event.EventInfo)

BeginCrossChain 如果要保存跨链信息的话，在这个函数里面实现就可以,可以根据结果写入数据库或者文件什么的都可以

@receiver r
@param eventInfo

func (*RequestManager) GatewayRegister

func (r *RequestManager) GatewayRegister(objectPath string) error

GatewayRegister 获取gateway注册信息

@receiver r
@param objectPath
@return error

func (*RequestManager) GatewayUpdate

func (r *RequestManager) GatewayUpdate(objectPath string) error

GatewayUpdate 获取更新gateway的信息

@receiver r
@param objectPath
@return error

func (*RequestManager) InitSpvContracta

func (r *RequestManager) InitSpvContracta(version, path, runtimeType, kvJsonStr, chainRid string) error

InitSpvContracta 初始化spv合约

@receiver r
@param version
@param path
@param runtimeType
@param kvJsonStr
@param chainRid
@return error

func (*RequestManager) SyncBlockHeader

func (r *RequestManager) SyncBlockHeader(blockHeader *chainmaker_common.BlockHeader, chainRid string)

SyncBlockHeader 同步区块头

@receiver r
@param blockHeader
@param chainRid

func (*RequestManager) UpdateSpvContract

func (r *RequestManager) UpdateSpvContract(version, path, runtimeType, kvJsonStr, chainRid string) error

UpdateSpvContract 更新spv合约

@receiver r
@param version
@param path
@param runtimeType
@param kvJsonStr
@param chainRid
@return error