client

Documentation

Index

• type WSClients
  • func NewWSClient(remoteAddr, endpoint string, privKey *ecdsa.PrivateKey, pubkey string) (*WSClients, error)
  • func (wsc *WSClients) RegisterResChannel(requestMsg chan tmtypes.RPCRequest, stopChan chan struct{}) error
  • func (wsc *WSClients) SendMsg(rsp tmtypes.RPCResponse) error

Types

type WSClients

type WSClients struct {
	ReqChan  chan tmtypes.RPCRequest
	StopChan chan struct{}

	//This is used to subscribe the msg from server
	Cli *tm.WSClient
	// contains filtered or unexported fields
}

func NewWSClient

func NewWSClient(remoteAddr, endpoint string, privKey *ecdsa.PrivateKey, pubkey string) (*WSClients, error)

func (*WSClients) RegisterResChannel

func (wsc *WSClients) RegisterResChannel(requestMsg chan tmtypes.RPCRequest, stopChan chan struct{}) error

func (*WSClients) SendMsg

func (wsc *WSClients) SendMsg(rsp tmtypes.RPCResponse) error