handler

Documentation

Index

• type Handler
  • func NewHandler() *Handler
  • func (h *Handler) ChainIdentity(ctx context.Context, req *cross_chain.ChainIdentityRequest) (*cross_chain.ChainIdentityResponse, error)
  • func (h *Handler) CrossChainCancel(ctx context.Context, req *cross_chain.CrossChainCancelRequest) (*cross_chain.CrossChainCancelResponse, error)
  • func (h *Handler) CrossChainConfirm(ctx context.Context, req *cross_chain.CrossChainConfirmRequest) (*cross_chain.CrossChainConfirmResponse, error)
  • func (h *Handler) CrossChainEvent(ctx context.Context, req *cross_chain.CrossChainEventRequest) (*cross_chain.CrossChainEventResponse, error)
  • func (h *Handler) CrossChainTry(ctx context.Context, req *cross_chain.CrossChainTryRequest) (*cross_chain.CrossChainTryResponse, error)
  • func (h *Handler) IsCrossChainSuccess(ctx context.Context, req *cross_chain.IsCrossChainSuccessRequest) (*cross_chain.IsCrossChainSuccessResponse, error)
  • func (h *Handler) PingPong(ctx context.Context, req *emptypb.Empty) (*cross_chain.PingPongResponse, error)
  • func (h *Handler) TxVerify(ctx context.Context, in *cross_chain.TxVerifyRequest) (*cross_chain.TxVerifyResponse, error)

Types

type Handler

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

Handler handler结构体

func NewHandler

func NewHandler() *Handler

NewHandler 初始化handler模块

@return *Handler

func (*Handler) ChainIdentity

func (h *Handler) ChainIdentity(ctx context.Context,
	req *cross_chain.ChainIdentityRequest) (*cross_chain.ChainIdentityResponse, error)

ChainIdentity 跨链触发事件管理

@receiver h
@param ctx
@param req
@return *cross_chain.ChainIdentityResponse
@return error

func (*Handler) CrossChainCancel

func (h *Handler) CrossChainCancel(
	ctx context.Context, req *cross_chain.CrossChainCancelRequest) (*cross_chain.CrossChainCancelResponse, error)

CrossChainCancel 跨链结果确认

@receiver h
@param ctx
@param req
@return *cross_chain.CrossChainCancelResponse
@return error

func (*Handler) CrossChainConfirm

func (h *Handler) CrossChainConfirm(ctx context.Context,
	req *cross_chain.CrossChainConfirmRequest) (*cross_chain.CrossChainConfirmResponse, error)

CrossChainConfirm 跨链结果确认

@receiver h
@param ctx
@param req
@return *cross_chain.CrossChainConfirmResponse
@return error

func (*Handler) CrossChainEvent

func (h *Handler) CrossChainEvent(ctx context.Context,
	req *cross_chain.CrossChainEventRequest) (*cross_chain.CrossChainEventResponse, error)

CrossChainEvent 跨链触发事件管理

@receiver h
@param ctx
@param req
@return *cross_chain.CrossChainEventResponse
@return error

func (*Handler) CrossChainTry

func (h *Handler) CrossChainTry(ctx context.Context,
	req *cross_chain.CrossChainTryRequest) (*cross_chain.CrossChainTryResponse, error)

CrossChainTry 接收跨链请求的接口

@receiver h
@param ctx
@param req
@return *cross_chain.CrossChainTryResponse
@return error

func (*Handler) IsCrossChainSuccess

func (h *Handler) IsCrossChainSuccess(
	ctx context.Context,
	req *cross_chain.IsCrossChainSuccessRequest) (*cross_chain.IsCrossChainSuccessResponse, error)

IsCrossChainSuccess 判断跨链结果

@receiver h
@param ctx
@param req
@return *cross_chain.IsCrossChainSuccessResponse
@return error

func (*Handler) PingPong

func (h *Handler) PingPong(ctx context.Context, req *emptypb.Empty) (*cross_chain.PingPongResponse, error)

PingPong 心跳

@receiver h
@param ctx
@param req
@return *cross_chain.PingPongResponse
@return error

func (*Handler) TxVerify

func (h *Handler) TxVerify(ctx context.Context,
	in *cross_chain.TxVerifyRequest) (*cross_chain.TxVerifyResponse, error)

TxVerify rpc交易验证，不是非要在当前服务中实现,本项目不支持rpc验证，不需要实现

@receiver h
@param ctx
@param in
@return *cross_chain.TxVerifyResponse
@return error