Versions in this module Expand all Collapse all v1 v1.5.0 Dec 9, 2022 v1.0.0 Nov 22, 2022 Changes in this version + var DockerVMCode_name = map[int32]string + var DockerVMCode_value = map[string]int32 + var DockerVMType_name = map[int32]string + var DockerVMType_value = map[string]int32 + var ErrIntOverflowDockervmMessage = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthDockervmMessage = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupDockervmMessage = fmt.Errorf("proto: unexpected end of group") + var StepType_name = map[int32]string + var StepType_value = map[string]int32 + func RegisterDockerVMRpcServer(s *grpc.Server, srv DockerVMRpcServer) + type CallContractRequest struct + Args map[string][]byte + ContractMethod string + ContractName string + func (*CallContractRequest) Descriptor() ([]byte, []int) + func (*CallContractRequest) ProtoMessage() + func (m *CallContractRequest) GetArgs() map[string][]byte + func (m *CallContractRequest) GetContractMethod() string + func (m *CallContractRequest) GetContractName() string + func (m *CallContractRequest) Marshal() (dAtA []byte, err error) + func (m *CallContractRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CallContractRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CallContractRequest) Reset() + func (m *CallContractRequest) Size() (n int) + func (m *CallContractRequest) String() string + func (m *CallContractRequest) Unmarshal(dAtA []byte) error + func (m *CallContractRequest) XXX_DiscardUnknown() + func (m *CallContractRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CallContractRequest) XXX_Merge(src proto.Message) + func (m *CallContractRequest) XXX_Size() int + func (m *CallContractRequest) XXX_Unmarshal(b []byte) error + type ContractResponse struct + Events []*Event + ReadMap map[string][]byte + Response *Response + WriteMap map[string][]byte + func (*ContractResponse) Descriptor() ([]byte, []int) + func (*ContractResponse) ProtoMessage() + func (m *ContractResponse) GetEvents() []*Event + func (m *ContractResponse) GetReadMap() map[string][]byte + func (m *ContractResponse) GetResponse() *Response + func (m *ContractResponse) GetWriteMap() map[string][]byte + func (m *ContractResponse) Marshal() (dAtA []byte, err error) + func (m *ContractResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ContractResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ContractResponse) Reset() + func (m *ContractResponse) Size() (n int) + func (m *ContractResponse) String() string + func (m *ContractResponse) Unmarshal(dAtA []byte) error + func (m *ContractResponse) XXX_DiscardUnknown() + func (m *ContractResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ContractResponse) XXX_Merge(src proto.Message) + func (m *ContractResponse) XXX_Size() int + func (m *ContractResponse) XXX_Unmarshal(b []byte) error + type CrossContext struct + CrossInfo uint64 + CurrentDepth uint32 + ProcessName string + func (*CrossContext) Descriptor() ([]byte, []int) + func (*CrossContext) ProtoMessage() + func (m *CrossContext) GetCrossInfo() uint64 + func (m *CrossContext) GetCurrentDepth() uint32 + func (m *CrossContext) GetProcessName() string + func (m *CrossContext) Marshal() (dAtA []byte, err error) + func (m *CrossContext) MarshalTo(dAtA []byte) (int, error) + func (m *CrossContext) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CrossContext) Reset() + func (m *CrossContext) Size() (n int) + func (m *CrossContext) String() string + func (m *CrossContext) Unmarshal(dAtA []byte) error + func (m *CrossContext) XXX_DiscardUnknown() + func (m *CrossContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CrossContext) XXX_Merge(src proto.Message) + func (m *CrossContext) XXX_Size() int + func (m *CrossContext) XXX_Unmarshal(b []byte) error + type DockerContractEvent struct + ContractName string + Data []string + Topic string + func (*DockerContractEvent) Descriptor() ([]byte, []int) + func (*DockerContractEvent) ProtoMessage() + func (m *DockerContractEvent) GetContractName() 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 DockerVMCode int32 + const DockerVMCode_FAIL + const DockerVMCode_OK + func (DockerVMCode) EnumDescriptor() ([]byte, []int) + func (x DockerVMCode) String() string + type DockerVMMessage struct + ChainId string + CrossContext *CrossContext + Request *TxRequest + Response *TxResponse + StepDurations []*StepDuration + SysCallMessage *SysCallMessage + TxId string + Type DockerVMType + func (*DockerVMMessage) Descriptor() ([]byte, []int) + func (*DockerVMMessage) ProtoMessage() + func (m *DockerVMMessage) GetChainId() string + func (m *DockerVMMessage) GetCrossContext() *CrossContext + func (m *DockerVMMessage) GetRequest() *TxRequest + func (m *DockerVMMessage) GetResponse() *TxResponse + func (m *DockerVMMessage) GetStepDurations() []*StepDuration + func (m *DockerVMMessage) GetSysCallMessage() *SysCallMessage + func (m *DockerVMMessage) GetTxId() string + func (m *DockerVMMessage) GetType() DockerVMType + func (m *DockerVMMessage) Marshal() (dAtA []byte, err error) + func (m *DockerVMMessage) MarshalTo(dAtA []byte) (int, error) + func (m *DockerVMMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DockerVMMessage) Reset() + func (m *DockerVMMessage) Size() (n int) + func (m *DockerVMMessage) String() string + func (m *DockerVMMessage) Unmarshal(dAtA []byte) error + func (m *DockerVMMessage) XXX_DiscardUnknown() + func (m *DockerVMMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DockerVMMessage) XXX_Merge(src proto.Message) + func (m *DockerVMMessage) XXX_Size() int + func (m *DockerVMMessage) XXX_Unmarshal(b []byte) error + type DockerVMRpcClient interface + DockerVMCommunicate func(ctx context.Context, opts ...grpc.CallOption) (DockerVMRpc_DockerVMCommunicateClient, error) + func NewDockerVMRpcClient(cc *grpc.ClientConn) DockerVMRpcClient + type DockerVMRpcServer interface + DockerVMCommunicate func(DockerVMRpc_DockerVMCommunicateServer) error + type DockerVMRpc_DockerVMCommunicateClient interface + Recv func() (*DockerVMMessage, error) + Send func(*DockerVMMessage) error + type DockerVMRpc_DockerVMCommunicateServer interface + Recv func() (*DockerVMMessage, error) + Send func(*DockerVMMessage) error + type DockerVMType int32 + const DockerVMType_CALL_CONTRACT_REQUEST + const DockerVMType_CALL_CONTRACT_RESPONSE + const DockerVMType_COMPLETED + const DockerVMType_CONSUME_KEY_HISTORY_ITER_REQUEST + const DockerVMType_CONSUME_KEY_HISTORY_ITER_RESPONSE + const DockerVMType_CONSUME_KV_ITERATOR_REQUEST + const DockerVMType_CONSUME_KV_ITERATOR_RESPONSE + const DockerVMType_CREATE_KEY_HISTORY_ITER_REQUEST + const DockerVMType_CREATE_KEY_HISTORY_TER_RESPONSE + const DockerVMType_CREATE_KV_ITERATOR_REQUEST + const DockerVMType_CREATE_KV_ITERATOR_RESPONSE + const DockerVMType_ERROR + const DockerVMType_GET_BATCH_STATE_REQUEST + const DockerVMType_GET_BATCH_STATE_RESPONSE + const DockerVMType_GET_BYTECODE_REQUEST + const DockerVMType_GET_BYTECODE_RESPONSE + const DockerVMType_GET_SENDER_ADDRESS_REQUEST + const DockerVMType_GET_SENDER_ADDRESS_RESPONSE + const DockerVMType_GET_STATE_REQUEST + const DockerVMType_GET_STATE_RESPONSE + const DockerVMType_INIT + const DockerVMType_INVOKE + const DockerVMType_PREPARE + const DockerVMType_READY + const DockerVMType_REGISTER + const DockerVMType_REGISTERED + const DockerVMType_TX_REQUEST + const DockerVMType_TX_RESPONSE + const DockerVMType_UNDEFINED + func (DockerVMType) EnumDescriptor() ([]byte, []int) + func (x DockerVMType) String() string + type Event struct + ContractName string + Data []string + Topic string + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (m *Event) GetContractName() string + func (m *Event) GetData() []string + func (m *Event) GetTopic() string + func (m *Event) Marshal() (dAtA []byte, err error) + func (m *Event) MarshalTo(dAtA []byte) (int, error) + func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Event) Reset() + func (m *Event) Size() (n int) + func (m *Event) String() string + func (m *Event) Unmarshal(dAtA []byte) error + func (m *Event) XXX_DiscardUnknown() + func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Event) XXX_Merge(src proto.Message) + func (m *Event) XXX_Size() int + func (m *Event) XXX_Unmarshal(b []byte) error + type Response struct + Message string + Payload []byte + Status int32 + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (m *Response) GetMessage() string + func (m *Response) GetPayload() []byte + func (m *Response) GetStatus() int32 + func (m *Response) Marshal() (dAtA []byte, err error) + func (m *Response) MarshalTo(dAtA []byte) (int, error) + func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Response) Reset() + func (m *Response) Size() (n int) + func (m *Response) String() string + func (m *Response) Unmarshal(dAtA []byte) error + func (m *Response) XXX_DiscardUnknown() + func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Response) XXX_Merge(src proto.Message) + func (m *Response) XXX_Size() int + func (m *Response) XXX_Unmarshal(b []byte) error + type StepDuration struct + Msg string + StartTime int64 + StepDuration int64 + Type StepType + UntilDuration int64 + func (*StepDuration) Descriptor() ([]byte, []int) + func (*StepDuration) ProtoMessage() + func (m *StepDuration) GetMsg() string + func (m *StepDuration) GetStartTime() int64 + func (m *StepDuration) GetStepDuration() int64 + func (m *StepDuration) GetType() StepType + func (m *StepDuration) GetUntilDuration() int64 + func (m *StepDuration) Marshal() (dAtA []byte, err error) + func (m *StepDuration) MarshalTo(dAtA []byte) (int, error) + func (m *StepDuration) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StepDuration) Reset() + func (m *StepDuration) Size() (n int) + func (m *StepDuration) String() string + func (m *StepDuration) Unmarshal(dAtA []byte) error + func (m *StepDuration) XXX_DiscardUnknown() + func (m *StepDuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StepDuration) XXX_Merge(src proto.Message) + func (m *StepDuration) XXX_Size() int + func (m *StepDuration) XXX_Unmarshal(b []byte) error + type StepType int32 + const StepType_ENGINE_GROUP_RECEIVE_TX_REQUEST + const StepType_ENGINE_GROUP_SEND_TX_REQUEST + const StepType_ENGINE_GRPC_RECEIVE_TX_REQUEST + const StepType_ENGINE_PROCESS_RECEIVE_TX_REQUEST + const StepType_ENGINE_PROCESS_RECEIVE_TX_RESPONSE + const StepType_ENGINE_PROCESS_SEND_TX_REQUEST + const StepType_ENGINE_SCHEDULER_RECEIVE_TX_REQUEST + const StepType_ENGINE_SCHEDULER_SEND_TX_REQUEST + const StepType_RUNTIME_GET_NOTIFY_TX_RESPONSE + const StepType_RUNTIME_GRPC_RECEIVE_TX_RESPONSE + const StepType_RUNTIME_GRPC_SEND_TX_REQUEST + const StepType_RUNTIME_HANDLER_RECEIVE_TX_RESPONSE + const StepType_RUNTIME_HANDLE_TX_RESPONSE + const StepType_RUNTIME_PREPARE_TX_REQUEST + const StepType_SANDBOX_CHAN_SEND_TX_REQUEST + const StepType_SANDBOX_GRPC_RECEIVE_TX_REQUEST + const StepType_SANDBOX_GRPC_SEND_CHAIN_RESP + const StepType_SANDBOX_GRPC_SEND_TX_REQUEST + const StepType_SANDBOX_HANDLER_EXECUTE + const StepType_SANDBOX_HANDLER_RECEIVE_TX_REQUEST + const StepType_SANDBOX_SEND_CHAIN_RESP + const StepType_SANDBOX_SEND_ENGINE_RESP + func (StepType) EnumDescriptor() ([]byte, []int) + func (x StepType) String() string + type SysCallMessage struct + Code DockerVMCode + Message string + Payload map[string][]byte + func (*SysCallMessage) Descriptor() ([]byte, []int) + func (*SysCallMessage) ProtoMessage() + func (m *SysCallMessage) GetCode() DockerVMCode + func (m *SysCallMessage) GetMessage() string + func (m *SysCallMessage) GetPayload() map[string][]byte + func (m *SysCallMessage) Marshal() (dAtA []byte, err error) + func (m *SysCallMessage) MarshalTo(dAtA []byte) (int, error) + func (m *SysCallMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SysCallMessage) Reset() + func (m *SysCallMessage) Size() (n int) + func (m *SysCallMessage) String() string + func (m *SysCallMessage) Unmarshal(dAtA []byte) error + func (m *SysCallMessage) XXX_DiscardUnknown() + func (m *SysCallMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SysCallMessage) XXX_Merge(src proto.Message) + func (m *SysCallMessage) XXX_Size() int + func (m *SysCallMessage) XXX_Unmarshal(b []byte) error + type TxContext struct + ReadMap map[string][]byte + WriteMap map[string][]byte + func (*TxContext) Descriptor() ([]byte, []int) + func (*TxContext) ProtoMessage() + 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 TxRequest struct + ChainId string + ContractName string + ContractVersion string + Method string + Parameters map[string][]byte + TxContext *TxContext + 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) 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 DockerVMCode + ContractName string + ContractVersion string + Events []*DockerContractEvent + Message string + ReadMap map[string][]byte + Result []byte + TxId string + WriteMap map[string][]byte + func (*TxResponse) Descriptor() ([]byte, []int) + func (*TxResponse) ProtoMessage() + func (m *TxResponse) GetChainId() string + func (m *TxResponse) GetCode() DockerVMCode + func (m *TxResponse) GetContractName() string + func (m *TxResponse) GetContractVersion() string + 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) 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 UnimplementedDockerVMRpcServer struct + func (*UnimplementedDockerVMRpcServer) DockerVMCommunicate(srv DockerVMRpc_DockerVMCommunicateServer) error