rpcdb

package
v1.23.3 Latest Latest
Warning

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

 Go to latest Published: Jan 26, 2026 License: BSD-3-Clause Imports: 5 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Error_name = map[int32]string{
		0: "ERROR_UNSPECIFIED",
		1: "ERROR_CLOSED",
		2: "ERROR_NOT_FOUND",
	}
	Error_value = map[string]int32{
		"ERROR_UNSPECIFIED": 0,
		"ERROR_CLOSED":      1,
		"ERROR_NOT_FOUND":   2,
	}
)

Enum value maps for Error.

View Source 
var File_rpcdb_rpcdb_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CloseRequest 

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

func (*CloseRequest) Descriptor deprecated 

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

Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) ProtoReflect 

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

func (*CloseRequest) Reset 

func (x *CloseRequest) Reset()

func (*CloseRequest) String 

func (x *CloseRequest) String() string

type CloseResponse 

type CloseResponse struct {
	Err Error `protobuf:"varint,1,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseResponse) Descriptor deprecated 

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

Deprecated: Use CloseResponse.ProtoReflect.Descriptor instead.

func (*CloseResponse) GetErr 

func (x *CloseResponse) GetErr() Error

func (*CloseResponse) ProtoMessage 

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) ProtoReflect 

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

func (*CloseResponse) Reset 

func (x *CloseResponse) Reset()

func (*CloseResponse) String 

func (x *CloseResponse) String() string

type CompactRequest 

type CompactRequest struct {
	Start []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Limit []byte `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactRequest) Descriptor deprecated 

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

Deprecated: Use CompactRequest.ProtoReflect.Descriptor instead.

func (*CompactRequest) GetLimit 

func (x *CompactRequest) GetLimit() []byte

func (*CompactRequest) GetStart 

func (x *CompactRequest) GetStart() []byte

func (*CompactRequest) ProtoMessage 

func (*CompactRequest) ProtoMessage()

func (*CompactRequest) ProtoReflect 

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

func (*CompactRequest) Reset 

func (x *CompactRequest) Reset()

func (*CompactRequest) String 

func (x *CompactRequest) String() string

type CompactResponse 

type CompactResponse struct {
	Err Error `protobuf:"varint,1,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactResponse) Descriptor deprecated 

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

Deprecated: Use CompactResponse.ProtoReflect.Descriptor instead.

func (*CompactResponse) GetErr 

func (x *CompactResponse) GetErr() Error

func (*CompactResponse) ProtoMessage 

func (*CompactResponse) ProtoMessage()

func (*CompactResponse) ProtoReflect 

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

func (*CompactResponse) Reset 

func (x *CompactResponse) Reset()

func (*CompactResponse) String 

func (x *CompactResponse) String() string

type DeleteRequest 

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

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetKey 

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

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

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

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	Err Error `protobuf:"varint,1,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetErr 

func (x *DeleteResponse) GetErr() Error

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

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

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type Error 

type Error int32
const (
	// ERROR_UNSPECIFIED is used to indicate that no error occurred.
	Error_ERROR_UNSPECIFIED Error = 0
	Error_ERROR_CLOSED      Error = 1
	Error_ERROR_NOT_FOUND   Error = 2
)

func (Error) Descriptor 

func (Error) Descriptor() protoreflect.EnumDescriptor

func (Error) Enum 

func (x Error) Enum() *Error

func (Error) EnumDescriptor deprecated 

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

Deprecated: Use Error.Descriptor instead.

func (Error) Number 

func (x Error) Number() protoreflect.EnumNumber

func (Error) String 

func (x Error) String() string

func (Error) Type 

func (Error) Type() protoreflect.EnumType

type GetRequest 

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

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetKey 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Err   Error  `protobuf:"varint,2,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetErr 

func (x *GetResponse) GetErr() Error

func (*GetResponse) GetValue 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

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

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type HasRequest 

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

func (*HasRequest) Descriptor deprecated 

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

Deprecated: Use HasRequest.ProtoReflect.Descriptor instead.

func (*HasRequest) GetKey 

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

func (*HasRequest) ProtoMessage 

func (*HasRequest) ProtoMessage()

func (*HasRequest) ProtoReflect 

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

func (*HasRequest) Reset 

func (x *HasRequest) Reset()

func (*HasRequest) String 

func (x *HasRequest) String() string

type HasResponse 

type HasResponse struct {
	Has bool  `protobuf:"varint,1,opt,name=has,proto3" json:"has,omitempty"`
	Err Error `protobuf:"varint,2,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*HasResponse) Descriptor deprecated 

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

Deprecated: Use HasResponse.ProtoReflect.Descriptor instead.

func (*HasResponse) GetErr 

func (x *HasResponse) GetErr() Error

func (*HasResponse) GetHas 

func (x *HasResponse) GetHas() bool

func (*HasResponse) ProtoMessage 

func (*HasResponse) ProtoMessage()

func (*HasResponse) ProtoReflect 

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

func (*HasResponse) Reset 

func (x *HasResponse) Reset()

func (*HasResponse) String 

func (x *HasResponse) String() string

type HealthCheckResponse 

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

func (*HealthCheckResponse) Descriptor deprecated 

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

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) GetDetails 

func (x *HealthCheckResponse) GetDetails() []byte

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect 

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

func (*HealthCheckResponse) Reset 

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (x *HealthCheckResponse) String() string

type IteratorErrorRequest 

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

func (*IteratorErrorRequest) Descriptor deprecated 

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

Deprecated: Use IteratorErrorRequest.ProtoReflect.Descriptor instead.

func (*IteratorErrorRequest) GetId 

func (x *IteratorErrorRequest) GetId() uint64

func (*IteratorErrorRequest) ProtoMessage 

func (*IteratorErrorRequest) ProtoMessage()

func (*IteratorErrorRequest) ProtoReflect 

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

func (*IteratorErrorRequest) Reset 

func (x *IteratorErrorRequest) Reset()

func (*IteratorErrorRequest) String 

func (x *IteratorErrorRequest) String() string

type IteratorErrorResponse 

type IteratorErrorResponse struct {
	Err Error `protobuf:"varint,1,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*IteratorErrorResponse) Descriptor deprecated 

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

Deprecated: Use IteratorErrorResponse.ProtoReflect.Descriptor instead.

func (*IteratorErrorResponse) GetErr 

func (x *IteratorErrorResponse) GetErr() Error

func (*IteratorErrorResponse) ProtoMessage 

func (*IteratorErrorResponse) ProtoMessage()

func (*IteratorErrorResponse) ProtoReflect 

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

func (*IteratorErrorResponse) Reset 

func (x *IteratorErrorResponse) Reset()

func (*IteratorErrorResponse) String 

func (x *IteratorErrorResponse) String() string

type IteratorNextRequest 

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

func (*IteratorNextRequest) Descriptor deprecated 

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

Deprecated: Use IteratorNextRequest.ProtoReflect.Descriptor instead.

func (*IteratorNextRequest) GetId 

func (x *IteratorNextRequest) GetId() uint64

func (*IteratorNextRequest) ProtoMessage 

func (*IteratorNextRequest) ProtoMessage()

func (*IteratorNextRequest) ProtoReflect 

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

func (*IteratorNextRequest) Reset 

func (x *IteratorNextRequest) Reset()

func (*IteratorNextRequest) String 

func (x *IteratorNextRequest) String() string

type IteratorNextResponse 

type IteratorNextResponse struct {
	Data []*PutRequest `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*IteratorNextResponse) Descriptor deprecated 

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

Deprecated: Use IteratorNextResponse.ProtoReflect.Descriptor instead.

func (*IteratorNextResponse) GetData 

func (x *IteratorNextResponse) GetData() []*PutRequest

func (*IteratorNextResponse) ProtoMessage 

func (*IteratorNextResponse) ProtoMessage()

func (*IteratorNextResponse) ProtoReflect 

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

func (*IteratorNextResponse) Reset 

func (x *IteratorNextResponse) Reset()

func (*IteratorNextResponse) String 

func (x *IteratorNextResponse) String() string

type IteratorReleaseRequest 

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

func (*IteratorReleaseRequest) Descriptor deprecated 

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

Deprecated: Use IteratorReleaseRequest.ProtoReflect.Descriptor instead.

func (*IteratorReleaseRequest) GetId 

func (x *IteratorReleaseRequest) GetId() uint64

func (*IteratorReleaseRequest) ProtoMessage 

func (*IteratorReleaseRequest) ProtoMessage()

func (*IteratorReleaseRequest) ProtoReflect 

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

func (*IteratorReleaseRequest) Reset 

func (x *IteratorReleaseRequest) Reset()

func (*IteratorReleaseRequest) String 

func (x *IteratorReleaseRequest) String() string

type IteratorReleaseResponse 

type IteratorReleaseResponse struct {
	Err Error `protobuf:"varint,1,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*IteratorReleaseResponse) Descriptor deprecated 

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

Deprecated: Use IteratorReleaseResponse.ProtoReflect.Descriptor instead.

func (*IteratorReleaseResponse) GetErr 

func (x *IteratorReleaseResponse) GetErr() Error

func (*IteratorReleaseResponse) ProtoMessage 

func (*IteratorReleaseResponse) ProtoMessage()

func (*IteratorReleaseResponse) ProtoReflect 

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

func (*IteratorReleaseResponse) Reset 

func (x *IteratorReleaseResponse) Reset()

func (*IteratorReleaseResponse) String 

func (x *IteratorReleaseResponse) String() string

type NewIteratorRequest 

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

func (*NewIteratorRequest) Descriptor deprecated 

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

Deprecated: Use NewIteratorRequest.ProtoReflect.Descriptor instead.

func (*NewIteratorRequest) ProtoMessage 

func (*NewIteratorRequest) ProtoMessage()

func (*NewIteratorRequest) ProtoReflect 

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

func (*NewIteratorRequest) Reset 

func (x *NewIteratorRequest) Reset()

func (*NewIteratorRequest) String 

func (x *NewIteratorRequest) String() string

type NewIteratorWithStartAndPrefixRequest 

type NewIteratorWithStartAndPrefixRequest struct {
	Start  []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Prefix []byte `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*NewIteratorWithStartAndPrefixRequest) Descriptor deprecated 

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

Deprecated: Use NewIteratorWithStartAndPrefixRequest.ProtoReflect.Descriptor instead.

func (*NewIteratorWithStartAndPrefixRequest) GetPrefix 

func (x *NewIteratorWithStartAndPrefixRequest) GetPrefix() []byte

func (*NewIteratorWithStartAndPrefixRequest) GetStart 

func (x *NewIteratorWithStartAndPrefixRequest) GetStart() []byte

func (*NewIteratorWithStartAndPrefixRequest) ProtoMessage 

func (*NewIteratorWithStartAndPrefixRequest) ProtoMessage()

func (*NewIteratorWithStartAndPrefixRequest) ProtoReflect 

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

func (*NewIteratorWithStartAndPrefixRequest) Reset 

func (x *NewIteratorWithStartAndPrefixRequest) Reset()

func (*NewIteratorWithStartAndPrefixRequest) String 

func (x *NewIteratorWithStartAndPrefixRequest) String() string

type NewIteratorWithStartAndPrefixResponse 

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

func (*NewIteratorWithStartAndPrefixResponse) Descriptor deprecated 

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

Deprecated: Use NewIteratorWithStartAndPrefixResponse.ProtoReflect.Descriptor instead.

func (*NewIteratorWithStartAndPrefixResponse) GetId 

func (x *NewIteratorWithStartAndPrefixResponse) GetId() uint64

func (*NewIteratorWithStartAndPrefixResponse) ProtoMessage 

func (*NewIteratorWithStartAndPrefixResponse) ProtoMessage()

func (*NewIteratorWithStartAndPrefixResponse) ProtoReflect 

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

func (*NewIteratorWithStartAndPrefixResponse) Reset 

func (x *NewIteratorWithStartAndPrefixResponse) Reset()

func (*NewIteratorWithStartAndPrefixResponse) String 

func (x *NewIteratorWithStartAndPrefixResponse) String() string

type PutRequest 

type PutRequest 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 (*PutRequest) Descriptor deprecated 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetKey 

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

func (*PutRequest) GetValue 

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

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

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

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) String 

func (x *PutRequest) String() string

type PutResponse 

type PutResponse struct {
	Err Error `protobuf:"varint,1,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*PutResponse) Descriptor deprecated 

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) GetErr 

func (x *PutResponse) GetErr() Error

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect 

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

func (*PutResponse) Reset 

func (x *PutResponse) Reset()

func (*PutResponse) String 

func (x *PutResponse) String() string

type WriteBatchRequest 

type WriteBatchRequest struct {
	Puts    []*PutRequest    `protobuf:"bytes,1,rep,name=puts,proto3" json:"puts,omitempty"`
	Deletes []*DeleteRequest `protobuf:"bytes,2,rep,name=deletes,proto3" json:"deletes,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteBatchRequest) Descriptor deprecated 

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

Deprecated: Use WriteBatchRequest.ProtoReflect.Descriptor instead.

func (*WriteBatchRequest) GetDeletes 

func (x *WriteBatchRequest) GetDeletes() []*DeleteRequest

func (*WriteBatchRequest) GetPuts 

func (x *WriteBatchRequest) GetPuts() []*PutRequest

func (*WriteBatchRequest) ProtoMessage 

func (*WriteBatchRequest) ProtoMessage()

func (*WriteBatchRequest) ProtoReflect 

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

func (*WriteBatchRequest) Reset 

func (x *WriteBatchRequest) Reset()

func (*WriteBatchRequest) String 

func (x *WriteBatchRequest) String() string

type WriteBatchResponse 

type WriteBatchResponse struct {
	Err Error `protobuf:"varint,1,opt,name=err,proto3,enum=rpcdb.Error" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteBatchResponse) Descriptor deprecated 

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

Deprecated: Use WriteBatchResponse.ProtoReflect.Descriptor instead.

func (*WriteBatchResponse) GetErr 

func (x *WriteBatchResponse) GetErr() Error

func (*WriteBatchResponse) ProtoMessage 

func (*WriteBatchResponse) ProtoMessage()

func (*WriteBatchResponse) ProtoReflect 

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

func (*WriteBatchResponse) Reset 

func (x *WriteBatchResponse) Reset()

func (*WriteBatchResponse) String 

func (x *WriteBatchResponse) 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.