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 + var CDMType_name = map[int32]string + var CDMType_value = map[string]int32 + var ContractResultCode_name = map[int32]string + var ContractResultCode_value = map[string]int32 + var ErrIntOverflowCdmMessage = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthCdmMessage = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupCdmMessage = fmt.Errorf("proto: unexpected end of group") + var ProcessState_name = map[int32]string + var ProcessState_value = map[string]int32 + func RegisterCDMRpcServer(s *grpc.Server, srv CDMRpcServer) + type CDMMessage struct + ChainId string + Message string + Payload []byte + ResultCode int32 + TxId string + TxRequest *TxRequest + TxResponse *TxResponse + Type CDMType + func (*CDMMessage) Descriptor() ([]byte, []int) + func (*CDMMessage) ProtoMessage() + func (m *CDMMessage) GetChainId() string + func (m *CDMMessage) GetMessage() string + func (m *CDMMessage) GetPayload() []byte + func (m *CDMMessage) GetResultCode() int32 + func (m *CDMMessage) GetTxId() string + func (m *CDMMessage) GetTxRequest() *TxRequest + func (m *CDMMessage) GetTxResponse() *TxResponse + func (m *CDMMessage) GetType() CDMType + func (m *CDMMessage) Marshal() (dAtA []byte, err error) + func (m *CDMMessage) MarshalTo(dAtA []byte) (int, error) + func (m *CDMMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CDMMessage) Reset() + func (m *CDMMessage) Size() (n int) + func (m *CDMMessage) String() string + func (m *CDMMessage) Unmarshal(dAtA []byte) error + func (m *CDMMessage) XXX_DiscardUnknown() + func (m *CDMMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CDMMessage) XXX_Merge(src proto.Message) + func (m *CDMMessage) XXX_Size() int + func (m *CDMMessage) XXX_Unmarshal(b []byte) error + type CDMRpcClient interface + CDMCommunicate func(ctx context.Context, opts ...grpc.CallOption) (CDMRpc_CDMCommunicateClient, error) + func NewCDMRpcClient(cc *grpc.ClientConn) CDMRpcClient + type CDMRpcServer interface + CDMCommunicate func(CDMRpc_CDMCommunicateServer) error + type CDMRpc_CDMCommunicateClient interface + Recv func() (*CDMMessage, error) + Send func(*CDMMessage) error + type CDMRpc_CDMCommunicateServer interface + Recv func() (*CDMMessage, error) + Send func(*CDMMessage) error + type CDMType int32 + const CDMType_CDM_TYPE_CALL_CONTRACT + const CDMType_CDM_TYPE_CONSUME_KEY_HISTORY_ITER + const CDMType_CDM_TYPE_CONSUME_KEY_HISTORY_ITER_RESPONSE + const CDMType_CDM_TYPE_CONSUME_KV_ITERATOR + const CDMType_CDM_TYPE_CONSUME_KV_ITERATOR_RESPONSE + const CDMType_CDM_TYPE_CREATE_KEY_HISTORY_ITER + const CDMType_CDM_TYPE_CREATE_KEY_HISTORY_TER_RESPONSE + const CDMType_CDM_TYPE_CREATE_KV_ITERATOR + const CDMType_CDM_TYPE_CREATE_KV_ITERATOR_RESPONSE + const CDMType_CDM_TYPE_GET_BATCH_STATE + const CDMType_CDM_TYPE_GET_BATCH_STATE_RESPONSE + const CDMType_CDM_TYPE_GET_BYTECODE + const CDMType_CDM_TYPE_GET_BYTECODE_RESPONSE + const CDMType_CDM_TYPE_GET_CONTRACT_NAME + const CDMType_CDM_TYPE_GET_CONTRACT_NAME_RESPONSE + const CDMType_CDM_TYPE_GET_SENDER_ADDRESS + const CDMType_CDM_TYPE_GET_SENDER_ADDRESS_RESPONSE + const CDMType_CDM_TYPE_GET_STATE + const CDMType_CDM_TYPE_GET_STATE_RESPONSE + const CDMType_CDM_TYPE_TX_REQUEST + const CDMType_CDM_TYPE_TX_RESPONSE + const CDMType_CDM_TYPE_UNDEFINED + func (CDMType) EnumDescriptor() ([]byte, []int) + func (x CDMType) String() string + type ContractResultCode int32 + const ContractResultCode_FAIL + const ContractResultCode_OK + func (ContractResultCode) EnumDescriptor() ([]byte, []int) + func (x ContractResultCode) String() string + type DockerContractEvent struct + ContractName string + ContractVersion string + Data []string + Topic string + func (*DockerContractEvent) Descriptor() ([]byte, []int) + func (*DockerContractEvent) ProtoMessage() + func (m *DockerContractEvent) GetContractName() string + func (m *DockerContractEvent) GetContractVersion() string + func (m *DockerContractEvent) GetData() []string + func (m *DockerContractEvent) GetTopic() string + func (m *DockerContractEvent) Marshal() (dAtA []byte, err error) + func (m *DockerContractEvent) MarshalTo(dAtA []byte) (int, error) + func (m *DockerContractEvent) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DockerContractEvent) Reset() + func (m *DockerContractEvent) Size() (n int) + func (m *DockerContractEvent) String() string + func (m *DockerContractEvent) Unmarshal(dAtA []byte) error + func (m *DockerContractEvent) XXX_DiscardUnknown() + func (m *DockerContractEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DockerContractEvent) XXX_Merge(src proto.Message) + func (m *DockerContractEvent) XXX_Size() int + func (m *DockerContractEvent) XXX_Unmarshal(b []byte) error + type ProcessState int32 + const ProcessState_PROCESS_STATE_CREATED + const ProcessState_PROCESS_STATE_CROSS_FAIL + const ProcessState_PROCESS_STATE_CROSS_FINISHED + const ProcessState_PROCESS_STATE_EXPIRE + const ProcessState_PROCESS_STATE_RUNNING + const ProcessState_PROCESS_STATE_TX_TIMEOUT + func (ProcessState) EnumDescriptor() ([]byte, []int) + func (x ProcessState) String() string + type TxContext struct + CurrentHeight uint32 + OriginalProcessName string + ReadMap map[string][]byte + WriteMap map[string][]byte + func (*TxContext) Descriptor() ([]byte, []int) + func (*TxContext) ProtoMessage() + func (m *TxContext) GetCurrentHeight() uint32 + func (m *TxContext) GetOriginalProcessName() string + func (m *TxContext) GetReadMap() map[string][]byte + func (m *TxContext) GetWriteMap() map[string][]byte + func (m *TxContext) Marshal() (dAtA []byte, err error) + func (m *TxContext) MarshalTo(dAtA []byte) (int, error) + func (m *TxContext) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TxContext) Reset() + func (m *TxContext) Size() (n int) + func (m *TxContext) String() string + func (m *TxContext) Unmarshal(dAtA []byte) error + func (m *TxContext) XXX_DiscardUnknown() + func (m *TxContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxContext) XXX_Merge(src proto.Message) + func (m *TxContext) XXX_Size() int + func (m *TxContext) XXX_Unmarshal(b []byte) error + type TxElapsedTime struct + CrossCallCnt int32 + CrossCallTime int64 + func (*TxElapsedTime) Descriptor() ([]byte, []int) + func (*TxElapsedTime) ProtoMessage() + func (m *TxElapsedTime) GetCrossCallCnt() int32 + func (m *TxElapsedTime) GetCrossCallTime() int64 + func (m *TxElapsedTime) Marshal() (dAtA []byte, err error) + func (m *TxElapsedTime) MarshalTo(dAtA []byte) (int, error) + func (m *TxElapsedTime) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TxElapsedTime) Reset() + func (m *TxElapsedTime) Size() (n int) + func (m *TxElapsedTime) String() string + func (m *TxElapsedTime) Unmarshal(dAtA []byte) error + func (m *TxElapsedTime) XXX_DiscardUnknown() + func (m *TxElapsedTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxElapsedTime) XXX_Merge(src proto.Message) + func (m *TxElapsedTime) XXX_Size() int + func (m *TxElapsedTime) XXX_Unmarshal(b []byte) error + type TxRequest struct + ChainId string + ContractName string + ContractVersion string + Method string + Parameters map[string][]byte + TxContext *TxContext + TxId string + func (*TxRequest) Descriptor() ([]byte, []int) + func (*TxRequest) ProtoMessage() + func (m *TxRequest) GetChainId() string + func (m *TxRequest) GetContractName() string + func (m *TxRequest) GetContractVersion() string + func (m *TxRequest) GetMethod() string + func (m *TxRequest) GetParameters() map[string][]byte + func (m *TxRequest) GetTxContext() *TxContext + func (m *TxRequest) GetTxId() string + func (m *TxRequest) Marshal() (dAtA []byte, err error) + func (m *TxRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TxRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TxRequest) Reset() + func (m *TxRequest) Size() (n int) + func (m *TxRequest) String() string + func (m *TxRequest) Unmarshal(dAtA []byte) error + func (m *TxRequest) XXX_DiscardUnknown() + func (m *TxRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxRequest) XXX_Merge(src proto.Message) + func (m *TxRequest) XXX_Size() int + func (m *TxRequest) XXX_Unmarshal(b []byte) error + type TxResponse struct + ChainId string + Code ContractResultCode + Events []*DockerContractEvent + Message string + ReadMap map[string][]byte + Result []byte + TxElapsedTime *TxElapsedTime + TxId string + WriteMap map[string][]byte + func (*TxResponse) Descriptor() ([]byte, []int) + func (*TxResponse) ProtoMessage() + func (m *TxResponse) GetChainId() string + func (m *TxResponse) GetCode() ContractResultCode + func (m *TxResponse) GetEvents() []*DockerContractEvent + func (m *TxResponse) GetMessage() string + func (m *TxResponse) GetReadMap() map[string][]byte + func (m *TxResponse) GetResult() []byte + func (m *TxResponse) GetTxElapsedTime() *TxElapsedTime + func (m *TxResponse) GetTxId() string + func (m *TxResponse) GetWriteMap() map[string][]byte + func (m *TxResponse) Marshal() (dAtA []byte, err error) + func (m *TxResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TxResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TxResponse) Reset() + func (m *TxResponse) Size() (n int) + func (m *TxResponse) String() string + func (m *TxResponse) Unmarshal(dAtA []byte) error + func (m *TxResponse) XXX_DiscardUnknown() + func (m *TxResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxResponse) XXX_Merge(src proto.Message) + func (m *TxResponse) XXX_Size() int + func (m *TxResponse) XXX_Unmarshal(b []byte) error + type UnimplementedCDMRpcServer struct + func (*UnimplementedCDMRpcServer) CDMCommunicate(srv CDMRpc_CDMCommunicateServer) error Other modules containing this package chainmaker.org/chainmaker/vm-docker-go/v2