remote

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: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Event_name = map[int32]string{
		0: "HEADER",
		1: "PENDING_LOGS",
		2: "PENDING_BLOCK",
		3: "NEW_SNAPSHOT",
	}
	Event_value = map[string]int32{
		"HEADER":        0,
		"PENDING_LOGS":  1,
		"PENDING_BLOCK": 2,
		"NEW_SNAPSHOT":  3,
	}
)

Enum value maps for Event.

View Source 
var (
	EngineStatus_name = map[int32]string{
		0: "VALID",
		1: "INVALID",
		2: "SYNCING",
		3: "ACCEPTED",
		4: "INVALID_BLOCK_HASH",
	}
	EngineStatus_value = map[string]int32{
		"VALID":              0,
		"INVALID":            1,
		"SYNCING":            2,
		"ACCEPTED":           3,
		"INVALID_BLOCK_HASH": 4,
	}
)

Enum value maps for EngineStatus.

View Source 
var (
	Op_name = map[int32]string{
		0:  "FIRST",
		1:  "FIRST_DUP",
		2:  "SEEK",
		3:  "SEEK_BOTH",
		4:  "CURRENT",
		6:  "LAST",
		7:  "LAST_DUP",
		8:  "NEXT",
		9:  "NEXT_DUP",
		11: "NEXT_NO_DUP",
		12: "PREV",
		13: "PREV_DUP",
		14: "PREV_NO_DUP",
		15: "SEEK_EXACT",
		16: "SEEK_BOTH_EXACT",
		30: "OPEN",
		31: "CLOSE",
		32: "OPEN_DUP_SORT",
	}
	Op_value = map[string]int32{
		"FIRST":           0,
		"FIRST_DUP":       1,
		"SEEK":            2,
		"SEEK_BOTH":       3,
		"CURRENT":         4,
		"LAST":            6,
		"LAST_DUP":        7,
		"NEXT":            8,
		"NEXT_DUP":        9,
		"NEXT_NO_DUP":     11,
		"PREV":            12,
		"PREV_DUP":        13,
		"PREV_NO_DUP":     14,
		"SEEK_EXACT":      15,
		"SEEK_BOTH_EXACT": 16,
		"OPEN":            30,
		"CLOSE":           31,
		"OPEN_DUP_SORT":   32,
	}
)

Enum value maps for Op.

View Source 
var (
	Action_name = map[int32]string{
		0: "STORAGE",
		1: "UPSERT",
		2: "CODE",
		3: "UPSERT_CODE",
		4: "REMOVE",
	}
	Action_value = map[string]int32{
		"STORAGE":     0,
		"UPSERT":      1,
		"CODE":        2,
		"UPSERT_CODE": 3,
		"REMOVE":      4,
	}
)

Enum value maps for Action.

View Source 
var (
	Direction_name = map[int32]string{
		0: "FORWARD",
		1: "UNWIND",
	}
	Direction_value = map[string]int32{
		"FORWARD": 0,
		"UNWIND":  1,
	}
)

Enum value maps for Direction.

View Source 
var ETHBACKEND_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "remote.ETHBACKEND",
	HandlerType: (*ETHBACKENDServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Etherbase",
			Handler:    _ETHBACKEND_Etherbase_Handler,
		},
		{
			MethodName: "NetVersion",
			Handler:    _ETHBACKEND_NetVersion_Handler,
		},
		{
			MethodName: "NetPeerCount",
			Handler:    _ETHBACKEND_NetPeerCount_Handler,
		},
		{
			MethodName: "EngineNewPayloadV1",
			Handler:    _ETHBACKEND_EngineNewPayloadV1_Handler,
		},
		{
			MethodName: "EngineNewPayloadV2",
			Handler:    _ETHBACKEND_EngineNewPayloadV2_Handler,
		},
		{
			MethodName: "EngineForkChoiceUpdatedV1",
			Handler:    _ETHBACKEND_EngineForkChoiceUpdatedV1_Handler,
		},
		{
			MethodName: "EngineForkChoiceUpdatedV2",
			Handler:    _ETHBACKEND_EngineForkChoiceUpdatedV2_Handler,
		},
		{
			MethodName: "EngineGetPayloadV1",
			Handler:    _ETHBACKEND_EngineGetPayloadV1_Handler,
		},
		{
			MethodName: "EngineGetPayloadV2",
			Handler:    _ETHBACKEND_EngineGetPayloadV2_Handler,
		},
		{
			MethodName: "Version",
			Handler:    _ETHBACKEND_Version_Handler,
		},
		{
			MethodName: "ProtocolVersion",
			Handler:    _ETHBACKEND_ProtocolVersion_Handler,
		},
		{
			MethodName: "ClientVersion",
			Handler:    _ETHBACKEND_ClientVersion_Handler,
		},
		{
			MethodName: "Block",
			Handler:    _ETHBACKEND_Block_Handler,
		},
		{
			MethodName: "TxnLookup",
			Handler:    _ETHBACKEND_TxnLookup_Handler,
		},
		{
			MethodName: "NodeInfo",
			Handler:    _ETHBACKEND_NodeInfo_Handler,
		},
		{
			MethodName: "Peers",
			Handler:    _ETHBACKEND_Peers_Handler,
		},
		{
			MethodName: "PendingBlock",
			Handler:    _ETHBACKEND_PendingBlock_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _ETHBACKEND_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeLogs",
			Handler:       _ETHBACKEND_SubscribeLogs_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "remote/ethbackend.proto",
}

ETHBACKEND_ServiceDesc is the grpc.ServiceDesc for ETHBACKEND 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_remote_ethbackend_proto protoreflect.FileDescriptor
View Source 
var File_remote_kv_proto protoreflect.FileDescriptor
View Source 
var KV_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "remote.KV",
	HandlerType: (*KVServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Version",
			Handler:    _KV_Version_Handler,
		},
		{
			MethodName: "Snapshots",
			Handler:    _KV_Snapshots_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Tx",
			Handler:       _KV_Tx_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "StateChanges",
			Handler:       _KV_StateChanges_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "remote/kv.proto",
}

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

Functions

func NodeInfoReplyLess 

func NodeInfoReplyLess(i, j *types.NodeInfoReply) bool

func RegisterETHBACKENDServer 

func RegisterETHBACKENDServer(s grpc.ServiceRegistrar, srv ETHBACKENDServer)

func RegisterKVServer 

func RegisterKVServer(s grpc.ServiceRegistrar, srv KVServer)

Types

type AccountChange 

type AccountChange struct {
	Address        *types.H160      `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Incarnation    uint64           `protobuf:"varint,2,opt,name=incarnation,proto3" json:"incarnation,omitempty"`
	Action         Action           `protobuf:"varint,3,opt,name=action,proto3,enum=remote.Action" json:"action,omitempty"`
	Data           []byte           `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` // nil if there is no UPSERT in action
	Code           []byte           `protobuf:"bytes,5,opt,name=code,proto3" json:"code,omitempty"` // nil if there is no CODE in action
	StorageChanges []*StorageChange `protobuf:"bytes,6,rep,name=storageChanges,proto3" json:"storageChanges,omitempty"`
	// contains filtered or unexported fields
}

func (*AccountChange) Descriptor deprecated 

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

Deprecated: Use AccountChange.ProtoReflect.Descriptor instead.

func (*AccountChange) GetAction 

func (x *AccountChange) GetAction() Action

func (*AccountChange) GetAddress 

func (x *AccountChange) GetAddress() *types.H160

func (*AccountChange) GetCode 

func (x *AccountChange) GetCode() []byte

func (*AccountChange) GetData 

func (x *AccountChange) GetData() []byte

func (*AccountChange) GetIncarnation 

func (x *AccountChange) GetIncarnation() uint64

func (*AccountChange) GetStorageChanges 

func (x *AccountChange) GetStorageChanges() []*StorageChange

func (*AccountChange) ProtoMessage 

func (*AccountChange) ProtoMessage()

func (*AccountChange) ProtoReflect 

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

func (*AccountChange) Reset 

func (x *AccountChange) Reset()

func (*AccountChange) String 

func (x *AccountChange) String() string

type Action 

type Action int32
const (
	Action_STORAGE     Action = 0 // Change only in the storage
	Action_UPSERT      Action = 1 // Change of balance or nonce (and optionally storage)
	Action_CODE        Action = 2 // Change of code (and optionally storage)
	Action_UPSERT_CODE Action = 3 // Change in (balance or nonce) and code (and optinally storage)
	Action_REMOVE      Action = 4 // Account is deleted
)

func (Action) Descriptor 

func (Action) Descriptor() protoreflect.EnumDescriptor

func (Action) Enum 

func (x Action) Enum() *Action

func (Action) EnumDescriptor deprecated 

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

Deprecated: Use Action.Descriptor instead.

func (Action) Number 

func (x Action) Number() protoreflect.EnumNumber

func (Action) String 

func (x Action) String() string

func (Action) Type 

func (Action) Type() protoreflect.EnumType

type BlockReply 

type BlockReply struct {
	BlockRlp []byte `protobuf:"bytes,1,opt,name=blockRlp,proto3" json:"blockRlp,omitempty"`
	Senders  []byte `protobuf:"bytes,2,opt,name=senders,proto3" json:"senders,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockReply) Descriptor deprecated 

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

Deprecated: Use BlockReply.ProtoReflect.Descriptor instead.

func (*BlockReply) GetBlockRlp 

func (x *BlockReply) GetBlockRlp() []byte

func (*BlockReply) GetSenders 

func (x *BlockReply) GetSenders() []byte

func (*BlockReply) ProtoMessage 

func (*BlockReply) ProtoMessage()

func (*BlockReply) ProtoReflect 

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

func (*BlockReply) Reset 

func (x *BlockReply) Reset()

func (*BlockReply) String 

func (x *BlockReply) String() string

type BlockRequest 

type BlockRequest struct {
	BlockHeight uint64      `protobuf:"varint,2,opt,name=blockHeight,proto3" json:"blockHeight,omitempty"`
	BlockHash   *types.H256 `protobuf:"bytes,3,opt,name=blockHash,proto3" json:"blockHash,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockRequest) Descriptor deprecated 

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

Deprecated: Use BlockRequest.ProtoReflect.Descriptor instead.

func (*BlockRequest) GetBlockHash 

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

func (*BlockRequest) GetBlockHeight 

func (x *BlockRequest) GetBlockHeight() uint64

func (*BlockRequest) ProtoMessage 

func (*BlockRequest) ProtoMessage()

func (*BlockRequest) ProtoReflect 

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

func (*BlockRequest) Reset 

func (x *BlockRequest) Reset()

func (*BlockRequest) String 

func (x *BlockRequest) String() string

type ClientVersionReply 

type ClientVersionReply struct {
	NodeName string `protobuf:"bytes,1,opt,name=nodeName,proto3" json:"nodeName,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientVersionReply) Descriptor deprecated 

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

Deprecated: Use ClientVersionReply.ProtoReflect.Descriptor instead.

func (*ClientVersionReply) GetNodeName 

func (x *ClientVersionReply) GetNodeName() string

func (*ClientVersionReply) ProtoMessage 

func (*ClientVersionReply) ProtoMessage()

func (*ClientVersionReply) ProtoReflect 

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

func (*ClientVersionReply) Reset 

func (x *ClientVersionReply) Reset()

func (*ClientVersionReply) String 

func (x *ClientVersionReply) String() string

type ClientVersionRequest 

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

func (*ClientVersionRequest) Descriptor deprecated 

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

Deprecated: Use ClientVersionRequest.ProtoReflect.Descriptor instead.

func (*ClientVersionRequest) ProtoMessage 

func (*ClientVersionRequest) ProtoMessage()

func (*ClientVersionRequest) ProtoReflect 

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

func (*ClientVersionRequest) Reset 

func (x *ClientVersionRequest) Reset()

func (*ClientVersionRequest) String 

func (x *ClientVersionRequest) String() string

type Cursor 

type Cursor struct {
	Op         Op     `protobuf:"varint,1,opt,name=op,proto3,enum=remote.Op" json:"op,omitempty"`
	BucketName string `protobuf:"bytes,2,opt,name=bucketName,proto3" json:"bucketName,omitempty"`
	Cursor     uint32 `protobuf:"varint,3,opt,name=cursor,proto3" json:"cursor,omitempty"`
	K          []byte `protobuf:"bytes,4,opt,name=k,proto3" json:"k,omitempty"`
	V          []byte `protobuf:"bytes,5,opt,name=v,proto3" json:"v,omitempty"`
	// contains filtered or unexported fields
}

func (*Cursor) Descriptor deprecated 

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

Deprecated: Use Cursor.ProtoReflect.Descriptor instead.

func (*Cursor) GetBucketName 

func (x *Cursor) GetBucketName() string

func (*Cursor) GetCursor 

func (x *Cursor) GetCursor() uint32

func (*Cursor) GetK 

func (x *Cursor) GetK() []byte

func (*Cursor) GetOp 

func (x *Cursor) GetOp() Op

func (*Cursor) GetV 

func (x *Cursor) GetV() []byte

func (*Cursor) ProtoMessage 

func (*Cursor) ProtoMessage()

func (*Cursor) ProtoReflect 

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

func (*Cursor) Reset 

func (x *Cursor) Reset()

func (*Cursor) String 

func (x *Cursor) String() string

type Direction 

type Direction int32
const (
	Direction_FORWARD Direction = 0
	Direction_UNWIND  Direction = 1
)

func (Direction) Descriptor 

func (Direction) Descriptor() protoreflect.EnumDescriptor

func (Direction) Enum 

func (x Direction) Enum() *Direction

func (Direction) EnumDescriptor deprecated 

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

Deprecated: Use Direction.Descriptor instead.

func (Direction) Number 

func (x Direction) Number() protoreflect.EnumNumber

func (Direction) String 

func (x Direction) String() string

func (Direction) Type 

func (Direction) Type() protoreflect.EnumType

type ETHBACKENDClient 

type ETHBACKENDClient interface {
	Etherbase(ctx context.Context, in *EtherbaseRequest, opts ...grpc.CallOption) (*EtherbaseReply, error)
	NetVersion(ctx context.Context, in *NetVersionRequest, opts ...grpc.CallOption) (*NetVersionReply, error)
	NetPeerCount(ctx context.Context, in *NetPeerCountRequest, opts ...grpc.CallOption) (*NetPeerCountReply, error)
	// Validate and possibly execute the payload.
	EngineNewPayloadV1(ctx context.Context, in *types.ExecutionPayload, opts ...grpc.CallOption) (*EnginePayloadStatus, error)
	// Validate and possibly execute the payload.
	EngineNewPayloadV2(ctx context.Context, in *types.ExecutionPayloadV2, opts ...grpc.CallOption) (*EnginePayloadStatus, error)
	// Update fork choice
	EngineForkChoiceUpdatedV1(ctx context.Context, in *EngineForkChoiceUpdatedRequest, opts ...grpc.CallOption) (*EngineForkChoiceUpdatedReply, error)
	// Update fork choice
	EngineForkChoiceUpdatedV2(ctx context.Context, in *EngineForkChoiceUpdatedRequestV2, opts ...grpc.CallOption) (*EngineForkChoiceUpdatedReply, error)
	// Fetch Execution Payload using its ID.
	EngineGetPayloadV1(ctx context.Context, in *EngineGetPayloadRequest, opts ...grpc.CallOption) (*types.ExecutionPayload, error)
	// Fetch Execution Payload using its ID.
	EngineGetPayloadV2(ctx context.Context, in *EngineGetPayloadRequest, opts ...grpc.CallOption) (*types.ExecutionPayloadV2, error)
	// Version returns the service version number
	Version(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.VersionReply, error)
	// ProtocolVersion returns the Ethereum protocol version number (e.g. 66 for ETH66).
	ProtocolVersion(ctx context.Context, in *ProtocolVersionRequest, opts ...grpc.CallOption) (*ProtocolVersionReply, error)
	// ClientVersion returns the Ethereum client version string using node name convention (e.g. TurboGeth/v2021.03.2-alpha/Linux).
	ClientVersion(ctx context.Context, in *ClientVersionRequest, opts ...grpc.CallOption) (*ClientVersionReply, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (ETHBACKEND_SubscribeClient, error)
	// Only one subscription is needed to serve all the users, LogsFilterRequest allows to dynamically modifying the subscription
	SubscribeLogs(ctx context.Context, opts ...grpc.CallOption) (ETHBACKEND_SubscribeLogsClient, error)
	// High-level method - can read block from db, snapshots or apply any other logic
	// it doesn't provide consistency
	// Request fields are optional - it's ok to request block only by hash or only by number
	Block(ctx context.Context, in *BlockRequest, opts ...grpc.CallOption) (*BlockReply, error)
	// High-level method - can find block number by txn hash
	// it doesn't provide consistency
	TxnLookup(ctx context.Context, in *TxnLookupRequest, opts ...grpc.CallOption) (*TxnLookupReply, error)
	// NodeInfo collects and returns NodeInfo from all running sentry instances.
	NodeInfo(ctx context.Context, in *NodesInfoRequest, opts ...grpc.CallOption) (*NodesInfoReply, error)
	// Peers collects and returns peers information from all running sentry instances.
	Peers(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PeersReply, error)
	PendingBlock(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PendingBlockReply, error)
}

ETHBACKENDClient is the client API for ETHBACKEND 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 NewETHBACKENDClient 

func NewETHBACKENDClient(cc grpc.ClientConnInterface) ETHBACKENDClient

type ETHBACKENDServer 

type ETHBACKENDServer interface {
	Etherbase(context.Context, *EtherbaseRequest) (*EtherbaseReply, error)
	NetVersion(context.Context, *NetVersionRequest) (*NetVersionReply, error)
	NetPeerCount(context.Context, *NetPeerCountRequest) (*NetPeerCountReply, error)
	// Validate and possibly execute the payload.
	EngineNewPayloadV1(context.Context, *types.ExecutionPayload) (*EnginePayloadStatus, error)
	// Validate and possibly execute the payload.
	EngineNewPayloadV2(context.Context, *types.ExecutionPayloadV2) (*EnginePayloadStatus, error)
	// Update fork choice
	EngineForkChoiceUpdatedV1(context.Context, *EngineForkChoiceUpdatedRequest) (*EngineForkChoiceUpdatedReply, error)
	// Update fork choice
	EngineForkChoiceUpdatedV2(context.Context, *EngineForkChoiceUpdatedRequestV2) (*EngineForkChoiceUpdatedReply, error)
	// Fetch Execution Payload using its ID.
	EngineGetPayloadV1(context.Context, *EngineGetPayloadRequest) (*types.ExecutionPayload, error)
	// Fetch Execution Payload using its ID.
	EngineGetPayloadV2(context.Context, *EngineGetPayloadRequest) (*types.ExecutionPayloadV2, error)
	// Version returns the service version number
	Version(context.Context, *emptypb.Empty) (*types.VersionReply, error)
	// ProtocolVersion returns the Ethereum protocol version number (e.g. 66 for ETH66).
	ProtocolVersion(context.Context, *ProtocolVersionRequest) (*ProtocolVersionReply, error)
	// ClientVersion returns the Ethereum client version string using node name convention (e.g. TurboGeth/v2021.03.2-alpha/Linux).
	ClientVersion(context.Context, *ClientVersionRequest) (*ClientVersionReply, error)
	Subscribe(*SubscribeRequest, ETHBACKEND_SubscribeServer) error
	// Only one subscription is needed to serve all the users, LogsFilterRequest allows to dynamically modifying the subscription
	SubscribeLogs(ETHBACKEND_SubscribeLogsServer) error
	// High-level method - can read block from db, snapshots or apply any other logic
	// it doesn't provide consistency
	// Request fields are optional - it's ok to request block only by hash or only by number
	Block(context.Context, *BlockRequest) (*BlockReply, error)
	// High-level method - can find block number by txn hash
	// it doesn't provide consistency
	TxnLookup(context.Context, *TxnLookupRequest) (*TxnLookupReply, error)
	// NodeInfo collects and returns NodeInfo from all running sentry instances.
	NodeInfo(context.Context, *NodesInfoRequest) (*NodesInfoReply, error)
	// Peers collects and returns peers information from all running sentry instances.
	Peers(context.Context, *emptypb.Empty) (*PeersReply, error)
	PendingBlock(context.Context, *emptypb.Empty) (*PendingBlockReply, error)
	// contains filtered or unexported methods
}

ETHBACKENDServer is the server API for ETHBACKEND service. All implementations must embed UnimplementedETHBACKENDServer for forward compatibility

type ETHBACKEND_SubscribeClient 

type ETHBACKEND_SubscribeClient interface {
	Recv() (*SubscribeReply, error)
	grpc.ClientStream
}

type ETHBACKEND_SubscribeLogsClient 

type ETHBACKEND_SubscribeLogsClient interface {
	Send(*LogsFilterRequest) error
	Recv() (*SubscribeLogsReply, error)
	grpc.ClientStream
}

type ETHBACKEND_SubscribeLogsServer 

type ETHBACKEND_SubscribeLogsServer interface {
	Send(*SubscribeLogsReply) error
	Recv() (*LogsFilterRequest, error)
	grpc.ServerStream
}

type ETHBACKEND_SubscribeServer 

type ETHBACKEND_SubscribeServer interface {
	Send(*SubscribeReply) error
	grpc.ServerStream
}

type EngineForkChoiceState 

type EngineForkChoiceState struct {
	HeadBlockHash      *types.H256 `protobuf:"bytes,1,opt,name=headBlockHash,proto3" json:"headBlockHash,omitempty"`
	SafeBlockHash      *types.H256 `protobuf:"bytes,2,opt,name=safeBlockHash,proto3" json:"safeBlockHash,omitempty"`
	FinalizedBlockHash *types.H256 `protobuf:"bytes,3,opt,name=finalizedBlockHash,proto3" json:"finalizedBlockHash,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineForkChoiceState) Descriptor deprecated 

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

Deprecated: Use EngineForkChoiceState.ProtoReflect.Descriptor instead.

func (*EngineForkChoiceState) GetFinalizedBlockHash 

func (x *EngineForkChoiceState) GetFinalizedBlockHash() *types.H256

func (*EngineForkChoiceState) GetHeadBlockHash 

func (x *EngineForkChoiceState) GetHeadBlockHash() *types.H256

func (*EngineForkChoiceState) GetSafeBlockHash 

func (x *EngineForkChoiceState) GetSafeBlockHash() *types.H256

func (*EngineForkChoiceState) ProtoMessage 

func (*EngineForkChoiceState) ProtoMessage()

func (*EngineForkChoiceState) ProtoReflect 

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

func (*EngineForkChoiceState) Reset 

func (x *EngineForkChoiceState) Reset()

func (*EngineForkChoiceState) String 

func (x *EngineForkChoiceState) String() string

type EngineForkChoiceUpdatedReply 

type EngineForkChoiceUpdatedReply struct {
	PayloadStatus *EnginePayloadStatus `protobuf:"bytes,1,opt,name=payloadStatus,proto3" json:"payloadStatus,omitempty"`
	PayloadId     uint64               `protobuf:"varint,2,opt,name=payloadId,proto3" json:"payloadId,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineForkChoiceUpdatedReply) Descriptor deprecated 

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

Deprecated: Use EngineForkChoiceUpdatedReply.ProtoReflect.Descriptor instead.

func (*EngineForkChoiceUpdatedReply) GetPayloadId 

func (x *EngineForkChoiceUpdatedReply) GetPayloadId() uint64

func (*EngineForkChoiceUpdatedReply) GetPayloadStatus 

func (x *EngineForkChoiceUpdatedReply) GetPayloadStatus() *EnginePayloadStatus

func (*EngineForkChoiceUpdatedReply) ProtoMessage 

func (*EngineForkChoiceUpdatedReply) ProtoMessage()

func (*EngineForkChoiceUpdatedReply) ProtoReflect 

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

func (*EngineForkChoiceUpdatedReply) Reset 

func (x *EngineForkChoiceUpdatedReply) Reset()

func (*EngineForkChoiceUpdatedReply) String 

func (x *EngineForkChoiceUpdatedReply) String() string

type EngineForkChoiceUpdatedRequest 

type EngineForkChoiceUpdatedRequest struct {
	ForkchoiceState   *EngineForkChoiceState   `protobuf:"bytes,1,opt,name=forkchoiceState,proto3" json:"forkchoiceState,omitempty"`
	PayloadAttributes *EnginePayloadAttributes `protobuf:"bytes,2,opt,name=payloadAttributes,proto3" json:"payloadAttributes,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineForkChoiceUpdatedRequest) Descriptor deprecated 

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

Deprecated: Use EngineForkChoiceUpdatedRequest.ProtoReflect.Descriptor instead.

func (*EngineForkChoiceUpdatedRequest) GetForkchoiceState 

func (x *EngineForkChoiceUpdatedRequest) GetForkchoiceState() *EngineForkChoiceState

func (*EngineForkChoiceUpdatedRequest) GetPayloadAttributes 

func (x *EngineForkChoiceUpdatedRequest) GetPayloadAttributes() *EnginePayloadAttributes

func (*EngineForkChoiceUpdatedRequest) ProtoMessage 

func (*EngineForkChoiceUpdatedRequest) ProtoMessage()

func (*EngineForkChoiceUpdatedRequest) ProtoReflect 

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

func (*EngineForkChoiceUpdatedRequest) Reset 

func (x *EngineForkChoiceUpdatedRequest) Reset()

func (*EngineForkChoiceUpdatedRequest) String 

func (x *EngineForkChoiceUpdatedRequest) String() string

type EngineForkChoiceUpdatedRequestV2 

type EngineForkChoiceUpdatedRequestV2 struct {
	ForkchoiceState   *EngineForkChoiceState     `protobuf:"bytes,1,opt,name=forkchoiceState,proto3" json:"forkchoiceState,omitempty"`
	PayloadAttributes *EnginePayloadAttributesV2 `protobuf:"bytes,2,opt,name=payloadAttributes,proto3" json:"payloadAttributes,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineForkChoiceUpdatedRequestV2) Descriptor deprecated 

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

Deprecated: Use EngineForkChoiceUpdatedRequestV2.ProtoReflect.Descriptor instead.

func (*EngineForkChoiceUpdatedRequestV2) GetForkchoiceState 

func (x *EngineForkChoiceUpdatedRequestV2) GetForkchoiceState() *EngineForkChoiceState

func (*EngineForkChoiceUpdatedRequestV2) GetPayloadAttributes 

func (x *EngineForkChoiceUpdatedRequestV2) GetPayloadAttributes() *EnginePayloadAttributesV2

func (*EngineForkChoiceUpdatedRequestV2) ProtoMessage 

func (*EngineForkChoiceUpdatedRequestV2) ProtoMessage()

func (*EngineForkChoiceUpdatedRequestV2) ProtoReflect 

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

func (*EngineForkChoiceUpdatedRequestV2) Reset 

func (x *EngineForkChoiceUpdatedRequestV2) Reset()

func (*EngineForkChoiceUpdatedRequestV2) String 

func (x *EngineForkChoiceUpdatedRequestV2) String() string

type EngineGetPayloadRequest 

type EngineGetPayloadRequest struct {
	PayloadId uint64 `protobuf:"varint,1,opt,name=payloadId,proto3" json:"payloadId,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineGetPayloadRequest) Descriptor deprecated 

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

Deprecated: Use EngineGetPayloadRequest.ProtoReflect.Descriptor instead.

func (*EngineGetPayloadRequest) GetPayloadId 

func (x *EngineGetPayloadRequest) GetPayloadId() uint64

func (*EngineGetPayloadRequest) ProtoMessage 

func (*EngineGetPayloadRequest) ProtoMessage()

func (*EngineGetPayloadRequest) ProtoReflect 

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

func (*EngineGetPayloadRequest) Reset 

func (x *EngineGetPayloadRequest) Reset()

func (*EngineGetPayloadRequest) String 

func (x *EngineGetPayloadRequest) String() string

type EnginePayloadAttributes 

type EnginePayloadAttributes struct {
	Timestamp             uint64      `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	PrevRandao            *types.H256 `protobuf:"bytes,2,opt,name=prevRandao,proto3" json:"prevRandao,omitempty"`
	SuggestedFeeRecipient *types.H160 `protobuf:"bytes,3,opt,name=suggestedFeeRecipient,proto3" json:"suggestedFeeRecipient,omitempty"`
	// contains filtered or unexported fields
}

func (*EnginePayloadAttributes) Descriptor deprecated 

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

Deprecated: Use EnginePayloadAttributes.ProtoReflect.Descriptor instead.

func (*EnginePayloadAttributes) GetPrevRandao 

func (x *EnginePayloadAttributes) GetPrevRandao() *types.H256

func (*EnginePayloadAttributes) GetSuggestedFeeRecipient 

func (x *EnginePayloadAttributes) GetSuggestedFeeRecipient() *types.H160

func (*EnginePayloadAttributes) GetTimestamp 

func (x *EnginePayloadAttributes) GetTimestamp() uint64

func (*EnginePayloadAttributes) ProtoMessage 

func (*EnginePayloadAttributes) ProtoMessage()

func (*EnginePayloadAttributes) ProtoReflect 

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

func (*EnginePayloadAttributes) Reset 

func (x *EnginePayloadAttributes) Reset()

func (*EnginePayloadAttributes) String 

func (x *EnginePayloadAttributes) String() string

type EnginePayloadAttributesV2 

type EnginePayloadAttributesV2 struct {
	Attributes  *EnginePayloadAttributes `protobuf:"bytes,1,opt,name=attributes,proto3" json:"attributes,omitempty"`
	Withdrawals []*types.Withdrawal      `protobuf:"bytes,2,rep,name=withdrawals,proto3" json:"withdrawals,omitempty"`
	// contains filtered or unexported fields
}

func (*EnginePayloadAttributesV2) Descriptor deprecated 

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

Deprecated: Use EnginePayloadAttributesV2.ProtoReflect.Descriptor instead.

func (*EnginePayloadAttributesV2) GetAttributes 

func (x *EnginePayloadAttributesV2) GetAttributes() *EnginePayloadAttributes

func (*EnginePayloadAttributesV2) GetWithdrawals 

func (x *EnginePayloadAttributesV2) GetWithdrawals() []*types.Withdrawal

func (*EnginePayloadAttributesV2) ProtoMessage 

func (*EnginePayloadAttributesV2) ProtoMessage()

func (*EnginePayloadAttributesV2) ProtoReflect 

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

func (*EnginePayloadAttributesV2) Reset 

func (x *EnginePayloadAttributesV2) Reset()

func (*EnginePayloadAttributesV2) String 

func (x *EnginePayloadAttributesV2) String() string

type EnginePayloadStatus 

type EnginePayloadStatus struct {
	Status          EngineStatus `protobuf:"varint,1,opt,name=status,proto3,enum=remote.EngineStatus" json:"status,omitempty"`
	LatestValidHash *types.H256  `protobuf:"bytes,2,opt,name=latestValidHash,proto3" json:"latestValidHash,omitempty"`
	ValidationError string       `protobuf:"bytes,3,opt,name=validationError,proto3" json:"validationError,omitempty"`
	// contains filtered or unexported fields
}

func (*EnginePayloadStatus) Descriptor deprecated 

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

Deprecated: Use EnginePayloadStatus.ProtoReflect.Descriptor instead.

func (*EnginePayloadStatus) GetLatestValidHash 

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

func (*EnginePayloadStatus) GetStatus 

func (x *EnginePayloadStatus) GetStatus() EngineStatus

func (*EnginePayloadStatus) GetValidationError 

func (x *EnginePayloadStatus) GetValidationError() string

func (*EnginePayloadStatus) ProtoMessage 

func (*EnginePayloadStatus) ProtoMessage()

func (*EnginePayloadStatus) ProtoReflect 

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

func (*EnginePayloadStatus) Reset 

func (x *EnginePayloadStatus) Reset()

func (*EnginePayloadStatus) String 

func (x *EnginePayloadStatus) String() string

type EngineStatus 

type EngineStatus int32
const (
	EngineStatus_VALID              EngineStatus = 0
	EngineStatus_INVALID            EngineStatus = 1
	EngineStatus_SYNCING            EngineStatus = 2
	EngineStatus_ACCEPTED           EngineStatus = 3
	EngineStatus_INVALID_BLOCK_HASH EngineStatus = 4
)

func (EngineStatus) Descriptor 

func (EngineStatus) Descriptor() protoreflect.EnumDescriptor

func (EngineStatus) Enum 

func (x EngineStatus) Enum() *EngineStatus

func (EngineStatus) EnumDescriptor deprecated 

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

Deprecated: Use EngineStatus.Descriptor instead.

func (EngineStatus) Number 

func (x EngineStatus) Number() protoreflect.EnumNumber

func (EngineStatus) String 

func (x EngineStatus) String() string

func (EngineStatus) Type 

func (EngineStatus) Type() protoreflect.EnumType

type EtherbaseReply 

type EtherbaseReply struct {
	Address *types.H160 `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*EtherbaseReply) Descriptor deprecated 

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

Deprecated: Use EtherbaseReply.ProtoReflect.Descriptor instead.

func (*EtherbaseReply) GetAddress 

func (x *EtherbaseReply) GetAddress() *types.H160

func (*EtherbaseReply) ProtoMessage 

func (*EtherbaseReply) ProtoMessage()

func (*EtherbaseReply) ProtoReflect 

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

func (*EtherbaseReply) Reset 

func (x *EtherbaseReply) Reset()

func (*EtherbaseReply) String 

func (x *EtherbaseReply) String() string

type EtherbaseRequest 

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

func (*EtherbaseRequest) Descriptor deprecated 

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

Deprecated: Use EtherbaseRequest.ProtoReflect.Descriptor instead.

func (*EtherbaseRequest) ProtoMessage 

func (*EtherbaseRequest) ProtoMessage()

func (*EtherbaseRequest) ProtoReflect 

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

func (*EtherbaseRequest) Reset 

func (x *EtherbaseRequest) Reset()

func (*EtherbaseRequest) String 

func (x *EtherbaseRequest) String() string

type Event 

type Event int32
const (
	Event_HEADER        Event = 0
	Event_PENDING_LOGS  Event = 1
	Event_PENDING_BLOCK Event = 2
	// NEW_SNAPSHOT - one or many new snapshots (of snapshot sync) were created,
	// client need to close old file descriptors and open new (on new segments),
	// then server can remove old files
	Event_NEW_SNAPSHOT Event = 3
)

func (Event) Descriptor 

func (Event) Descriptor() protoreflect.EnumDescriptor

func (Event) Enum 

func (x Event) Enum() *Event

func (Event) EnumDescriptor deprecated 

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

Deprecated: Use Event.Descriptor instead.

func (Event) Number 

func (x Event) Number() protoreflect.EnumNumber

func (Event) String 

func (x Event) String() string

func (Event) Type 

func (Event) Type() protoreflect.EnumType

type KVClient 

type KVClient interface {
	// Version returns the service version number
	Version(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.VersionReply, error)
	// Tx exposes read-only transactions for the key-value store
	//
	// When tx open, client must receive 1 message from server with txID
	// When cursor open, client must receive 1 message from server with cursorID
	// Then only client can initiate messages from server
	Tx(ctx context.Context, opts ...grpc.CallOption) (KV_TxClient, error)
	StateChanges(ctx context.Context, in *StateChangeRequest, opts ...grpc.CallOption) (KV_StateChangesClient, error)
	// Snapshots returns list of current snapshot files. Then client can just open all of them.
	Snapshots(ctx context.Context, in *SnapshotsRequest, opts ...grpc.CallOption) (*SnapshotsReply, error)
}

KVClient is the client API for KV 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 NewKVClient 

func NewKVClient(cc grpc.ClientConnInterface) KVClient

type KVClientMock 

type KVClientMock struct {
	// SnapshotsFunc mocks the Snapshots method.
	SnapshotsFunc func(ctx context.Context, in *SnapshotsRequest, opts ...grpc.CallOption) (*SnapshotsReply, error)

	// StateChangesFunc mocks the StateChanges method.
	StateChangesFunc func(ctx context.Context, in *StateChangeRequest, opts ...grpc.CallOption) (KV_StateChangesClient, error)

	// TxFunc mocks the Tx method.
	TxFunc func(ctx context.Context, opts ...grpc.CallOption) (KV_TxClient, error)

	// VersionFunc mocks the Version method.
	VersionFunc func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.VersionReply, error)
	// contains filtered or unexported fields
}

KVClientMock is a mock implementation of KVClient. 

func TestSomethingThatUsesKVClient(t *testing.T) {

	// make and configure a mocked KVClient
	mockedKVClient := &KVClientMock{
		SnapshotsFunc: func(ctx context.Context, in *SnapshotsRequest, opts ...grpc.CallOption) (*SnapshotsReply, error) {
			panic("mock out the Snapshots method")
		},
		StateChangesFunc: func(ctx context.Context, in *StateChangeRequest, opts ...grpc.CallOption) (KV_StateChangesClient, error) {
			panic("mock out the StateChanges method")
		},
		TxFunc: func(ctx context.Context, opts ...grpc.CallOption) (KV_TxClient, error) {
			panic("mock out the Tx method")
		},
		VersionFunc: func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.VersionReply, error) {
			panic("mock out the Version method")
		},
	}

	// use mockedKVClient in code that requires KVClient
	// and then make assertions.

}

func (*KVClientMock) Snapshots 

func (mock *KVClientMock) Snapshots(ctx context.Context, in *SnapshotsRequest, opts ...grpc.CallOption) (*SnapshotsReply, error)

Snapshots calls SnapshotsFunc.

func (*KVClientMock) SnapshotsCalls 

func (mock *KVClientMock) SnapshotsCalls() []struct {
	Ctx  context.Context
	In   *SnapshotsRequest
	Opts []grpc.CallOption
}

SnapshotsCalls gets all the calls that were made to Snapshots. Check the length with: 

len(mockedKVClient.SnapshotsCalls())

func (*KVClientMock) StateChanges 

func (mock *KVClientMock) StateChanges(ctx context.Context, in *StateChangeRequest, opts ...grpc.CallOption) (KV_StateChangesClient, error)

StateChanges calls StateChangesFunc.

func (*KVClientMock) StateChangesCalls 

func (mock *KVClientMock) StateChangesCalls() []struct {
	Ctx  context.Context
	In   *StateChangeRequest
	Opts []grpc.CallOption
}

StateChangesCalls gets all the calls that were made to StateChanges. Check the length with: 

len(mockedKVClient.StateChangesCalls())

func (*KVClientMock) Tx 

func (mock *KVClientMock) Tx(ctx context.Context, opts ...grpc.CallOption) (KV_TxClient, error)

Tx calls TxFunc.

func (*KVClientMock) TxCalls 

func (mock *KVClientMock) TxCalls() []struct {
	Ctx  context.Context
	Opts []grpc.CallOption
}

TxCalls gets all the calls that were made to Tx. Check the length with: 

len(mockedKVClient.TxCalls())

func (*KVClientMock) Version 

func (mock *KVClientMock) Version(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.VersionReply, error)

Version calls VersionFunc.

func (*KVClientMock) VersionCalls 

func (mock *KVClientMock) VersionCalls() []struct {
	Ctx  context.Context
	In   *emptypb.Empty
	Opts []grpc.CallOption
}

VersionCalls gets all the calls that were made to Version. Check the length with: 

len(mockedKVClient.VersionCalls())

type KVServer 

type KVServer interface {
	// Version returns the service version number
	Version(context.Context, *emptypb.Empty) (*types.VersionReply, error)
	// Tx exposes read-only transactions for the key-value store
	//
	// When tx open, client must receive 1 message from server with txID
	// When cursor open, client must receive 1 message from server with cursorID
	// Then only client can initiate messages from server
	Tx(KV_TxServer) error
	StateChanges(*StateChangeRequest, KV_StateChangesServer) error
	// Snapshots returns list of current snapshot files. Then client can just open all of them.
	Snapshots(context.Context, *SnapshotsRequest) (*SnapshotsReply, error)
	// contains filtered or unexported methods
}

KVServer is the server API for KV service. All implementations must embed UnimplementedKVServer for forward compatibility

type KV_StateChangesClient 

type KV_StateChangesClient interface {
	Recv() (*StateChangeBatch, error)
	grpc.ClientStream
}

type KV_StateChangesClientMock 

type KV_StateChangesClientMock struct {
	// CloseSendFunc mocks the CloseSend method.
	CloseSendFunc func() error

	// ContextFunc mocks the Context method.
	ContextFunc func() context.Context

	// HeaderFunc mocks the Header method.
	HeaderFunc func() (metadata.MD, error)

	// RecvFunc mocks the Recv method.
	RecvFunc func() (*StateChangeBatch, error)

	// RecvMsgFunc mocks the RecvMsg method.
	RecvMsgFunc func(m interface{}) error

	// SendMsgFunc mocks the SendMsg method.
	SendMsgFunc func(m interface{}) error

	// TrailerFunc mocks the Trailer method.
	TrailerFunc func() metadata.MD
	// contains filtered or unexported fields
}

KV_StateChangesClientMock is a mock implementation of KV_StateChangesClient. 

func TestSomethingThatUsesKV_StateChangesClient(t *testing.T) {

	// make and configure a mocked KV_StateChangesClient
	mockedKV_StateChangesClient := &KV_StateChangesClientMock{
		CloseSendFunc: func() error {
			panic("mock out the CloseSend method")
		},
		ContextFunc: func() context.Context {
			panic("mock out the Context method")
		},
		HeaderFunc: func() (metadata.MD, error) {
			panic("mock out the Header method")
		},
		RecvFunc: func() (*StateChangeBatch, error) {
			panic("mock out the Recv method")
		},
		RecvMsgFunc: func(m interface{}) error {
			panic("mock out the RecvMsg method")
		},
		SendMsgFunc: func(m interface{}) error {
			panic("mock out the SendMsg method")
		},
		TrailerFunc: func() metadata.MD {
			panic("mock out the Trailer method")
		},
	}

	// use mockedKV_StateChangesClient in code that requires KV_StateChangesClient
	// and then make assertions.

}

func (*KV_StateChangesClientMock) CloseSend 

func (mock *KV_StateChangesClientMock) CloseSend() error

CloseSend calls CloseSendFunc.

func (*KV_StateChangesClientMock) CloseSendCalls 

func (mock *KV_StateChangesClientMock) CloseSendCalls() []struct {
}

CloseSendCalls gets all the calls that were made to CloseSend. Check the length with: 

len(mockedKV_StateChangesClient.CloseSendCalls())

func (*KV_StateChangesClientMock) Context 

func (mock *KV_StateChangesClientMock) Context() context.Context

Context calls ContextFunc.

func (*KV_StateChangesClientMock) ContextCalls 

func (mock *KV_StateChangesClientMock) ContextCalls() []struct {
}

ContextCalls gets all the calls that were made to Context. Check the length with: 

len(mockedKV_StateChangesClient.ContextCalls())

func (*KV_StateChangesClientMock) Header 

func (mock *KV_StateChangesClientMock) Header() (metadata.MD, error)

Header calls HeaderFunc.

func (*KV_StateChangesClientMock) HeaderCalls 

func (mock *KV_StateChangesClientMock) HeaderCalls() []struct {
}

HeaderCalls gets all the calls that were made to Header. Check the length with: 

len(mockedKV_StateChangesClient.HeaderCalls())

func (*KV_StateChangesClientMock) Recv 

func (mock *KV_StateChangesClientMock) Recv() (*StateChangeBatch, error)

Recv calls RecvFunc.

func (*KV_StateChangesClientMock) RecvCalls 

func (mock *KV_StateChangesClientMock) RecvCalls() []struct {
}

RecvCalls gets all the calls that were made to Recv. Check the length with: 

len(mockedKV_StateChangesClient.RecvCalls())

func (*KV_StateChangesClientMock) RecvMsg 

func (mock *KV_StateChangesClientMock) RecvMsg(m interface{}) error

RecvMsg calls RecvMsgFunc.

func (*KV_StateChangesClientMock) RecvMsgCalls 

func (mock *KV_StateChangesClientMock) RecvMsgCalls() []struct {
	M interface{}
}

RecvMsgCalls gets all the calls that were made to RecvMsg. Check the length with: 

len(mockedKV_StateChangesClient.RecvMsgCalls())

func (*KV_StateChangesClientMock) SendMsg 

func (mock *KV_StateChangesClientMock) SendMsg(m interface{}) error

SendMsg calls SendMsgFunc.

func (*KV_StateChangesClientMock) SendMsgCalls 

func (mock *KV_StateChangesClientMock) SendMsgCalls() []struct {
	M interface{}
}

SendMsgCalls gets all the calls that were made to SendMsg. Check the length with: 

len(mockedKV_StateChangesClient.SendMsgCalls())

func (*KV_StateChangesClientMock) Trailer 

func (mock *KV_StateChangesClientMock) Trailer() metadata.MD

Trailer calls TrailerFunc.

func (*KV_StateChangesClientMock) TrailerCalls 

func (mock *KV_StateChangesClientMock) TrailerCalls() []struct {
}

TrailerCalls gets all the calls that were made to Trailer. Check the length with: 

len(mockedKV_StateChangesClient.TrailerCalls())

type KV_StateChangesServer 

type KV_StateChangesServer interface {
	Send(*StateChangeBatch) error
	grpc.ServerStream
}

type KV_TxClient 

type KV_TxClient interface {
	Send(*Cursor) error
	Recv() (*Pair, error)
	grpc.ClientStream
}

type KV_TxServer 

type KV_TxServer interface {
	Send(*Pair) error
	Recv() (*Cursor, error)
	grpc.ServerStream
}

type LogsFilterRequest 

type LogsFilterRequest struct {
	AllAddresses bool          `protobuf:"varint,1,opt,name=allAddresses,proto3" json:"allAddresses,omitempty"`
	Addresses    []*types.H160 `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"`
	AllTopics    bool          `protobuf:"varint,3,opt,name=allTopics,proto3" json:"allTopics,omitempty"`
	Topics       []*types.H256 `protobuf:"bytes,4,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*LogsFilterRequest) Descriptor deprecated 

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

Deprecated: Use LogsFilterRequest.ProtoReflect.Descriptor instead.

func (*LogsFilterRequest) GetAddresses 

func (x *LogsFilterRequest) GetAddresses() []*types.H160

func (*LogsFilterRequest) GetAllAddresses 

func (x *LogsFilterRequest) GetAllAddresses() bool

func (*LogsFilterRequest) GetAllTopics 

func (x *LogsFilterRequest) GetAllTopics() bool

func (*LogsFilterRequest) GetTopics 

func (x *LogsFilterRequest) GetTopics() []*types.H256

func (*LogsFilterRequest) ProtoMessage 

func (*LogsFilterRequest) ProtoMessage()

func (*LogsFilterRequest) ProtoReflect 

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

func (*LogsFilterRequest) Reset 

func (x *LogsFilterRequest) Reset()

func (*LogsFilterRequest) String 

func (x *LogsFilterRequest) String() string

type NetPeerCountReply 

type NetPeerCountReply struct {
	Count uint64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*NetPeerCountReply) Descriptor deprecated 

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

Deprecated: Use NetPeerCountReply.ProtoReflect.Descriptor instead.

func (*NetPeerCountReply) GetCount 

func (x *NetPeerCountReply) GetCount() uint64

func (*NetPeerCountReply) ProtoMessage 

func (*NetPeerCountReply) ProtoMessage()

func (*NetPeerCountReply) ProtoReflect 

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

func (*NetPeerCountReply) Reset 

func (x *NetPeerCountReply) Reset()

func (*NetPeerCountReply) String 

func (x *NetPeerCountReply) String() string

type NetPeerCountRequest 

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

func (*NetPeerCountRequest) Descriptor deprecated 

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

Deprecated: Use NetPeerCountRequest.ProtoReflect.Descriptor instead.

func (*NetPeerCountRequest) ProtoMessage 

func (*NetPeerCountRequest) ProtoMessage()

func (*NetPeerCountRequest) ProtoReflect 

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

func (*NetPeerCountRequest) Reset 

func (x *NetPeerCountRequest) Reset()

func (*NetPeerCountRequest) String 

func (x *NetPeerCountRequest) String() string

type NetVersionReply 

type NetVersionReply struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*NetVersionReply) Descriptor deprecated 

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

Deprecated: Use NetVersionReply.ProtoReflect.Descriptor instead.

func (*NetVersionReply) GetId 

func (x *NetVersionReply) GetId() uint64

func (*NetVersionReply) ProtoMessage 

func (*NetVersionReply) ProtoMessage()

func (*NetVersionReply) ProtoReflect 

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

func (*NetVersionReply) Reset 

func (x *NetVersionReply) Reset()

func (*NetVersionReply) String 

func (x *NetVersionReply) String() string

type NetVersionRequest 

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

func (*NetVersionRequest) Descriptor deprecated 

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

Deprecated: Use NetVersionRequest.ProtoReflect.Descriptor instead.

func (*NetVersionRequest) ProtoMessage 

func (*NetVersionRequest) ProtoMessage()

func (*NetVersionRequest) ProtoReflect 

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

func (*NetVersionRequest) Reset 

func (x *NetVersionRequest) Reset()

func (*NetVersionRequest) String 

func (x *NetVersionRequest) String() string

type NodesInfoReply 

type NodesInfoReply struct {
	NodesInfo []*types.NodeInfoReply `protobuf:"bytes,1,rep,name=nodesInfo,proto3" json:"nodesInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*NodesInfoReply) Descriptor deprecated 

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

Deprecated: Use NodesInfoReply.ProtoReflect.Descriptor instead.

func (*NodesInfoReply) GetNodesInfo 

func (x *NodesInfoReply) GetNodesInfo() []*types.NodeInfoReply

func (*NodesInfoReply) ProtoMessage 

func (*NodesInfoReply) ProtoMessage()

func (*NodesInfoReply) ProtoReflect 

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

func (*NodesInfoReply) Reset 

func (x *NodesInfoReply) Reset()

func (*NodesInfoReply) String 

func (x *NodesInfoReply) String() string

type NodesInfoRequest 

type NodesInfoRequest struct {
	Limit uint32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*NodesInfoRequest) Descriptor deprecated 

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

Deprecated: Use NodesInfoRequest.ProtoReflect.Descriptor instead.

func (*NodesInfoRequest) GetLimit 

func (x *NodesInfoRequest) GetLimit() uint32

func (*NodesInfoRequest) ProtoMessage 

func (*NodesInfoRequest) ProtoMessage()

func (*NodesInfoRequest) ProtoReflect 

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

func (*NodesInfoRequest) Reset 

func (x *NodesInfoRequest) Reset()

func (*NodesInfoRequest) String 

func (x *NodesInfoRequest) String() string

type Op 

type Op int32
const (
	Op_FIRST           Op = 0
	Op_FIRST_DUP       Op = 1
	Op_SEEK            Op = 2
	Op_SEEK_BOTH       Op = 3
	Op_CURRENT         Op = 4
	Op_LAST            Op = 6
	Op_LAST_DUP        Op = 7
	Op_NEXT            Op = 8
	Op_NEXT_DUP        Op = 9
	Op_NEXT_NO_DUP     Op = 11
	Op_PREV            Op = 12
	Op_PREV_DUP        Op = 13
	Op_PREV_NO_DUP     Op = 14
	Op_SEEK_EXACT      Op = 15
	Op_SEEK_BOTH_EXACT Op = 16
	Op_OPEN            Op = 30
	Op_CLOSE           Op = 31
	Op_OPEN_DUP_SORT   Op = 32
)

func (Op) Descriptor 

func (Op) Descriptor() protoreflect.EnumDescriptor

func (Op) Enum 

func (x Op) Enum() *Op

func (Op) EnumDescriptor deprecated 

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

Deprecated: Use Op.Descriptor instead.

func (Op) Number 

func (x Op) Number() protoreflect.EnumNumber

func (Op) String 

func (x Op) String() string

func (Op) Type 

func (Op) Type() protoreflect.EnumType

type Pair 

type Pair struct {
	K        []byte `protobuf:"bytes,1,opt,name=k,proto3" json:"k,omitempty"`
	V        []byte `protobuf:"bytes,2,opt,name=v,proto3" json:"v,omitempty"`
	CursorID uint32 `protobuf:"varint,3,opt,name=cursorID,proto3" json:"cursorID,omitempty"` // send once after new cursor open
	TxID     uint64 `protobuf:"varint,4,opt,name=txID,proto3" json:"txID,omitempty"`         // send once after tx open. mdbx's tx.ID() - id of write transaction in db - where this changes happened
	// contains filtered or unexported fields
}

func (*Pair) Descriptor deprecated 

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

Deprecated: Use Pair.ProtoReflect.Descriptor instead.

func (*Pair) GetCursorID 

func (x *Pair) GetCursorID() uint32

func (*Pair) GetK 

func (x *Pair) GetK() []byte

func (*Pair) GetTxID 

func (x *Pair) GetTxID() uint64

func (*Pair) GetV 

func (x *Pair) GetV() []byte

func (*Pair) ProtoMessage 

func (*Pair) ProtoMessage()

func (*Pair) ProtoReflect 

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

func (*Pair) Reset 

func (x *Pair) Reset()

func (*Pair) String 

func (x *Pair) String() string

type PeersReply 

type PeersReply struct {
	Peers []*types.PeerInfo `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

func (*PeersReply) Descriptor deprecated 

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

Deprecated: Use PeersReply.ProtoReflect.Descriptor instead.

func (*PeersReply) GetPeers 

func (x *PeersReply) GetPeers() []*types.PeerInfo

func (*PeersReply) ProtoMessage 

func (*PeersReply) ProtoMessage()

func (*PeersReply) ProtoReflect 

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

func (*PeersReply) Reset 

func (x *PeersReply) Reset()

func (*PeersReply) String 

func (x *PeersReply) String() string

type PendingBlockReply 

type PendingBlockReply struct {
	BlockRlp []byte `protobuf:"bytes,1,opt,name=blockRlp,proto3" json:"blockRlp,omitempty"`
	// contains filtered or unexported fields
}

func (*PendingBlockReply) Descriptor deprecated 

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

Deprecated: Use PendingBlockReply.ProtoReflect.Descriptor instead.

func (*PendingBlockReply) GetBlockRlp 

func (x *PendingBlockReply) GetBlockRlp() []byte

func (*PendingBlockReply) ProtoMessage 

func (*PendingBlockReply) ProtoMessage()

func (*PendingBlockReply) ProtoReflect 

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

func (*PendingBlockReply) Reset 

func (x *PendingBlockReply) Reset()

func (*PendingBlockReply) String 

func (x *PendingBlockReply) String() string

type ProtocolVersionReply 

type ProtocolVersionReply struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ProtocolVersionReply) Descriptor deprecated 

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

Deprecated: Use ProtocolVersionReply.ProtoReflect.Descriptor instead.

func (*ProtocolVersionReply) GetId 

func (x *ProtocolVersionReply) GetId() uint64

func (*ProtocolVersionReply) ProtoMessage 

func (*ProtocolVersionReply) ProtoMessage()

func (*ProtocolVersionReply) ProtoReflect 

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

func (*ProtocolVersionReply) Reset 

func (x *ProtocolVersionReply) Reset()

func (*ProtocolVersionReply) String 

func (x *ProtocolVersionReply) String() string

type ProtocolVersionRequest 

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

func (*ProtocolVersionRequest) Descriptor deprecated 

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

Deprecated: Use ProtocolVersionRequest.ProtoReflect.Descriptor instead.

func (*ProtocolVersionRequest) ProtoMessage 

func (*ProtocolVersionRequest) ProtoMessage()

func (*ProtocolVersionRequest) ProtoReflect 

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

func (*ProtocolVersionRequest) Reset 

func (x *ProtocolVersionRequest) Reset()

func (*ProtocolVersionRequest) String 

func (x *ProtocolVersionRequest) String() string

type SnapshotsReply 

type SnapshotsReply struct {
	Files []string `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotsReply) Descriptor deprecated 

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

Deprecated: Use SnapshotsReply.ProtoReflect.Descriptor instead.

func (*SnapshotsReply) GetFiles 

func (x *SnapshotsReply) GetFiles() []string

func (*SnapshotsReply) ProtoMessage 

func (*SnapshotsReply) ProtoMessage()

func (*SnapshotsReply) ProtoReflect 

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

func (*SnapshotsReply) Reset 

func (x *SnapshotsReply) Reset()

func (*SnapshotsReply) String 

func (x *SnapshotsReply) String() string

type SnapshotsRequest 

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

func (*SnapshotsRequest) Descriptor deprecated 

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

Deprecated: Use SnapshotsRequest.ProtoReflect.Descriptor instead.

func (*SnapshotsRequest) ProtoMessage 

func (*SnapshotsRequest) ProtoMessage()

func (*SnapshotsRequest) ProtoReflect 

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

func (*SnapshotsRequest) Reset 

func (x *SnapshotsRequest) Reset()

func (*SnapshotsRequest) String 

func (x *SnapshotsRequest) String() string

type StateChange 

type StateChange struct {
	Direction   Direction        `protobuf:"varint,1,opt,name=direction,proto3,enum=remote.Direction" json:"direction,omitempty"`
	BlockHeight uint64           `protobuf:"varint,2,opt,name=blockHeight,proto3" json:"blockHeight,omitempty"`
	BlockHash   *types.H256      `protobuf:"bytes,3,opt,name=blockHash,proto3" json:"blockHash,omitempty"`
	Changes     []*AccountChange `protobuf:"bytes,4,rep,name=changes,proto3" json:"changes,omitempty"`
	Txs         [][]byte         `protobuf:"bytes,5,rep,name=txs,proto3" json:"txs,omitempty"` // enable by withTransactions=true
	// contains filtered or unexported fields
}

StateChange - changes done by 1 block or by 1 unwind

func (*StateChange) Descriptor deprecated 

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

Deprecated: Use StateChange.ProtoReflect.Descriptor instead.

func (*StateChange) GetBlockHash 

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

func (*StateChange) GetBlockHeight 

func (x *StateChange) GetBlockHeight() uint64

func (*StateChange) GetChanges 

func (x *StateChange) GetChanges() []*AccountChange

func (*StateChange) GetDirection 

func (x *StateChange) GetDirection() Direction

func (*StateChange) GetTxs 

func (x *StateChange) GetTxs() [][]byte

func (*StateChange) ProtoMessage 

func (*StateChange) ProtoMessage()

func (*StateChange) ProtoReflect 

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

func (*StateChange) Reset 

func (x *StateChange) Reset()

func (*StateChange) String 

func (x *StateChange) String() string

type StateChangeBatch 

type StateChangeBatch struct {
	StateVersionID      uint64         `protobuf:"varint,1,opt,name=stateVersionID,proto3" json:"stateVersionID,omitempty"` // mdbx's tx.ID() - id of write transaction in db - where this changes happened
	ChangeBatch         []*StateChange `protobuf:"bytes,2,rep,name=changeBatch,proto3" json:"changeBatch,omitempty"`
	PendingBlockBaseFee uint64         `protobuf:"varint,3,opt,name=pendingBlockBaseFee,proto3" json:"pendingBlockBaseFee,omitempty"` // BaseFee of the next block to be produced
	BlockGasLimit       uint64         `protobuf:"varint,4,opt,name=blockGasLimit,proto3" json:"blockGasLimit,omitempty"`             // GasLimit of the latest block - proxy for the gas limit of the next block to be produced
	// contains filtered or unexported fields
}

StateChangeBatch - list of StateDiff done in one DB transaction

func (*StateChangeBatch) Descriptor deprecated 

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

Deprecated: Use StateChangeBatch.ProtoReflect.Descriptor instead.

func (*StateChangeBatch) GetBlockGasLimit 

func (x *StateChangeBatch) GetBlockGasLimit() uint64

func (*StateChangeBatch) GetChangeBatch 

func (x *StateChangeBatch) GetChangeBatch() []*StateChange

func (*StateChangeBatch) GetPendingBlockBaseFee 

func (x *StateChangeBatch) GetPendingBlockBaseFee() uint64

func (*StateChangeBatch) GetStateVersionID 

func (x *StateChangeBatch) GetStateVersionID() uint64

func (*StateChangeBatch) ProtoMessage 

func (*StateChangeBatch) ProtoMessage()

func (*StateChangeBatch) ProtoReflect 

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

func (*StateChangeBatch) Reset 

func (x *StateChangeBatch) Reset()

func (*StateChangeBatch) String 

func (x *StateChangeBatch) String() string

type StateChangeRequest 

type StateChangeRequest struct {
	WithStorage      bool `protobuf:"varint,1,opt,name=withStorage,proto3" json:"withStorage,omitempty"`
	WithTransactions bool `protobuf:"varint,2,opt,name=withTransactions,proto3" json:"withTransactions,omitempty"`
	// contains filtered or unexported fields
}

func (*StateChangeRequest) Descriptor deprecated 

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

Deprecated: Use StateChangeRequest.ProtoReflect.Descriptor instead.

func (*StateChangeRequest) GetWithStorage 

func (x *StateChangeRequest) GetWithStorage() bool

func (*StateChangeRequest) GetWithTransactions 

func (x *StateChangeRequest) GetWithTransactions() bool

func (*StateChangeRequest) ProtoMessage 

func (*StateChangeRequest) ProtoMessage()

func (*StateChangeRequest) ProtoReflect 

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

func (*StateChangeRequest) Reset 

func (x *StateChangeRequest) Reset()

func (*StateChangeRequest) String 

func (x *StateChangeRequest) String() string

type StorageChange 

type StorageChange struct {
	Location *types.H256 `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	Data     []byte      `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageChange) Descriptor deprecated 

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

Deprecated: Use StorageChange.ProtoReflect.Descriptor instead.

func (*StorageChange) GetData 

func (x *StorageChange) GetData() []byte

func (*StorageChange) GetLocation 

func (x *StorageChange) GetLocation() *types.H256

func (*StorageChange) ProtoMessage 

func (*StorageChange) ProtoMessage()

func (*StorageChange) ProtoReflect 

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

func (*StorageChange) Reset 

func (x *StorageChange) Reset()

func (*StorageChange) String 

func (x *StorageChange) String() string

type SubscribeLogsReply 

type SubscribeLogsReply struct {
	Address          *types.H160   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	BlockHash        *types.H256   `protobuf:"bytes,2,opt,name=blockHash,proto3" json:"blockHash,omitempty"`
	BlockNumber      uint64        `protobuf:"varint,3,opt,name=blockNumber,proto3" json:"blockNumber,omitempty"`
	Data             []byte        `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	LogIndex         uint64        `protobuf:"varint,5,opt,name=logIndex,proto3" json:"logIndex,omitempty"`
	Topics           []*types.H256 `protobuf:"bytes,6,rep,name=topics,proto3" json:"topics,omitempty"`
	TransactionHash  *types.H256   `protobuf:"bytes,7,opt,name=transactionHash,proto3" json:"transactionHash,omitempty"`
	TransactionIndex uint64        `protobuf:"varint,8,opt,name=transactionIndex,proto3" json:"transactionIndex,omitempty"`
	Removed          bool          `protobuf:"varint,9,opt,name=removed,proto3" json:"removed,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeLogsReply) Descriptor deprecated 

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

Deprecated: Use SubscribeLogsReply.ProtoReflect.Descriptor instead.

func (*SubscribeLogsReply) GetAddress 

func (x *SubscribeLogsReply) GetAddress() *types.H160

func (*SubscribeLogsReply) GetBlockHash 

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

func (*SubscribeLogsReply) GetBlockNumber 

func (x *SubscribeLogsReply) GetBlockNumber() uint64

func (*SubscribeLogsReply) GetData 

func (x *SubscribeLogsReply) GetData() []byte

func (*SubscribeLogsReply) GetLogIndex 

func (x *SubscribeLogsReply) GetLogIndex() uint64

func (*SubscribeLogsReply) GetRemoved 

func (x *SubscribeLogsReply) GetRemoved() bool

func (*SubscribeLogsReply) GetTopics 

func (x *SubscribeLogsReply) GetTopics() []*types.H256

func (*SubscribeLogsReply) GetTransactionHash 

func (x *SubscribeLogsReply) GetTransactionHash() *types.H256

func (*SubscribeLogsReply) GetTransactionIndex 

func (x *SubscribeLogsReply) GetTransactionIndex() uint64

func (*SubscribeLogsReply) ProtoMessage 

func (*SubscribeLogsReply) ProtoMessage()

func (*SubscribeLogsReply) ProtoReflect 

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

func (*SubscribeLogsReply) Reset 

func (x *SubscribeLogsReply) Reset()

func (*SubscribeLogsReply) String 

func (x *SubscribeLogsReply) String() string

type SubscribeReply 

type SubscribeReply struct {
	Type Event  `protobuf:"varint,1,opt,name=type,proto3,enum=remote.Event" json:"type,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` //  serialized data
	// contains filtered or unexported fields
}

func (*SubscribeReply) Descriptor deprecated 

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

Deprecated: Use SubscribeReply.ProtoReflect.Descriptor instead.

func (*SubscribeReply) GetData 

func (x *SubscribeReply) GetData() []byte

func (*SubscribeReply) GetType 

func (x *SubscribeReply) GetType() Event

func (*SubscribeReply) ProtoMessage 

func (*SubscribeReply) ProtoMessage()

func (*SubscribeReply) ProtoReflect 

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

func (*SubscribeReply) Reset 

func (x *SubscribeReply) Reset()

func (*SubscribeReply) String 

func (x *SubscribeReply) String() string

type SubscribeRequest 

type SubscribeRequest struct {
	Type Event `protobuf:"varint,1,opt,name=type,proto3,enum=remote.Event" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetType 

func (x *SubscribeRequest) GetType() Event

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type TxnLookupReply 

type TxnLookupReply struct {
	BlockNumber uint64 `protobuf:"varint,1,opt,name=blockNumber,proto3" json:"blockNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*TxnLookupReply) Descriptor deprecated 

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

Deprecated: Use TxnLookupReply.ProtoReflect.Descriptor instead.

func (*TxnLookupReply) GetBlockNumber 

func (x *TxnLookupReply) GetBlockNumber() uint64

func (*TxnLookupReply) ProtoMessage 

func (*TxnLookupReply) ProtoMessage()

func (*TxnLookupReply) ProtoReflect 

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

func (*TxnLookupReply) Reset 

func (x *TxnLookupReply) Reset()

func (*TxnLookupReply) String 

func (x *TxnLookupReply) String() string

type TxnLookupRequest 

type TxnLookupRequest struct {
	TxnHash *types.H256 `protobuf:"bytes,1,opt,name=txnHash,proto3" json:"txnHash,omitempty"`
	// contains filtered or unexported fields
}

func (*TxnLookupRequest) Descriptor deprecated 

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

Deprecated: Use TxnLookupRequest.ProtoReflect.Descriptor instead.

func (*TxnLookupRequest) GetTxnHash 

func (x *TxnLookupRequest) GetTxnHash() *types.H256

func (*TxnLookupRequest) ProtoMessage 

func (*TxnLookupRequest) ProtoMessage()

func (*TxnLookupRequest) ProtoReflect 

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

func (*TxnLookupRequest) Reset 

func (x *TxnLookupRequest) Reset()

func (*TxnLookupRequest) String 

func (x *TxnLookupRequest) String() string

type UnimplementedETHBACKENDServer 

type UnimplementedETHBACKENDServer struct {
}

UnimplementedETHBACKENDServer must be embedded to have forward compatible implementations.

func (UnimplementedETHBACKENDServer) Block 

func (UnimplementedETHBACKENDServer) Block(context.Context, *BlockRequest) (*BlockReply, error)

func (UnimplementedETHBACKENDServer) ClientVersion 

func (UnimplementedETHBACKENDServer) ClientVersion(context.Context, *ClientVersionRequest) (*ClientVersionReply, error)

func (UnimplementedETHBACKENDServer) EngineForkChoiceUpdatedV1 

func (UnimplementedETHBACKENDServer) EngineForkChoiceUpdatedV1(context.Context, *EngineForkChoiceUpdatedRequest) (*EngineForkChoiceUpdatedReply, error)

func (UnimplementedETHBACKENDServer) EngineForkChoiceUpdatedV2 

func (UnimplementedETHBACKENDServer) EngineForkChoiceUpdatedV2(context.Context, *EngineForkChoiceUpdatedRequestV2) (*EngineForkChoiceUpdatedReply, error)

func (UnimplementedETHBACKENDServer) EngineGetPayloadV1 

func (UnimplementedETHBACKENDServer) EngineGetPayloadV1(context.Context, *EngineGetPayloadRequest) (*types.ExecutionPayload, error)

func (UnimplementedETHBACKENDServer) EngineGetPayloadV2 

func (UnimplementedETHBACKENDServer) EngineGetPayloadV2(context.Context, *EngineGetPayloadRequest) (*types.ExecutionPayloadV2, error)

func (UnimplementedETHBACKENDServer) EngineNewPayloadV1 

func (UnimplementedETHBACKENDServer) EngineNewPayloadV1(context.Context, *types.ExecutionPayload) (*EnginePayloadStatus, error)

func (UnimplementedETHBACKENDServer) EngineNewPayloadV2 

func (UnimplementedETHBACKENDServer) EngineNewPayloadV2(context.Context, *types.ExecutionPayloadV2) (*EnginePayloadStatus, error)

func (UnimplementedETHBACKENDServer) Etherbase 

func (UnimplementedETHBACKENDServer) Etherbase(context.Context, *EtherbaseRequest) (*EtherbaseReply, error)

func (UnimplementedETHBACKENDServer) NetPeerCount 

func (UnimplementedETHBACKENDServer) NetPeerCount(context.Context, *NetPeerCountRequest) (*NetPeerCountReply, error)

func (UnimplementedETHBACKENDServer) NetVersion 

func (UnimplementedETHBACKENDServer) NetVersion(context.Context, *NetVersionRequest) (*NetVersionReply, error)

func (UnimplementedETHBACKENDServer) NodeInfo 

func (UnimplementedETHBACKENDServer) NodeInfo(context.Context, *NodesInfoRequest) (*NodesInfoReply, error)

func (UnimplementedETHBACKENDServer) Peers 

func (UnimplementedETHBACKENDServer) Peers(context.Context, *emptypb.Empty) (*PeersReply, error)

func (UnimplementedETHBACKENDServer) PendingBlock 

func (UnimplementedETHBACKENDServer) PendingBlock(context.Context, *emptypb.Empty) (*PendingBlockReply, error)

func (UnimplementedETHBACKENDServer) ProtocolVersion 

func (UnimplementedETHBACKENDServer) ProtocolVersion(context.Context, *ProtocolVersionRequest) (*ProtocolVersionReply, error)

func (UnimplementedETHBACKENDServer) Subscribe 

func (UnimplementedETHBACKENDServer) Subscribe(*SubscribeRequest, ETHBACKEND_SubscribeServer) error

func (UnimplementedETHBACKENDServer) SubscribeLogs 

func (UnimplementedETHBACKENDServer) SubscribeLogs(ETHBACKEND_SubscribeLogsServer) error

func (UnimplementedETHBACKENDServer) TxnLookup 

func (UnimplementedETHBACKENDServer) TxnLookup(context.Context, *TxnLookupRequest) (*TxnLookupReply, error)

func (UnimplementedETHBACKENDServer) Version 

func (UnimplementedETHBACKENDServer) Version(context.Context, *emptypb.Empty) (*types.VersionReply, error)

type UnimplementedKVServer 

type UnimplementedKVServer struct {
}

UnimplementedKVServer must be embedded to have forward compatible implementations.

func (UnimplementedKVServer) Snapshots 

func (UnimplementedKVServer) Snapshots(context.Context, *SnapshotsRequest) (*SnapshotsReply, error)

func (UnimplementedKVServer) StateChanges 

func (UnimplementedKVServer) StateChanges(*StateChangeRequest, KV_StateChangesServer) error

func (UnimplementedKVServer) Tx 

func (UnimplementedKVServer) Tx(KV_TxServer) error

func (UnimplementedKVServer) Version 

func (UnimplementedKVServer) Version(context.Context, *emptypb.Empty) (*types.VersionReply, error)

type UnsafeETHBACKENDServer 

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

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

type UnsafeKVServer 

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

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

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.