protogo

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 9, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDockervmMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDockervmMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDockervmMessage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var DockerVMCode_name = map[int32]string{
	0: "OK",
	1: "FAIL",
}
View Source 
var DockerVMCode_value = map[string]int32{
	"OK":   0,
	"FAIL": 1,
}
View Source 
var DockerVMType_name = map[int32]string{
	0:  "UNDEFINED",
	1:  "REGISTER",
	2:  "REGISTERED",
	3:  "PREPARE",
	4:  "READY",
	5:  "INIT",
	6:  "INVOKE",
	7:  "TX_REQUEST",
	8:  "TX_RESPONSE",
	9:  "GET_STATE_REQUEST",
	10: "GET_STATE_RESPONSE",
	11: "GET_BYTECODE_REQUEST",
	12: "GET_BYTECODE_RESPONSE",
	13: "CALL_CONTRACT_REQUEST",
	14: "CALL_CONTRACT_RESPONSE",
	15: "COMPLETED",
	16: "ERROR",
	17: "CREATE_KV_ITERATOR_REQUEST",
	18: "CREATE_KV_ITERATOR_RESPONSE",
	19: "CONSUME_KV_ITERATOR_REQUEST",
	20: "CONSUME_KV_ITERATOR_RESPONSE",
	21: "CREATE_KEY_HISTORY_ITER_REQUEST",
	22: "CREATE_KEY_HISTORY_TER_RESPONSE",
	23: "CONSUME_KEY_HISTORY_ITER_REQUEST",
	24: "CONSUME_KEY_HISTORY_ITER_RESPONSE",
	25: "GET_SENDER_ADDRESS_REQUEST",
	26: "GET_SENDER_ADDRESS_RESPONSE",
	27: "GET_BATCH_STATE_REQUEST",
	28: "GET_BATCH_STATE_RESPONSE",
}
View Source 
var DockerVMType_value = map[string]int32{
	"UNDEFINED":                         0,
	"REGISTER":                          1,
	"REGISTERED":                        2,
	"PREPARE":                           3,
	"READY":                             4,
	"INIT":                              5,
	"INVOKE":                            6,
	"TX_REQUEST":                        7,
	"TX_RESPONSE":                       8,
	"GET_STATE_REQUEST":                 9,
	"GET_STATE_RESPONSE":                10,
	"GET_BYTECODE_REQUEST":              11,
	"GET_BYTECODE_RESPONSE":             12,
	"CALL_CONTRACT_REQUEST":             13,
	"CALL_CONTRACT_RESPONSE":            14,
	"COMPLETED":                         15,
	"ERROR":                             16,
	"CREATE_KV_ITERATOR_REQUEST":        17,
	"CREATE_KV_ITERATOR_RESPONSE":       18,
	"CONSUME_KV_ITERATOR_REQUEST":       19,
	"CONSUME_KV_ITERATOR_RESPONSE":      20,
	"CREATE_KEY_HISTORY_ITER_REQUEST":   21,
	"CREATE_KEY_HISTORY_TER_RESPONSE":   22,
	"CONSUME_KEY_HISTORY_ITER_REQUEST":  23,
	"CONSUME_KEY_HISTORY_ITER_RESPONSE": 24,
	"GET_SENDER_ADDRESS_REQUEST":        25,
	"GET_SENDER_ADDRESS_RESPONSE":       26,
	"GET_BATCH_STATE_REQUEST":           27,
	"GET_BATCH_STATE_RESPONSE":          28,
}
View Source 
var StepType_name = map[int32]string{
	0:  "RUNTIME_PREPARE_TX_REQUEST",
	1:  "RUNTIME_GRPC_SEND_TX_REQUEST",
	2:  "ENGINE_GRPC_RECEIVE_TX_REQUEST",
	3:  "ENGINE_SCHEDULER_RECEIVE_TX_REQUEST",
	4:  "ENGINE_SCHEDULER_SEND_TX_REQUEST",
	5:  "ENGINE_GROUP_RECEIVE_TX_REQUEST",
	6:  "ENGINE_GROUP_SEND_TX_REQUEST",
	7:  "ENGINE_PROCESS_RECEIVE_TX_REQUEST",
	8:  "ENGINE_PROCESS_SEND_TX_REQUEST",
	9:  "ENGINE_PROCESS_RECEIVE_TX_RESPONSE",
	10: "SANDBOX_GRPC_RECEIVE_TX_REQUEST",
	11: "SANDBOX_GRPC_SEND_TX_REQUEST",
	12: "SANDBOX_CHAN_SEND_TX_REQUEST",
	13: "SANDBOX_HANDLER_RECEIVE_TX_REQUEST",
	14: "SANDBOX_HANDLER_EXECUTE",
	15: "SANDBOX_SEND_CHAIN_RESP",
	16: "SANDBOX_GRPC_SEND_CHAIN_RESP",
	17: "SANDBOX_SEND_ENGINE_RESP",
	18: "RUNTIME_GRPC_RECEIVE_TX_RESPONSE",
	19: "RUNTIME_GET_NOTIFY_TX_RESPONSE",
	20: "RUNTIME_HANDLER_RECEIVE_TX_RESPONSE",
	21: "RUNTIME_HANDLE_TX_RESPONSE",
}
View Source 
var StepType_value = map[string]int32{
	"RUNTIME_PREPARE_TX_REQUEST":          0,
	"RUNTIME_GRPC_SEND_TX_REQUEST":        1,
	"ENGINE_GRPC_RECEIVE_TX_REQUEST":      2,
	"ENGINE_SCHEDULER_RECEIVE_TX_REQUEST": 3,
	"ENGINE_SCHEDULER_SEND_TX_REQUEST":    4,
	"ENGINE_GROUP_RECEIVE_TX_REQUEST":     5,
	"ENGINE_GROUP_SEND_TX_REQUEST":        6,
	"ENGINE_PROCESS_RECEIVE_TX_REQUEST":   7,
	"ENGINE_PROCESS_SEND_TX_REQUEST":      8,
	"ENGINE_PROCESS_RECEIVE_TX_RESPONSE":  9,
	"SANDBOX_GRPC_RECEIVE_TX_REQUEST":     10,
	"SANDBOX_GRPC_SEND_TX_REQUEST":        11,
	"SANDBOX_CHAN_SEND_TX_REQUEST":        12,
	"SANDBOX_HANDLER_RECEIVE_TX_REQUEST":  13,
	"SANDBOX_HANDLER_EXECUTE":             14,
	"SANDBOX_SEND_CHAIN_RESP":             15,
	"SANDBOX_GRPC_SEND_CHAIN_RESP":        16,
	"SANDBOX_SEND_ENGINE_RESP":            17,
	"RUNTIME_GRPC_RECEIVE_TX_RESPONSE":    18,
	"RUNTIME_GET_NOTIFY_TX_RESPONSE":      19,
	"RUNTIME_HANDLER_RECEIVE_TX_RESPONSE": 20,
	"RUNTIME_HANDLE_TX_RESPONSE":          21,
}

Functions

func RegisterDockerVMRpcServer 

func RegisterDockerVMRpcServer(s *grpc.Server, srv DockerVMRpcServer)

Types

type CallContractRequest 

type CallContractRequest struct {
	ContractName   string `protobuf:"bytes,1,opt,name=contract_name,json=contractName,proto3" json:"contract_name,omitempty"`
	ContractMethod string `protobuf:"bytes,2,opt,name=contract_method,json=contractMethod,proto3" json:"contract_method,omitempty"`
	// args
	Args map[string][]byte `` /* 149-byte string literal not displayed */
}

============== DMS pb ============== -------------------- request message ---------------------

func (*CallContractRequest) Descriptor 

func (*CallContractRequest) Descriptor() ([]byte, []int)

func (*CallContractRequest) GetArgs 

func (m *CallContractRequest) GetArgs() map[string][]byte

func (*CallContractRequest) GetContractMethod 

func (m *CallContractRequest) GetContractMethod() string

func (*CallContractRequest) GetContractName 

func (m *CallContractRequest) GetContractName() string

func (*CallContractRequest) Marshal 

func (m *CallContractRequest) Marshal() (dAtA []byte, err error)

func (*CallContractRequest) MarshalTo 

func (m *CallContractRequest) MarshalTo(dAtA []byte) (int, error)

func (*CallContractRequest) MarshalToSizedBuffer 

func (m *CallContractRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CallContractRequest) ProtoMessage 

func (*CallContractRequest) ProtoMessage()

func (*CallContractRequest) Reset 

func (m *CallContractRequest) Reset()

func (*CallContractRequest) Size 

func (m *CallContractRequest) Size() (n int)

func (*CallContractRequest) String 

func (m *CallContractRequest) String() string

func (*CallContractRequest) Unmarshal 

func (m *CallContractRequest) Unmarshal(dAtA []byte) error

func (*CallContractRequest) XXX_DiscardUnknown 

func (m *CallContractRequest) XXX_DiscardUnknown()

func (*CallContractRequest) XXX_Marshal 

func (m *CallContractRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CallContractRequest) XXX_Merge 

func (m *CallContractRequest) XXX_Merge(src proto.Message)

func (*CallContractRequest) XXX_Size 

func (m *CallContractRequest) XXX_Size() int

func (*CallContractRequest) XXX_Unmarshal 

func (m *CallContractRequest) XXX_Unmarshal(b []byte) error

type ContractResponse 

type ContractResponse struct {
	// always has response
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// always has write map
	WriteMap map[string][]byte `` /* 173-byte string literal not displayed */
	// only cross contracts has read map
	ReadMap map[string][]byte `` /* 170-byte string literal not displayed */
	// always has events
	Events []*Event `protobuf:"bytes,4,rep,name=events,proto3" json:"events,omitempty"`
}

real user contract response

func (*ContractResponse) Descriptor 

func (*ContractResponse) Descriptor() ([]byte, []int)

func (*ContractResponse) GetEvents 

func (m *ContractResponse) GetEvents() []*Event

func (*ContractResponse) GetReadMap 

func (m *ContractResponse) GetReadMap() map[string][]byte

func (*ContractResponse) GetResponse 

func (m *ContractResponse) GetResponse() *Response

func (*ContractResponse) GetWriteMap 

func (m *ContractResponse) GetWriteMap() map[string][]byte

func (*ContractResponse) Marshal 

func (m *ContractResponse) Marshal() (dAtA []byte, err error)

func (*ContractResponse) MarshalTo 

func (m *ContractResponse) MarshalTo(dAtA []byte) (int, error)

func (*ContractResponse) MarshalToSizedBuffer 

func (m *ContractResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContractResponse) ProtoMessage 

func (*ContractResponse) ProtoMessage()

func (*ContractResponse) Reset 

func (m *ContractResponse) Reset()

func (*ContractResponse) Size 

func (m *ContractResponse) Size() (n int)

func (*ContractResponse) String 

func (m *ContractResponse) String() string

func (*ContractResponse) Unmarshal 

func (m *ContractResponse) Unmarshal(dAtA []byte) error

func (*ContractResponse) XXX_DiscardUnknown 

func (m *ContractResponse) XXX_DiscardUnknown()

func (*ContractResponse) XXX_Marshal 

func (m *ContractResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContractResponse) XXX_Merge 

func (m *ContractResponse) XXX_Merge(src proto.Message)

func (*ContractResponse) XXX_Size 

func (m *ContractResponse) XXX_Size() int

func (*ContractResponse) XXX_Unmarshal 

func (m *ContractResponse) XXX_Unmarshal(b []byte) error

type CrossContext 

type CrossContext struct {
	CurrentDepth uint32 `protobuf:"varint,1,opt,name=current_depth,json=currentDepth,proto3" json:"current_depth,omitempty"`
	ProcessName  string `protobuf:"bytes,2,opt,name=process_name,json=processName,proto3" json:"process_name,omitempty"`
	//
	//63          59           43                   0
	//+----------+^-----------+-^---------+-^-------
	//|   4bits   |   16bits    |   .....   | 4bits|
	//+----------+^-----------+-^---------+-^-------
	//depth_count | history_flag | vec<runtime_type>
	//the length of vec is controlled by depth_count
	CrossInfo uint64 `protobuf:"varint,3,opt,name=cross_info,json=crossInfo,proto3" json:"cross_info,omitempty"`
}

func (*CrossContext) Descriptor 

func (*CrossContext) Descriptor() ([]byte, []int)

func (*CrossContext) GetCrossInfo 

func (m *CrossContext) GetCrossInfo() uint64

func (*CrossContext) GetCurrentDepth 

func (m *CrossContext) GetCurrentDepth() uint32

func (*CrossContext) GetProcessName 

func (m *CrossContext) GetProcessName() string

func (*CrossContext) Marshal 

func (m *CrossContext) Marshal() (dAtA []byte, err error)

func (*CrossContext) MarshalTo 

func (m *CrossContext) MarshalTo(dAtA []byte) (int, error)

func (*CrossContext) MarshalToSizedBuffer 

func (m *CrossContext) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CrossContext) ProtoMessage 

func (*CrossContext) ProtoMessage()

func (*CrossContext) Reset 

func (m *CrossContext) Reset()

func (*CrossContext) Size 

func (m *CrossContext) Size() (n int)

func (*CrossContext) String 

func (m *CrossContext) String() string

func (*CrossContext) Unmarshal 

func (m *CrossContext) Unmarshal(dAtA []byte) error

func (*CrossContext) XXX_DiscardUnknown 

func (m *CrossContext) XXX_DiscardUnknown()

func (*CrossContext) XXX_Marshal 

func (m *CrossContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrossContext) XXX_Merge 

func (m *CrossContext) XXX_Merge(src proto.Message)

func (*CrossContext) XXX_Size 

func (m *CrossContext) XXX_Size() int

func (*CrossContext) XXX_Unmarshal 

func (m *CrossContext) XXX_Unmarshal(b []byte) error

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 payload
	Data []string `protobuf:"bytes,3,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) 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 DockerVMCode 

type DockerVMCode int32
const (
	DockerVMCode_OK   DockerVMCode = 0
	DockerVMCode_FAIL DockerVMCode = 1
)

func (DockerVMCode) EnumDescriptor 

func (DockerVMCode) EnumDescriptor() ([]byte, []int)

func (DockerVMCode) String 

func (x DockerVMCode) String() string

type DockerVMMessage 

type DockerVMMessage struct {
	TxId         string        `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	Type         DockerVMType  `protobuf:"varint,2,opt,name=type,proto3,enum=proto.DockerVMType" json:"type,omitempty"`
	CrossContext *CrossContext `protobuf:"bytes,3,opt,name=cross_context,json=crossContext,proto3" json:"cross_context,omitempty"`
	// if not used, set to nil
	SysCallMessage *SysCallMessage `protobuf:"bytes,4,opt,name=sys_call_message,json=sysCallMessage,proto3" json:"sys_call_message,omitempty"`
	// if not used, set to nil
	Request *TxRequest `protobuf:"bytes,5,opt,name=request,proto3" json:"request,omitempty"`
	// if not used, set to nil
	Response      *TxResponse     `protobuf:"bytes,6,opt,name=response,proto3" json:"response,omitempty"`
	ChainId       string          `protobuf:"bytes,7,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	StepDurations []*StepDuration `protobuf:"bytes,8,rep,name=step_durations,json=stepDurations,proto3" json:"step_durations,omitempty"`
}

DockerVMMessage means message between herbt and docker vm

func (*DockerVMMessage) Descriptor 

func (*DockerVMMessage) Descriptor() ([]byte, []int)

func (*DockerVMMessage) GetChainId 

func (m *DockerVMMessage) GetChainId() string

func (*DockerVMMessage) GetCrossContext 

func (m *DockerVMMessage) GetCrossContext() *CrossContext

func (*DockerVMMessage) GetRequest 

func (m *DockerVMMessage) GetRequest() *TxRequest

func (*DockerVMMessage) GetResponse 

func (m *DockerVMMessage) GetResponse() *TxResponse

func (*DockerVMMessage) GetStepDurations 

func (m *DockerVMMessage) GetStepDurations() []*StepDuration

func (*DockerVMMessage) GetSysCallMessage 

func (m *DockerVMMessage) GetSysCallMessage() *SysCallMessage

func (*DockerVMMessage) GetTxId 

func (m *DockerVMMessage) GetTxId() string

func (*DockerVMMessage) GetType 

func (m *DockerVMMessage) GetType() DockerVMType

func (*DockerVMMessage) Marshal 

func (m *DockerVMMessage) Marshal() (dAtA []byte, err error)

func (*DockerVMMessage) MarshalTo 

func (m *DockerVMMessage) MarshalTo(dAtA []byte) (int, error)

func (*DockerVMMessage) MarshalToSizedBuffer 

func (m *DockerVMMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DockerVMMessage) ProtoMessage 

func (*DockerVMMessage) ProtoMessage()

func (*DockerVMMessage) Reset 

func (m *DockerVMMessage) Reset()

func (*DockerVMMessage) Size 

func (m *DockerVMMessage) Size() (n int)

func (*DockerVMMessage) String 

func (m *DockerVMMessage) String() string

func (*DockerVMMessage) Unmarshal 

func (m *DockerVMMessage) Unmarshal(dAtA []byte) error

func (*DockerVMMessage) XXX_DiscardUnknown 

func (m *DockerVMMessage) XXX_DiscardUnknown()

func (*DockerVMMessage) XXX_Marshal 

func (m *DockerVMMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DockerVMMessage) XXX_Merge 

func (m *DockerVMMessage) XXX_Merge(src proto.Message)

func (*DockerVMMessage) XXX_Size 

func (m *DockerVMMessage) XXX_Size() int

func (*DockerVMMessage) XXX_Unmarshal 

func (m *DockerVMMessage) XXX_Unmarshal(b []byte) error

type DockerVMRpcClient 

type DockerVMRpcClient interface {
	DockerVMCommunicate(ctx context.Context, opts ...grpc.CallOption) (DockerVMRpc_DockerVMCommunicateClient, error)
}

DockerVMRpcClient is the client API for DockerVMRpc service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDockerVMRpcClient 

func NewDockerVMRpcClient(cc *grpc.ClientConn) DockerVMRpcClient

type DockerVMRpcServer 

type DockerVMRpcServer interface {
	DockerVMCommunicate(DockerVMRpc_DockerVMCommunicateServer) error
}

DockerVMRpcServer is the server API for DockerVMRpc service.

type DockerVMRpc_DockerVMCommunicateClient 

type DockerVMRpc_DockerVMCommunicateClient interface {
	Send(*DockerVMMessage) error
	Recv() (*DockerVMMessage, error)
	grpc.ClientStream
}

type DockerVMRpc_DockerVMCommunicateServer 

type DockerVMRpc_DockerVMCommunicateServer interface {
	Send(*DockerVMMessage) error
	Recv() (*DockerVMMessage, error)
	grpc.ServerStream
}

type DockerVMType 

type DockerVMType int32
const (
	DockerVMType_UNDEFINED                         DockerVMType = 0
	DockerVMType_REGISTER                          DockerVMType = 1
	DockerVMType_REGISTERED                        DockerVMType = 2
	DockerVMType_PREPARE                           DockerVMType = 3
	DockerVMType_READY                             DockerVMType = 4
	DockerVMType_INIT                              DockerVMType = 5
	DockerVMType_INVOKE                            DockerVMType = 6
	DockerVMType_TX_REQUEST                        DockerVMType = 7
	DockerVMType_TX_RESPONSE                       DockerVMType = 8
	DockerVMType_GET_STATE_REQUEST                 DockerVMType = 9
	DockerVMType_GET_STATE_RESPONSE                DockerVMType = 10
	DockerVMType_GET_BYTECODE_REQUEST              DockerVMType = 11
	DockerVMType_GET_BYTECODE_RESPONSE             DockerVMType = 12
	DockerVMType_CALL_CONTRACT_REQUEST             DockerVMType = 13
	DockerVMType_CALL_CONTRACT_RESPONSE            DockerVMType = 14
	DockerVMType_COMPLETED                         DockerVMType = 15
	DockerVMType_ERROR                             DockerVMType = 16
	DockerVMType_CREATE_KV_ITERATOR_REQUEST        DockerVMType = 17
	DockerVMType_CREATE_KV_ITERATOR_RESPONSE       DockerVMType = 18
	DockerVMType_CONSUME_KV_ITERATOR_REQUEST       DockerVMType = 19
	DockerVMType_CONSUME_KV_ITERATOR_RESPONSE      DockerVMType = 20
	DockerVMType_CREATE_KEY_HISTORY_ITER_REQUEST   DockerVMType = 21
	DockerVMType_CREATE_KEY_HISTORY_TER_RESPONSE   DockerVMType = 22
	DockerVMType_CONSUME_KEY_HISTORY_ITER_REQUEST  DockerVMType = 23
	DockerVMType_CONSUME_KEY_HISTORY_ITER_RESPONSE DockerVMType = 24
	DockerVMType_GET_SENDER_ADDRESS_REQUEST        DockerVMType = 25
	DockerVMType_GET_SENDER_ADDRESS_RESPONSE       DockerVMType = 26
	DockerVMType_GET_BATCH_STATE_REQUEST           DockerVMType = 27
	DockerVMType_GET_BATCH_STATE_RESPONSE          DockerVMType = 28
)

func (DockerVMType) EnumDescriptor 

func (DockerVMType) EnumDescriptor() ([]byte, []int)

func (DockerVMType) String 

func (x DockerVMType) String() string

type Event 

type Event 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 payload
	Data []string `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"`
}

func (*Event) Descriptor 

func (*Event) Descriptor() ([]byte, []int)

func (*Event) GetContractName 

func (m *Event) GetContractName() string

func (*Event) GetData 

func (m *Event) GetData() []string

func (*Event) GetTopic 

func (m *Event) GetTopic() string

func (*Event) Marshal 

func (m *Event) Marshal() (dAtA []byte, err error)

func (*Event) MarshalTo 

func (m *Event) MarshalTo(dAtA []byte) (int, error)

func (*Event) MarshalToSizedBuffer 

func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

func (m *Event) Size() (n int)

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type Response 

type Response struct {
	// A status code that should follow the HTTP status codes.
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// A message associated with the response code. error has message
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// A payload that can be used to include metadata with this response. success with payload
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
}

user method response

func (*Response) Descriptor 

func (*Response) Descriptor() ([]byte, []int)

func (*Response) GetMessage 

func (m *Response) GetMessage() string

func (*Response) GetPayload 

func (m *Response) GetPayload() []byte

func (*Response) GetStatus 

func (m *Response) GetStatus() int32

func (*Response) Marshal 

func (m *Response) Marshal() (dAtA []byte, err error)

func (*Response) MarshalTo 

func (m *Response) MarshalTo(dAtA []byte) (int, error)

func (*Response) MarshalToSizedBuffer 

func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

func (m *Response) Size() (n int)

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

func (m *Response) Unmarshal(dAtA []byte) error

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Response) XXX_Merge 

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

func (m *Response) XXX_Unmarshal(b []byte) error

type StepDuration 

type StepDuration struct {
	Type          StepType `protobuf:"varint,1,opt,name=type,proto3,enum=proto.StepType" json:"type,omitempty"`
	StartTime     int64    `protobuf:"varint,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	StepDuration  int64    `protobuf:"varint,3,opt,name=step_duration,json=stepDuration,proto3" json:"step_duration,omitempty"`
	UntilDuration int64    `protobuf:"varint,4,opt,name=until_duration,json=untilDuration,proto3" json:"until_duration,omitempty"`
	Msg           string   `protobuf:"bytes,5,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*StepDuration) Descriptor 

func (*StepDuration) Descriptor() ([]byte, []int)

func (*StepDuration) GetMsg 

func (m *StepDuration) GetMsg() string

func (*StepDuration) GetStartTime 

func (m *StepDuration) GetStartTime() int64

func (*StepDuration) GetStepDuration 

func (m *StepDuration) GetStepDuration() int64

func (*StepDuration) GetType 

func (m *StepDuration) GetType() StepType

func (*StepDuration) GetUntilDuration 

func (m *StepDuration) GetUntilDuration() int64

func (*StepDuration) Marshal 

func (m *StepDuration) Marshal() (dAtA []byte, err error)

func (*StepDuration) MarshalTo 

func (m *StepDuration) MarshalTo(dAtA []byte) (int, error)

func (*StepDuration) MarshalToSizedBuffer 

func (m *StepDuration) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StepDuration) ProtoMessage 

func (*StepDuration) ProtoMessage()

func (*StepDuration) Reset 

func (m *StepDuration) Reset()

func (*StepDuration) Size 

func (m *StepDuration) Size() (n int)

func (*StepDuration) String 

func (m *StepDuration) String() string

func (*StepDuration) Unmarshal 

func (m *StepDuration) Unmarshal(dAtA []byte) error

func (*StepDuration) XXX_DiscardUnknown 

func (m *StepDuration) XXX_DiscardUnknown()

func (*StepDuration) XXX_Marshal 

func (m *StepDuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StepDuration) XXX_Merge 

func (m *StepDuration) XXX_Merge(src proto.Message)

func (*StepDuration) XXX_Size 

func (m *StepDuration) XXX_Size() int

func (*StepDuration) XXX_Unmarshal 

func (m *StepDuration) XXX_Unmarshal(b []byte) error

type StepType 

type StepType int32
const (
	StepType_RUNTIME_PREPARE_TX_REQUEST          StepType = 0
	StepType_RUNTIME_GRPC_SEND_TX_REQUEST        StepType = 1
	StepType_ENGINE_GRPC_RECEIVE_TX_REQUEST      StepType = 2
	StepType_ENGINE_SCHEDULER_RECEIVE_TX_REQUEST StepType = 3
	StepType_ENGINE_SCHEDULER_SEND_TX_REQUEST    StepType = 4
	StepType_ENGINE_GROUP_RECEIVE_TX_REQUEST     StepType = 5
	StepType_ENGINE_GROUP_SEND_TX_REQUEST        StepType = 6
	StepType_ENGINE_PROCESS_RECEIVE_TX_REQUEST   StepType = 7
	StepType_ENGINE_PROCESS_SEND_TX_REQUEST      StepType = 8
	StepType_ENGINE_PROCESS_RECEIVE_TX_RESPONSE  StepType = 9
	StepType_SANDBOX_GRPC_RECEIVE_TX_REQUEST     StepType = 10
	StepType_SANDBOX_GRPC_SEND_TX_REQUEST        StepType = 11
	StepType_SANDBOX_CHAN_SEND_TX_REQUEST        StepType = 12
	StepType_SANDBOX_HANDLER_RECEIVE_TX_REQUEST  StepType = 13
	StepType_SANDBOX_HANDLER_EXECUTE             StepType = 14
	StepType_SANDBOX_SEND_CHAIN_RESP             StepType = 15
	StepType_SANDBOX_GRPC_SEND_CHAIN_RESP        StepType = 16
	StepType_SANDBOX_SEND_ENGINE_RESP            StepType = 17
	StepType_RUNTIME_GRPC_RECEIVE_TX_RESPONSE    StepType = 18
	StepType_RUNTIME_GET_NOTIFY_TX_RESPONSE      StepType = 19
	StepType_RUNTIME_HANDLER_RECEIVE_TX_RESPONSE StepType = 20
	StepType_RUNTIME_HANDLE_TX_RESPONSE          StepType = 21
)

func (StepType) EnumDescriptor 

func (StepType) EnumDescriptor() ([]byte, []int)

func (StepType) String 

func (x StepType) String() string

type SysCallMessage 

type SysCallMessage struct {
	Code    DockerVMCode `protobuf:"varint,1,opt,name=code,proto3,enum=proto.DockerVMCode" json:"code,omitempty"`
	Message string       `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// if not used, set to nil
	Payload map[string][]byte `` /* 155-byte string literal not displayed */
}

func (*SysCallMessage) Descriptor 

func (*SysCallMessage) Descriptor() ([]byte, []int)

func (*SysCallMessage) GetCode 

func (m *SysCallMessage) GetCode() DockerVMCode

func (*SysCallMessage) GetMessage 

func (m *SysCallMessage) GetMessage() string

func (*SysCallMessage) GetPayload 

func (m *SysCallMessage) GetPayload() map[string][]byte

func (*SysCallMessage) Marshal 

func (m *SysCallMessage) Marshal() (dAtA []byte, err error)

func (*SysCallMessage) MarshalTo 

func (m *SysCallMessage) MarshalTo(dAtA []byte) (int, error)

func (*SysCallMessage) MarshalToSizedBuffer 

func (m *SysCallMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SysCallMessage) ProtoMessage 

func (*SysCallMessage) ProtoMessage()

func (*SysCallMessage) Reset 

func (m *SysCallMessage) Reset()

func (*SysCallMessage) Size 

func (m *SysCallMessage) Size() (n int)

func (*SysCallMessage) String 

func (m *SysCallMessage) String() string

func (*SysCallMessage) Unmarshal 

func (m *SysCallMessage) Unmarshal(dAtA []byte) error

func (*SysCallMessage) XXX_DiscardUnknown 

func (m *SysCallMessage) XXX_DiscardUnknown()

func (*SysCallMessage) XXX_Marshal 

func (m *SysCallMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SysCallMessage) XXX_Merge 

func (m *SysCallMessage) XXX_Merge(src proto.Message)

func (*SysCallMessage) XXX_Size 

func (m *SysCallMessage) XXX_Size() int

func (*SysCallMessage) XXX_Unmarshal 

func (m *SysCallMessage) XXX_Unmarshal(b []byte) error

type TxContext 

type TxContext struct {
	WriteMap map[string][]byte `` /* 173-byte string literal not displayed */
	ReadMap  map[string][]byte `` /* 170-byte string literal not displayed */
}

func (*TxContext) Descriptor 

func (*TxContext) Descriptor() ([]byte, []int)

func (*TxContext) GetReadMap 

func (m *TxContext) GetReadMap() map[string][]byte

func (*TxContext) GetWriteMap 

func (m *TxContext) GetWriteMap() map[string][]byte

func (*TxContext) Marshal 

func (m *TxContext) Marshal() (dAtA []byte, err error)

func (*TxContext) MarshalTo 

func (m *TxContext) MarshalTo(dAtA []byte) (int, error)

func (*TxContext) MarshalToSizedBuffer 

func (m *TxContext) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TxContext) ProtoMessage 

func (*TxContext) ProtoMessage()

func (*TxContext) Reset 

func (m *TxContext) Reset()

func (*TxContext) Size 

func (m *TxContext) Size() (n int)

func (*TxContext) String 

func (m *TxContext) String() string

func (*TxContext) Unmarshal 

func (m *TxContext) Unmarshal(dAtA []byte) error

func (*TxContext) XXX_DiscardUnknown 

func (m *TxContext) XXX_DiscardUnknown()

func (*TxContext) XXX_Marshal 

func (m *TxContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TxContext) XXX_Merge 

func (m *TxContext) XXX_Merge(src proto.Message)

func (*TxContext) XXX_Size 

func (m *TxContext) XXX_Size() int

func (*TxContext) XXX_Unmarshal 

func (m *TxContext) XXX_Unmarshal(b []byte) error

type TxRequest 

type TxRequest struct {
	ContractName    string            `protobuf:"bytes,1,opt,name=contract_name,json=contractName,proto3" json:"contract_name,omitempty"`
	ContractVersion string            `protobuf:"bytes,2,opt,name=contract_version,json=contractVersion,proto3" json:"contract_version,omitempty"`
	Method          string            `protobuf:"bytes,3,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,5,opt,name=tx_context,json=txContext,proto3" json:"tx_context,omitempty"`
	ChainId   string     `protobuf:"bytes,6,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
}

TX_REQUEST

func (*TxRequest) Descriptor 

func (*TxRequest) Descriptor() ([]byte, []int)

func (*TxRequest) GetChainId 

func (m *TxRequest) GetChainId() string

func (*TxRequest) GetContractName 

func (m *TxRequest) GetContractName() string

func (*TxRequest) GetContractVersion 

func (m *TxRequest) GetContractVersion() string

func (*TxRequest) GetMethod 

func (m *TxRequest) GetMethod() string

func (*TxRequest) GetParameters 

func (m *TxRequest) GetParameters() map[string][]byte

func (*TxRequest) GetTxContext 

func (m *TxRequest) GetTxContext() *TxContext

func (*TxRequest) Marshal 

func (m *TxRequest) Marshal() (dAtA []byte, err error)

func (*TxRequest) MarshalTo 

func (m *TxRequest) MarshalTo(dAtA []byte) (int, error)

func (*TxRequest) MarshalToSizedBuffer 

func (m *TxRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TxRequest) ProtoMessage 

func (*TxRequest) ProtoMessage()

func (*TxRequest) Reset 

func (m *TxRequest) Reset()

func (*TxRequest) Size 

func (m *TxRequest) Size() (n int)

func (*TxRequest) String 

func (m *TxRequest) String() string

func (*TxRequest) Unmarshal 

func (m *TxRequest) Unmarshal(dAtA []byte) error

func (*TxRequest) XXX_DiscardUnknown 

func (m *TxRequest) XXX_DiscardUnknown()

func (*TxRequest) XXX_Marshal 

func (m *TxRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TxRequest) XXX_Merge 

func (m *TxRequest) XXX_Merge(src proto.Message)

func (*TxRequest) XXX_Size 

func (m *TxRequest) XXX_Size() int

func (*TxRequest) XXX_Unmarshal 

func (m *TxRequest) XXX_Unmarshal(b []byte) error

type TxResponse 

type TxResponse struct {
	TxId            string                 `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	Code            DockerVMCode           `protobuf:"varint,2,opt,name=code,proto3,enum=proto.DockerVMCode" 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 */
	ReadMap         map[string][]byte      `` /* 170-byte string literal not displayed */
	Events          []*DockerContractEvent `protobuf:"bytes,7,rep,name=events,proto3" json:"events,omitempty"`
	ContractName    string                 `protobuf:"bytes,8,opt,name=contract_name,json=contractName,proto3" json:"contract_name,omitempty"`
	ContractVersion string                 `protobuf:"bytes,9,opt,name=contract_version,json=contractVersion,proto3" json:"contract_version,omitempty"`
	ChainId         string                 `protobuf:"bytes,10,opt,name=chain_id,json=chainId,proto3" json:"chain_id,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() DockerVMCode

func (*TxResponse) GetContractName 

func (m *TxResponse) GetContractName() string

func (*TxResponse) GetContractVersion 

func (m *TxResponse) GetContractVersion() string

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) 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 UnimplementedDockerVMRpcServer 

type UnimplementedDockerVMRpcServer struct {
}

UnimplementedDockerVMRpcServer can be embedded to have forward compatible implementations.

func (*UnimplementedDockerVMRpcServer) DockerVMCommunicate 

func (*UnimplementedDockerVMRpcServer) DockerVMCommunicate(srv DockerVMRpc_DockerVMCommunicateServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.