Documentation ¶
Index ¶
- Variables
- func RegisterCDMRpcServer(s *grpc.Server, srv CDMRpcServer)
- type CDMMessage
- func (*CDMMessage) Descriptor() ([]byte, []int)
- 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 (*CDMMessage) ProtoMessage()
- 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
- type CDMRpcServer
- type CDMRpc_CDMCommunicateClient
- type CDMRpc_CDMCommunicateServer
- type CDMType
- type ContractResultCode
- type DockerContractEvent
- func (*DockerContractEvent) Descriptor() ([]byte, []int)
- 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 (*DockerContractEvent) ProtoMessage()
- 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
- type TxContext
- func (*TxContext) Descriptor() ([]byte, []int)
- 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 (*TxContext) ProtoMessage()
- 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
- func (*TxElapsedTime) Descriptor() ([]byte, []int)
- 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 (*TxElapsedTime) ProtoMessage()
- 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
- func (*TxRequest) Descriptor() ([]byte, []int)
- 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 (*TxRequest) ProtoMessage()
- 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
- func (*TxResponse) Descriptor() ([]byte, []int)
- 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 (*TxResponse) ProtoMessage()
- 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
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthCdmMessage = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowCdmMessage = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupCdmMessage = fmt.Errorf("proto: unexpected end of group") )
View Source
var CDMType_name = map[int32]string{
0: "CDM_TYPE_UNDEFINED",
1: "CDM_TYPE_TX_REQUEST",
2: "CDM_TYPE_TX_RESPONSE",
3: "CDM_TYPE_GET_STATE",
4: "CDM_TYPE_GET_STATE_RESPONSE",
5: "CDM_TYPE_GET_BYTECODE",
6: "CDM_TYPE_GET_BYTECODE_RESPONSE",
7: "CDM_TYPE_CREATE_KV_ITERATOR",
8: "CDM_TYPE_CREATE_KV_ITERATOR_RESPONSE",
9: "CDM_TYPE_CONSUME_KV_ITERATOR",
10: "CDM_TYPE_CONSUME_KV_ITERATOR_RESPONSE",
11: "CDM_TYPE_CREATE_KEY_HISTORY_ITER",
12: "CDM_TYPE_CREATE_KEY_HISTORY_TER_RESPONSE",
13: "CDM_TYPE_CONSUME_KEY_HISTORY_ITER",
14: "CDM_TYPE_CONSUME_KEY_HISTORY_ITER_RESPONSE",
15: "CDM_TYPE_GET_SENDER_ADDRESS",
16: "CDM_TYPE_GET_SENDER_ADDRESS_RESPONSE",
17: "CDM_TYPE_GET_CONTRACT_NAME",
18: "CDM_TYPE_GET_CONTRACT_NAME_RESPONSE",
19: "CDM_TYPE_GET_BATCH_STATE",
20: "CDM_TYPE_GET_BATCH_STATE_RESPONSE",
21: "CDM_TYPE_CALL_CONTRACT",
}
View Source
var CDMType_value = map[string]int32{
"CDM_TYPE_UNDEFINED": 0,
"CDM_TYPE_TX_REQUEST": 1,
"CDM_TYPE_TX_RESPONSE": 2,
"CDM_TYPE_GET_STATE": 3,
"CDM_TYPE_GET_STATE_RESPONSE": 4,
"CDM_TYPE_GET_BYTECODE": 5,
"CDM_TYPE_GET_BYTECODE_RESPONSE": 6,
"CDM_TYPE_CREATE_KV_ITERATOR": 7,
"CDM_TYPE_CREATE_KV_ITERATOR_RESPONSE": 8,
"CDM_TYPE_CONSUME_KV_ITERATOR": 9,
"CDM_TYPE_CONSUME_KV_ITERATOR_RESPONSE": 10,
"CDM_TYPE_CREATE_KEY_HISTORY_ITER": 11,
"CDM_TYPE_CREATE_KEY_HISTORY_TER_RESPONSE": 12,
"CDM_TYPE_CONSUME_KEY_HISTORY_ITER": 13,
"CDM_TYPE_CONSUME_KEY_HISTORY_ITER_RESPONSE": 14,
"CDM_TYPE_GET_SENDER_ADDRESS": 15,
"CDM_TYPE_GET_SENDER_ADDRESS_RESPONSE": 16,
"CDM_TYPE_GET_CONTRACT_NAME": 17,
"CDM_TYPE_GET_CONTRACT_NAME_RESPONSE": 18,
"CDM_TYPE_GET_BATCH_STATE": 19,
"CDM_TYPE_GET_BATCH_STATE_RESPONSE": 20,
"CDM_TYPE_CALL_CONTRACT": 21,
}
Functions ¶
func RegisterCDMRpcServer ¶
func RegisterCDMRpcServer(s *grpc.Server, srv CDMRpcServer)
Types ¶
type CDMMessage ¶
type CDMMessage struct { TxId string `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` Type CDMType `protobuf:"varint,2,opt,name=type,proto3,enum=dockergo.CDMType" json:"type,omitempty"` ResultCode int32 `protobuf:"varint,3,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"` Payload []byte `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"` Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"` TxRequest *TxRequest `protobuf:"bytes,6,opt,name=txRequest,proto3" json:"txRequest,omitempty"` TxResponse *TxResponse `protobuf:"bytes,7,opt,name=txResponse,proto3" json:"txResponse,omitempty"` ChainId string `protobuf:"bytes,8,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` }
CMMessage means message between chainmaker and docker manager
func (*CDMMessage) Descriptor ¶
func (*CDMMessage) Descriptor() ([]byte, []int)
func (*CDMMessage) GetChainId ¶
func (m *CDMMessage) GetChainId() string
func (*CDMMessage) GetMessage ¶
func (m *CDMMessage) GetMessage() string
func (*CDMMessage) GetPayload ¶
func (m *CDMMessage) GetPayload() []byte
func (*CDMMessage) GetResultCode ¶
func (m *CDMMessage) GetResultCode() int32
func (*CDMMessage) GetTxId ¶
func (m *CDMMessage) GetTxId() string
func (*CDMMessage) GetTxRequest ¶
func (m *CDMMessage) GetTxRequest() *TxRequest
func (*CDMMessage) GetTxResponse ¶
func (m *CDMMessage) GetTxResponse() *TxResponse
func (*CDMMessage) GetType ¶
func (m *CDMMessage) GetType() CDMType
func (*CDMMessage) Marshal ¶
func (m *CDMMessage) Marshal() (dAtA []byte, err error)
func (*CDMMessage) MarshalTo ¶
func (m *CDMMessage) MarshalTo(dAtA []byte) (int, error)
func (*CDMMessage) MarshalToSizedBuffer ¶
func (m *CDMMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CDMMessage) ProtoMessage ¶
func (*CDMMessage) ProtoMessage()
func (*CDMMessage) Reset ¶
func (m *CDMMessage) Reset()
func (*CDMMessage) Size ¶
func (m *CDMMessage) Size() (n int)
func (*CDMMessage) String ¶
func (m *CDMMessage) String() string
func (*CDMMessage) Unmarshal ¶
func (m *CDMMessage) Unmarshal(dAtA []byte) error
func (*CDMMessage) XXX_DiscardUnknown ¶
func (m *CDMMessage) XXX_DiscardUnknown()
func (*CDMMessage) XXX_Marshal ¶
func (m *CDMMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CDMMessage) XXX_Merge ¶
func (m *CDMMessage) XXX_Merge(src proto.Message)
func (*CDMMessage) XXX_Size ¶
func (m *CDMMessage) XXX_Size() int
func (*CDMMessage) XXX_Unmarshal ¶
func (m *CDMMessage) XXX_Unmarshal(b []byte) error
type CDMRpcClient ¶
type CDMRpcClient interface {
CDMCommunicate(ctx context.Context, opts ...grpc.CallOption) (CDMRpc_CDMCommunicateClient, error)
}
CDMRpcClient is the client API for CDMRpc service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewCDMRpcClient ¶
func NewCDMRpcClient(cc *grpc.ClientConn) CDMRpcClient
type CDMRpcServer ¶
type CDMRpcServer interface {
CDMCommunicate(CDMRpc_CDMCommunicateServer) error
}
CDMRpcServer is the server API for CDMRpc service.
type CDMRpc_CDMCommunicateClient ¶
type CDMRpc_CDMCommunicateClient interface { Send(*CDMMessage) error Recv() (*CDMMessage, error) grpc.ClientStream }
type CDMRpc_CDMCommunicateServer ¶
type CDMRpc_CDMCommunicateServer interface { Send(*CDMMessage) error Recv() (*CDMMessage, error) grpc.ServerStream }
type CDMType ¶
type CDMType int32
const ( CDMType_CDM_TYPE_UNDEFINED CDMType = 0 CDMType_CDM_TYPE_TX_REQUEST CDMType = 1 CDMType_CDM_TYPE_TX_RESPONSE CDMType = 2 CDMType_CDM_TYPE_GET_STATE CDMType = 3 CDMType_CDM_TYPE_GET_STATE_RESPONSE CDMType = 4 CDMType_CDM_TYPE_GET_BYTECODE CDMType = 5 CDMType_CDM_TYPE_GET_BYTECODE_RESPONSE CDMType = 6 CDMType_CDM_TYPE_CREATE_KV_ITERATOR CDMType = 7 CDMType_CDM_TYPE_CREATE_KV_ITERATOR_RESPONSE CDMType = 8 CDMType_CDM_TYPE_CONSUME_KV_ITERATOR CDMType = 9 CDMType_CDM_TYPE_CONSUME_KV_ITERATOR_RESPONSE CDMType = 10 CDMType_CDM_TYPE_CREATE_KEY_HISTORY_ITER CDMType = 11 CDMType_CDM_TYPE_CREATE_KEY_HISTORY_TER_RESPONSE CDMType = 12 CDMType_CDM_TYPE_CONSUME_KEY_HISTORY_ITER CDMType = 13 CDMType_CDM_TYPE_CONSUME_KEY_HISTORY_ITER_RESPONSE CDMType = 14 CDMType_CDM_TYPE_GET_SENDER_ADDRESS CDMType = 15 CDMType_CDM_TYPE_GET_SENDER_ADDRESS_RESPONSE CDMType = 16 CDMType_CDM_TYPE_GET_CONTRACT_NAME CDMType = 17 CDMType_CDM_TYPE_GET_CONTRACT_NAME_RESPONSE CDMType = 18 CDMType_CDM_TYPE_GET_BATCH_STATE CDMType = 19 CDMType_CDM_TYPE_GET_BATCH_STATE_RESPONSE CDMType = 20 CDMType_CDM_TYPE_CALL_CONTRACT CDMType = 21 )
type ContractResultCode ¶
type ContractResultCode int32
const ( ContractResultCode_OK ContractResultCode = 0 ContractResultCode_FAIL ContractResultCode = 1 )
func (ContractResultCode) EnumDescriptor ¶
func (ContractResultCode) EnumDescriptor() ([]byte, []int)
func (ContractResultCode) String ¶
func (x ContractResultCode) String() string
type DockerContractEvent ¶
type DockerContractEvent struct { // Event topic Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` // Event contract name ContractName string `protobuf:"bytes,2,opt,name=contract_name,json=contractName,proto3" json:"contract_name,omitempty"` // Event contract version ContractVersion string `protobuf:"bytes,3,opt,name=contract_version,json=contractVersion,proto3" json:"contract_version,omitempty"` // Event payload Data []string `protobuf:"bytes,4,rep,name=data,proto3" json:"data,omitempty"` }
func (*DockerContractEvent) Descriptor ¶
func (*DockerContractEvent) Descriptor() ([]byte, []int)
func (*DockerContractEvent) GetContractName ¶
func (m *DockerContractEvent) GetContractName() string
func (*DockerContractEvent) GetContractVersion ¶
func (m *DockerContractEvent) GetContractVersion() string
func (*DockerContractEvent) GetData ¶
func (m *DockerContractEvent) GetData() []string
func (*DockerContractEvent) GetTopic ¶
func (m *DockerContractEvent) GetTopic() string
func (*DockerContractEvent) Marshal ¶
func (m *DockerContractEvent) Marshal() (dAtA []byte, err error)
func (*DockerContractEvent) MarshalTo ¶
func (m *DockerContractEvent) MarshalTo(dAtA []byte) (int, error)
func (*DockerContractEvent) MarshalToSizedBuffer ¶
func (m *DockerContractEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DockerContractEvent) ProtoMessage ¶
func (*DockerContractEvent) ProtoMessage()
func (*DockerContractEvent) Reset ¶
func (m *DockerContractEvent) Reset()
func (*DockerContractEvent) Size ¶
func (m *DockerContractEvent) Size() (n int)
func (*DockerContractEvent) String ¶
func (m *DockerContractEvent) String() string
func (*DockerContractEvent) Unmarshal ¶
func (m *DockerContractEvent) Unmarshal(dAtA []byte) error
func (*DockerContractEvent) XXX_DiscardUnknown ¶
func (m *DockerContractEvent) XXX_DiscardUnknown()
func (*DockerContractEvent) XXX_Marshal ¶
func (m *DockerContractEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DockerContractEvent) XXX_Merge ¶
func (m *DockerContractEvent) XXX_Merge(src proto.Message)
func (*DockerContractEvent) XXX_Size ¶
func (m *DockerContractEvent) XXX_Size() int
func (*DockerContractEvent) XXX_Unmarshal ¶
func (m *DockerContractEvent) XXX_Unmarshal(b []byte) error
type ProcessState ¶
type ProcessState int32
const ( ProcessState_PROCESS_STATE_CREATED ProcessState = 0 ProcessState_PROCESS_STATE_RUNNING ProcessState = 1 ProcessState_PROCESS_STATE_EXPIRE ProcessState = 2 ProcessState_PROCESS_STATE_TX_TIMEOUT ProcessState = 3 ProcessState_PROCESS_STATE_CROSS_FINISHED ProcessState = 4 ProcessState_PROCESS_STATE_CROSS_FAIL ProcessState = 5 )
func (ProcessState) EnumDescriptor ¶
func (ProcessState) EnumDescriptor() ([]byte, []int)
func (ProcessState) String ¶
func (x ProcessState) String() string
type TxContext ¶
type TxContext struct { CurrentHeight uint32 `protobuf:"varint,1,opt,name=current_height,json=currentHeight,proto3" json:"current_height,omitempty"` WriteMap map[string][]byte `` /* 173-byte string literal not displayed */ ReadMap map[string][]byte `` /* 170-byte string literal not displayed */ OriginalProcessName string `protobuf:"bytes,4,opt,name=original_process_name,json=originalProcessName,proto3" json:"original_process_name,omitempty"` }
func (*TxContext) MarshalToSizedBuffer ¶
func (*TxContext) XXX_Marshal ¶
type TxElapsedTime ¶
type TxElapsedTime struct { CrossCallCnt int32 `protobuf:"varint,1,opt,name=CrossCallCnt,proto3" json:"CrossCallCnt,omitempty"` CrossCallTime int64 `protobuf:"varint,2,opt,name=CrossCallTime,proto3" json:"CrossCallTime,omitempty"` }
func (*TxElapsedTime) Descriptor ¶
func (*TxElapsedTime) Descriptor() ([]byte, []int)
func (*TxElapsedTime) GetCrossCallCnt ¶
func (m *TxElapsedTime) GetCrossCallCnt() int32
func (*TxElapsedTime) GetCrossCallTime ¶
func (m *TxElapsedTime) GetCrossCallTime() int64
func (*TxElapsedTime) Marshal ¶
func (m *TxElapsedTime) Marshal() (dAtA []byte, err error)
func (*TxElapsedTime) MarshalTo ¶
func (m *TxElapsedTime) MarshalTo(dAtA []byte) (int, error)
func (*TxElapsedTime) MarshalToSizedBuffer ¶
func (m *TxElapsedTime) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TxElapsedTime) ProtoMessage ¶
func (*TxElapsedTime) ProtoMessage()
func (*TxElapsedTime) Reset ¶
func (m *TxElapsedTime) Reset()
func (*TxElapsedTime) Size ¶
func (m *TxElapsedTime) Size() (n int)
func (*TxElapsedTime) String ¶
func (m *TxElapsedTime) String() string
func (*TxElapsedTime) Unmarshal ¶
func (m *TxElapsedTime) Unmarshal(dAtA []byte) error
func (*TxElapsedTime) XXX_DiscardUnknown ¶
func (m *TxElapsedTime) XXX_DiscardUnknown()
func (*TxElapsedTime) XXX_Marshal ¶
func (m *TxElapsedTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TxElapsedTime) XXX_Merge ¶
func (m *TxElapsedTime) XXX_Merge(src proto.Message)
func (*TxElapsedTime) XXX_Size ¶
func (m *TxElapsedTime) XXX_Size() int
func (*TxElapsedTime) XXX_Unmarshal ¶
func (m *TxElapsedTime) XXX_Unmarshal(b []byte) error
type TxRequest ¶
type TxRequest struct { TxId string `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` ContractName string `protobuf:"bytes,2,opt,name=contract_name,json=contractName,proto3" json:"contract_name,omitempty"` ContractVersion string `protobuf:"bytes,3,opt,name=contract_version,json=contractVersion,proto3" json:"contract_version,omitempty"` Method string `protobuf:"bytes,4,opt,name=method,proto3" json:"method,omitempty"` Parameters map[string][]byte `` /* 161-byte string literal not displayed */ // cross contract in use TxContext *TxContext `protobuf:"bytes,6,opt,name=tx_context,json=txContext,proto3" json:"tx_context,omitempty"` ChainId string `protobuf:"bytes,7,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` }
TX_REQUEST
func (*TxRequest) MarshalToSizedBuffer ¶
func (*TxRequest) XXX_Marshal ¶
type TxResponse ¶
type TxResponse struct { TxId string `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` Code ContractResultCode `protobuf:"varint,2,opt,name=code,proto3,enum=dockergo.ContractResultCode" json:"code,omitempty"` Result []byte `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"` Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"` WriteMap map[string][]byte `` /* 173-byte string literal not displayed */ Events []*DockerContractEvent `protobuf:"bytes,6,rep,name=events,proto3" json:"events,omitempty"` ReadMap map[string][]byte `` /* 170-byte string literal not displayed */ ChainId string `protobuf:"bytes,8,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` TxElapsedTime *TxElapsedTime `protobuf:"bytes,9,opt,name=tx_elapsed_time,json=txElapsedTime,proto3" json:"tx_elapsed_time,omitempty"` }
TX_RESPONSE
func (*TxResponse) Descriptor ¶
func (*TxResponse) Descriptor() ([]byte, []int)
func (*TxResponse) GetChainId ¶
func (m *TxResponse) GetChainId() string
func (*TxResponse) GetCode ¶
func (m *TxResponse) GetCode() ContractResultCode
func (*TxResponse) GetEvents ¶
func (m *TxResponse) GetEvents() []*DockerContractEvent
func (*TxResponse) GetMessage ¶
func (m *TxResponse) GetMessage() string
func (*TxResponse) GetReadMap ¶
func (m *TxResponse) GetReadMap() map[string][]byte
func (*TxResponse) GetResult ¶
func (m *TxResponse) GetResult() []byte
func (*TxResponse) GetTxElapsedTime ¶
func (m *TxResponse) GetTxElapsedTime() *TxElapsedTime
func (*TxResponse) GetTxId ¶
func (m *TxResponse) GetTxId() string
func (*TxResponse) GetWriteMap ¶
func (m *TxResponse) GetWriteMap() map[string][]byte
func (*TxResponse) Marshal ¶
func (m *TxResponse) Marshal() (dAtA []byte, err error)
func (*TxResponse) MarshalTo ¶
func (m *TxResponse) MarshalTo(dAtA []byte) (int, error)
func (*TxResponse) MarshalToSizedBuffer ¶
func (m *TxResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TxResponse) ProtoMessage ¶
func (*TxResponse) ProtoMessage()
func (*TxResponse) Reset ¶
func (m *TxResponse) Reset()
func (*TxResponse) Size ¶
func (m *TxResponse) Size() (n int)
func (*TxResponse) String ¶
func (m *TxResponse) String() string
func (*TxResponse) Unmarshal ¶
func (m *TxResponse) Unmarshal(dAtA []byte) error
func (*TxResponse) XXX_DiscardUnknown ¶
func (m *TxResponse) XXX_DiscardUnknown()
func (*TxResponse) XXX_Marshal ¶
func (m *TxResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TxResponse) XXX_Merge ¶
func (m *TxResponse) XXX_Merge(src proto.Message)
func (*TxResponse) XXX_Size ¶
func (m *TxResponse) XXX_Size() int
func (*TxResponse) XXX_Unmarshal ¶
func (m *TxResponse) XXX_Unmarshal(b []byte) error
type UnimplementedCDMRpcServer ¶
type UnimplementedCDMRpcServer struct { }
UnimplementedCDMRpcServer can be embedded to have forward compatible implementations.
func (*UnimplementedCDMRpcServer) CDMCommunicate ¶
func (*UnimplementedCDMRpcServer) CDMCommunicate(srv CDMRpc_CDMCommunicateServer) error
Click to show internal directories.
Click to hide internal directories.