Versions in this module Expand all Collapse all v3 v3.0.1 Dec 27, 2023 v3.0.0 Dec 23, 2022 Changes in this version + func GetCDMClientStream(conn *grpc.ClientConn) (protogo.CDMRpc_CDMCommunicateClient, error) + type CDMClient struct + func NewCDMClient(_id uint64, _logger *logger.CMLogger, _clientMgr ClientMgr) *CDMClient + func (c *CDMClient) NewClientConn() (*grpc.ClientConn, error) + func (c *CDMClient) StartClient() error + func (c *CDMClient) StopSendRecv() + type ClientManager struct + func NewClientManager(vmConfig *config.DockerVMConfig) *ClientManager + func (cm *ClientManager) CloseAllConnections() + func (cm *ClientManager) DeleteReceiveChan(chainId, txId string) bool + func (cm *ClientManager) GetAndDeleteReceiveChan(chainId, txId string) chan *protogo.CDMMessage + func (cm *ClientManager) GetReceiveChan(chainId, txId string) chan *protogo.CDMMessage + func (cm *ClientManager) GetSysCallRespSendCh() chan *protogo.CDMMessage + func (cm *ClientManager) GetTxSendCh() chan *protogo.CDMMessage + func (cm *ClientManager) GetUniqueTxKey(txId string) string + func (cm *ClientManager) GetVMConfig() *config.DockerVMConfig + func (cm *ClientManager) HasActiveConnections() bool + func (cm *ClientManager) NeedSendContractByteCode() bool + func (cm *ClientManager) PutEvent(event *Event) + func (cm *ClientManager) PutSysCallResponse(sysCallResp *protogo.CDMMessage) + func (cm *ClientManager) PutTxRequest(txRequest *protogo.CDMMessage) + func (cm *ClientManager) RegisterReceiveChan(chainId, txId string, receiveCh chan *protogo.CDMMessage) error + func (cm *ClientManager) Start() error + type ClientMgr interface + GetAndDeleteReceiveChan func(chainId, txId string) chan *protogo.CDMMessage + GetReceiveChan func(chainId, txId string) chan *protogo.CDMMessage + GetSysCallRespSendCh func() chan *protogo.CDMMessage + GetTxSendCh func() chan *protogo.CDMMessage + GetVMConfig func() *config.DockerVMConfig + PutEvent func(event *Event) + type Event struct + type EventType int Other modules containing this package chainmaker.org/chainmaker/vm-docker-go/v2