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 GetClientStream(conn *grpc.ClientConn) (protogo.DockerVMRpc_DockerVMCommunicateClient, error) + func NewClientManager(logger protocol.Logger, vmConfig *config.DockerVMConfig) interfaces.ContractEngineClientMgr + type ContractEngineClient struct + func NewContractEngineClient(id uint64, logger protocol.Logger, cm interfaces.ContractEngineClientMgr) *ContractEngineClient + func (c *ContractEngineClient) NewClientConn() (*grpc.ClientConn, error) + func (c *ContractEngineClient) Start() error + func (c *ContractEngineClient) Stop() + type ContractEngineClientManager struct + func (cm *ContractEngineClientManager) DeleteNotify(chainId, txId string) bool + func (cm *ContractEngineClientManager) GetByteCodeRespChLen() int + func (cm *ContractEngineClientManager) GetByteCodeRespSendCh() chan *protogo.DockerVMMessage + func (cm *ContractEngineClientManager) GetReceiveNotify(chainId, txId string) func(msg *protogo.DockerVMMessage) + func (cm *ContractEngineClientManager) GetTxSendCh() chan *protogo.DockerVMMessage + func (cm *ContractEngineClientManager) GetTxSendChLen() int + func (cm *ContractEngineClientManager) GetUniqueTxKey(txId string) string + func (cm *ContractEngineClientManager) GetVMConfig() *config.DockerVMConfig + func (cm *ContractEngineClientManager) HasActiveConnections() bool + func (cm *ContractEngineClientManager) NeedSendContractByteCode() bool + func (cm *ContractEngineClientManager) PutByteCodeResp(getByteCodeResp *protogo.DockerVMMessage) + func (cm *ContractEngineClientManager) PutEvent(event *interfaces.Event) + func (cm *ContractEngineClientManager) PutTxRequestWithNotify(txRequest *protogo.DockerVMMessage, chainId string, ...) error + func (cm *ContractEngineClientManager) Start() error + func (cm *ContractEngineClientManager) Stop() error + type RuntimeServer struct + func NewRuntimeServer(logger protocol.Logger, vmConfig *config.DockerVMConfig) (*RuntimeServer, error) + func (s *RuntimeServer) StartRuntimeServer(runtimeService *RuntimeService) error + func (s *RuntimeServer) StopRuntimeServer() + type RuntimeService struct + func NewRuntimeService(logger protocol.Logger) *RuntimeService + func (s *RuntimeService) DeleteSandboxMsgNotify(chainId, txId string) bool + func (s *RuntimeService) DockerVMCommunicate(stream protogo.DockerVMRpc_DockerVMCommunicateServer) error + func (s *RuntimeService) RegisterSandboxMsgNotify(chainId, txKey string, ...) error Other modules containing this package chainmaker.org/chainmaker/vm-engine/v2