Versions in this module Expand all Collapse all v1 v1.0.0 Sep 20, 2023 Changes in this version + const ETHBACKEND_AddPeer_FullMethodName + const ETHBACKEND_Block_FullMethodName + const ETHBACKEND_BorEvent_FullMethodName + const ETHBACKEND_ClientVersion_FullMethodName + const ETHBACKEND_Etherbase_FullMethodName + const ETHBACKEND_NetPeerCount_FullMethodName + const ETHBACKEND_NetVersion_FullMethodName + const ETHBACKEND_NodeInfo_FullMethodName + const ETHBACKEND_Peers_FullMethodName + const ETHBACKEND_PendingBlock_FullMethodName + const ETHBACKEND_ProtocolVersion_FullMethodName + const ETHBACKEND_SubscribeLogs_FullMethodName + const ETHBACKEND_Subscribe_FullMethodName + const ETHBACKEND_TxnLookup_FullMethodName + const ETHBACKEND_Version_FullMethodName + const KV_DomainGet_FullMethodName + const KV_DomainRange_FullMethodName + const KV_HistoryGet_FullMethodName + const KV_HistoryRange_FullMethodName + const KV_IndexRange_FullMethodName + const KV_Range_FullMethodName + const KV_Snapshots_FullMethodName + const KV_StateChanges_FullMethodName + const KV_Tx_FullMethodName + const KV_Version_FullMethodName + var Action_name = map[int32]string + var Action_value = map[string]int32 + var Direction_name = map[int32]string + var Direction_value = map[string]int32 + var ETHBACKEND_ServiceDesc = grpc.ServiceDesc + var Event_name = map[int32]string + var Event_value = map[string]int32 + var File_remote_ethbackend_proto protoreflect.FileDescriptor + var File_remote_kv_proto protoreflect.FileDescriptor + var KV_ServiceDesc = grpc.ServiceDesc + var Op_name = map[int32]string + var Op_value = map[string]int32 + func NodeInfoReplyLess(i, j *types.NodeInfoReply) bool + func RegisterETHBACKENDServer(s grpc.ServiceRegistrar, srv ETHBACKENDServer) + func RegisterKVServer(s grpc.ServiceRegistrar, srv KVServer) + type AccountChange struct + Action Action + Address *types.H160 + Code []byte + Data []byte + Incarnation uint64 + StorageChanges []*StorageChange + func (*AccountChange) Descriptor() ([]byte, []int) + func (*AccountChange) ProtoMessage() + func (x *AccountChange) GetAction() Action + func (x *AccountChange) GetAddress() *types.H160 + func (x *AccountChange) GetCode() []byte + func (x *AccountChange) GetData() []byte + func (x *AccountChange) GetIncarnation() uint64 + func (x *AccountChange) GetStorageChanges() []*StorageChange + func (x *AccountChange) ProtoReflect() protoreflect.Message + func (x *AccountChange) Reset() + func (x *AccountChange) String() string + type Action int32 + const Action_CODE + const Action_REMOVE + const Action_STORAGE + const Action_UPSERT + const Action_UPSERT_CODE + func (Action) Descriptor() protoreflect.EnumDescriptor + func (Action) EnumDescriptor() ([]byte, []int) + func (Action) Type() protoreflect.EnumType + func (x Action) Enum() *Action + func (x Action) Number() protoreflect.EnumNumber + func (x Action) String() string + type AddPeerReply struct + Success bool + func (*AddPeerReply) Descriptor() ([]byte, []int) + func (*AddPeerReply) ProtoMessage() + func (x *AddPeerReply) GetSuccess() bool + func (x *AddPeerReply) ProtoReflect() protoreflect.Message + func (x *AddPeerReply) Reset() + func (x *AddPeerReply) String() string + type AddPeerRequest struct + Url string + func (*AddPeerRequest) Descriptor() ([]byte, []int) + func (*AddPeerRequest) ProtoMessage() + func (x *AddPeerRequest) GetUrl() string + func (x *AddPeerRequest) ProtoReflect() protoreflect.Message + func (x *AddPeerRequest) Reset() + func (x *AddPeerRequest) String() string + type BlockReply struct + BlockRlp []byte + Senders []byte + func (*BlockReply) Descriptor() ([]byte, []int) + func (*BlockReply) ProtoMessage() + func (x *BlockReply) GetBlockRlp() []byte + func (x *BlockReply) GetSenders() []byte + func (x *BlockReply) ProtoReflect() protoreflect.Message + func (x *BlockReply) Reset() + func (x *BlockReply) String() string + type BlockRequest struct + BlockHash *types.H256 + BlockHeight uint64 + func (*BlockRequest) Descriptor() ([]byte, []int) + func (*BlockRequest) ProtoMessage() + func (x *BlockRequest) GetBlockHash() *types.H256 + func (x *BlockRequest) GetBlockHeight() uint64 + func (x *BlockRequest) ProtoReflect() protoreflect.Message + func (x *BlockRequest) Reset() + func (x *BlockRequest) String() string + type BorEventReply struct + BlockNumber uint64 + EventRlps [][]byte + Present bool + func (*BorEventReply) Descriptor() ([]byte, []int) + func (*BorEventReply) ProtoMessage() + func (x *BorEventReply) GetBlockNumber() uint64 + func (x *BorEventReply) GetEventRlps() [][]byte + func (x *BorEventReply) GetPresent() bool + func (x *BorEventReply) ProtoReflect() protoreflect.Message + func (x *BorEventReply) Reset() + func (x *BorEventReply) String() string + type BorEventRequest struct + BorTxHash *types.H256 + func (*BorEventRequest) Descriptor() ([]byte, []int) + func (*BorEventRequest) ProtoMessage() + func (x *BorEventRequest) GetBorTxHash() *types.H256 + func (x *BorEventRequest) ProtoReflect() protoreflect.Message + func (x *BorEventRequest) Reset() + func (x *BorEventRequest) String() string + type ClientVersionReply struct + NodeName string + func (*ClientVersionReply) Descriptor() ([]byte, []int) + func (*ClientVersionReply) ProtoMessage() + func (x *ClientVersionReply) GetNodeName() string + func (x *ClientVersionReply) ProtoReflect() protoreflect.Message + func (x *ClientVersionReply) Reset() + func (x *ClientVersionReply) String() string + type ClientVersionRequest struct + func (*ClientVersionRequest) Descriptor() ([]byte, []int) + func (*ClientVersionRequest) ProtoMessage() + func (x *ClientVersionRequest) ProtoReflect() protoreflect.Message + func (x *ClientVersionRequest) Reset() + func (x *ClientVersionRequest) String() string + type Cursor struct + BucketName string + Cursor uint32 + K []byte + Op Op + V []byte + func (*Cursor) Descriptor() ([]byte, []int) + func (*Cursor) ProtoMessage() + func (x *Cursor) GetBucketName() string + func (x *Cursor) GetCursor() uint32 + func (x *Cursor) GetK() []byte + func (x *Cursor) GetOp() Op + func (x *Cursor) GetV() []byte + func (x *Cursor) ProtoReflect() protoreflect.Message + func (x *Cursor) Reset() + func (x *Cursor) String() string + type Direction int32 + const Direction_FORWARD + const Direction_UNWIND + func (Direction) Descriptor() protoreflect.EnumDescriptor + func (Direction) EnumDescriptor() ([]byte, []int) + func (Direction) Type() protoreflect.EnumType + func (x Direction) Enum() *Direction + func (x Direction) Number() protoreflect.EnumNumber + func (x Direction) String() string + type DomainGetReply struct + Ok bool + V []byte + func (*DomainGetReply) Descriptor() ([]byte, []int) + func (*DomainGetReply) ProtoMessage() + func (x *DomainGetReply) GetOk() bool + func (x *DomainGetReply) GetV() []byte + func (x *DomainGetReply) ProtoReflect() protoreflect.Message + func (x *DomainGetReply) Reset() + func (x *DomainGetReply) String() string + type DomainGetReq struct + K []byte + K2 []byte + Latest bool + Table string + Ts uint64 + TxId uint64 + func (*DomainGetReq) Descriptor() ([]byte, []int) + func (*DomainGetReq) ProtoMessage() + func (x *DomainGetReq) GetK() []byte + func (x *DomainGetReq) GetK2() []byte + func (x *DomainGetReq) GetLatest() bool + func (x *DomainGetReq) GetTable() string + func (x *DomainGetReq) GetTs() uint64 + func (x *DomainGetReq) GetTxId() uint64 + func (x *DomainGetReq) ProtoReflect() protoreflect.Message + func (x *DomainGetReq) Reset() + func (x *DomainGetReq) String() string + type DomainRangeReq struct + FromKey []byte + Latest bool + Limit int64 + OrderAscend bool + PageSize int32 + PageToken string + Table string + ToKey []byte + Ts uint64 + TxId uint64 + func (*DomainRangeReq) Descriptor() ([]byte, []int) + func (*DomainRangeReq) ProtoMessage() + func (x *DomainRangeReq) GetFromKey() []byte + func (x *DomainRangeReq) GetLatest() bool + func (x *DomainRangeReq) GetLimit() int64 + func (x *DomainRangeReq) GetOrderAscend() bool + func (x *DomainRangeReq) GetPageSize() int32 + func (x *DomainRangeReq) GetPageToken() string + func (x *DomainRangeReq) GetTable() string + func (x *DomainRangeReq) GetToKey() []byte + func (x *DomainRangeReq) GetTs() uint64 + func (x *DomainRangeReq) GetTxId() uint64 + func (x *DomainRangeReq) ProtoReflect() protoreflect.Message + func (x *DomainRangeReq) Reset() + func (x *DomainRangeReq) String() string + type ETHBACKENDClient interface + AddPeer func(ctx context.Context, in *AddPeerRequest, opts ...grpc.CallOption) (*AddPeerReply, error) + Block func(ctx context.Context, in *BlockRequest, opts ...grpc.CallOption) (*BlockReply, error) + BorEvent func(ctx context.Context, in *BorEventRequest, opts ...grpc.CallOption) (*BorEventReply, error) + ClientVersion func(ctx context.Context, in *ClientVersionRequest, opts ...grpc.CallOption) (*ClientVersionReply, error) + Etherbase func(ctx context.Context, in *EtherbaseRequest, opts ...grpc.CallOption) (*EtherbaseReply, error) + NetPeerCount func(ctx context.Context, in *NetPeerCountRequest, opts ...grpc.CallOption) (*NetPeerCountReply, error) + NetVersion func(ctx context.Context, in *NetVersionRequest, opts ...grpc.CallOption) (*NetVersionReply, error) + NodeInfo func(ctx context.Context, in *NodesInfoRequest, opts ...grpc.CallOption) (*NodesInfoReply, error) + Peers func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PeersReply, error) + PendingBlock func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PendingBlockReply, error) + ProtocolVersion func(ctx context.Context, in *ProtocolVersionRequest, opts ...grpc.CallOption) (*ProtocolVersionReply, error) + Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (ETHBACKEND_SubscribeClient, error) + SubscribeLogs func(ctx context.Context, opts ...grpc.CallOption) (ETHBACKEND_SubscribeLogsClient, error) + TxnLookup func(ctx context.Context, in *TxnLookupRequest, opts ...grpc.CallOption) (*TxnLookupReply, error) + Version func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.VersionReply, error) + func NewETHBACKENDClient(cc grpc.ClientConnInterface) ETHBACKENDClient + type ETHBACKENDServer interface + AddPeer func(context.Context, *AddPeerRequest) (*AddPeerReply, error) + Block func(context.Context, *BlockRequest) (*BlockReply, error) + BorEvent func(context.Context, *BorEventRequest) (*BorEventReply, error) + ClientVersion func(context.Context, *ClientVersionRequest) (*ClientVersionReply, error) + Etherbase func(context.Context, *EtherbaseRequest) (*EtherbaseReply, error) + NetPeerCount func(context.Context, *NetPeerCountRequest) (*NetPeerCountReply, error) + NetVersion func(context.Context, *NetVersionRequest) (*NetVersionReply, error) + NodeInfo func(context.Context, *NodesInfoRequest) (*NodesInfoReply, error) + Peers func(context.Context, *emptypb.Empty) (*PeersReply, error) + PendingBlock func(context.Context, *emptypb.Empty) (*PendingBlockReply, error) + ProtocolVersion func(context.Context, *ProtocolVersionRequest) (*ProtocolVersionReply, error) + Subscribe func(*SubscribeRequest, ETHBACKEND_SubscribeServer) error + SubscribeLogs func(ETHBACKEND_SubscribeLogsServer) error + TxnLookup func(context.Context, *TxnLookupRequest) (*TxnLookupReply, error) + Version func(context.Context, *emptypb.Empty) (*types.VersionReply, error) + type ETHBACKEND_SubscribeClient interface + Recv func() (*SubscribeReply, error) + type ETHBACKEND_SubscribeLogsClient interface + Recv func() (*SubscribeLogsReply, error) + Send func(*LogsFilterRequest) error + type ETHBACKEND_SubscribeLogsServer interface + Recv func() (*LogsFilterRequest, error) + Send func(*SubscribeLogsReply) error + type ETHBACKEND_SubscribeServer interface + Send func(*SubscribeReply) error + type EngineGetPayloadBodiesByHashV1Request struct + Hashes []*types.H256 + func (*EngineGetPayloadBodiesByHashV1Request) Descriptor() ([]byte, []int) + func (*EngineGetPayloadBodiesByHashV1Request) ProtoMessage() + func (x *EngineGetPayloadBodiesByHashV1Request) GetHashes() []*types.H256 + func (x *EngineGetPayloadBodiesByHashV1Request) ProtoReflect() protoreflect.Message + func (x *EngineGetPayloadBodiesByHashV1Request) Reset() + func (x *EngineGetPayloadBodiesByHashV1Request) String() string + type EngineGetPayloadBodiesByRangeV1Request struct + Count uint64 + Start uint64 + func (*EngineGetPayloadBodiesByRangeV1Request) Descriptor() ([]byte, []int) + func (*EngineGetPayloadBodiesByRangeV1Request) ProtoMessage() + func (x *EngineGetPayloadBodiesByRangeV1Request) GetCount() uint64 + func (x *EngineGetPayloadBodiesByRangeV1Request) GetStart() uint64 + func (x *EngineGetPayloadBodiesByRangeV1Request) ProtoReflect() protoreflect.Message + func (x *EngineGetPayloadBodiesByRangeV1Request) Reset() + func (x *EngineGetPayloadBodiesByRangeV1Request) String() string + type EtherbaseReply struct + Address *types.H160 + func (*EtherbaseReply) Descriptor() ([]byte, []int) + func (*EtherbaseReply) ProtoMessage() + func (x *EtherbaseReply) GetAddress() *types.H160 + func (x *EtherbaseReply) ProtoReflect() protoreflect.Message + func (x *EtherbaseReply) Reset() + func (x *EtherbaseReply) String() string + type EtherbaseRequest struct + func (*EtherbaseRequest) Descriptor() ([]byte, []int) + func (*EtherbaseRequest) ProtoMessage() + func (x *EtherbaseRequest) ProtoReflect() protoreflect.Message + func (x *EtherbaseRequest) Reset() + func (x *EtherbaseRequest) String() string + type Event int32 + const Event_HEADER + const Event_NEW_SNAPSHOT + const Event_PENDING_BLOCK + const Event_PENDING_LOGS + func (Event) Descriptor() protoreflect.EnumDescriptor + func (Event) EnumDescriptor() ([]byte, []int) + func (Event) Type() protoreflect.EnumType + func (x Event) Enum() *Event + func (x Event) Number() protoreflect.EnumNumber + func (x Event) String() string + type HistoryGetReply struct + Ok bool + V []byte + func (*HistoryGetReply) Descriptor() ([]byte, []int) + func (*HistoryGetReply) ProtoMessage() + func (x *HistoryGetReply) GetOk() bool + func (x *HistoryGetReply) GetV() []byte + func (x *HistoryGetReply) ProtoReflect() protoreflect.Message + func (x *HistoryGetReply) Reset() + func (x *HistoryGetReply) String() string + type HistoryGetReq struct + K []byte + Table string + Ts uint64 + TxId uint64 + func (*HistoryGetReq) Descriptor() ([]byte, []int) + func (*HistoryGetReq) ProtoMessage() + func (x *HistoryGetReq) GetK() []byte + func (x *HistoryGetReq) GetTable() string + func (x *HistoryGetReq) GetTs() uint64 + func (x *HistoryGetReq) GetTxId() uint64 + func (x *HistoryGetReq) ProtoReflect() protoreflect.Message + func (x *HistoryGetReq) Reset() + func (x *HistoryGetReq) String() string + type HistoryRangeReq struct + FromTs int64 + Limit int64 + OrderAscend bool + PageSize int32 + PageToken string + Table string + ToTs int64 + TxId uint64 + func (*HistoryRangeReq) Descriptor() ([]byte, []int) + func (*HistoryRangeReq) ProtoMessage() + func (x *HistoryRangeReq) GetFromTs() int64 + func (x *HistoryRangeReq) GetLimit() int64 + func (x *HistoryRangeReq) GetOrderAscend() bool + func (x *HistoryRangeReq) GetPageSize() int32 + func (x *HistoryRangeReq) GetPageToken() string + func (x *HistoryRangeReq) GetTable() string + func (x *HistoryRangeReq) GetToTs() int64 + func (x *HistoryRangeReq) GetTxId() uint64 + func (x *HistoryRangeReq) ProtoReflect() protoreflect.Message + func (x *HistoryRangeReq) Reset() + func (x *HistoryRangeReq) String() string + type IndexPagination struct + Limit int64 + NextTimeStamp int64 + func (*IndexPagination) Descriptor() ([]byte, []int) + func (*IndexPagination) ProtoMessage() + func (x *IndexPagination) GetLimit() int64 + func (x *IndexPagination) GetNextTimeStamp() int64 + func (x *IndexPagination) ProtoReflect() protoreflect.Message + func (x *IndexPagination) Reset() + func (x *IndexPagination) String() string + type IndexRangeReply struct + NextPageToken string + Timestamps []uint64 + func (*IndexRangeReply) Descriptor() ([]byte, []int) + func (*IndexRangeReply) ProtoMessage() + func (x *IndexRangeReply) GetNextPageToken() string + func (x *IndexRangeReply) GetTimestamps() []uint64 + func (x *IndexRangeReply) ProtoReflect() protoreflect.Message + func (x *IndexRangeReply) Reset() + func (x *IndexRangeReply) String() string + type IndexRangeReq struct + FromTs int64 + K []byte + Limit int64 + OrderAscend bool + PageSize int32 + PageToken string + Table string + ToTs int64 + TxId uint64 + func (*IndexRangeReq) Descriptor() ([]byte, []int) + func (*IndexRangeReq) ProtoMessage() + func (x *IndexRangeReq) GetFromTs() int64 + func (x *IndexRangeReq) GetK() []byte + func (x *IndexRangeReq) GetLimit() int64 + func (x *IndexRangeReq) GetOrderAscend() bool + func (x *IndexRangeReq) GetPageSize() int32 + func (x *IndexRangeReq) GetPageToken() string + func (x *IndexRangeReq) GetTable() string + func (x *IndexRangeReq) GetToTs() int64 + func (x *IndexRangeReq) GetTxId() uint64 + func (x *IndexRangeReq) ProtoReflect() protoreflect.Message + func (x *IndexRangeReq) Reset() + func (x *IndexRangeReq) String() string + type KVClient interface + DomainGet func(ctx context.Context, in *DomainGetReq, opts ...grpc.CallOption) (*DomainGetReply, error) + DomainRange func(ctx context.Context, in *DomainRangeReq, opts ...grpc.CallOption) (*Pairs, error) + HistoryGet func(ctx context.Context, in *HistoryGetReq, opts ...grpc.CallOption) (*HistoryGetReply, error) + HistoryRange func(ctx context.Context, in *HistoryRangeReq, opts ...grpc.CallOption) (*Pairs, error) + IndexRange func(ctx context.Context, in *IndexRangeReq, opts ...grpc.CallOption) (*IndexRangeReply, error) + Range func(ctx context.Context, in *RangeReq, opts ...grpc.CallOption) (*Pairs, error) + Snapshots func(ctx context.Context, in *SnapshotsRequest, opts ...grpc.CallOption) (*SnapshotsReply, error) + StateChanges func(ctx context.Context, in *StateChangeRequest, opts ...grpc.CallOption) (KV_StateChangesClient, error) + Tx func(ctx context.Context, opts ...grpc.CallOption) (KV_TxClient, error) + Version func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.VersionReply, error) + func NewKVClient(cc grpc.ClientConnInterface) KVClient + type KVClientMock struct + DomainGetFunc func(ctx context.Context, in *DomainGetReq, opts ...grpc.CallOption) (*DomainGetReply, error) + DomainRangeFunc func(ctx context.Context, in *DomainRangeReq, opts ...grpc.CallOption) (*Pairs, error) + HistoryGetFunc func(ctx context.Context, in *HistoryGetReq, opts ...grpc.CallOption) (*HistoryGetReply, error) + HistoryRangeFunc func(ctx context.Context, in *HistoryRangeReq, opts ...grpc.CallOption) (*Pairs, error) + IndexRangeFunc func(ctx context.Context, in *IndexRangeReq, opts ...grpc.CallOption) (*IndexRangeReply, error) + RangeFunc func(ctx context.Context, in *RangeReq, opts ...grpc.CallOption) (*Pairs, error) + SnapshotsFunc func(ctx context.Context, in *SnapshotsRequest, opts ...grpc.CallOption) (*SnapshotsReply, error) + StateChangesFunc func(ctx context.Context, in *StateChangeRequest, opts ...grpc.CallOption) (KV_StateChangesClient, error) + TxFunc func(ctx context.Context, opts ...grpc.CallOption) (KV_TxClient, error) + VersionFunc func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.VersionReply, error) + func (mock *KVClientMock) DomainGet(ctx context.Context, in *DomainGetReq, opts ...grpc.CallOption) (*DomainGetReply, error) + func (mock *KVClientMock) DomainGetCalls() []struct{ ... } + func (mock *KVClientMock) DomainRange(ctx context.Context, in *DomainRangeReq, opts ...grpc.CallOption) (*Pairs, error) + func (mock *KVClientMock) DomainRangeCalls() []struct{ ... } + func (mock *KVClientMock) HistoryGet(ctx context.Context, in *HistoryGetReq, opts ...grpc.CallOption) (*HistoryGetReply, error) + func (mock *KVClientMock) HistoryGetCalls() []struct{ ... } + func (mock *KVClientMock) HistoryRange(ctx context.Context, in *HistoryRangeReq, opts ...grpc.CallOption) (*Pairs, error) + func (mock *KVClientMock) HistoryRangeCalls() []struct{ ... } + func (mock *KVClientMock) IndexRange(ctx context.Context, in *IndexRangeReq, opts ...grpc.CallOption) (*IndexRangeReply, error) + func (mock *KVClientMock) IndexRangeCalls() []struct{ ... } + func (mock *KVClientMock) Range(ctx context.Context, in *RangeReq, opts ...grpc.CallOption) (*Pairs, error) + func (mock *KVClientMock) RangeCalls() []struct{ ... } + func (mock *KVClientMock) Snapshots(ctx context.Context, in *SnapshotsRequest, opts ...grpc.CallOption) (*SnapshotsReply, error) + func (mock *KVClientMock) SnapshotsCalls() []struct{ ... } + func (mock *KVClientMock) StateChanges(ctx context.Context, in *StateChangeRequest, opts ...grpc.CallOption) (KV_StateChangesClient, error) + func (mock *KVClientMock) StateChangesCalls() []struct{ ... } + func (mock *KVClientMock) Tx(ctx context.Context, opts ...grpc.CallOption) (KV_TxClient, error) + func (mock *KVClientMock) TxCalls() []struct{ ... } + func (mock *KVClientMock) Version(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.VersionReply, error) + func (mock *KVClientMock) VersionCalls() []struct{ ... } + type KVServer interface + DomainGet func(context.Context, *DomainGetReq) (*DomainGetReply, error) + DomainRange func(context.Context, *DomainRangeReq) (*Pairs, error) + HistoryGet func(context.Context, *HistoryGetReq) (*HistoryGetReply, error) + HistoryRange func(context.Context, *HistoryRangeReq) (*Pairs, error) + IndexRange func(context.Context, *IndexRangeReq) (*IndexRangeReply, error) + Range func(context.Context, *RangeReq) (*Pairs, error) + Snapshots func(context.Context, *SnapshotsRequest) (*SnapshotsReply, error) + StateChanges func(*StateChangeRequest, KV_StateChangesServer) error + Tx func(KV_TxServer) error + Version func(context.Context, *emptypb.Empty) (*types.VersionReply, error) + type KV_StateChangesClient interface + Recv func() (*StateChangeBatch, error) + type KV_StateChangesClientMock struct + CloseSendFunc func() error + ContextFunc func() context.Context + HeaderFunc func() (metadata.MD, error) + RecvFunc func() (*StateChangeBatch, error) + RecvMsgFunc func(m any) error + SendMsgFunc func(m any) error + TrailerFunc func() metadata.MD + func (mock *KV_StateChangesClientMock) CloseSend() error + func (mock *KV_StateChangesClientMock) CloseSendCalls() []struct{} + func (mock *KV_StateChangesClientMock) Context() context.Context + func (mock *KV_StateChangesClientMock) ContextCalls() []struct{} + func (mock *KV_StateChangesClientMock) Header() (metadata.MD, error) + func (mock *KV_StateChangesClientMock) HeaderCalls() []struct{} + func (mock *KV_StateChangesClientMock) Recv() (*StateChangeBatch, error) + func (mock *KV_StateChangesClientMock) RecvCalls() []struct{} + func (mock *KV_StateChangesClientMock) RecvMsg(m any) error + func (mock *KV_StateChangesClientMock) RecvMsgCalls() []struct{ ... } + func (mock *KV_StateChangesClientMock) SendMsg(m any) error + func (mock *KV_StateChangesClientMock) SendMsgCalls() []struct{ ... } + func (mock *KV_StateChangesClientMock) Trailer() metadata.MD + func (mock *KV_StateChangesClientMock) TrailerCalls() []struct{} + type KV_StateChangesServer interface + Send func(*StateChangeBatch) error + type KV_TxClient interface + Recv func() (*Pair, error) + Send func(*Cursor) error + type KV_TxServer interface + Recv func() (*Cursor, error) + Send func(*Pair) error + type LogsFilterRequest struct + Addresses []*types.H160 + AllAddresses bool + AllTopics bool + Topics []*types.H256 + func (*LogsFilterRequest) Descriptor() ([]byte, []int) + func (*LogsFilterRequest) ProtoMessage() + func (x *LogsFilterRequest) GetAddresses() []*types.H160 + func (x *LogsFilterRequest) GetAllAddresses() bool + func (x *LogsFilterRequest) GetAllTopics() bool + func (x *LogsFilterRequest) GetTopics() []*types.H256 + func (x *LogsFilterRequest) ProtoReflect() protoreflect.Message + func (x *LogsFilterRequest) Reset() + func (x *LogsFilterRequest) String() string + type NetPeerCountReply struct + Count uint64 + func (*NetPeerCountReply) Descriptor() ([]byte, []int) + func (*NetPeerCountReply) ProtoMessage() + func (x *NetPeerCountReply) GetCount() uint64 + func (x *NetPeerCountReply) ProtoReflect() protoreflect.Message + func (x *NetPeerCountReply) Reset() + func (x *NetPeerCountReply) String() string + type NetPeerCountRequest struct + func (*NetPeerCountRequest) Descriptor() ([]byte, []int) + func (*NetPeerCountRequest) ProtoMessage() + func (x *NetPeerCountRequest) ProtoReflect() protoreflect.Message + func (x *NetPeerCountRequest) Reset() + func (x *NetPeerCountRequest) String() string + type NetVersionReply struct + Id uint64 + func (*NetVersionReply) Descriptor() ([]byte, []int) + func (*NetVersionReply) ProtoMessage() + func (x *NetVersionReply) GetId() uint64 + func (x *NetVersionReply) ProtoReflect() protoreflect.Message + func (x *NetVersionReply) Reset() + func (x *NetVersionReply) String() string + type NetVersionRequest struct + func (*NetVersionRequest) Descriptor() ([]byte, []int) + func (*NetVersionRequest) ProtoMessage() + func (x *NetVersionRequest) ProtoReflect() protoreflect.Message + func (x *NetVersionRequest) Reset() + func (x *NetVersionRequest) String() string + type NodesInfoReply struct + NodesInfo []*types.NodeInfoReply + func (*NodesInfoReply) Descriptor() ([]byte, []int) + func (*NodesInfoReply) ProtoMessage() + func (x *NodesInfoReply) GetNodesInfo() []*types.NodeInfoReply + func (x *NodesInfoReply) ProtoReflect() protoreflect.Message + func (x *NodesInfoReply) Reset() + func (x *NodesInfoReply) String() string + type NodesInfoRequest struct + Limit uint32 + func (*NodesInfoRequest) Descriptor() ([]byte, []int) + func (*NodesInfoRequest) ProtoMessage() + func (x *NodesInfoRequest) GetLimit() uint32 + func (x *NodesInfoRequest) ProtoReflect() protoreflect.Message + func (x *NodesInfoRequest) Reset() + func (x *NodesInfoRequest) String() string + type Op int32 + const Op_CLOSE + const Op_COUNT + const Op_CURRENT + const Op_FIRST + const Op_FIRST_DUP + const Op_LAST + const Op_LAST_DUP + const Op_NEXT + const Op_NEXT_DUP + const Op_NEXT_NO_DUP + const Op_OPEN + const Op_OPEN_DUP_SORT + const Op_PREV + const Op_PREV_DUP + const Op_PREV_NO_DUP + const Op_SEEK + const Op_SEEK_BOTH + const Op_SEEK_BOTH_EXACT + const Op_SEEK_EXACT + func (Op) Descriptor() protoreflect.EnumDescriptor + func (Op) EnumDescriptor() ([]byte, []int) + func (Op) Type() protoreflect.EnumType + func (x Op) Enum() *Op + func (x Op) Number() protoreflect.EnumNumber + func (x Op) String() string + type Pair struct + CursorId uint32 + K []byte + TxId uint64 + V []byte + ViewId uint64 + func (*Pair) Descriptor() ([]byte, []int) + func (*Pair) ProtoMessage() + func (x *Pair) GetCursorId() uint32 + func (x *Pair) GetK() []byte + func (x *Pair) GetTxId() uint64 + func (x *Pair) GetV() []byte + func (x *Pair) GetViewId() uint64 + func (x *Pair) ProtoReflect() protoreflect.Message + func (x *Pair) Reset() + func (x *Pair) String() string + type Pairs struct + Keys [][]byte + NextPageToken string + Values [][]byte + func (*Pairs) Descriptor() ([]byte, []int) + func (*Pairs) ProtoMessage() + func (x *Pairs) GetKeys() [][]byte + func (x *Pairs) GetNextPageToken() string + func (x *Pairs) GetValues() [][]byte + func (x *Pairs) ProtoReflect() protoreflect.Message + func (x *Pairs) Reset() + func (x *Pairs) String() string + type ParisPagination struct + Limit int64 + NextKey []byte + func (*ParisPagination) Descriptor() ([]byte, []int) + func (*ParisPagination) ProtoMessage() + func (x *ParisPagination) GetLimit() int64 + func (x *ParisPagination) GetNextKey() []byte + func (x *ParisPagination) ProtoReflect() protoreflect.Message + func (x *ParisPagination) Reset() + func (x *ParisPagination) String() string + type PeersReply struct + Peers []*types.PeerInfo + func (*PeersReply) Descriptor() ([]byte, []int) + func (*PeersReply) ProtoMessage() + func (x *PeersReply) GetPeers() []*types.PeerInfo + func (x *PeersReply) ProtoReflect() protoreflect.Message + func (x *PeersReply) Reset() + func (x *PeersReply) String() string + type PendingBlockReply struct + BlockRlp []byte + func (*PendingBlockReply) Descriptor() ([]byte, []int) + func (*PendingBlockReply) ProtoMessage() + func (x *PendingBlockReply) GetBlockRlp() []byte + func (x *PendingBlockReply) ProtoReflect() protoreflect.Message + func (x *PendingBlockReply) Reset() + func (x *PendingBlockReply) String() string + type ProtocolVersionReply struct + Id uint64 + func (*ProtocolVersionReply) Descriptor() ([]byte, []int) + func (*ProtocolVersionReply) ProtoMessage() + func (x *ProtocolVersionReply) GetId() uint64 + func (x *ProtocolVersionReply) ProtoReflect() protoreflect.Message + func (x *ProtocolVersionReply) Reset() + func (x *ProtocolVersionReply) String() string + type ProtocolVersionRequest struct + func (*ProtocolVersionRequest) Descriptor() ([]byte, []int) + func (*ProtocolVersionRequest) ProtoMessage() + func (x *ProtocolVersionRequest) ProtoReflect() protoreflect.Message + func (x *ProtocolVersionRequest) Reset() + func (x *ProtocolVersionRequest) String() string + type RangeReq struct + FromPrefix []byte + Limit int64 + OrderAscend bool + PageSize int32 + PageToken string + Table string + ToPrefix []byte + TxId uint64 + func (*RangeReq) Descriptor() ([]byte, []int) + func (*RangeReq) ProtoMessage() + func (x *RangeReq) GetFromPrefix() []byte + func (x *RangeReq) GetLimit() int64 + func (x *RangeReq) GetOrderAscend() bool + func (x *RangeReq) GetPageSize() int32 + func (x *RangeReq) GetPageToken() string + func (x *RangeReq) GetTable() string + func (x *RangeReq) GetToPrefix() []byte + func (x *RangeReq) GetTxId() uint64 + func (x *RangeReq) ProtoReflect() protoreflect.Message + func (x *RangeReq) Reset() + func (x *RangeReq) String() string + type SnapshotsReply struct + BlocksFiles []string + HistoryFiles []string + func (*SnapshotsReply) Descriptor() ([]byte, []int) + func (*SnapshotsReply) ProtoMessage() + func (x *SnapshotsReply) GetBlocksFiles() []string + func (x *SnapshotsReply) GetHistoryFiles() []string + func (x *SnapshotsReply) ProtoReflect() protoreflect.Message + func (x *SnapshotsReply) Reset() + func (x *SnapshotsReply) String() string + type SnapshotsRequest struct + func (*SnapshotsRequest) Descriptor() ([]byte, []int) + func (*SnapshotsRequest) ProtoMessage() + func (x *SnapshotsRequest) ProtoReflect() protoreflect.Message + func (x *SnapshotsRequest) Reset() + func (x *SnapshotsRequest) String() string + type StateChange struct + BlockHash *types.H256 + BlockHeight uint64 + Changes []*AccountChange + Direction Direction + Txs [][]byte + func (*StateChange) Descriptor() ([]byte, []int) + func (*StateChange) ProtoMessage() + func (x *StateChange) GetBlockHash() *types.H256 + func (x *StateChange) GetBlockHeight() uint64 + func (x *StateChange) GetChanges() []*AccountChange + func (x *StateChange) GetDirection() Direction + func (x *StateChange) GetTxs() [][]byte + func (x *StateChange) ProtoReflect() protoreflect.Message + func (x *StateChange) Reset() + func (x *StateChange) String() string + type StateChangeBatch struct + BlockGasLimit uint64 + ChangeBatch []*StateChange + FinalizedBlock uint64 + PendingBlobFeePerGas uint64 + PendingBlockBaseFee uint64 + StateVersionId uint64 + func (*StateChangeBatch) Descriptor() ([]byte, []int) + func (*StateChangeBatch) ProtoMessage() + func (x *StateChangeBatch) GetBlockGasLimit() uint64 + func (x *StateChangeBatch) GetChangeBatch() []*StateChange + func (x *StateChangeBatch) GetFinalizedBlock() uint64 + func (x *StateChangeBatch) GetPendingBlobFeePerGas() uint64 + func (x *StateChangeBatch) GetPendingBlockBaseFee() uint64 + func (x *StateChangeBatch) GetStateVersionId() uint64 + func (x *StateChangeBatch) ProtoReflect() protoreflect.Message + func (x *StateChangeBatch) Reset() + func (x *StateChangeBatch) String() string + type StateChangeRequest struct + WithStorage bool + WithTransactions bool + func (*StateChangeRequest) Descriptor() ([]byte, []int) + func (*StateChangeRequest) ProtoMessage() + func (x *StateChangeRequest) GetWithStorage() bool + func (x *StateChangeRequest) GetWithTransactions() bool + func (x *StateChangeRequest) ProtoReflect() protoreflect.Message + func (x *StateChangeRequest) Reset() + func (x *StateChangeRequest) String() string + type StorageChange struct + Data []byte + Location *types.H256 + func (*StorageChange) Descriptor() ([]byte, []int) + func (*StorageChange) ProtoMessage() + func (x *StorageChange) GetData() []byte + func (x *StorageChange) GetLocation() *types.H256 + func (x *StorageChange) ProtoReflect() protoreflect.Message + func (x *StorageChange) Reset() + func (x *StorageChange) String() string + type SubscribeLogsReply struct + Address *types.H160 + BlockHash *types.H256 + BlockNumber uint64 + Data []byte + LogIndex uint64 + Removed bool + Topics []*types.H256 + TransactionHash *types.H256 + TransactionIndex uint64 + func (*SubscribeLogsReply) Descriptor() ([]byte, []int) + func (*SubscribeLogsReply) ProtoMessage() + func (x *SubscribeLogsReply) GetAddress() *types.H160 + func (x *SubscribeLogsReply) GetBlockHash() *types.H256 + func (x *SubscribeLogsReply) GetBlockNumber() uint64 + func (x *SubscribeLogsReply) GetData() []byte + func (x *SubscribeLogsReply) GetLogIndex() uint64 + func (x *SubscribeLogsReply) GetRemoved() bool + func (x *SubscribeLogsReply) GetTopics() []*types.H256 + func (x *SubscribeLogsReply) GetTransactionHash() *types.H256 + func (x *SubscribeLogsReply) GetTransactionIndex() uint64 + func (x *SubscribeLogsReply) ProtoReflect() protoreflect.Message + func (x *SubscribeLogsReply) Reset() + func (x *SubscribeLogsReply) String() string + type SubscribeReply struct + Data []byte + Type Event + func (*SubscribeReply) Descriptor() ([]byte, []int) + func (*SubscribeReply) ProtoMessage() + func (x *SubscribeReply) GetData() []byte + func (x *SubscribeReply) GetType() Event + func (x *SubscribeReply) ProtoReflect() protoreflect.Message + func (x *SubscribeReply) Reset() + func (x *SubscribeReply) String() string + type SubscribeRequest struct + Type Event + func (*SubscribeRequest) Descriptor() ([]byte, []int) + func (*SubscribeRequest) ProtoMessage() + func (x *SubscribeRequest) GetType() Event + func (x *SubscribeRequest) ProtoReflect() protoreflect.Message + func (x *SubscribeRequest) Reset() + func (x *SubscribeRequest) String() string + type TxnLookupReply struct + BlockNumber uint64 + func (*TxnLookupReply) Descriptor() ([]byte, []int) + func (*TxnLookupReply) ProtoMessage() + func (x *TxnLookupReply) GetBlockNumber() uint64 + func (x *TxnLookupReply) ProtoReflect() protoreflect.Message + func (x *TxnLookupReply) Reset() + func (x *TxnLookupReply) String() string + type TxnLookupRequest struct + TxnHash *types.H256 + func (*TxnLookupRequest) Descriptor() ([]byte, []int) + func (*TxnLookupRequest) ProtoMessage() + func (x *TxnLookupRequest) GetTxnHash() *types.H256 + func (x *TxnLookupRequest) ProtoReflect() protoreflect.Message + func (x *TxnLookupRequest) Reset() + func (x *TxnLookupRequest) String() string + type UnimplementedETHBACKENDServer struct + func (UnimplementedETHBACKENDServer) AddPeer(context.Context, *AddPeerRequest) (*AddPeerReply, error) + func (UnimplementedETHBACKENDServer) Block(context.Context, *BlockRequest) (*BlockReply, error) + func (UnimplementedETHBACKENDServer) BorEvent(context.Context, *BorEventRequest) (*BorEventReply, error) + func (UnimplementedETHBACKENDServer) ClientVersion(context.Context, *ClientVersionRequest) (*ClientVersionReply, error) + func (UnimplementedETHBACKENDServer) Etherbase(context.Context, *EtherbaseRequest) (*EtherbaseReply, error) + func (UnimplementedETHBACKENDServer) NetPeerCount(context.Context, *NetPeerCountRequest) (*NetPeerCountReply, error) + func (UnimplementedETHBACKENDServer) NetVersion(context.Context, *NetVersionRequest) (*NetVersionReply, error) + func (UnimplementedETHBACKENDServer) NodeInfo(context.Context, *NodesInfoRequest) (*NodesInfoReply, error) + func (UnimplementedETHBACKENDServer) Peers(context.Context, *emptypb.Empty) (*PeersReply, error) + func (UnimplementedETHBACKENDServer) PendingBlock(context.Context, *emptypb.Empty) (*PendingBlockReply, error) + func (UnimplementedETHBACKENDServer) ProtocolVersion(context.Context, *ProtocolVersionRequest) (*ProtocolVersionReply, error) + func (UnimplementedETHBACKENDServer) Subscribe(*SubscribeRequest, ETHBACKEND_SubscribeServer) error + func (UnimplementedETHBACKENDServer) SubscribeLogs(ETHBACKEND_SubscribeLogsServer) error + func (UnimplementedETHBACKENDServer) TxnLookup(context.Context, *TxnLookupRequest) (*TxnLookupReply, error) + func (UnimplementedETHBACKENDServer) Version(context.Context, *emptypb.Empty) (*types.VersionReply, error) + type UnimplementedKVServer struct + func (UnimplementedKVServer) DomainGet(context.Context, *DomainGetReq) (*DomainGetReply, error) + func (UnimplementedKVServer) DomainRange(context.Context, *DomainRangeReq) (*Pairs, error) + func (UnimplementedKVServer) HistoryGet(context.Context, *HistoryGetReq) (*HistoryGetReply, error) + func (UnimplementedKVServer) HistoryRange(context.Context, *HistoryRangeReq) (*Pairs, error) + func (UnimplementedKVServer) IndexRange(context.Context, *IndexRangeReq) (*IndexRangeReply, error) + func (UnimplementedKVServer) Range(context.Context, *RangeReq) (*Pairs, error) + func (UnimplementedKVServer) Snapshots(context.Context, *SnapshotsRequest) (*SnapshotsReply, error) + func (UnimplementedKVServer) StateChanges(*StateChangeRequest, KV_StateChangesServer) error + func (UnimplementedKVServer) Tx(KV_TxServer) error + func (UnimplementedKVServer) Version(context.Context, *emptypb.Empty) (*types.VersionReply, error) + type UnsafeETHBACKENDServer interface + type UnsafeKVServer interface