prxyxchain

Documentation

Overview

* Copyright (c) 2019. Baidu Inc. All Rights Reserved.

Index

• type XchainP2pProxy
  • func GetXchainP2pProxy() *XchainP2pProxy
  • func (cli *XchainP2pProxy) Defer()
  • func (cli *XchainP2pProxy) SendMessage(ctx context.Context, msg *xuperp2p.XuperMessage) error
  • func (cli *XchainP2pProxy) SendMessageWithResponse(ctx context.Context, msg *xuperp2p.XuperMessage) (*xuperp2p.XuperMessage, error)

Types

type XchainP2pProxy

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

func GetXchainP2pProxy

func GetXchainP2pProxy() *XchainP2pProxy

func (*XchainP2pProxy) Defer

func (cli *XchainP2pProxy) Defer()

@todo 复用一个conn 会出问题, 后面再排查下原因吧

func (*XchainP2pProxy) SendMessage

func (cli *XchainP2pProxy) SendMessage(ctx context.Context, msg *xuperp2p.XuperMessage) error

SendMessage send message to a peer

func (*XchainP2pProxy) SendMessageWithResponse

func (cli *XchainP2pProxy) SendMessageWithResponse(ctx context.Context, msg *xuperp2p.XuperMessage) (*xuperp2p.XuperMessage, error)

SendMessageWithResponse send message to a peer with responce