execution

package
v0.0.0-...-c80a3f0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ValidationStatus_name = map[int32]string{
		0: "Success",
		1: "InvalidChain",
		2: "TooFarAway",
		3: "MissingSegment",
	}
	ValidationStatus_value = map[string]int32{
		"Success":        0,
		"InvalidChain":   1,
		"TooFarAway":     2,
		"MissingSegment": 3,
	}
)

Enum value maps for ValidationStatus.

View Source 
var Execution_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "execution.Execution",
	HandlerType: (*ExecutionServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "InsertHeaders",
			Handler:    _Execution_InsertHeaders_Handler,
		},
		{
			MethodName: "InsertBodies",
			Handler:    _Execution_InsertBodies_Handler,
		},
		{
			MethodName: "ValidateChain",
			Handler:    _Execution_ValidateChain_Handler,
		},
		{
			MethodName: "UpdateForkChoice",
			Handler:    _Execution_UpdateForkChoice_Handler,
		},
		{
			MethodName: "AssembleBlock",
			Handler:    _Execution_AssembleBlock_Handler,
		},
		{
			MethodName: "GetHeader",
			Handler:    _Execution_GetHeader_Handler,
		},
		{
			MethodName: "GetBody",
			Handler:    _Execution_GetBody_Handler,
		},
		{
			MethodName: "IsCanonicalHash",
			Handler:    _Execution_IsCanonicalHash_Handler,
		},
		{
			MethodName: "GetHeaderHashNumber",
			Handler:    _Execution_GetHeaderHashNumber_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "execution/execution.proto",
}

Execution_ServiceDesc is the grpc.ServiceDesc for Execution service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_execution_execution_proto protoreflect.FileDescriptor

Functions

func RegisterExecutionServer 

func RegisterExecutionServer(s grpc.ServiceRegistrar, srv ExecutionServer)

Types

type BlockBody 

type BlockBody struct {
	BlockHash   *types.H256 `protobuf:"bytes,1,opt,name=blockHash,proto3" json:"blockHash,omitempty"`
	BlockNumber uint64      `protobuf:"varint,2,opt,name=blockNumber,proto3" json:"blockNumber,omitempty"`
	// Raw transactions in byte format.
	Transactions [][]byte `protobuf:"bytes,3,rep,name=transactions,proto3" json:"transactions,omitempty"`
	// contains filtered or unexported fields
}

Body is a block body for execution

func (*BlockBody) Descriptor deprecated 

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

Deprecated: Use BlockBody.ProtoReflect.Descriptor instead.

func (*BlockBody) GetBlockHash 

func (x *BlockBody) GetBlockHash() *types.H256

func (*BlockBody) GetBlockNumber 

func (x *BlockBody) GetBlockNumber() uint64

func (*BlockBody) GetTransactions 

func (x *BlockBody) GetTransactions() [][]byte

func (*BlockBody) ProtoMessage 

func (*BlockBody) ProtoMessage()

func (*BlockBody) ProtoReflect 

func (x *BlockBody) ProtoReflect() protoreflect.Message

func (*BlockBody) Reset 

func (x *BlockBody) Reset()

func (*BlockBody) String 

func (x *BlockBody) String() string

type EmptyMessage 

type EmptyMessage struct {
	// contains filtered or unexported fields
}

func (*EmptyMessage) Descriptor deprecated 

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

Deprecated: Use EmptyMessage.ProtoReflect.Descriptor instead.

func (*EmptyMessage) ProtoMessage 

func (*EmptyMessage) ProtoMessage()

func (*EmptyMessage) ProtoReflect 

func (x *EmptyMessage) ProtoReflect() protoreflect.Message

func (*EmptyMessage) Reset 

func (x *EmptyMessage) Reset()

func (*EmptyMessage) String 

func (x *EmptyMessage) String() string

type ExecutionClient 

type ExecutionClient interface {
	// Chain Putters.
	InsertHeaders(ctx context.Context, in *InsertHeadersRequest, opts ...grpc.CallOption) (*EmptyMessage, error)
	InsertBodies(ctx context.Context, in *InsertBodiesRequest, opts ...grpc.CallOption) (*EmptyMessage, error)
	// Chain Validation and ForkChoice.
	ValidateChain(ctx context.Context, in *types.H256, opts ...grpc.CallOption) (*ValidationReceipt, error)
	UpdateForkChoice(ctx context.Context, in *types.H256, opts ...grpc.CallOption) (*ForkChoiceReceipt, error)
	AssembleBlock(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (*types.ExecutionPayload, error)
	// Chain Getters.
	GetHeader(ctx context.Context, in *GetSegmentRequest, opts ...grpc.CallOption) (*GetHeaderResponse, error)
	GetBody(ctx context.Context, in *GetSegmentRequest, opts ...grpc.CallOption) (*GetBodyResponse, error)
	IsCanonicalHash(ctx context.Context, in *types.H256, opts ...grpc.CallOption) (*IsCanonicalResponse, error)
	GetHeaderHashNumber(ctx context.Context, in *types.H256, opts ...grpc.CallOption) (*GetHeaderHashNumberResponse, error)
}

ExecutionClient is the client API for Execution service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewExecutionClient 

func NewExecutionClient(cc grpc.ClientConnInterface) ExecutionClient

type ExecutionServer 

type ExecutionServer interface {
	// Chain Putters.
	InsertHeaders(context.Context, *InsertHeadersRequest) (*EmptyMessage, error)
	InsertBodies(context.Context, *InsertBodiesRequest) (*EmptyMessage, error)
	// Chain Validation and ForkChoice.
	ValidateChain(context.Context, *types.H256) (*ValidationReceipt, error)
	UpdateForkChoice(context.Context, *types.H256) (*ForkChoiceReceipt, error)
	AssembleBlock(context.Context, *EmptyMessage) (*types.ExecutionPayload, error)
	// Chain Getters.
	GetHeader(context.Context, *GetSegmentRequest) (*GetHeaderResponse, error)
	GetBody(context.Context, *GetSegmentRequest) (*GetBodyResponse, error)
	IsCanonicalHash(context.Context, *types.H256) (*IsCanonicalResponse, error)
	GetHeaderHashNumber(context.Context, *types.H256) (*GetHeaderHashNumberResponse, error)
	// contains filtered or unexported methods
}

ExecutionServer is the server API for Execution service. All implementations must embed UnimplementedExecutionServer for forward compatibility

type ForkChoiceReceipt 

type ForkChoiceReceipt struct {
	Success         bool        `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`                // Forkchoice is either successful or unsuccessful.
	LatestValidHash *types.H256 `protobuf:"bytes,2,opt,name=latestValidHash,proto3" json:"latestValidHash,omitempty"` // Return latest valid hash in case of halt of execution.
	// contains filtered or unexported fields
}

func (*ForkChoiceReceipt) Descriptor deprecated 

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

Deprecated: Use ForkChoiceReceipt.ProtoReflect.Descriptor instead.

func (*ForkChoiceReceipt) GetLatestValidHash 

func (x *ForkChoiceReceipt) GetLatestValidHash() *types.H256

func (*ForkChoiceReceipt) GetSuccess 

func (x *ForkChoiceReceipt) GetSuccess() bool

func (*ForkChoiceReceipt) ProtoMessage 

func (*ForkChoiceReceipt) ProtoMessage()

func (*ForkChoiceReceipt) ProtoReflect 

func (x *ForkChoiceReceipt) ProtoReflect() protoreflect.Message

func (*ForkChoiceReceipt) Reset 

func (x *ForkChoiceReceipt) Reset()

func (*ForkChoiceReceipt) String 

func (x *ForkChoiceReceipt) String() string

type GetBodyResponse 

type GetBodyResponse struct {
	Body *BlockBody `protobuf:"bytes,1,opt,name=body,proto3,oneof" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBodyResponse) Descriptor deprecated 

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

Deprecated: Use GetBodyResponse.ProtoReflect.Descriptor instead.

func (*GetBodyResponse) GetBody 

func (x *GetBodyResponse) GetBody() *BlockBody

func (*GetBodyResponse) ProtoMessage 

func (*GetBodyResponse) ProtoMessage()

func (*GetBodyResponse) ProtoReflect 

func (x *GetBodyResponse) ProtoReflect() protoreflect.Message

func (*GetBodyResponse) Reset 

func (x *GetBodyResponse) Reset()

func (*GetBodyResponse) String 

func (x *GetBodyResponse) String() string

type GetHeaderHashNumberResponse 

type GetHeaderHashNumberResponse struct {
	BlockNumber *uint64 `protobuf:"varint,1,opt,name=blockNumber,proto3,oneof" json:"blockNumber,omitempty"` // null if not found.
	// contains filtered or unexported fields
}

func (*GetHeaderHashNumberResponse) Descriptor deprecated 

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

Deprecated: Use GetHeaderHashNumberResponse.ProtoReflect.Descriptor instead.

func (*GetHeaderHashNumberResponse) GetBlockNumber 

func (x *GetHeaderHashNumberResponse) GetBlockNumber() uint64

func (*GetHeaderHashNumberResponse) ProtoMessage 

func (*GetHeaderHashNumberResponse) ProtoMessage()

func (*GetHeaderHashNumberResponse) ProtoReflect 

func (x *GetHeaderHashNumberResponse) ProtoReflect() protoreflect.Message

func (*GetHeaderHashNumberResponse) Reset 

func (x *GetHeaderHashNumberResponse) Reset()

func (*GetHeaderHashNumberResponse) String 

func (x *GetHeaderHashNumberResponse) String() string

type GetHeaderResponse 

type GetHeaderResponse struct {
	Header *Header `protobuf:"bytes,1,opt,name=header,proto3,oneof" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHeaderResponse) Descriptor deprecated 

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

Deprecated: Use GetHeaderResponse.ProtoReflect.Descriptor instead.

func (*GetHeaderResponse) GetHeader 

func (x *GetHeaderResponse) GetHeader() *Header

func (*GetHeaderResponse) ProtoMessage 

func (*GetHeaderResponse) ProtoMessage()

func (*GetHeaderResponse) ProtoReflect 

func (x *GetHeaderResponse) ProtoReflect() protoreflect.Message

func (*GetHeaderResponse) Reset 

func (x *GetHeaderResponse) Reset()

func (*GetHeaderResponse) String 

func (x *GetHeaderResponse) String() string

type GetSegmentRequest 

type GetSegmentRequest struct {

	// Get headers/body by number or hash, invalid if none set.
	BlockNumber *uint64     `protobuf:"varint,1,opt,name=blockNumber,proto3,oneof" json:"blockNumber,omitempty"`
	BlockHash   *types.H256 `protobuf:"bytes,2,opt,name=blockHash,proto3,oneof" json:"blockHash,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSegmentRequest) Descriptor deprecated 

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

Deprecated: Use GetSegmentRequest.ProtoReflect.Descriptor instead.

func (*GetSegmentRequest) GetBlockHash 

func (x *GetSegmentRequest) GetBlockHash() *types.H256

func (*GetSegmentRequest) GetBlockNumber 

func (x *GetSegmentRequest) GetBlockNumber() uint64

func (*GetSegmentRequest) ProtoMessage 

func (*GetSegmentRequest) ProtoMessage()

func (*GetSegmentRequest) ProtoReflect 

func (x *GetSegmentRequest) ProtoReflect() protoreflect.Message

func (*GetSegmentRequest) Reset 

func (x *GetSegmentRequest) Reset()

func (*GetSegmentRequest) String 

func (x *GetSegmentRequest) String() string
type Header struct {
	ParentHash    *types.H256  `protobuf:"bytes,1,opt,name=parentHash,proto3" json:"parentHash,omitempty"`
	Coinbase      *types.H160  `protobuf:"bytes,2,opt,name=coinbase,proto3" json:"coinbase,omitempty"`
	StateRoot     *types.H256  `protobuf:"bytes,3,opt,name=stateRoot,proto3" json:"stateRoot,omitempty"`
	ReceiptRoot   *types.H256  `protobuf:"bytes,4,opt,name=receiptRoot,proto3" json:"receiptRoot,omitempty"`
	LogsBloom     *types.H2048 `protobuf:"bytes,5,opt,name=logsBloom,proto3" json:"logsBloom,omitempty"`
	MixDigest     *types.H256  `protobuf:"bytes,6,opt,name=mixDigest,proto3" json:"mixDigest,omitempty"`
	BlockNumber   uint64       `protobuf:"varint,7,opt,name=blockNumber,proto3" json:"blockNumber,omitempty"`
	GasLimit      uint64       `protobuf:"varint,8,opt,name=gasLimit,proto3" json:"gasLimit,omitempty"`
	GasUsed       uint64       `protobuf:"varint,9,opt,name=gasUsed,proto3" json:"gasUsed,omitempty"`
	Timestamp     uint64       `protobuf:"varint,10,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ExtraData     []byte       `protobuf:"bytes,11,opt,name=extraData,proto3" json:"extraData,omitempty"`
	BaseFeePerGas *types.H256  `protobuf:"bytes,12,opt,name=baseFeePerGas,proto3" json:"baseFeePerGas,omitempty"`
	BlockHash     *types.H256  `protobuf:"bytes,13,opt,name=blockHash,proto3" json:"blockHash,omitempty"` // We keep this so that we can validate it
	OmmerHash     *types.H256  `protobuf:"bytes,14,opt,name=ommerHash,proto3" json:"ommerHash,omitempty"`
	// contains filtered or unexported fields
}

Header is an header for execution

func (*Header) Descriptor deprecated 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetBaseFeePerGas 

func (x *Header) GetBaseFeePerGas() *types.H256

func (*Header) GetBlockHash 

func (x *Header) GetBlockHash() *types.H256

func (*Header) GetBlockNumber 

func (x *Header) GetBlockNumber() uint64

func (*Header) GetCoinbase 

func (x *Header) GetCoinbase() *types.H160

func (*Header) GetExtraData 

func (x *Header) GetExtraData() []byte

func (*Header) GetGasLimit 

func (x *Header) GetGasLimit() uint64

func (*Header) GetGasUsed 

func (x *Header) GetGasUsed() uint64

func (*Header) GetLogsBloom 

func (x *Header) GetLogsBloom() *types.H2048

func (*Header) GetMixDigest 

func (x *Header) GetMixDigest() *types.H256

func (*Header) GetOmmerHash 

func (x *Header) GetOmmerHash() *types.H256

func (*Header) GetParentHash 

func (x *Header) GetParentHash() *types.H256

func (*Header) GetReceiptRoot 

func (x *Header) GetReceiptRoot() *types.H256

func (*Header) GetStateRoot 

func (x *Header) GetStateRoot() *types.H256

func (*Header) GetTimestamp 

func (x *Header) GetTimestamp() uint64

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

func (x *Header) ProtoReflect() protoreflect.Message

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type InsertBodiesRequest 

type InsertBodiesRequest struct {
	Bodies []*BlockBody `protobuf:"bytes,1,rep,name=bodies,proto3" json:"bodies,omitempty"`
	// contains filtered or unexported fields
}

func (*InsertBodiesRequest) Descriptor deprecated 

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

Deprecated: Use InsertBodiesRequest.ProtoReflect.Descriptor instead.

func (*InsertBodiesRequest) GetBodies 

func (x *InsertBodiesRequest) GetBodies() []*BlockBody

func (*InsertBodiesRequest) ProtoMessage 

func (*InsertBodiesRequest) ProtoMessage()

func (*InsertBodiesRequest) ProtoReflect 

func (x *InsertBodiesRequest) ProtoReflect() protoreflect.Message

func (*InsertBodiesRequest) Reset 

func (x *InsertBodiesRequest) Reset()

func (*InsertBodiesRequest) String 

func (x *InsertBodiesRequest) String() string

type InsertHeadersRequest 

type InsertHeadersRequest struct {
	Headers []*Header `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"`
	// contains filtered or unexported fields
}

func (*InsertHeadersRequest) Descriptor deprecated 

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

Deprecated: Use InsertHeadersRequest.ProtoReflect.Descriptor instead.

func (*InsertHeadersRequest) GetHeaders 

func (x *InsertHeadersRequest) GetHeaders() []*Header

func (*InsertHeadersRequest) ProtoMessage 

func (*InsertHeadersRequest) ProtoMessage()

func (*InsertHeadersRequest) ProtoReflect 

func (x *InsertHeadersRequest) ProtoReflect() protoreflect.Message

func (*InsertHeadersRequest) Reset 

func (x *InsertHeadersRequest) Reset()

func (*InsertHeadersRequest) String 

func (x *InsertHeadersRequest) String() string

type IsCanonicalResponse 

type IsCanonicalResponse struct {
	Canonical bool `protobuf:"varint,1,opt,name=canonical,proto3" json:"canonical,omitempty"` // Whether hash is canonical or not.
	// contains filtered or unexported fields
}

func (*IsCanonicalResponse) Descriptor deprecated 

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

Deprecated: Use IsCanonicalResponse.ProtoReflect.Descriptor instead.

func (*IsCanonicalResponse) GetCanonical 

func (x *IsCanonicalResponse) GetCanonical() bool

func (*IsCanonicalResponse) ProtoMessage 

func (*IsCanonicalResponse) ProtoMessage()

func (*IsCanonicalResponse) ProtoReflect 

func (x *IsCanonicalResponse) ProtoReflect() protoreflect.Message

func (*IsCanonicalResponse) Reset 

func (x *IsCanonicalResponse) Reset()

func (*IsCanonicalResponse) String 

func (x *IsCanonicalResponse) String() string

type UnimplementedExecutionServer 

type UnimplementedExecutionServer struct {
}

UnimplementedExecutionServer must be embedded to have forward compatible implementations.

func (UnimplementedExecutionServer) AssembleBlock 

func (UnimplementedExecutionServer) AssembleBlock(context.Context, *EmptyMessage) (*types.ExecutionPayload, error)

func (UnimplementedExecutionServer) GetBody 

func (UnimplementedExecutionServer) GetBody(context.Context, *GetSegmentRequest) (*GetBodyResponse, error)

func (UnimplementedExecutionServer) GetHeader 

func (UnimplementedExecutionServer) GetHeader(context.Context, *GetSegmentRequest) (*GetHeaderResponse, error)

func (UnimplementedExecutionServer) GetHeaderHashNumber 

func (UnimplementedExecutionServer) GetHeaderHashNumber(context.Context, *types.H256) (*GetHeaderHashNumberResponse, error)

func (UnimplementedExecutionServer) InsertBodies 

func (UnimplementedExecutionServer) InsertBodies(context.Context, *InsertBodiesRequest) (*EmptyMessage, error)

func (UnimplementedExecutionServer) InsertHeaders 

func (UnimplementedExecutionServer) InsertHeaders(context.Context, *InsertHeadersRequest) (*EmptyMessage, error)

func (UnimplementedExecutionServer) IsCanonicalHash 

func (UnimplementedExecutionServer) IsCanonicalHash(context.Context, *types.H256) (*IsCanonicalResponse, error)

func (UnimplementedExecutionServer) UpdateForkChoice 

func (UnimplementedExecutionServer) UpdateForkChoice(context.Context, *types.H256) (*ForkChoiceReceipt, error)

func (UnimplementedExecutionServer) ValidateChain 

func (UnimplementedExecutionServer) ValidateChain(context.Context, *types.H256) (*ValidationReceipt, error)

type UnsafeExecutionServer 

type UnsafeExecutionServer interface {
	// contains filtered or unexported methods
}

UnsafeExecutionServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExecutionServer will result in compilation errors.

type ValidationReceipt 

type ValidationReceipt struct {
	ValidationStatus ValidationStatus `protobuf:"varint,1,opt,name=validationStatus,proto3,enum=execution.ValidationStatus" json:"validationStatus,omitempty"`
	LatestValidHash  *types.H256      `protobuf:"bytes,2,opt,name=latestValidHash,proto3" json:"latestValidHash,omitempty"`
	MissingHash      *types.H256      `protobuf:"bytes,3,opt,name=missingHash,proto3,oneof" json:"missingHash,omitempty"` // The missing hash, in case we receive MissingSegment so that we can reverse download it.
	// contains filtered or unexported fields
}

Result we receive after validation

func (*ValidationReceipt) Descriptor deprecated 

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

Deprecated: Use ValidationReceipt.ProtoReflect.Descriptor instead.

func (*ValidationReceipt) GetLatestValidHash 

func (x *ValidationReceipt) GetLatestValidHash() *types.H256

func (*ValidationReceipt) GetMissingHash 

func (x *ValidationReceipt) GetMissingHash() *types.H256

func (*ValidationReceipt) GetValidationStatus 

func (x *ValidationReceipt) GetValidationStatus() ValidationStatus

func (*ValidationReceipt) ProtoMessage 

func (*ValidationReceipt) ProtoMessage()

func (*ValidationReceipt) ProtoReflect 

func (x *ValidationReceipt) ProtoReflect() protoreflect.Message

func (*ValidationReceipt) Reset 

func (x *ValidationReceipt) Reset()

func (*ValidationReceipt) String 

func (x *ValidationReceipt) String() string

type ValidationStatus 

type ValidationStatus int32
const (
	ValidationStatus_Success        ValidationStatus = 0 // State transition simulation is successful.
	ValidationStatus_InvalidChain   ValidationStatus = 1 // State transition simulation is Unsuccessful.
	ValidationStatus_TooFarAway     ValidationStatus = 2 // Chain hash is too far away from current chain head and unfeasible to validate.
	ValidationStatus_MissingSegment ValidationStatus = 3 // Chain segments are missing.
)

func (ValidationStatus) Descriptor 

func (ValidationStatus) Descriptor() protoreflect.EnumDescriptor

func (ValidationStatus) Enum 

func (x ValidationStatus) Enum() *ValidationStatus

func (ValidationStatus) EnumDescriptor deprecated 

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

Deprecated: Use ValidationStatus.Descriptor instead.

func (ValidationStatus) Number 

func (x ValidationStatus) Number() protoreflect.EnumNumber

func (ValidationStatus) String 

func (x ValidationStatus) String() string

func (ValidationStatus) Type 

func (ValidationStatus) Type() protoreflect.EnumType

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.