execution

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Jan 15, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthExecution        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExecution          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupExecution = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ExecutionService_serviceDesc = _ExecutionService_serviceDesc

Functions

func RegisterExecutionServiceServer 

func RegisterExecutionServiceServer(s grpc1.Server, srv ExecutionServiceServer)

Types

type ExecuteTxsRequest 

type ExecuteTxsRequest struct {
	Txs           [][]byte `protobuf:"bytes,1,rep,name=txs,proto3" json:"txs,omitempty"`
	BlockHeight   uint64   `protobuf:"varint,2,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	Timestamp     int64    `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	PrevStateRoot []byte   `protobuf:"bytes,4,opt,name=prev_state_root,json=prevStateRoot,proto3" json:"prev_state_root,omitempty"`
}

func (*ExecuteTxsRequest) Descriptor 

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

func (*ExecuteTxsRequest) GetBlockHeight 

func (m *ExecuteTxsRequest) GetBlockHeight() uint64

func (*ExecuteTxsRequest) GetPrevStateRoot 

func (m *ExecuteTxsRequest) GetPrevStateRoot() []byte

func (*ExecuteTxsRequest) GetTimestamp 

func (m *ExecuteTxsRequest) GetTimestamp() int64

func (*ExecuteTxsRequest) GetTxs 

func (m *ExecuteTxsRequest) GetTxs() [][]byte

func (*ExecuteTxsRequest) Marshal 

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

func (*ExecuteTxsRequest) MarshalTo 

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

func (*ExecuteTxsRequest) MarshalToSizedBuffer 

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

func (*ExecuteTxsRequest) ProtoMessage 

func (*ExecuteTxsRequest) ProtoMessage()

func (*ExecuteTxsRequest) Reset 

func (m *ExecuteTxsRequest) Reset()

func (*ExecuteTxsRequest) Size 

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

func (*ExecuteTxsRequest) String 

func (m *ExecuteTxsRequest) String() string

func (*ExecuteTxsRequest) Unmarshal 

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

func (*ExecuteTxsRequest) XXX_DiscardUnknown 

func (m *ExecuteTxsRequest) XXX_DiscardUnknown()

func (*ExecuteTxsRequest) XXX_Marshal 

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

func (*ExecuteTxsRequest) XXX_Merge 

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

func (*ExecuteTxsRequest) XXX_Size 

func (m *ExecuteTxsRequest) XXX_Size() int

func (*ExecuteTxsRequest) XXX_Unmarshal 

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

type ExecuteTxsResponse 

type ExecuteTxsResponse struct {
	UpdatedStateRoot []byte `protobuf:"bytes,1,opt,name=updated_state_root,json=updatedStateRoot,proto3" json:"updated_state_root,omitempty"`
	MaxBytes         uint64 `protobuf:"varint,2,opt,name=max_bytes,json=maxBytes,proto3" json:"max_bytes,omitempty"`
}

func (*ExecuteTxsResponse) Descriptor 

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

func (*ExecuteTxsResponse) GetMaxBytes 

func (m *ExecuteTxsResponse) GetMaxBytes() uint64

func (*ExecuteTxsResponse) GetUpdatedStateRoot 

func (m *ExecuteTxsResponse) GetUpdatedStateRoot() []byte

func (*ExecuteTxsResponse) Marshal 

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

func (*ExecuteTxsResponse) MarshalTo 

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

func (*ExecuteTxsResponse) MarshalToSizedBuffer 

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

func (*ExecuteTxsResponse) ProtoMessage 

func (*ExecuteTxsResponse) ProtoMessage()

func (*ExecuteTxsResponse) Reset 

func (m *ExecuteTxsResponse) Reset()

func (*ExecuteTxsResponse) Size 

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

func (*ExecuteTxsResponse) String 

func (m *ExecuteTxsResponse) String() string

func (*ExecuteTxsResponse) Unmarshal 

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

func (*ExecuteTxsResponse) XXX_DiscardUnknown 

func (m *ExecuteTxsResponse) XXX_DiscardUnknown()

func (*ExecuteTxsResponse) XXX_Marshal 

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

func (*ExecuteTxsResponse) XXX_Merge 

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

func (*ExecuteTxsResponse) XXX_Size 

func (m *ExecuteTxsResponse) XXX_Size() int

func (*ExecuteTxsResponse) XXX_Unmarshal 

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

type ExecutionServiceClient 

type ExecutionServiceClient interface {
	InitChain(ctx context.Context, in *InitChainRequest, opts ...grpc.CallOption) (*InitChainResponse, error)
	GetTxs(ctx context.Context, in *GetTxsRequest, opts ...grpc.CallOption) (*GetTxsResponse, error)
	ExecuteTxs(ctx context.Context, in *ExecuteTxsRequest, opts ...grpc.CallOption) (*ExecuteTxsResponse, error)
	SetFinal(ctx context.Context, in *SetFinalRequest, opts ...grpc.CallOption) (*SetFinalResponse, error)
}

ExecutionServiceClient is the client API for ExecutionService service.

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

func NewExecutionServiceClient 

func NewExecutionServiceClient(cc grpc1.ClientConn) ExecutionServiceClient

type ExecutionServiceServer 

type ExecutionServiceServer interface {
	InitChain(context.Context, *InitChainRequest) (*InitChainResponse, error)
	GetTxs(context.Context, *GetTxsRequest) (*GetTxsResponse, error)
	ExecuteTxs(context.Context, *ExecuteTxsRequest) (*ExecuteTxsResponse, error)
	SetFinal(context.Context, *SetFinalRequest) (*SetFinalResponse, error)
}

ExecutionServiceServer is the server API for ExecutionService service.

type GetTxsRequest 

type GetTxsRequest struct {
}

func (*GetTxsRequest) Descriptor 

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

func (*GetTxsRequest) Marshal 

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

func (*GetTxsRequest) MarshalTo 

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

func (*GetTxsRequest) MarshalToSizedBuffer 

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

func (*GetTxsRequest) ProtoMessage 

func (*GetTxsRequest) ProtoMessage()

func (*GetTxsRequest) Reset 

func (m *GetTxsRequest) Reset()

func (*GetTxsRequest) Size 

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

func (*GetTxsRequest) String 

func (m *GetTxsRequest) String() string

func (*GetTxsRequest) Unmarshal 

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

func (*GetTxsRequest) XXX_DiscardUnknown 

func (m *GetTxsRequest) XXX_DiscardUnknown()

func (*GetTxsRequest) XXX_Marshal 

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

func (*GetTxsRequest) XXX_Merge 

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

func (*GetTxsRequest) XXX_Size 

func (m *GetTxsRequest) XXX_Size() int

func (*GetTxsRequest) XXX_Unmarshal 

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

type GetTxsResponse 

type GetTxsResponse struct {
	Txs [][]byte `protobuf:"bytes,1,rep,name=txs,proto3" json:"txs,omitempty"`
}

func (*GetTxsResponse) Descriptor 

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

func (*GetTxsResponse) GetTxs 

func (m *GetTxsResponse) GetTxs() [][]byte

func (*GetTxsResponse) Marshal 

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

func (*GetTxsResponse) MarshalTo 

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

func (*GetTxsResponse) MarshalToSizedBuffer 

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

func (*GetTxsResponse) ProtoMessage 

func (*GetTxsResponse) ProtoMessage()

func (*GetTxsResponse) Reset 

func (m *GetTxsResponse) Reset()

func (*GetTxsResponse) Size 

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

func (*GetTxsResponse) String 

func (m *GetTxsResponse) String() string

func (*GetTxsResponse) Unmarshal 

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

func (*GetTxsResponse) XXX_DiscardUnknown 

func (m *GetTxsResponse) XXX_DiscardUnknown()

func (*GetTxsResponse) XXX_Marshal 

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

func (*GetTxsResponse) XXX_Merge 

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

func (*GetTxsResponse) XXX_Size 

func (m *GetTxsResponse) XXX_Size() int

func (*GetTxsResponse) XXX_Unmarshal 

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

type InitChainRequest 

type InitChainRequest struct {
	GenesisTime   int64  `protobuf:"varint,1,opt,name=genesis_time,json=genesisTime,proto3" json:"genesis_time,omitempty"`
	InitialHeight uint64 `protobuf:"varint,2,opt,name=initial_height,json=initialHeight,proto3" json:"initial_height,omitempty"`
	ChainId       string `protobuf:"bytes,3,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
}

func (*InitChainRequest) Descriptor 

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

func (*InitChainRequest) GetChainId 

func (m *InitChainRequest) GetChainId() string

func (*InitChainRequest) GetGenesisTime 

func (m *InitChainRequest) GetGenesisTime() int64

func (*InitChainRequest) GetInitialHeight 

func (m *InitChainRequest) GetInitialHeight() uint64

func (*InitChainRequest) Marshal 

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

func (*InitChainRequest) MarshalTo 

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

func (*InitChainRequest) MarshalToSizedBuffer 

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

func (*InitChainRequest) ProtoMessage 

func (*InitChainRequest) ProtoMessage()

func (*InitChainRequest) Reset 

func (m *InitChainRequest) Reset()

func (*InitChainRequest) Size 

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

func (*InitChainRequest) String 

func (m *InitChainRequest) String() string

func (*InitChainRequest) Unmarshal 

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

func (*InitChainRequest) XXX_DiscardUnknown 

func (m *InitChainRequest) XXX_DiscardUnknown()

func (*InitChainRequest) XXX_Marshal 

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

func (*InitChainRequest) XXX_Merge 

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

func (*InitChainRequest) XXX_Size 

func (m *InitChainRequest) XXX_Size() int

func (*InitChainRequest) XXX_Unmarshal 

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

type InitChainResponse 

type InitChainResponse struct {
	StateRoot []byte `protobuf:"bytes,1,opt,name=state_root,json=stateRoot,proto3" json:"state_root,omitempty"`
	MaxBytes  uint64 `protobuf:"varint,2,opt,name=max_bytes,json=maxBytes,proto3" json:"max_bytes,omitempty"`
}

func (*InitChainResponse) Descriptor 

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

func (*InitChainResponse) GetMaxBytes 

func (m *InitChainResponse) GetMaxBytes() uint64

func (*InitChainResponse) GetStateRoot 

func (m *InitChainResponse) GetStateRoot() []byte

func (*InitChainResponse) Marshal 

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

func (*InitChainResponse) MarshalTo 

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

func (*InitChainResponse) MarshalToSizedBuffer 

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

func (*InitChainResponse) ProtoMessage 

func (*InitChainResponse) ProtoMessage()

func (*InitChainResponse) Reset 

func (m *InitChainResponse) Reset()

func (*InitChainResponse) Size 

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

func (*InitChainResponse) String 

func (m *InitChainResponse) String() string

func (*InitChainResponse) Unmarshal 

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

func (*InitChainResponse) XXX_DiscardUnknown 

func (m *InitChainResponse) XXX_DiscardUnknown()

func (*InitChainResponse) XXX_Marshal 

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

func (*InitChainResponse) XXX_Merge 

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

func (*InitChainResponse) XXX_Size 

func (m *InitChainResponse) XXX_Size() int

func (*InitChainResponse) XXX_Unmarshal 

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

type SetFinalRequest 

type SetFinalRequest struct {
	BlockHeight uint64 `protobuf:"varint,1,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
}

func (*SetFinalRequest) Descriptor 

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

func (*SetFinalRequest) GetBlockHeight 

func (m *SetFinalRequest) GetBlockHeight() uint64

func (*SetFinalRequest) Marshal 

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

func (*SetFinalRequest) MarshalTo 

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

func (*SetFinalRequest) MarshalToSizedBuffer 

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

func (*SetFinalRequest) ProtoMessage 

func (*SetFinalRequest) ProtoMessage()

func (*SetFinalRequest) Reset 

func (m *SetFinalRequest) Reset()

func (*SetFinalRequest) Size 

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

func (*SetFinalRequest) String 

func (m *SetFinalRequest) String() string

func (*SetFinalRequest) Unmarshal 

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

func (*SetFinalRequest) XXX_DiscardUnknown 

func (m *SetFinalRequest) XXX_DiscardUnknown()

func (*SetFinalRequest) XXX_Marshal 

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

func (*SetFinalRequest) XXX_Merge 

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

func (*SetFinalRequest) XXX_Size 

func (m *SetFinalRequest) XXX_Size() int

func (*SetFinalRequest) XXX_Unmarshal 

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

type SetFinalResponse 

type SetFinalResponse struct {
}

func (*SetFinalResponse) Descriptor 

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

func (*SetFinalResponse) Marshal 

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

func (*SetFinalResponse) MarshalTo 

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

func (*SetFinalResponse) MarshalToSizedBuffer 

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

func (*SetFinalResponse) ProtoMessage 

func (*SetFinalResponse) ProtoMessage()

func (*SetFinalResponse) Reset 

func (m *SetFinalResponse) Reset()

func (*SetFinalResponse) Size 

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

func (*SetFinalResponse) String 

func (m *SetFinalResponse) String() string

func (*SetFinalResponse) Unmarshal 

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

func (*SetFinalResponse) XXX_DiscardUnknown 

func (m *SetFinalResponse) XXX_DiscardUnknown()

func (*SetFinalResponse) XXX_Marshal 

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

func (*SetFinalResponse) XXX_Merge 

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

func (*SetFinalResponse) XXX_Size 

func (m *SetFinalResponse) XXX_Size() int

func (*SetFinalResponse) XXX_Unmarshal 

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

type UnimplementedExecutionServiceServer 

type UnimplementedExecutionServiceServer struct {
}

UnimplementedExecutionServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedExecutionServiceServer) ExecuteTxs 

func (*UnimplementedExecutionServiceServer) ExecuteTxs(ctx context.Context, req *ExecuteTxsRequest) (*ExecuteTxsResponse, error)

func (*UnimplementedExecutionServiceServer) GetTxs 

func (*UnimplementedExecutionServiceServer) GetTxs(ctx context.Context, req *GetTxsRequest) (*GetTxsResponse, error)

func (*UnimplementedExecutionServiceServer) InitChain 

func (*UnimplementedExecutionServiceServer) InitChain(ctx context.Context, req *InitChainRequest) (*InitChainResponse, error)

func (*UnimplementedExecutionServiceServer) SetFinal 

func (*UnimplementedExecutionServiceServer) SetFinal(ctx context.Context, req *SetFinalRequest) (*SetFinalResponse, 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.