remote

package
v0.0.0-...-ff78b6e Latest Latest
Warning

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

Go to latest
Published: Dec 6, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
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"
)
View Source
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

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

Enum value maps for Event.

View Source
var (
	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.

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

Enum value maps for Action.

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

Enum value maps for Direction.

View Source
var ETHBACKEND_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "remote.ETHBACKEND",
	HandlerType: (*ETHBACKENDServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Etherbase",
			Handler:    _ETHBACKEND_Etherbase_Handler,
		},
		{
			MethodName: "NetVersion",
			Handler:    _ETHBACKEND_NetVersion_Handler,
		},
		{
			MethodName: "NetPeerCount",
			Handler:    _ETHBACKEND_NetPeerCount_Handler,
		},
		{
			MethodName: "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)

View Source
var File_remote_ethbackend_proto protoreflect.FileDescriptor
View Source
var File_remote_kv_proto protoreflect.FileDescriptor
View Source
var KV_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "remote.KV",
	HandlerType: (*KVServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Version",
			Handler:    _KV_Version_Handler,
		},
		{
			MethodName: "Snapshots",
			Handler:    _KV_Snapshots_Handler,
		},
		{
			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) Enum

func (x Action) Enum() *Action

func (Action) EnumDescriptor deprecated

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

Deprecated: Use Action.Descriptor instead.

func (Action) Number

func (x Action) Number() protoreflect.EnumNumber

func (Action) String

func (x Action) String() string

func (Action) Type

func (Action) Type() protoreflect.EnumType

type 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) Descriptor() ([]byte, []int)

Deprecated: Use Cursor.ProtoReflect.Descriptor instead.

func (*Cursor) GetBucketName

func (x *Cursor) GetBucketName() string

func (*Cursor) GetCursor

func (x *Cursor) GetCursor() uint32

func (*Cursor) GetK

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

func (*Cursor) GetOp

func (x *Cursor) GetOp() Op

func (*Cursor) GetV

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

func (*Cursor) ProtoMessage

func (*Cursor) ProtoMessage()

func (*Cursor) ProtoReflect

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

func (*Cursor) Reset

func (x *Cursor) Reset()

func (*Cursor) String

func (x *Cursor) String() string

type Direction

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

func (Direction) Descriptor

func (Direction) Descriptor() protoreflect.EnumDescriptor

func (Direction) Enum

func (x Direction) Enum() *Direction

func (Direction) EnumDescriptor deprecated

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

Deprecated: Use Direction.Descriptor instead.

func (Direction) Number

func (x Direction) Number() protoreflect.EnumNumber

func (Direction) String

func (x Direction) String() string

func (Direction) Type

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 (*EngineGetPayloadBodiesByHashV1Request) ProtoMessage

func (*EngineGetPayloadBodiesByHashV1Request) ProtoMessage()

func (*EngineGetPayloadBodiesByHashV1Request) ProtoReflect

func (*EngineGetPayloadBodiesByHashV1Request) Reset

func (*EngineGetPayloadBodiesByHashV1Request) 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 (*EngineGetPayloadBodiesByRangeV1Request) GetStart

func (*EngineGetPayloadBodiesByRangeV1Request) ProtoMessage

func (*EngineGetPayloadBodiesByRangeV1Request) ProtoReflect

func (*EngineGetPayloadBodiesByRangeV1Request) Reset

func (*EngineGetPayloadBodiesByRangeV1Request) 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) Enum

func (x Event) Enum() *Event

func (Event) EnumDescriptor deprecated

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

Deprecated: Use Event.Descriptor instead.

func (Event) Number

func (x Event) Number() protoreflect.EnumNumber

func (Event) String

func (x Event) String() string

func (Event) Type

func (Event) Type() protoreflect.EnumType

type 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

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_TxClient interface {
	Send(*Cursor) error
	Recv() (*Pair, error)
	grpc.ClientStream
}

type KV_TxServer

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

type LogsFilterRequest

type LogsFilterRequest struct {
	AllAddresses bool          `protobuf:"varint,1,opt,name=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) Enum

func (x Op) Enum() *Op

func (Op) EnumDescriptor deprecated

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

Deprecated: Use Op.Descriptor instead.

func (Op) Number

func (x Op) Number() protoreflect.EnumNumber

func (Op) String

func (x Op) String() string

func (Op) Type

func (Op) Type() protoreflect.EnumType

type Pair

type Pair struct {
	K        []byte `protobuf:"bytes,1,opt,name=k,proto3" json:"k,omitempty"`
	V        []byte `protobuf:"bytes,2,opt,name=v,proto3" json:"v,omitempty"`
	CursorId uint32 `protobuf:"varint,3,opt,name=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) Descriptor() ([]byte, []int)

Deprecated: Use Pair.ProtoReflect.Descriptor instead.

func (*Pair) GetCursorId

func (x *Pair) GetCursorId() uint32

func (*Pair) GetK

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

func (*Pair) GetTxId

func (x *Pair) GetTxId() uint64

func (*Pair) GetV

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

func (*Pair) GetViewId

func (x *Pair) GetViewId() uint64

func (*Pair) ProtoMessage

func (*Pair) ProtoMessage()

func (*Pair) ProtoReflect

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

func (*Pair) Reset

func (x *Pair) Reset()

func (*Pair) String

func (x *Pair) String() string

type 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) Descriptor() ([]byte, []int)

Deprecated: Use Pairs.ProtoReflect.Descriptor instead.

func (*Pairs) GetKeys

func (x *Pairs) GetKeys() [][]byte

func (*Pairs) GetNextPageToken

func (x *Pairs) GetNextPageToken() string

func (*Pairs) GetValues

func (x *Pairs) GetValues() [][]byte

func (*Pairs) ProtoMessage

func (*Pairs) ProtoMessage()

func (*Pairs) ProtoReflect

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

func (*Pairs) Reset

func (x *Pairs) Reset()

func (*Pairs) String

func (x *Pairs) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use RangeReq.ProtoReflect.Descriptor instead.

func (*RangeReq) GetFromPrefix

func (x *RangeReq) GetFromPrefix() []byte

func (*RangeReq) GetLimit

func (x *RangeReq) GetLimit() int64

func (*RangeReq) GetOrderAscend

func (x *RangeReq) GetOrderAscend() bool

func (*RangeReq) GetPageSize

func (x *RangeReq) GetPageSize() int32

func (*RangeReq) GetPageToken

func (x *RangeReq) GetPageToken() string

func (*RangeReq) GetTable

func (x *RangeReq) GetTable() string

func (*RangeReq) GetToPrefix

func (x *RangeReq) GetToPrefix() []byte

func (*RangeReq) GetTxId

func (x *RangeReq) GetTxId() uint64

func (*RangeReq) ProtoMessage

func (*RangeReq) ProtoMessage()

func (*RangeReq) ProtoReflect

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

func (*RangeReq) Reset

func (x *RangeReq) Reset()

func (*RangeReq) String

func (x *RangeReq) String() string

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) Block

func (UnimplementedETHBACKENDServer) BorEvent

func (UnimplementedETHBACKENDServer) ClientVersion

func (UnimplementedETHBACKENDServer) Etherbase

func (UnimplementedETHBACKENDServer) NetPeerCount

func (UnimplementedETHBACKENDServer) NetVersion

func (UnimplementedETHBACKENDServer) NodeInfo

func (UnimplementedETHBACKENDServer) Peers

func (UnimplementedETHBACKENDServer) PendingBlock

func (UnimplementedETHBACKENDServer) ProtocolVersion

func (UnimplementedETHBACKENDServer) Subscribe

func (UnimplementedETHBACKENDServer) SubscribeLogs

func (UnimplementedETHBACKENDServer) TxnLookup

func (UnimplementedETHBACKENDServer) Version

type UnimplementedKVServer

type UnimplementedKVServer struct {
}

UnimplementedKVServer must be embedded to have forward compatible implementations.

func (UnimplementedKVServer) DomainGet

func (UnimplementedKVServer) DomainRange

func (UnimplementedKVServer) HistoryGet

func (UnimplementedKVServer) HistoryRange

func (UnimplementedKVServer) IndexRange

func (UnimplementedKVServer) Range

func (UnimplementedKVServer) Snapshots

func (UnimplementedKVServer) StateChanges

func (UnimplementedKVServer) Tx

func (UnimplementedKVServer) Version

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL