Documentation ¶
Index ¶
- Constants
- Variables
- func NodeInfoReplyCmp(i, j *types.NodeInfoReply) int
- func RegisterETHBACKENDServer(s grpc.ServiceRegistrar, srv ETHBACKENDServer)
- func RegisterKVServer(s grpc.ServiceRegistrar, srv KVServer)
- type AccountChange
- func (*AccountChange) Descriptor() ([]byte, []int)deprecated
- 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 (*AccountChange) ProtoMessage()
- func (x *AccountChange) ProtoReflect() protoreflect.Message
- func (x *AccountChange) Reset()
- func (x *AccountChange) String() string
- type Action
- type AddPeerReply
- type AddPeerRequest
- type BlockReply
- type BlockRequest
- func (*BlockRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BlockRequest) GetBlockHash() *types.H256
- func (x *BlockRequest) GetBlockHeight() uint64
- func (*BlockRequest) ProtoMessage()
- func (x *BlockRequest) ProtoReflect() protoreflect.Message
- func (x *BlockRequest) Reset()
- func (x *BlockRequest) String() string
- type BorEventReply
- func (*BorEventReply) Descriptor() ([]byte, []int)deprecated
- func (x *BorEventReply) GetBlockNumber() uint64
- func (x *BorEventReply) GetEventRlps() [][]byte
- func (x *BorEventReply) GetPresent() bool
- func (*BorEventReply) ProtoMessage()
- func (x *BorEventReply) ProtoReflect() protoreflect.Message
- func (x *BorEventReply) Reset()
- func (x *BorEventReply) String() string
- type BorEventRequest
- type ClientVersionReply
- func (*ClientVersionReply) Descriptor() ([]byte, []int)deprecated
- func (x *ClientVersionReply) GetNodeName() string
- func (*ClientVersionReply) ProtoMessage()
- func (x *ClientVersionReply) ProtoReflect() protoreflect.Message
- func (x *ClientVersionReply) Reset()
- func (x *ClientVersionReply) String() string
- type ClientVersionRequest
- type Cursor
- func (*Cursor) Descriptor() ([]byte, []int)deprecated
- 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 (*Cursor) ProtoMessage()
- func (x *Cursor) ProtoReflect() protoreflect.Message
- func (x *Cursor) Reset()
- func (x *Cursor) String() string
- type Direction
- type DomainGetReply
- func (*DomainGetReply) Descriptor() ([]byte, []int)deprecated
- func (x *DomainGetReply) GetOk() bool
- func (x *DomainGetReply) GetV() []byte
- func (*DomainGetReply) ProtoMessage()
- func (x *DomainGetReply) ProtoReflect() protoreflect.Message
- func (x *DomainGetReply) Reset()
- func (x *DomainGetReply) String() string
- type DomainGetReq
- func (*DomainGetReq) Descriptor() ([]byte, []int)deprecated
- 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 (*DomainGetReq) ProtoMessage()
- func (x *DomainGetReq) ProtoReflect() protoreflect.Message
- func (x *DomainGetReq) Reset()
- func (x *DomainGetReq) String() string
- type DomainRangeReq
- func (*DomainRangeReq) Descriptor() ([]byte, []int)deprecated
- 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 (*DomainRangeReq) ProtoMessage()
- func (x *DomainRangeReq) ProtoReflect() protoreflect.Message
- func (x *DomainRangeReq) Reset()
- func (x *DomainRangeReq) String() string
- type ETHBACKENDClient
- type ETHBACKENDServer
- type ETHBACKEND_SubscribeClient
- type ETHBACKEND_SubscribeLogsClient
- type ETHBACKEND_SubscribeLogsServer
- type ETHBACKEND_SubscribeServer
- type EngineGetPayloadBodiesByHashV1Request
- func (*EngineGetPayloadBodiesByHashV1Request) Descriptor() ([]byte, []int)deprecated
- func (x *EngineGetPayloadBodiesByHashV1Request) GetHashes() []*types.H256
- func (*EngineGetPayloadBodiesByHashV1Request) ProtoMessage()
- func (x *EngineGetPayloadBodiesByHashV1Request) ProtoReflect() protoreflect.Message
- func (x *EngineGetPayloadBodiesByHashV1Request) Reset()
- func (x *EngineGetPayloadBodiesByHashV1Request) String() string
- type EngineGetPayloadBodiesByRangeV1Request
- func (*EngineGetPayloadBodiesByRangeV1Request) Descriptor() ([]byte, []int)deprecated
- func (x *EngineGetPayloadBodiesByRangeV1Request) GetCount() uint64
- func (x *EngineGetPayloadBodiesByRangeV1Request) GetStart() uint64
- func (*EngineGetPayloadBodiesByRangeV1Request) ProtoMessage()
- func (x *EngineGetPayloadBodiesByRangeV1Request) ProtoReflect() protoreflect.Message
- func (x *EngineGetPayloadBodiesByRangeV1Request) Reset()
- func (x *EngineGetPayloadBodiesByRangeV1Request) String() string
- type EtherbaseReply
- type EtherbaseRequest
- type Event
- type HistoryGetReply
- func (*HistoryGetReply) Descriptor() ([]byte, []int)deprecated
- func (x *HistoryGetReply) GetOk() bool
- func (x *HistoryGetReply) GetV() []byte
- func (*HistoryGetReply) ProtoMessage()
- func (x *HistoryGetReply) ProtoReflect() protoreflect.Message
- func (x *HistoryGetReply) Reset()
- func (x *HistoryGetReply) String() string
- type HistoryGetReq
- func (*HistoryGetReq) Descriptor() ([]byte, []int)deprecated
- func (x *HistoryGetReq) GetK() []byte
- func (x *HistoryGetReq) GetTable() string
- func (x *HistoryGetReq) GetTs() uint64
- func (x *HistoryGetReq) GetTxId() uint64
- func (*HistoryGetReq) ProtoMessage()
- func (x *HistoryGetReq) ProtoReflect() protoreflect.Message
- func (x *HistoryGetReq) Reset()
- func (x *HistoryGetReq) String() string
- type HistoryRangeReq
- func (*HistoryRangeReq) Descriptor() ([]byte, []int)deprecated
- 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 (*HistoryRangeReq) ProtoMessage()
- func (x *HistoryRangeReq) ProtoReflect() protoreflect.Message
- func (x *HistoryRangeReq) Reset()
- func (x *HistoryRangeReq) String() string
- type IndexPagination
- func (*IndexPagination) Descriptor() ([]byte, []int)deprecated
- func (x *IndexPagination) GetLimit() int64
- func (x *IndexPagination) GetNextTimeStamp() int64
- func (*IndexPagination) ProtoMessage()
- func (x *IndexPagination) ProtoReflect() protoreflect.Message
- func (x *IndexPagination) Reset()
- func (x *IndexPagination) String() string
- type IndexRangeReply
- func (*IndexRangeReply) Descriptor() ([]byte, []int)deprecated
- func (x *IndexRangeReply) GetNextPageToken() string
- func (x *IndexRangeReply) GetTimestamps() []uint64
- func (*IndexRangeReply) ProtoMessage()
- func (x *IndexRangeReply) ProtoReflect() protoreflect.Message
- func (x *IndexRangeReply) Reset()
- func (x *IndexRangeReply) String() string
- type IndexRangeReq
- func (*IndexRangeReq) Descriptor() ([]byte, []int)deprecated
- 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 (*IndexRangeReq) ProtoMessage()
- func (x *IndexRangeReq) ProtoReflect() protoreflect.Message
- func (x *IndexRangeReq) Reset()
- func (x *IndexRangeReq) String() string
- type KVClient
- type KVClientMock
- 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
- type KV_StateChangesClient
- type KV_StateChangesClientMock
- 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
- type KV_TxClient
- type KV_TxServer
- type LogsFilterRequest
- func (*LogsFilterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LogsFilterRequest) GetAddresses() []*types.H160
- func (x *LogsFilterRequest) GetAllAddresses() bool
- func (x *LogsFilterRequest) GetAllTopics() bool
- func (x *LogsFilterRequest) GetTopics() []*types.H256
- func (*LogsFilterRequest) ProtoMessage()
- func (x *LogsFilterRequest) ProtoReflect() protoreflect.Message
- func (x *LogsFilterRequest) Reset()
- func (x *LogsFilterRequest) String() string
- type NetPeerCountReply
- type NetPeerCountRequest
- type NetVersionReply
- type NetVersionRequest
- type NodesInfoReply
- type NodesInfoRequest
- type Op
- type Pair
- func (*Pair) Descriptor() ([]byte, []int)deprecated
- 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 (*Pair) ProtoMessage()
- func (x *Pair) ProtoReflect() protoreflect.Message
- func (x *Pair) Reset()
- func (x *Pair) String() string
- type Pairs
- func (*Pairs) Descriptor() ([]byte, []int)deprecated
- func (x *Pairs) GetKeys() [][]byte
- func (x *Pairs) GetNextPageToken() string
- func (x *Pairs) GetValues() [][]byte
- func (*Pairs) ProtoMessage()
- func (x *Pairs) ProtoReflect() protoreflect.Message
- func (x *Pairs) Reset()
- func (x *Pairs) String() string
- type ParisPagination
- func (*ParisPagination) Descriptor() ([]byte, []int)deprecated
- func (x *ParisPagination) GetLimit() int64
- func (x *ParisPagination) GetNextKey() []byte
- func (*ParisPagination) ProtoMessage()
- func (x *ParisPagination) ProtoReflect() protoreflect.Message
- func (x *ParisPagination) Reset()
- func (x *ParisPagination) String() string
- type PeersReply
- type PendingBlockReply
- type ProtocolVersionReply
- func (*ProtocolVersionReply) Descriptor() ([]byte, []int)deprecated
- func (x *ProtocolVersionReply) GetId() uint64
- func (*ProtocolVersionReply) ProtoMessage()
- func (x *ProtocolVersionReply) ProtoReflect() protoreflect.Message
- func (x *ProtocolVersionReply) Reset()
- func (x *ProtocolVersionReply) String() string
- type ProtocolVersionRequest
- type RangeReq
- func (*RangeReq) Descriptor() ([]byte, []int)deprecated
- 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 (*RangeReq) ProtoMessage()
- func (x *RangeReq) ProtoReflect() protoreflect.Message
- func (x *RangeReq) Reset()
- func (x *RangeReq) String() string
- type SnapshotsReply
- func (*SnapshotsReply) Descriptor() ([]byte, []int)deprecated
- func (x *SnapshotsReply) GetBlocksFiles() []string
- func (x *SnapshotsReply) GetHistoryFiles() []string
- func (*SnapshotsReply) ProtoMessage()
- func (x *SnapshotsReply) ProtoReflect() protoreflect.Message
- func (x *SnapshotsReply) Reset()
- func (x *SnapshotsReply) String() string
- type SnapshotsRequest
- type StateChange
- func (*StateChange) Descriptor() ([]byte, []int)deprecated
- 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 (*StateChange) ProtoMessage()
- func (x *StateChange) ProtoReflect() protoreflect.Message
- func (x *StateChange) Reset()
- func (x *StateChange) String() string
- type StateChangeBatch
- func (*StateChangeBatch) Descriptor() ([]byte, []int)deprecated
- 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 (*StateChangeBatch) ProtoMessage()
- func (x *StateChangeBatch) ProtoReflect() protoreflect.Message
- func (x *StateChangeBatch) Reset()
- func (x *StateChangeBatch) String() string
- type StateChangeRequest
- func (*StateChangeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StateChangeRequest) GetWithStorage() bool
- func (x *StateChangeRequest) GetWithTransactions() bool
- func (*StateChangeRequest) ProtoMessage()
- func (x *StateChangeRequest) ProtoReflect() protoreflect.Message
- func (x *StateChangeRequest) Reset()
- func (x *StateChangeRequest) String() string
- type StorageChange
- func (*StorageChange) Descriptor() ([]byte, []int)deprecated
- func (x *StorageChange) GetData() []byte
- func (x *StorageChange) GetLocation() *types.H256
- func (*StorageChange) ProtoMessage()
- func (x *StorageChange) ProtoReflect() protoreflect.Message
- func (x *StorageChange) Reset()
- func (x *StorageChange) String() string
- type SubscribeLogsReply
- func (*SubscribeLogsReply) Descriptor() ([]byte, []int)deprecated
- 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 (*SubscribeLogsReply) ProtoMessage()
- func (x *SubscribeLogsReply) ProtoReflect() protoreflect.Message
- func (x *SubscribeLogsReply) Reset()
- func (x *SubscribeLogsReply) String() string
- type SubscribeReply
- func (*SubscribeReply) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeReply) GetData() []byte
- func (x *SubscribeReply) GetType() Event
- func (*SubscribeReply) ProtoMessage()
- func (x *SubscribeReply) ProtoReflect() protoreflect.Message
- func (x *SubscribeReply) Reset()
- func (x *SubscribeReply) String() string
- type SubscribeRequest
- type TxnLookupReply
- type TxnLookupRequest
- type UnimplementedETHBACKENDServer
- 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
- 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
- type UnsafeKVServer
Constants ¶
const ( ETHBACKEND_Etherbase_FullMethodName = "/remote.ETHBACKEND/Etherbase" ETHBACKEND_NetVersion_FullMethodName = "/remote.ETHBACKEND/NetVersion" ETHBACKEND_NetPeerCount_FullMethodName = "/remote.ETHBACKEND/NetPeerCount" ETHBACKEND_Version_FullMethodName = "/remote.ETHBACKEND/Version" ETHBACKEND_ProtocolVersion_FullMethodName = "/remote.ETHBACKEND/ProtocolVersion" ETHBACKEND_ClientVersion_FullMethodName = "/remote.ETHBACKEND/ClientVersion" ETHBACKEND_Subscribe_FullMethodName = "/remote.ETHBACKEND/Subscribe" ETHBACKEND_SubscribeLogs_FullMethodName = "/remote.ETHBACKEND/SubscribeLogs" ETHBACKEND_Block_FullMethodName = "/remote.ETHBACKEND/Block" ETHBACKEND_TxnLookup_FullMethodName = "/remote.ETHBACKEND/TxnLookup" ETHBACKEND_NodeInfo_FullMethodName = "/remote.ETHBACKEND/NodeInfo" ETHBACKEND_Peers_FullMethodName = "/remote.ETHBACKEND/Peers" ETHBACKEND_AddPeer_FullMethodName = "/remote.ETHBACKEND/AddPeer" ETHBACKEND_PendingBlock_FullMethodName = "/remote.ETHBACKEND/PendingBlock" ETHBACKEND_BorEvent_FullMethodName = "/remote.ETHBACKEND/BorEvent" )
const ( KV_Version_FullMethodName = "/remote.KV/Version" KV_Tx_FullMethodName = "/remote.KV/Tx" KV_StateChanges_FullMethodName = "/remote.KV/StateChanges" KV_Snapshots_FullMethodName = "/remote.KV/Snapshots" KV_Range_FullMethodName = "/remote.KV/Range" KV_DomainGet_FullMethodName = "/remote.KV/DomainGet" KV_HistoryGet_FullMethodName = "/remote.KV/HistoryGet" KV_IndexRange_FullMethodName = "/remote.KV/IndexRange" KV_HistoryRange_FullMethodName = "/remote.KV/HistoryRange" KV_DomainRange_FullMethodName = "/remote.KV/DomainRange" )
Variables ¶
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.
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", 33: "COUNT", } 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, "COUNT": 33, } )
Enum value maps for Op.
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.
var ( Direction_name = map[int32]string{ 0: "FORWARD", 1: "UNWIND", } Direction_value = map[string]int32{ "FORWARD": 0, "UNWIND": 1, } )
Enum value maps for Direction.
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: "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: "AddPeer", Handler: _ETHBACKEND_AddPeer_Handler, }, { MethodName: "PendingBlock", Handler: _ETHBACKEND_PendingBlock_Handler, }, { MethodName: "BorEvent", Handler: _ETHBACKEND_BorEvent_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)
var File_remote_ethbackend_proto protoreflect.FileDescriptor
var File_remote_kv_proto protoreflect.FileDescriptor
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, }, { MethodName: "Range", Handler: _KV_Range_Handler, }, { MethodName: "DomainGet", Handler: _KV_DomainGet_Handler, }, { MethodName: "HistoryGet", Handler: _KV_HistoryGet_Handler, }, { MethodName: "IndexRange", Handler: _KV_IndexRange_Handler, }, { MethodName: "HistoryRange", Handler: _KV_HistoryRange_Handler, }, { MethodName: "DomainRange", Handler: _KV_DomainRange_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 NodeInfoReplyCmp ¶
func NodeInfoReplyCmp(i, j *types.NodeInfoReply) int
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=storage_changes,json=storageChanges,proto3" json:"storage_changes,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) EnumDescriptor
deprecated
func (Action) Number ¶
func (x Action) Number() protoreflect.EnumNumber
func (Action) Type ¶
func (Action) Type() protoreflect.EnumType
type AddPeerReply ¶
type AddPeerReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
func (*AddPeerReply) Descriptor
deprecated
func (*AddPeerReply) Descriptor() ([]byte, []int)
Deprecated: Use AddPeerReply.ProtoReflect.Descriptor instead.
func (*AddPeerReply) GetSuccess ¶
func (x *AddPeerReply) GetSuccess() bool
func (*AddPeerReply) ProtoMessage ¶
func (*AddPeerReply) ProtoMessage()
func (*AddPeerReply) ProtoReflect ¶
func (x *AddPeerReply) ProtoReflect() protoreflect.Message
func (*AddPeerReply) Reset ¶
func (x *AddPeerReply) Reset()
func (*AddPeerReply) String ¶
func (x *AddPeerReply) String() string
type AddPeerRequest ¶
type AddPeerRequest struct { Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` // contains filtered or unexported fields }
func (*AddPeerRequest) Descriptor
deprecated
func (*AddPeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddPeerRequest.ProtoReflect.Descriptor instead.
func (*AddPeerRequest) GetUrl ¶
func (x *AddPeerRequest) GetUrl() string
func (*AddPeerRequest) ProtoMessage ¶
func (*AddPeerRequest) ProtoMessage()
func (*AddPeerRequest) ProtoReflect ¶
func (x *AddPeerRequest) ProtoReflect() protoreflect.Message
func (*AddPeerRequest) Reset ¶
func (x *AddPeerRequest) Reset()
func (*AddPeerRequest) String ¶
func (x *AddPeerRequest) String() string
type BlockReply ¶
type BlockReply struct { BlockRlp []byte `protobuf:"bytes,1,opt,name=block_rlp,json=blockRlp,proto3" json:"block_rlp,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=block_height,json=blockHeight,proto3" json:"block_height,omitempty"` BlockHash *types.H256 `protobuf:"bytes,3,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,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 BorEventReply ¶
type BorEventReply struct { Present bool `protobuf:"varint,1,opt,name=present,proto3" json:"present,omitempty"` BlockNumber uint64 `protobuf:"varint,2,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"` EventRlps [][]byte `protobuf:"bytes,3,rep,name=event_rlps,json=eventRlps,proto3" json:"event_rlps,omitempty"` // contains filtered or unexported fields }
func (*BorEventReply) Descriptor
deprecated
func (*BorEventReply) Descriptor() ([]byte, []int)
Deprecated: Use BorEventReply.ProtoReflect.Descriptor instead.
func (*BorEventReply) GetBlockNumber ¶
func (x *BorEventReply) GetBlockNumber() uint64
func (*BorEventReply) GetEventRlps ¶
func (x *BorEventReply) GetEventRlps() [][]byte
func (*BorEventReply) GetPresent ¶
func (x *BorEventReply) GetPresent() bool
func (*BorEventReply) ProtoMessage ¶
func (*BorEventReply) ProtoMessage()
func (*BorEventReply) ProtoReflect ¶
func (x *BorEventReply) ProtoReflect() protoreflect.Message
func (*BorEventReply) Reset ¶
func (x *BorEventReply) Reset()
func (*BorEventReply) String ¶
func (x *BorEventReply) String() string
type BorEventRequest ¶
type BorEventRequest struct { BorTxHash *types.H256 `protobuf:"bytes,1,opt,name=bor_tx_hash,json=borTxHash,proto3" json:"bor_tx_hash,omitempty"` // contains filtered or unexported fields }
func (*BorEventRequest) Descriptor
deprecated
func (*BorEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use BorEventRequest.ProtoReflect.Descriptor instead.
func (*BorEventRequest) GetBorTxHash ¶
func (x *BorEventRequest) GetBorTxHash() *types.H256
func (*BorEventRequest) ProtoMessage ¶
func (*BorEventRequest) ProtoMessage()
func (*BorEventRequest) ProtoReflect ¶
func (x *BorEventRequest) ProtoReflect() protoreflect.Message
func (*BorEventRequest) Reset ¶
func (x *BorEventRequest) Reset()
func (*BorEventRequest) String ¶
func (x *BorEventRequest) String() string
type ClientVersionReply ¶
type ClientVersionReply struct { NodeName string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,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=bucket_name,json=bucketName,proto3" json:"bucket_name,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) GetBucketName ¶
func (*Cursor) ProtoMessage ¶
func (*Cursor) ProtoMessage()
func (*Cursor) ProtoReflect ¶
func (x *Cursor) ProtoReflect() protoreflect.Message
type Direction ¶
type Direction int32
func (Direction) Descriptor ¶
func (Direction) Descriptor() protoreflect.EnumDescriptor
func (Direction) EnumDescriptor
deprecated
func (Direction) Number ¶
func (x Direction) Number() protoreflect.EnumNumber
func (Direction) Type ¶
func (Direction) Type() protoreflect.EnumType
type DomainGetReply ¶
type DomainGetReply struct { V []byte `protobuf:"bytes,1,opt,name=v,proto3" json:"v,omitempty"` Ok bool `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"` // contains filtered or unexported fields }
func (*DomainGetReply) Descriptor
deprecated
func (*DomainGetReply) Descriptor() ([]byte, []int)
Deprecated: Use DomainGetReply.ProtoReflect.Descriptor instead.
func (*DomainGetReply) GetOk ¶
func (x *DomainGetReply) GetOk() bool
func (*DomainGetReply) GetV ¶
func (x *DomainGetReply) GetV() []byte
func (*DomainGetReply) ProtoMessage ¶
func (*DomainGetReply) ProtoMessage()
func (*DomainGetReply) ProtoReflect ¶
func (x *DomainGetReply) ProtoReflect() protoreflect.Message
func (*DomainGetReply) Reset ¶
func (x *DomainGetReply) Reset()
func (*DomainGetReply) String ¶
func (x *DomainGetReply) String() string
type DomainGetReq ¶
type DomainGetReq struct { TxId uint64 `protobuf:"varint,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` // returned by .Tx() // query params Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"` K []byte `protobuf:"bytes,3,opt,name=k,proto3" json:"k,omitempty"` Ts uint64 `protobuf:"varint,4,opt,name=ts,proto3" json:"ts,omitempty"` K2 []byte `protobuf:"bytes,5,opt,name=k2,proto3" json:"k2,omitempty"` Latest bool `protobuf:"varint,6,opt,name=latest,proto3" json:"latest,omitempty"` // if true, then `ts` ignored and return latest state (without history lookup) // contains filtered or unexported fields }
Temporal methods
func (*DomainGetReq) Descriptor
deprecated
func (*DomainGetReq) Descriptor() ([]byte, []int)
Deprecated: Use DomainGetReq.ProtoReflect.Descriptor instead.
func (*DomainGetReq) GetK ¶
func (x *DomainGetReq) GetK() []byte
func (*DomainGetReq) GetK2 ¶
func (x *DomainGetReq) GetK2() []byte
func (*DomainGetReq) GetLatest ¶
func (x *DomainGetReq) GetLatest() bool
func (*DomainGetReq) GetTable ¶
func (x *DomainGetReq) GetTable() string
func (*DomainGetReq) GetTs ¶
func (x *DomainGetReq) GetTs() uint64
func (*DomainGetReq) GetTxId ¶
func (x *DomainGetReq) GetTxId() uint64
func (*DomainGetReq) ProtoMessage ¶
func (*DomainGetReq) ProtoMessage()
func (*DomainGetReq) ProtoReflect ¶
func (x *DomainGetReq) ProtoReflect() protoreflect.Message
func (*DomainGetReq) Reset ¶
func (x *DomainGetReq) Reset()
func (*DomainGetReq) String ¶
func (x *DomainGetReq) String() string
type DomainRangeReq ¶
type DomainRangeReq struct { TxId uint64 `protobuf:"varint,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` // returned by .Tx() // query params Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"` FromKey []byte `protobuf:"bytes,3,opt,name=from_key,json=fromKey,proto3" json:"from_key,omitempty"` // nil means Inf ToKey []byte `protobuf:"bytes,4,opt,name=to_key,json=toKey,proto3" json:"to_key,omitempty"` // nil means Inf Ts uint64 `protobuf:"varint,5,opt,name=ts,proto3" json:"ts,omitempty"` Latest bool `protobuf:"varint,6,opt,name=latest,proto3" json:"latest,omitempty"` // if true, then `ts` ignored and return latest state (without history lookup) OrderAscend bool `protobuf:"varint,7,opt,name=order_ascend,json=orderAscend,proto3" json:"order_ascend,omitempty"` Limit int64 `protobuf:"zigzag64,8,opt,name=limit,proto3" json:"limit,omitempty"` // <= 0 means no limit // pagination params PageSize int32 `protobuf:"varint,9,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // <= 0 means server will choose PageToken string `protobuf:"bytes,10,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // contains filtered or unexported fields }
func (*DomainRangeReq) Descriptor
deprecated
func (*DomainRangeReq) Descriptor() ([]byte, []int)
Deprecated: Use DomainRangeReq.ProtoReflect.Descriptor instead.
func (*DomainRangeReq) GetFromKey ¶
func (x *DomainRangeReq) GetFromKey() []byte
func (*DomainRangeReq) GetLatest ¶
func (x *DomainRangeReq) GetLatest() bool
func (*DomainRangeReq) GetLimit ¶
func (x *DomainRangeReq) GetLimit() int64
func (*DomainRangeReq) GetOrderAscend ¶
func (x *DomainRangeReq) GetOrderAscend() bool
func (*DomainRangeReq) GetPageSize ¶
func (x *DomainRangeReq) GetPageSize() int32
func (*DomainRangeReq) GetPageToken ¶
func (x *DomainRangeReq) GetPageToken() string
func (*DomainRangeReq) GetTable ¶
func (x *DomainRangeReq) GetTable() string
func (*DomainRangeReq) GetToKey ¶
func (x *DomainRangeReq) GetToKey() []byte
func (*DomainRangeReq) GetTs ¶
func (x *DomainRangeReq) GetTs() uint64
func (*DomainRangeReq) GetTxId ¶
func (x *DomainRangeReq) GetTxId() uint64
func (*DomainRangeReq) ProtoMessage ¶
func (*DomainRangeReq) ProtoMessage()
func (*DomainRangeReq) ProtoReflect ¶
func (x *DomainRangeReq) ProtoReflect() protoreflect.Message
func (*DomainRangeReq) Reset ¶
func (x *DomainRangeReq) Reset()
func (*DomainRangeReq) String ¶
func (x *DomainRangeReq) String() string
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) // 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) AddPeer(ctx context.Context, in *AddPeerRequest, opts ...grpc.CallOption) (*AddPeerReply, error) // PendingBlock returns latest built block. PendingBlock(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PendingBlockReply, error) BorEvent(ctx context.Context, in *BorEventRequest, opts ...grpc.CallOption) (*BorEventReply, 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) // 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) AddPeer(context.Context, *AddPeerRequest) (*AddPeerReply, error) // PendingBlock returns latest built block. PendingBlock(context.Context, *emptypb.Empty) (*PendingBlockReply, error) BorEvent(context.Context, *BorEventRequest) (*BorEventReply, 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 EngineGetPayloadBodiesByHashV1Request ¶
type EngineGetPayloadBodiesByHashV1Request struct { Hashes []*types.H256 `protobuf:"bytes,1,rep,name=hashes,proto3" json:"hashes,omitempty"` // contains filtered or unexported fields }
func (*EngineGetPayloadBodiesByHashV1Request) Descriptor
deprecated
func (*EngineGetPayloadBodiesByHashV1Request) Descriptor() ([]byte, []int)
Deprecated: Use EngineGetPayloadBodiesByHashV1Request.ProtoReflect.Descriptor instead.
func (*EngineGetPayloadBodiesByHashV1Request) GetHashes ¶
func (x *EngineGetPayloadBodiesByHashV1Request) GetHashes() []*types.H256
func (*EngineGetPayloadBodiesByHashV1Request) ProtoMessage ¶
func (*EngineGetPayloadBodiesByHashV1Request) ProtoMessage()
func (*EngineGetPayloadBodiesByHashV1Request) ProtoReflect ¶
func (x *EngineGetPayloadBodiesByHashV1Request) ProtoReflect() protoreflect.Message
func (*EngineGetPayloadBodiesByHashV1Request) Reset ¶
func (x *EngineGetPayloadBodiesByHashV1Request) Reset()
func (*EngineGetPayloadBodiesByHashV1Request) String ¶
func (x *EngineGetPayloadBodiesByHashV1Request) String() string
type EngineGetPayloadBodiesByRangeV1Request ¶
type EngineGetPayloadBodiesByRangeV1Request struct { Start uint64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"` Count uint64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*EngineGetPayloadBodiesByRangeV1Request) Descriptor
deprecated
func (*EngineGetPayloadBodiesByRangeV1Request) Descriptor() ([]byte, []int)
Deprecated: Use EngineGetPayloadBodiesByRangeV1Request.ProtoReflect.Descriptor instead.
func (*EngineGetPayloadBodiesByRangeV1Request) GetCount ¶
func (x *EngineGetPayloadBodiesByRangeV1Request) GetCount() uint64
func (*EngineGetPayloadBodiesByRangeV1Request) GetStart ¶
func (x *EngineGetPayloadBodiesByRangeV1Request) GetStart() uint64
func (*EngineGetPayloadBodiesByRangeV1Request) ProtoMessage ¶
func (*EngineGetPayloadBodiesByRangeV1Request) ProtoMessage()
func (*EngineGetPayloadBodiesByRangeV1Request) ProtoReflect ¶
func (x *EngineGetPayloadBodiesByRangeV1Request) ProtoReflect() protoreflect.Message
func (*EngineGetPayloadBodiesByRangeV1Request) Reset ¶
func (x *EngineGetPayloadBodiesByRangeV1Request) Reset()
func (*EngineGetPayloadBodiesByRangeV1Request) String ¶
func (x *EngineGetPayloadBodiesByRangeV1Request) String() string
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) EnumDescriptor
deprecated
func (Event) Number ¶
func (x Event) Number() protoreflect.EnumNumber
func (Event) Type ¶
func (Event) Type() protoreflect.EnumType
type HistoryGetReply ¶
type HistoryGetReply struct { V []byte `protobuf:"bytes,1,opt,name=v,proto3" json:"v,omitempty"` Ok bool `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"` // contains filtered or unexported fields }
func (*HistoryGetReply) Descriptor
deprecated
func (*HistoryGetReply) Descriptor() ([]byte, []int)
Deprecated: Use HistoryGetReply.ProtoReflect.Descriptor instead.
func (*HistoryGetReply) GetOk ¶
func (x *HistoryGetReply) GetOk() bool
func (*HistoryGetReply) GetV ¶
func (x *HistoryGetReply) GetV() []byte
func (*HistoryGetReply) ProtoMessage ¶
func (*HistoryGetReply) ProtoMessage()
func (*HistoryGetReply) ProtoReflect ¶
func (x *HistoryGetReply) ProtoReflect() protoreflect.Message
func (*HistoryGetReply) Reset ¶
func (x *HistoryGetReply) Reset()
func (*HistoryGetReply) String ¶
func (x *HistoryGetReply) String() string
type HistoryGetReq ¶
type HistoryGetReq struct { TxId uint64 `protobuf:"varint,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` // returned by .Tx() Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"` K []byte `protobuf:"bytes,3,opt,name=k,proto3" json:"k,omitempty"` Ts uint64 `protobuf:"varint,4,opt,name=ts,proto3" json:"ts,omitempty"` // contains filtered or unexported fields }
func (*HistoryGetReq) Descriptor
deprecated
func (*HistoryGetReq) Descriptor() ([]byte, []int)
Deprecated: Use HistoryGetReq.ProtoReflect.Descriptor instead.
func (*HistoryGetReq) GetK ¶
func (x *HistoryGetReq) GetK() []byte
func (*HistoryGetReq) GetTable ¶
func (x *HistoryGetReq) GetTable() string
func (*HistoryGetReq) GetTs ¶
func (x *HistoryGetReq) GetTs() uint64
func (*HistoryGetReq) GetTxId ¶
func (x *HistoryGetReq) GetTxId() uint64
func (*HistoryGetReq) ProtoMessage ¶
func (*HistoryGetReq) ProtoMessage()
func (*HistoryGetReq) ProtoReflect ¶
func (x *HistoryGetReq) ProtoReflect() protoreflect.Message
func (*HistoryGetReq) Reset ¶
func (x *HistoryGetReq) Reset()
func (*HistoryGetReq) String ¶
func (x *HistoryGetReq) String() string
type HistoryRangeReq ¶
type HistoryRangeReq struct { TxId uint64 `protobuf:"varint,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` // returned by .Tx() // query params Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"` FromTs int64 `protobuf:"zigzag64,4,opt,name=from_ts,json=fromTs,proto3" json:"from_ts,omitempty"` // -1 means Inf ToTs int64 `protobuf:"zigzag64,5,opt,name=to_ts,json=toTs,proto3" json:"to_ts,omitempty"` // -1 means Inf OrderAscend bool `protobuf:"varint,6,opt,name=order_ascend,json=orderAscend,proto3" json:"order_ascend,omitempty"` Limit int64 `protobuf:"zigzag64,7,opt,name=limit,proto3" json:"limit,omitempty"` // <= 0 means no limit // pagination params PageSize int32 `protobuf:"varint,8,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // <= 0 means server will choose PageToken string `protobuf:"bytes,9,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // contains filtered or unexported fields }
func (*HistoryRangeReq) Descriptor
deprecated
func (*HistoryRangeReq) Descriptor() ([]byte, []int)
Deprecated: Use HistoryRangeReq.ProtoReflect.Descriptor instead.
func (*HistoryRangeReq) GetFromTs ¶
func (x *HistoryRangeReq) GetFromTs() int64
func (*HistoryRangeReq) GetLimit ¶
func (x *HistoryRangeReq) GetLimit() int64
func (*HistoryRangeReq) GetOrderAscend ¶
func (x *HistoryRangeReq) GetOrderAscend() bool
func (*HistoryRangeReq) GetPageSize ¶
func (x *HistoryRangeReq) GetPageSize() int32
func (*HistoryRangeReq) GetPageToken ¶
func (x *HistoryRangeReq) GetPageToken() string
func (*HistoryRangeReq) GetTable ¶
func (x *HistoryRangeReq) GetTable() string
func (*HistoryRangeReq) GetToTs ¶
func (x *HistoryRangeReq) GetToTs() int64
func (*HistoryRangeReq) GetTxId ¶
func (x *HistoryRangeReq) GetTxId() uint64
func (*HistoryRangeReq) ProtoMessage ¶
func (*HistoryRangeReq) ProtoMessage()
func (*HistoryRangeReq) ProtoReflect ¶
func (x *HistoryRangeReq) ProtoReflect() protoreflect.Message
func (*HistoryRangeReq) Reset ¶
func (x *HistoryRangeReq) Reset()
func (*HistoryRangeReq) String ¶
func (x *HistoryRangeReq) String() string
type IndexPagination ¶
type IndexPagination struct { NextTimeStamp int64 `protobuf:"zigzag64,1,opt,name=next_time_stamp,json=nextTimeStamp,proto3" json:"next_time_stamp,omitempty"` Limit int64 `protobuf:"zigzag64,2,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*IndexPagination) Descriptor
deprecated
func (*IndexPagination) Descriptor() ([]byte, []int)
Deprecated: Use IndexPagination.ProtoReflect.Descriptor instead.
func (*IndexPagination) GetLimit ¶
func (x *IndexPagination) GetLimit() int64
func (*IndexPagination) GetNextTimeStamp ¶
func (x *IndexPagination) GetNextTimeStamp() int64
func (*IndexPagination) ProtoMessage ¶
func (*IndexPagination) ProtoMessage()
func (*IndexPagination) ProtoReflect ¶
func (x *IndexPagination) ProtoReflect() protoreflect.Message
func (*IndexPagination) Reset ¶
func (x *IndexPagination) Reset()
func (*IndexPagination) String ¶
func (x *IndexPagination) String() string
type IndexRangeReply ¶
type IndexRangeReply struct { Timestamps []uint64 `protobuf:"varint,1,rep,packed,name=timestamps,proto3" json:"timestamps,omitempty"` //TODO: it can be a bitmap NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
func (*IndexRangeReply) Descriptor
deprecated
func (*IndexRangeReply) Descriptor() ([]byte, []int)
Deprecated: Use IndexRangeReply.ProtoReflect.Descriptor instead.
func (*IndexRangeReply) GetNextPageToken ¶
func (x *IndexRangeReply) GetNextPageToken() string
func (*IndexRangeReply) GetTimestamps ¶
func (x *IndexRangeReply) GetTimestamps() []uint64
func (*IndexRangeReply) ProtoMessage ¶
func (*IndexRangeReply) ProtoMessage()
func (*IndexRangeReply) ProtoReflect ¶
func (x *IndexRangeReply) ProtoReflect() protoreflect.Message
func (*IndexRangeReply) Reset ¶
func (x *IndexRangeReply) Reset()
func (*IndexRangeReply) String ¶
func (x *IndexRangeReply) String() string
type IndexRangeReq ¶
type IndexRangeReq struct { TxId uint64 `protobuf:"varint,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` // returned by .Tx() // query params Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"` K []byte `protobuf:"bytes,3,opt,name=k,proto3" json:"k,omitempty"` FromTs int64 `protobuf:"zigzag64,4,opt,name=from_ts,json=fromTs,proto3" json:"from_ts,omitempty"` // -1 means Inf ToTs int64 `protobuf:"zigzag64,5,opt,name=to_ts,json=toTs,proto3" json:"to_ts,omitempty"` // -1 means Inf OrderAscend bool `protobuf:"varint,6,opt,name=order_ascend,json=orderAscend,proto3" json:"order_ascend,omitempty"` Limit int64 `protobuf:"zigzag64,7,opt,name=limit,proto3" json:"limit,omitempty"` // <= 0 means no limit // pagination params PageSize int32 `protobuf:"varint,8,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // <= 0 means server will choose PageToken string `protobuf:"bytes,9,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // contains filtered or unexported fields }
func (*IndexRangeReq) Descriptor
deprecated
func (*IndexRangeReq) Descriptor() ([]byte, []int)
Deprecated: Use IndexRangeReq.ProtoReflect.Descriptor instead.
func (*IndexRangeReq) GetFromTs ¶
func (x *IndexRangeReq) GetFromTs() int64
func (*IndexRangeReq) GetK ¶
func (x *IndexRangeReq) GetK() []byte
func (*IndexRangeReq) GetLimit ¶
func (x *IndexRangeReq) GetLimit() int64
func (*IndexRangeReq) GetOrderAscend ¶
func (x *IndexRangeReq) GetOrderAscend() bool
func (*IndexRangeReq) GetPageSize ¶
func (x *IndexRangeReq) GetPageSize() int32
func (*IndexRangeReq) GetPageToken ¶
func (x *IndexRangeReq) GetPageToken() string
func (*IndexRangeReq) GetTable ¶
func (x *IndexRangeReq) GetTable() string
func (*IndexRangeReq) GetToTs ¶
func (x *IndexRangeReq) GetToTs() int64
func (*IndexRangeReq) GetTxId ¶
func (x *IndexRangeReq) GetTxId() uint64
func (*IndexRangeReq) ProtoMessage ¶
func (*IndexRangeReq) ProtoMessage()
func (*IndexRangeReq) ProtoReflect ¶
func (x *IndexRangeReq) ProtoReflect() protoreflect.Message
func (*IndexRangeReq) Reset ¶
func (x *IndexRangeReq) Reset()
func (*IndexRangeReq) String ¶
func (x *IndexRangeReq) String() string
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) // Range [from, to) // Range(from, nil) means [from, EndOfTable) // Range(nil, to) means [StartOfTable, to) // If orderAscend=false server expecting `from`<`to`. Example: Range("B", "A") Range(ctx context.Context, in *RangeReq, opts ...grpc.CallOption) (*Pairs, error) // Temporal methods DomainGet(ctx context.Context, in *DomainGetReq, opts ...grpc.CallOption) (*DomainGetReply, error) HistoryGet(ctx context.Context, in *HistoryGetReq, opts ...grpc.CallOption) (*HistoryGetReply, error) IndexRange(ctx context.Context, in *IndexRangeReq, opts ...grpc.CallOption) (*IndexRangeReply, error) HistoryRange(ctx context.Context, in *HistoryRangeReq, opts ...grpc.CallOption) (*Pairs, error) DomainRange(ctx context.Context, in *DomainRangeReq, opts ...grpc.CallOption) (*Pairs, 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 { // DomainGetFunc mocks the DomainGet method. DomainGetFunc func(ctx context.Context, in *DomainGetReq, opts ...grpc.CallOption) (*DomainGetReply, error) // DomainRangeFunc mocks the DomainRange method. DomainRangeFunc func(ctx context.Context, in *DomainRangeReq, opts ...grpc.CallOption) (*Pairs, error) // HistoryGetFunc mocks the HistoryGet method. HistoryGetFunc func(ctx context.Context, in *HistoryGetReq, opts ...grpc.CallOption) (*HistoryGetReply, error) // HistoryRangeFunc mocks the HistoryRange method. HistoryRangeFunc func(ctx context.Context, in *HistoryRangeReq, opts ...grpc.CallOption) (*Pairs, error) // IndexRangeFunc mocks the IndexRange method. IndexRangeFunc func(ctx context.Context, in *IndexRangeReq, opts ...grpc.CallOption) (*IndexRangeReply, error) // RangeFunc mocks the Range method. RangeFunc func(ctx context.Context, in *RangeReq, opts ...grpc.CallOption) (*Pairs, error) // 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{ DomainGetFunc: func(ctx context.Context, in *DomainGetReq, opts ...grpc.CallOption) (*DomainGetReply, error) { panic("mock out the DomainGet method") }, DomainRangeFunc: func(ctx context.Context, in *DomainRangeReq, opts ...grpc.CallOption) (*Pairs, error) { panic("mock out the DomainRange method") }, HistoryGetFunc: func(ctx context.Context, in *HistoryGetReq, opts ...grpc.CallOption) (*HistoryGetReply, error) { panic("mock out the HistoryGet method") }, HistoryRangeFunc: func(ctx context.Context, in *HistoryRangeReq, opts ...grpc.CallOption) (*Pairs, error) { panic("mock out the HistoryRange method") }, IndexRangeFunc: func(ctx context.Context, in *IndexRangeReq, opts ...grpc.CallOption) (*IndexRangeReply, error) { panic("mock out the IndexRange method") }, RangeFunc: func(ctx context.Context, in *RangeReq, opts ...grpc.CallOption) (*Pairs, error) { panic("mock out the Range method") }, 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) DomainGet ¶
func (mock *KVClientMock) DomainGet(ctx context.Context, in *DomainGetReq, opts ...grpc.CallOption) (*DomainGetReply, error)
DomainGet calls DomainGetFunc.
func (*KVClientMock) DomainGetCalls ¶
func (mock *KVClientMock) DomainGetCalls() []struct { Ctx context.Context In *DomainGetReq Opts []grpc.CallOption }
DomainGetCalls gets all the calls that were made to DomainGet. Check the length with:
len(mockedKVClient.DomainGetCalls())
func (*KVClientMock) DomainRange ¶
func (mock *KVClientMock) DomainRange(ctx context.Context, in *DomainRangeReq, opts ...grpc.CallOption) (*Pairs, error)
DomainRange calls DomainRangeFunc.
func (*KVClientMock) DomainRangeCalls ¶
func (mock *KVClientMock) DomainRangeCalls() []struct { Ctx context.Context In *DomainRangeReq Opts []grpc.CallOption }
DomainRangeCalls gets all the calls that were made to DomainRange. Check the length with:
len(mockedKVClient.DomainRangeCalls())
func (*KVClientMock) HistoryGet ¶
func (mock *KVClientMock) HistoryGet(ctx context.Context, in *HistoryGetReq, opts ...grpc.CallOption) (*HistoryGetReply, error)
HistoryGet calls HistoryGetFunc.
func (*KVClientMock) HistoryGetCalls ¶
func (mock *KVClientMock) HistoryGetCalls() []struct { Ctx context.Context In *HistoryGetReq Opts []grpc.CallOption }
HistoryGetCalls gets all the calls that were made to HistoryGet. Check the length with:
len(mockedKVClient.HistoryGetCalls())
func (*KVClientMock) HistoryRange ¶
func (mock *KVClientMock) HistoryRange(ctx context.Context, in *HistoryRangeReq, opts ...grpc.CallOption) (*Pairs, error)
HistoryRange calls HistoryRangeFunc.
func (*KVClientMock) HistoryRangeCalls ¶
func (mock *KVClientMock) HistoryRangeCalls() []struct { Ctx context.Context In *HistoryRangeReq Opts []grpc.CallOption }
HistoryRangeCalls gets all the calls that were made to HistoryRange. Check the length with:
len(mockedKVClient.HistoryRangeCalls())
func (*KVClientMock) IndexRange ¶
func (mock *KVClientMock) IndexRange(ctx context.Context, in *IndexRangeReq, opts ...grpc.CallOption) (*IndexRangeReply, error)
IndexRange calls IndexRangeFunc.
func (*KVClientMock) IndexRangeCalls ¶
func (mock *KVClientMock) IndexRangeCalls() []struct { Ctx context.Context In *IndexRangeReq Opts []grpc.CallOption }
IndexRangeCalls gets all the calls that were made to IndexRange. Check the length with:
len(mockedKVClient.IndexRangeCalls())
func (*KVClientMock) Range ¶
func (mock *KVClientMock) Range(ctx context.Context, in *RangeReq, opts ...grpc.CallOption) (*Pairs, error)
Range calls RangeFunc.
func (*KVClientMock) RangeCalls ¶
func (mock *KVClientMock) RangeCalls() []struct { Ctx context.Context In *RangeReq Opts []grpc.CallOption }
RangeCalls gets all the calls that were made to Range. Check the length with:
len(mockedKVClient.RangeCalls())
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) // Range [from, to) // Range(from, nil) means [from, EndOfTable) // Range(nil, to) means [StartOfTable, to) // If orderAscend=false server expecting `from`<`to`. Example: Range("B", "A") Range(context.Context, *RangeReq) (*Pairs, error) // Temporal methods DomainGet(context.Context, *DomainGetReq) (*DomainGetReply, error) HistoryGet(context.Context, *HistoryGetReq) (*HistoryGetReply, error) IndexRange(context.Context, *IndexRangeReq) (*IndexRangeReply, error) HistoryRange(context.Context, *HistoryRangeReq) (*Pairs, error) DomainRange(context.Context, *DomainRangeReq) (*Pairs, 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 any) error // SendMsgFunc mocks the SendMsg method. SendMsgFunc func(m any) 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 any) error { panic("mock out the RecvMsg method") }, SendMsgFunc: func(m any) 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 any) error
RecvMsg calls RecvMsgFunc.
func (*KV_StateChangesClientMock) RecvMsgCalls ¶
func (mock *KV_StateChangesClientMock) RecvMsgCalls() []struct { M any }
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 any) error
SendMsg calls SendMsgFunc.
func (*KV_StateChangesClientMock) SendMsgCalls ¶
func (mock *KV_StateChangesClientMock) SendMsgCalls() []struct { M any }
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_TxServer ¶
type LogsFilterRequest ¶
type LogsFilterRequest struct { AllAddresses bool `protobuf:"varint,1,opt,name=all_addresses,json=allAddresses,proto3" json:"all_addresses,omitempty"` Addresses []*types.H160 `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"` AllTopics bool `protobuf:"varint,3,opt,name=all_topics,json=allTopics,proto3" json:"all_topics,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=nodes_info,json=nodesInfo,proto3" json:"nodes_info,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 Op_COUNT Op = 33 )
func (Op) Descriptor ¶
func (Op) Descriptor() protoreflect.EnumDescriptor
func (Op) EnumDescriptor
deprecated
func (Op) Number ¶
func (x Op) Number() protoreflect.EnumNumber
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=cursor_id,json=cursorId,proto3" json:"cursor_id,omitempty"` // send once after new cursor open ViewId uint64 `protobuf:"varint,4,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` // return once after tx open. mdbx's tx.ViewID() - id of write transaction in db TxId uint64 `protobuf:"varint,5,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` // return once after tx open. internal identifier - use it in other methods - to achieve consistant DB view (to read data from same DB tx on server). // contains filtered or unexported fields }
func (*Pair) Descriptor
deprecated
func (*Pair) GetCursorId ¶
func (*Pair) ProtoMessage ¶
func (*Pair) ProtoMessage()
func (*Pair) ProtoReflect ¶
func (x *Pair) ProtoReflect() protoreflect.Message
type Pairs ¶
type Pairs struct { Keys [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` // TODO: replace by lengtsh+arena? Anyway on server we need copy (serialization happening outside tx) Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"` NextPageToken string `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // uint32 estimateTotal = 3; // send once after stream creation // contains filtered or unexported fields }
func (*Pairs) Descriptor
deprecated
func (*Pairs) GetNextPageToken ¶
func (*Pairs) ProtoMessage ¶
func (*Pairs) ProtoMessage()
func (*Pairs) ProtoReflect ¶
func (x *Pairs) ProtoReflect() protoreflect.Message
type ParisPagination ¶
type ParisPagination struct { NextKey []byte `protobuf:"bytes,1,opt,name=next_key,json=nextKey,proto3" json:"next_key,omitempty"` Limit int64 `protobuf:"zigzag64,2,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*ParisPagination) Descriptor
deprecated
func (*ParisPagination) Descriptor() ([]byte, []int)
Deprecated: Use ParisPagination.ProtoReflect.Descriptor instead.
func (*ParisPagination) GetLimit ¶
func (x *ParisPagination) GetLimit() int64
func (*ParisPagination) GetNextKey ¶
func (x *ParisPagination) GetNextKey() []byte
func (*ParisPagination) ProtoMessage ¶
func (*ParisPagination) ProtoMessage()
func (*ParisPagination) ProtoReflect ¶
func (x *ParisPagination) ProtoReflect() protoreflect.Message
func (*ParisPagination) Reset ¶
func (x *ParisPagination) Reset()
func (*ParisPagination) String ¶
func (x *ParisPagination) 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=block_rlp,json=blockRlp,proto3" json:"block_rlp,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 RangeReq ¶
type RangeReq struct { TxId uint64 `protobuf:"varint,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"` // returned by .Tx() // query params Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"` FromPrefix []byte `protobuf:"bytes,3,opt,name=from_prefix,json=fromPrefix,proto3" json:"from_prefix,omitempty"` ToPrefix []byte `protobuf:"bytes,4,opt,name=to_prefix,json=toPrefix,proto3" json:"to_prefix,omitempty"` OrderAscend bool `protobuf:"varint,5,opt,name=order_ascend,json=orderAscend,proto3" json:"order_ascend,omitempty"` Limit int64 `protobuf:"zigzag64,6,opt,name=limit,proto3" json:"limit,omitempty"` // <= 0 means no limit // pagination params PageSize int32 `protobuf:"varint,7,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // <= 0 means server will choose PageToken string `protobuf:"bytes,8,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // contains filtered or unexported fields }
func (*RangeReq) Descriptor
deprecated
func (*RangeReq) GetFromPrefix ¶
func (*RangeReq) GetOrderAscend ¶
func (*RangeReq) GetPageSize ¶
func (*RangeReq) GetPageToken ¶
func (*RangeReq) GetToPrefix ¶
func (*RangeReq) ProtoMessage ¶
func (*RangeReq) ProtoMessage()
func (*RangeReq) ProtoReflect ¶
func (x *RangeReq) ProtoReflect() protoreflect.Message
type SnapshotsReply ¶
type SnapshotsReply struct { BlocksFiles []string `protobuf:"bytes,1,rep,name=blocks_files,json=blocksFiles,proto3" json:"blocks_files,omitempty"` HistoryFiles []string `protobuf:"bytes,2,rep,name=history_files,json=historyFiles,proto3" json:"history_files,omitempty"` // contains filtered or unexported fields }
func (*SnapshotsReply) Descriptor
deprecated
func (*SnapshotsReply) Descriptor() ([]byte, []int)
Deprecated: Use SnapshotsReply.ProtoReflect.Descriptor instead.
func (*SnapshotsReply) GetBlocksFiles ¶
func (x *SnapshotsReply) GetBlocksFiles() []string
func (*SnapshotsReply) GetHistoryFiles ¶
func (x *SnapshotsReply) GetHistoryFiles() []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=block_height,json=blockHeight,proto3" json:"block_height,omitempty"` BlockHash *types.H256 `protobuf:"bytes,3,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,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=state_version_id,json=stateVersionId,proto3" json:"state_version_id,omitempty"` // mdbx's tx.ID() - id of write transaction in db - where this changes happened ChangeBatch []*StateChange `protobuf:"bytes,2,rep,name=change_batch,json=changeBatch,proto3" json:"change_batch,omitempty"` PendingBlockBaseFee uint64 `protobuf:"varint,3,opt,name=pending_block_base_fee,json=pendingBlockBaseFee,proto3" json:"pending_block_base_fee,omitempty"` // BaseFee of the next block to be produced BlockGasLimit uint64 `protobuf:"varint,4,opt,name=block_gas_limit,json=blockGasLimit,proto3" json:"block_gas_limit,omitempty"` // GasLimit of the latest block - proxy for the gas limit of the next block to be produced FinalizedBlock uint64 `protobuf:"varint,5,opt,name=finalized_block,json=finalizedBlock,proto3" json:"finalized_block,omitempty"` PendingBlobFeePerGas uint64 `` // Base Blob Fee for the next block to be produced /* 128-byte string literal not displayed */ // 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) GetFinalizedBlock ¶
func (x *StateChangeBatch) GetFinalizedBlock() uint64
func (*StateChangeBatch) GetPendingBlobFeePerGas ¶
func (x *StateChangeBatch) GetPendingBlobFeePerGas() uint64
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=with_storage,json=withStorage,proto3" json:"with_storage,omitempty"` WithTransactions bool `protobuf:"varint,2,opt,name=with_transactions,json=withTransactions,proto3" json:"with_transactions,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=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"` BlockNumber uint64 `protobuf:"varint,3,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"` Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` LogIndex uint64 `protobuf:"varint,5,opt,name=log_index,json=logIndex,proto3" json:"log_index,omitempty"` Topics []*types.H256 `protobuf:"bytes,6,rep,name=topics,proto3" json:"topics,omitempty"` TransactionHash *types.H256 `protobuf:"bytes,7,opt,name=transaction_hash,json=transactionHash,proto3" json:"transaction_hash,omitempty"` TransactionIndex uint64 `protobuf:"varint,8,opt,name=transaction_index,json=transactionIndex,proto3" json:"transaction_index,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=block_number,json=blockNumber,proto3" json:"block_number,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=txn_hash,json=txnHash,proto3" json:"txn_hash,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) AddPeer ¶
func (UnimplementedETHBACKENDServer) AddPeer(context.Context, *AddPeerRequest) (*AddPeerReply, error)
func (UnimplementedETHBACKENDServer) Block ¶
func (UnimplementedETHBACKENDServer) Block(context.Context, *BlockRequest) (*BlockReply, error)
func (UnimplementedETHBACKENDServer) BorEvent ¶
func (UnimplementedETHBACKENDServer) BorEvent(context.Context, *BorEventRequest) (*BorEventReply, error)
func (UnimplementedETHBACKENDServer) ClientVersion ¶
func (UnimplementedETHBACKENDServer) ClientVersion(context.Context, *ClientVersionRequest) (*ClientVersionReply, 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) DomainGet ¶
func (UnimplementedKVServer) DomainGet(context.Context, *DomainGetReq) (*DomainGetReply, error)
func (UnimplementedKVServer) DomainRange ¶
func (UnimplementedKVServer) DomainRange(context.Context, *DomainRangeReq) (*Pairs, error)
func (UnimplementedKVServer) HistoryGet ¶
func (UnimplementedKVServer) HistoryGet(context.Context, *HistoryGetReq) (*HistoryGetReply, error)
func (UnimplementedKVServer) HistoryRange ¶
func (UnimplementedKVServer) HistoryRange(context.Context, *HistoryRangeReq) (*Pairs, error)
func (UnimplementedKVServer) IndexRange ¶
func (UnimplementedKVServer) IndexRange(context.Context, *IndexRangeReq) (*IndexRangeReply, error)
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.