sync

package
v1.0.0-maxwell Latest Latest
Warning

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

 Go to latest Published: May 27, 2024 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DB_GetMerkleRoot_FullMethodName     = "/sync.DB/GetMerkleRoot"
	DB_Clear_FullMethodName             = "/sync.DB/Clear"
	DB_GetProof_FullMethodName          = "/sync.DB/GetProof"
	DB_GetChangeProof_FullMethodName    = "/sync.DB/GetChangeProof"
	DB_VerifyChangeProof_FullMethodName = "/sync.DB/VerifyChangeProof"
	DB_CommitChangeProof_FullMethodName = "/sync.DB/CommitChangeProof"
	DB_GetRangeProof_FullMethodName     = "/sync.DB/GetRangeProof"
	DB_CommitRangeProof_FullMethodName  = "/sync.DB/CommitRangeProof"
)

Variables

View Source 
var DB_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sync.DB",
	HandlerType: (*DBServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetMerkleRoot",
			Handler:    _DB_GetMerkleRoot_Handler,
		},
		{
			MethodName: "Clear",
			Handler:    _DB_Clear_Handler,
		},
		{
			MethodName: "GetProof",
			Handler:    _DB_GetProof_Handler,
		},
		{
			MethodName: "GetChangeProof",
			Handler:    _DB_GetChangeProof_Handler,
		},
		{
			MethodName: "VerifyChangeProof",
			Handler:    _DB_VerifyChangeProof_Handler,
		},
		{
			MethodName: "CommitChangeProof",
			Handler:    _DB_CommitChangeProof_Handler,
		},
		{
			MethodName: "GetRangeProof",
			Handler:    _DB_GetRangeProof_Handler,
		},
		{
			MethodName: "CommitRangeProof",
			Handler:    _DB_CommitRangeProof_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sync/sync.proto",
}

DB_ServiceDesc is the grpc.ServiceDesc for DB 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_sync_sync_proto protoreflect.FileDescriptor

Functions

func RegisterDBServer 

func RegisterDBServer(s grpc.ServiceRegistrar, srv DBServer)

Types

type ChangeProof 

type ChangeProof struct {
	StartProof []*ProofNode `protobuf:"bytes,1,rep,name=start_proof,json=startProof,proto3" json:"start_proof,omitempty"`
	EndProof   []*ProofNode `protobuf:"bytes,2,rep,name=end_proof,json=endProof,proto3" json:"end_proof,omitempty"`
	KeyChanges []*KeyChange `protobuf:"bytes,3,rep,name=key_changes,json=keyChanges,proto3" json:"key_changes,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeProof) Descriptor deprecated 

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

Deprecated: Use ChangeProof.ProtoReflect.Descriptor instead.

func (*ChangeProof) GetEndProof 

func (x *ChangeProof) GetEndProof() []*ProofNode

func (*ChangeProof) GetKeyChanges 

func (x *ChangeProof) GetKeyChanges() []*KeyChange

func (*ChangeProof) GetStartProof 

func (x *ChangeProof) GetStartProof() []*ProofNode

func (*ChangeProof) ProtoMessage 

func (*ChangeProof) ProtoMessage()

func (*ChangeProof) ProtoReflect 

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

func (*ChangeProof) Reset 

func (x *ChangeProof) Reset()

func (*ChangeProof) String 

func (x *ChangeProof) String() string

type CommitChangeProofRequest 

type CommitChangeProofRequest struct {
	Proof *ChangeProof `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitChangeProofRequest) Descriptor deprecated 

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

Deprecated: Use CommitChangeProofRequest.ProtoReflect.Descriptor instead.

func (*CommitChangeProofRequest) GetProof 

func (x *CommitChangeProofRequest) GetProof() *ChangeProof

func (*CommitChangeProofRequest) ProtoMessage 

func (*CommitChangeProofRequest) ProtoMessage()

func (*CommitChangeProofRequest) ProtoReflect 

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

func (*CommitChangeProofRequest) Reset 

func (x *CommitChangeProofRequest) Reset()

func (*CommitChangeProofRequest) String 

func (x *CommitChangeProofRequest) String() string

type CommitRangeProofRequest 

type CommitRangeProofRequest struct {
	StartKey   *MaybeBytes `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey     *MaybeBytes `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	RangeProof *RangeProof `protobuf:"bytes,3,opt,name=range_proof,json=rangeProof,proto3" json:"range_proof,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitRangeProofRequest) Descriptor deprecated 

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

Deprecated: Use CommitRangeProofRequest.ProtoReflect.Descriptor instead.

func (*CommitRangeProofRequest) GetEndKey 

func (x *CommitRangeProofRequest) GetEndKey() *MaybeBytes

func (*CommitRangeProofRequest) GetRangeProof 

func (x *CommitRangeProofRequest) GetRangeProof() *RangeProof

func (*CommitRangeProofRequest) GetStartKey 

func (x *CommitRangeProofRequest) GetStartKey() *MaybeBytes

func (*CommitRangeProofRequest) ProtoMessage 

func (*CommitRangeProofRequest) ProtoMessage()

func (*CommitRangeProofRequest) ProtoReflect 

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

func (*CommitRangeProofRequest) Reset 

func (x *CommitRangeProofRequest) Reset()

func (*CommitRangeProofRequest) String 

func (x *CommitRangeProofRequest) String() string

type DBClient 

type DBClient interface {
	GetMerkleRoot(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetMerkleRootResponse, error)
	Clear(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetProof(ctx context.Context, in *GetProofRequest, opts ...grpc.CallOption) (*GetProofResponse, error)
	GetChangeProof(ctx context.Context, in *GetChangeProofRequest, opts ...grpc.CallOption) (*GetChangeProofResponse, error)
	VerifyChangeProof(ctx context.Context, in *VerifyChangeProofRequest, opts ...grpc.CallOption) (*VerifyChangeProofResponse, error)
	CommitChangeProof(ctx context.Context, in *CommitChangeProofRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetRangeProof(ctx context.Context, in *GetRangeProofRequest, opts ...grpc.CallOption) (*GetRangeProofResponse, error)
	CommitRangeProof(ctx context.Context, in *CommitRangeProofRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DBClient is the client API for DB 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 NewDBClient 

func NewDBClient(cc grpc.ClientConnInterface) DBClient

type DBServer 

type DBServer interface {
	GetMerkleRoot(context.Context, *emptypb.Empty) (*GetMerkleRootResponse, error)
	Clear(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	GetProof(context.Context, *GetProofRequest) (*GetProofResponse, error)
	GetChangeProof(context.Context, *GetChangeProofRequest) (*GetChangeProofResponse, error)
	VerifyChangeProof(context.Context, *VerifyChangeProofRequest) (*VerifyChangeProofResponse, error)
	CommitChangeProof(context.Context, *CommitChangeProofRequest) (*emptypb.Empty, error)
	GetRangeProof(context.Context, *GetRangeProofRequest) (*GetRangeProofResponse, error)
	CommitRangeProof(context.Context, *CommitRangeProofRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

DBServer is the server API for DB service. All implementations must embed UnimplementedDBServer for forward compatibility

type GetChangeProofRequest 

type GetChangeProofRequest struct {
	StartRootHash []byte      `protobuf:"bytes,1,opt,name=start_root_hash,json=startRootHash,proto3" json:"start_root_hash,omitempty"`
	EndRootHash   []byte      `protobuf:"bytes,2,opt,name=end_root_hash,json=endRootHash,proto3" json:"end_root_hash,omitempty"`
	StartKey      *MaybeBytes `protobuf:"bytes,3,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey        *MaybeBytes `protobuf:"bytes,4,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	KeyLimit      uint32      `protobuf:"varint,5,opt,name=key_limit,json=keyLimit,proto3" json:"key_limit,omitempty"`
	// contains filtered or unexported fields
}

func (*GetChangeProofRequest) Descriptor deprecated 

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

Deprecated: Use GetChangeProofRequest.ProtoReflect.Descriptor instead.

func (*GetChangeProofRequest) GetEndKey 

func (x *GetChangeProofRequest) GetEndKey() *MaybeBytes

func (*GetChangeProofRequest) GetEndRootHash 

func (x *GetChangeProofRequest) GetEndRootHash() []byte

func (*GetChangeProofRequest) GetKeyLimit 

func (x *GetChangeProofRequest) GetKeyLimit() uint32

func (*GetChangeProofRequest) GetStartKey 

func (x *GetChangeProofRequest) GetStartKey() *MaybeBytes

func (*GetChangeProofRequest) GetStartRootHash 

func (x *GetChangeProofRequest) GetStartRootHash() []byte

func (*GetChangeProofRequest) ProtoMessage 

func (*GetChangeProofRequest) ProtoMessage()

func (*GetChangeProofRequest) ProtoReflect 

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

func (*GetChangeProofRequest) Reset 

func (x *GetChangeProofRequest) Reset()

func (*GetChangeProofRequest) String 

func (x *GetChangeProofRequest) String() string

type GetChangeProofResponse 

type GetChangeProofResponse struct {

	// Types that are assignable to Response:
	//
	//	*GetChangeProofResponse_ChangeProof
	//	*GetChangeProofResponse_RootNotPresent
	Response isGetChangeProofResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*GetChangeProofResponse) Descriptor deprecated 

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

Deprecated: Use GetChangeProofResponse.ProtoReflect.Descriptor instead.

func (*GetChangeProofResponse) GetChangeProof 

func (x *GetChangeProofResponse) GetChangeProof() *ChangeProof

func (*GetChangeProofResponse) GetResponse 

func (m *GetChangeProofResponse) GetResponse() isGetChangeProofResponse_Response

func (*GetChangeProofResponse) GetRootNotPresent 

func (x *GetChangeProofResponse) GetRootNotPresent() bool

func (*GetChangeProofResponse) ProtoMessage 

func (*GetChangeProofResponse) ProtoMessage()

func (*GetChangeProofResponse) ProtoReflect 

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

func (*GetChangeProofResponse) Reset 

func (x *GetChangeProofResponse) Reset()

func (*GetChangeProofResponse) String 

func (x *GetChangeProofResponse) String() string

type GetChangeProofResponse_ChangeProof 

type GetChangeProofResponse_ChangeProof struct {
	ChangeProof *ChangeProof `protobuf:"bytes,1,opt,name=change_proof,json=changeProof,proto3,oneof"`
}

type GetChangeProofResponse_RootNotPresent 

type GetChangeProofResponse_RootNotPresent struct {
	// True iff server errored with merkledb.ErrInsufficientHistory.
	RootNotPresent bool `protobuf:"varint,2,opt,name=root_not_present,json=rootNotPresent,proto3,oneof"`
}

type GetMerkleRootResponse 

type GetMerkleRootResponse struct {
	RootHash []byte `protobuf:"bytes,1,opt,name=root_hash,json=rootHash,proto3" json:"root_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMerkleRootResponse) Descriptor deprecated 

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

Deprecated: Use GetMerkleRootResponse.ProtoReflect.Descriptor instead.

func (*GetMerkleRootResponse) GetRootHash 

func (x *GetMerkleRootResponse) GetRootHash() []byte

func (*GetMerkleRootResponse) ProtoMessage 

func (*GetMerkleRootResponse) ProtoMessage()

func (*GetMerkleRootResponse) ProtoReflect 

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

func (*GetMerkleRootResponse) Reset 

func (x *GetMerkleRootResponse) Reset()

func (*GetMerkleRootResponse) String 

func (x *GetMerkleRootResponse) String() string

type GetProofRequest 

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

func (*GetProofRequest) Descriptor deprecated 

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

Deprecated: Use GetProofRequest.ProtoReflect.Descriptor instead.

func (*GetProofRequest) GetKey 

func (x *GetProofRequest) GetKey() []byte

func (*GetProofRequest) ProtoMessage 

func (*GetProofRequest) ProtoMessage()

func (*GetProofRequest) ProtoReflect 

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

func (*GetProofRequest) Reset 

func (x *GetProofRequest) Reset()

func (*GetProofRequest) String 

func (x *GetProofRequest) String() string

type GetProofResponse 

type GetProofResponse struct {
	Proof *Proof `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
	// contains filtered or unexported fields
}

func (*GetProofResponse) Descriptor deprecated 

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

Deprecated: Use GetProofResponse.ProtoReflect.Descriptor instead.

func (*GetProofResponse) GetProof 

func (x *GetProofResponse) GetProof() *Proof

func (*GetProofResponse) ProtoMessage 

func (*GetProofResponse) ProtoMessage()

func (*GetProofResponse) ProtoReflect 

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

func (*GetProofResponse) Reset 

func (x *GetProofResponse) Reset()

func (*GetProofResponse) String 

func (x *GetProofResponse) String() string

type GetRangeProofRequest 

type GetRangeProofRequest struct {
	RootHash []byte      `protobuf:"bytes,1,opt,name=root_hash,json=rootHash,proto3" json:"root_hash,omitempty"`
	StartKey *MaybeBytes `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey   *MaybeBytes `protobuf:"bytes,3,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	KeyLimit uint32      `protobuf:"varint,4,opt,name=key_limit,json=keyLimit,proto3" json:"key_limit,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRangeProofRequest) Descriptor deprecated 

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

Deprecated: Use GetRangeProofRequest.ProtoReflect.Descriptor instead.

func (*GetRangeProofRequest) GetEndKey 

func (x *GetRangeProofRequest) GetEndKey() *MaybeBytes

func (*GetRangeProofRequest) GetKeyLimit 

func (x *GetRangeProofRequest) GetKeyLimit() uint32

func (*GetRangeProofRequest) GetRootHash 

func (x *GetRangeProofRequest) GetRootHash() []byte

func (*GetRangeProofRequest) GetStartKey 

func (x *GetRangeProofRequest) GetStartKey() *MaybeBytes

func (*GetRangeProofRequest) ProtoMessage 

func (*GetRangeProofRequest) ProtoMessage()

func (*GetRangeProofRequest) ProtoReflect 

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

func (*GetRangeProofRequest) Reset 

func (x *GetRangeProofRequest) Reset()

func (*GetRangeProofRequest) String 

func (x *GetRangeProofRequest) String() string

type GetRangeProofResponse 

type GetRangeProofResponse struct {
	Proof *RangeProof `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRangeProofResponse) Descriptor deprecated 

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

Deprecated: Use GetRangeProofResponse.ProtoReflect.Descriptor instead.

func (*GetRangeProofResponse) GetProof 

func (x *GetRangeProofResponse) GetProof() *RangeProof

func (*GetRangeProofResponse) ProtoMessage 

func (*GetRangeProofResponse) ProtoMessage()

func (*GetRangeProofResponse) ProtoReflect 

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

func (*GetRangeProofResponse) Reset 

func (x *GetRangeProofResponse) Reset()

func (*GetRangeProofResponse) String 

func (x *GetRangeProofResponse) String() string

type Key 

type Key struct {
	Length uint64 `protobuf:"varint,1,opt,name=length,proto3" json:"length,omitempty"`
	Value  []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Key) Descriptor deprecated 

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

Deprecated: Use Key.ProtoReflect.Descriptor instead.

func (*Key) GetLength 

func (x *Key) GetLength() uint64

func (*Key) GetValue 

func (x *Key) GetValue() []byte

func (*Key) ProtoMessage 

func (*Key) ProtoMessage()

func (*Key) ProtoReflect 

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

func (*Key) Reset 

func (x *Key) Reset()

func (*Key) String 

func (x *Key) String() string

type KeyChange 

type KeyChange struct {
	Key   []byte      `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *MaybeBytes `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyChange) Descriptor deprecated 

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

Deprecated: Use KeyChange.ProtoReflect.Descriptor instead.

func (*KeyChange) GetKey 

func (x *KeyChange) GetKey() []byte

func (*KeyChange) GetValue 

func (x *KeyChange) GetValue() *MaybeBytes

func (*KeyChange) ProtoMessage 

func (*KeyChange) ProtoMessage()

func (*KeyChange) ProtoReflect 

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

func (*KeyChange) Reset 

func (x *KeyChange) Reset()

func (*KeyChange) String 

func (x *KeyChange) String() string

type KeyValue 

type KeyValue struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyValue) Descriptor deprecated 

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

Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.

func (*KeyValue) GetKey 

func (x *KeyValue) GetKey() []byte

func (*KeyValue) GetValue 

func (x *KeyValue) GetValue() []byte

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) ProtoReflect 

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

func (*KeyValue) Reset 

func (x *KeyValue) Reset()

func (*KeyValue) String 

func (x *KeyValue) String() string

type MaybeBytes 

type MaybeBytes struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// If false, this is None.
	// Otherwise this is Some.
	IsNothing bool `protobuf:"varint,2,opt,name=is_nothing,json=isNothing,proto3" json:"is_nothing,omitempty"`
	// contains filtered or unexported fields
}

func (*MaybeBytes) Descriptor deprecated 

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

Deprecated: Use MaybeBytes.ProtoReflect.Descriptor instead.

func (*MaybeBytes) GetIsNothing 

func (x *MaybeBytes) GetIsNothing() bool

func (*MaybeBytes) GetValue 

func (x *MaybeBytes) GetValue() []byte

func (*MaybeBytes) ProtoMessage 

func (*MaybeBytes) ProtoMessage()

func (*MaybeBytes) ProtoReflect 

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

func (*MaybeBytes) Reset 

func (x *MaybeBytes) Reset()

func (*MaybeBytes) String 

func (x *MaybeBytes) String() string

type Proof 

type Proof struct {
	Key   []byte       `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *MaybeBytes  `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Proof []*ProofNode `protobuf:"bytes,3,rep,name=proof,proto3" json:"proof,omitempty"`
	// contains filtered or unexported fields
}

func (*Proof) Descriptor deprecated 

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

Deprecated: Use Proof.ProtoReflect.Descriptor instead.

func (*Proof) GetKey 

func (x *Proof) GetKey() []byte

func (*Proof) GetProof 

func (x *Proof) GetProof() []*ProofNode

func (*Proof) GetValue 

func (x *Proof) GetValue() *MaybeBytes

func (*Proof) ProtoMessage 

func (*Proof) ProtoMessage()

func (*Proof) ProtoReflect 

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

func (*Proof) Reset 

func (x *Proof) Reset()

func (*Proof) String 

func (x *Proof) String() string

type ProofNode 

type ProofNode struct {
	Key         *Key              `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	ValueOrHash *MaybeBytes       `protobuf:"bytes,2,opt,name=value_or_hash,json=valueOrHash,proto3" json:"value_or_hash,omitempty"`
	Children    map[uint32][]byte `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ProofNode) Descriptor deprecated 

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

Deprecated: Use ProofNode.ProtoReflect.Descriptor instead.

func (*ProofNode) GetChildren 

func (x *ProofNode) GetChildren() map[uint32][]byte

func (*ProofNode) GetKey 

func (x *ProofNode) GetKey() *Key

func (*ProofNode) GetValueOrHash 

func (x *ProofNode) GetValueOrHash() *MaybeBytes

func (*ProofNode) ProtoMessage 

func (*ProofNode) ProtoMessage()

func (*ProofNode) ProtoReflect 

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

func (*ProofNode) Reset 

func (x *ProofNode) Reset()

func (*ProofNode) String 

func (x *ProofNode) String() string

type RangeProof 

type RangeProof struct {
	StartProof []*ProofNode `protobuf:"bytes,1,rep,name=start_proof,json=startProof,proto3" json:"start_proof,omitempty"`
	EndProof   []*ProofNode `protobuf:"bytes,2,rep,name=end_proof,json=endProof,proto3" json:"end_proof,omitempty"`
	KeyValues  []*KeyValue  `protobuf:"bytes,3,rep,name=key_values,json=keyValues,proto3" json:"key_values,omitempty"`
	// contains filtered or unexported fields
}

func (*RangeProof) Descriptor deprecated 

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

Deprecated: Use RangeProof.ProtoReflect.Descriptor instead.

func (*RangeProof) GetEndProof 

func (x *RangeProof) GetEndProof() []*ProofNode

func (*RangeProof) GetKeyValues 

func (x *RangeProof) GetKeyValues() []*KeyValue

func (*RangeProof) GetStartProof 

func (x *RangeProof) GetStartProof() []*ProofNode

func (*RangeProof) ProtoMessage 

func (*RangeProof) ProtoMessage()

func (*RangeProof) ProtoReflect 

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

func (*RangeProof) Reset 

func (x *RangeProof) Reset()

func (*RangeProof) String 

func (x *RangeProof) String() string

type Request 

type Request struct {

	// Types that are assignable to Message:
	//
	//	*Request_RangeProofRequest
	//	*Request_ChangeProofRequest
	Message isRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

Request represents a request for information during syncing.

func (*Request) Descriptor deprecated 

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetChangeProofRequest 

func (x *Request) GetChangeProofRequest() *SyncGetChangeProofRequest

func (*Request) GetMessage 

func (m *Request) GetMessage() isRequest_Message

func (*Request) GetRangeProofRequest 

func (x *Request) GetRangeProofRequest() *SyncGetRangeProofRequest

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

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

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

type Request_ChangeProofRequest 

type Request_ChangeProofRequest struct {
	ChangeProofRequest *SyncGetChangeProofRequest `protobuf:"bytes,2,opt,name=change_proof_request,json=changeProofRequest,proto3,oneof"`
}

type Request_RangeProofRequest 

type Request_RangeProofRequest struct {
	RangeProofRequest *SyncGetRangeProofRequest `protobuf:"bytes,1,opt,name=range_proof_request,json=rangeProofRequest,proto3,oneof"`
}

type SyncGetChangeProofRequest 

type SyncGetChangeProofRequest struct {
	StartRootHash []byte      `protobuf:"bytes,1,opt,name=start_root_hash,json=startRootHash,proto3" json:"start_root_hash,omitempty"`
	EndRootHash   []byte      `protobuf:"bytes,2,opt,name=end_root_hash,json=endRootHash,proto3" json:"end_root_hash,omitempty"`
	StartKey      *MaybeBytes `protobuf:"bytes,3,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey        *MaybeBytes `protobuf:"bytes,4,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	KeyLimit      uint32      `protobuf:"varint,5,opt,name=key_limit,json=keyLimit,proto3" json:"key_limit,omitempty"`
	BytesLimit    uint32      `protobuf:"varint,6,opt,name=bytes_limit,json=bytesLimit,proto3" json:"bytes_limit,omitempty"`
	// contains filtered or unexported fields
}

For use in sync client, which has a restriction on the size of the response. GetChangeProof in the DB service doesn't.

func (*SyncGetChangeProofRequest) Descriptor deprecated 

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

Deprecated: Use SyncGetChangeProofRequest.ProtoReflect.Descriptor instead.

func (*SyncGetChangeProofRequest) GetBytesLimit 

func (x *SyncGetChangeProofRequest) GetBytesLimit() uint32

func (*SyncGetChangeProofRequest) GetEndKey 

func (x *SyncGetChangeProofRequest) GetEndKey() *MaybeBytes

func (*SyncGetChangeProofRequest) GetEndRootHash 

func (x *SyncGetChangeProofRequest) GetEndRootHash() []byte

func (*SyncGetChangeProofRequest) GetKeyLimit 

func (x *SyncGetChangeProofRequest) GetKeyLimit() uint32

func (*SyncGetChangeProofRequest) GetStartKey 

func (x *SyncGetChangeProofRequest) GetStartKey() *MaybeBytes

func (*SyncGetChangeProofRequest) GetStartRootHash 

func (x *SyncGetChangeProofRequest) GetStartRootHash() []byte

func (*SyncGetChangeProofRequest) ProtoMessage 

func (*SyncGetChangeProofRequest) ProtoMessage()

func (*SyncGetChangeProofRequest) ProtoReflect 

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

func (*SyncGetChangeProofRequest) Reset 

func (x *SyncGetChangeProofRequest) Reset()

func (*SyncGetChangeProofRequest) String 

func (x *SyncGetChangeProofRequest) String() string

type SyncGetChangeProofResponse 

type SyncGetChangeProofResponse struct {

	// Types that are assignable to Response:
	//
	//	*SyncGetChangeProofResponse_ChangeProof
	//	*SyncGetChangeProofResponse_RangeProof
	Response isSyncGetChangeProofResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*SyncGetChangeProofResponse) Descriptor deprecated 

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

Deprecated: Use SyncGetChangeProofResponse.ProtoReflect.Descriptor instead.

func (*SyncGetChangeProofResponse) GetChangeProof 

func (x *SyncGetChangeProofResponse) GetChangeProof() *ChangeProof

func (*SyncGetChangeProofResponse) GetRangeProof 

func (x *SyncGetChangeProofResponse) GetRangeProof() *RangeProof

func (*SyncGetChangeProofResponse) GetResponse 

func (m *SyncGetChangeProofResponse) GetResponse() isSyncGetChangeProofResponse_Response

func (*SyncGetChangeProofResponse) ProtoMessage 

func (*SyncGetChangeProofResponse) ProtoMessage()

func (*SyncGetChangeProofResponse) ProtoReflect 

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

func (*SyncGetChangeProofResponse) Reset 

func (x *SyncGetChangeProofResponse) Reset()

func (*SyncGetChangeProofResponse) String 

func (x *SyncGetChangeProofResponse) String() string

type SyncGetChangeProofResponse_ChangeProof 

type SyncGetChangeProofResponse_ChangeProof struct {
	ChangeProof *ChangeProof `protobuf:"bytes,1,opt,name=change_proof,json=changeProof,proto3,oneof"`
}

type SyncGetChangeProofResponse_RangeProof 

type SyncGetChangeProofResponse_RangeProof struct {
	RangeProof *RangeProof `protobuf:"bytes,2,opt,name=range_proof,json=rangeProof,proto3,oneof"`
}

type SyncGetRangeProofRequest 

type SyncGetRangeProofRequest struct {
	RootHash   []byte      `protobuf:"bytes,1,opt,name=root_hash,json=rootHash,proto3" json:"root_hash,omitempty"`
	StartKey   *MaybeBytes `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey     *MaybeBytes `protobuf:"bytes,3,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	KeyLimit   uint32      `protobuf:"varint,4,opt,name=key_limit,json=keyLimit,proto3" json:"key_limit,omitempty"`
	BytesLimit uint32      `protobuf:"varint,5,opt,name=bytes_limit,json=bytesLimit,proto3" json:"bytes_limit,omitempty"`
	// contains filtered or unexported fields
}

For use in sync client, which has a restriction on the size of the response. GetRangeProof in the DB service doesn't.

func (*SyncGetRangeProofRequest) Descriptor deprecated 

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

Deprecated: Use SyncGetRangeProofRequest.ProtoReflect.Descriptor instead.

func (*SyncGetRangeProofRequest) GetBytesLimit 

func (x *SyncGetRangeProofRequest) GetBytesLimit() uint32

func (*SyncGetRangeProofRequest) GetEndKey 

func (x *SyncGetRangeProofRequest) GetEndKey() *MaybeBytes

func (*SyncGetRangeProofRequest) GetKeyLimit 

func (x *SyncGetRangeProofRequest) GetKeyLimit() uint32

func (*SyncGetRangeProofRequest) GetRootHash 

func (x *SyncGetRangeProofRequest) GetRootHash() []byte

func (*SyncGetRangeProofRequest) GetStartKey 

func (x *SyncGetRangeProofRequest) GetStartKey() *MaybeBytes

func (*SyncGetRangeProofRequest) ProtoMessage 

func (*SyncGetRangeProofRequest) ProtoMessage()

func (*SyncGetRangeProofRequest) ProtoReflect 

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

func (*SyncGetRangeProofRequest) Reset 

func (x *SyncGetRangeProofRequest) Reset()

func (*SyncGetRangeProofRequest) String 

func (x *SyncGetRangeProofRequest) String() string

type UnimplementedDBServer 

type UnimplementedDBServer struct {
}

UnimplementedDBServer must be embedded to have forward compatible implementations.

func (UnimplementedDBServer) Clear 

func (UnimplementedDBServer) Clear(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedDBServer) CommitChangeProof 

func (UnimplementedDBServer) CommitChangeProof(context.Context, *CommitChangeProofRequest) (*emptypb.Empty, error)

func (UnimplementedDBServer) CommitRangeProof 

func (UnimplementedDBServer) CommitRangeProof(context.Context, *CommitRangeProofRequest) (*emptypb.Empty, error)

func (UnimplementedDBServer) GetChangeProof 

func (UnimplementedDBServer) GetChangeProof(context.Context, *GetChangeProofRequest) (*GetChangeProofResponse, error)

func (UnimplementedDBServer) GetMerkleRoot 

func (UnimplementedDBServer) GetMerkleRoot(context.Context, *emptypb.Empty) (*GetMerkleRootResponse, error)

func (UnimplementedDBServer) GetProof 

func (UnimplementedDBServer) GetProof(context.Context, *GetProofRequest) (*GetProofResponse, error)

func (UnimplementedDBServer) GetRangeProof 

func (UnimplementedDBServer) GetRangeProof(context.Context, *GetRangeProofRequest) (*GetRangeProofResponse, error)

func (UnimplementedDBServer) VerifyChangeProof 

func (UnimplementedDBServer) VerifyChangeProof(context.Context, *VerifyChangeProofRequest) (*VerifyChangeProofResponse, error)

type UnsafeDBServer 

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

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

type VerifyChangeProofRequest 

type VerifyChangeProofRequest struct {
	Proof            *ChangeProof `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
	StartKey         *MaybeBytes  `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey           *MaybeBytes  `protobuf:"bytes,3,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	ExpectedRootHash []byte       `protobuf:"bytes,4,opt,name=expected_root_hash,json=expectedRootHash,proto3" json:"expected_root_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifyChangeProofRequest) Descriptor deprecated 

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

Deprecated: Use VerifyChangeProofRequest.ProtoReflect.Descriptor instead.

func (*VerifyChangeProofRequest) GetEndKey 

func (x *VerifyChangeProofRequest) GetEndKey() *MaybeBytes

func (*VerifyChangeProofRequest) GetExpectedRootHash 

func (x *VerifyChangeProofRequest) GetExpectedRootHash() []byte

func (*VerifyChangeProofRequest) GetProof 

func (x *VerifyChangeProofRequest) GetProof() *ChangeProof

func (*VerifyChangeProofRequest) GetStartKey 

func (x *VerifyChangeProofRequest) GetStartKey() *MaybeBytes

func (*VerifyChangeProofRequest) ProtoMessage 

func (*VerifyChangeProofRequest) ProtoMessage()

func (*VerifyChangeProofRequest) ProtoReflect 

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

func (*VerifyChangeProofRequest) Reset 

func (x *VerifyChangeProofRequest) Reset()

func (*VerifyChangeProofRequest) String 

func (x *VerifyChangeProofRequest) String() string

type VerifyChangeProofResponse 

type VerifyChangeProofResponse struct {

	// If empty, there was no error.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifyChangeProofResponse) Descriptor deprecated 

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

Deprecated: Use VerifyChangeProofResponse.ProtoReflect.Descriptor instead.

func (*VerifyChangeProofResponse) GetError 

func (x *VerifyChangeProofResponse) GetError() string

func (*VerifyChangeProofResponse) ProtoMessage 

func (*VerifyChangeProofResponse) ProtoMessage()

func (*VerifyChangeProofResponse) ProtoReflect 

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

func (*VerifyChangeProofResponse) Reset 

func (x *VerifyChangeProofResponse) Reset()

func (*VerifyChangeProofResponse) String 

func (x *VerifyChangeProofResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.