kvfile

Apr 24, 2024

Changes in this version

type IndexEntry

+ func (x *IndexEntry) MarshalProtoText() string

Apr 22, 2024

Changes in this version

type IndexEntry

+ func (x *IndexEntry) MarshalJSON() ([]byte, error)

+ func (x *IndexEntry) MarshalProtoJSON(s *json.MarshalState)

+ func (x *IndexEntry) UnmarshalJSON(b []byte) error

+ func (x *IndexEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

Apr 5, 2024

Changes in this version

+ var File_github_com_aperturerobotics_go_kvfile_kv_proto protoreflect.FileDescriptor

+ func WriteIndex(writer io.Writer, index []*IndexEntry, pos uint64) (uint64, error)

type IndexEntry

+ Size uint64

+ func (x *IndexEntry) GetSize() uint64

+ type Writer struct

+ func NewWriter(out io.Writer) *Writer

+ func (w *Writer) Close() error

+ func (w *Writer) GetPos() uint64

+ func (w *Writer) WriteValue(key []byte, valueRdr io.Reader) error

Mar 22, 2024

Changes in this version

type Reader

+ func (r *Reader) GetValueSize(key []byte) (int64, error)

Oct 27, 2023

Changes in this version

+ var ErrIntOverflow = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")

+ var File_compressed_kv_file_kv_proto protoreflect.FileDescriptor

+ func Write(writer io.Writer, keys [][]byte, writeValue WriteValueFunc) error

+ func WriteIterator(writer io.Writer, keyIterator KeyIteratorFunc, writeValueFunc WriteValueFunc) error

+ type FileReaderAt interface

+ type IndexEntry struct

+ Key []byte

+ Offset uint64

+ func (*IndexEntry) Descriptor() ([]byte, []int)

+ func (*IndexEntry) ProtoMessage()

+ func (m *IndexEntry) CloneMessageVT() proto.Message

+ func (m *IndexEntry) CloneVT() *IndexEntry

+ func (m *IndexEntry) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IndexEntry) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IndexEntry) MarshalVT() (dAtA []byte, err error)

+ func (m *IndexEntry) SizeVT() (n int)

+ func (m *IndexEntry) UnmarshalVT(dAtA []byte) error

+ func (this *IndexEntry) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *IndexEntry) EqualVT(that *IndexEntry) bool

+ func (x *IndexEntry) GetKey() []byte

+ func (x *IndexEntry) GetOffset() uint64

+ func (x *IndexEntry) ProtoReflect() protoreflect.Message

+ func (x *IndexEntry) Reset()

+ func (x *IndexEntry) String() string

+ type KeyIteratorFunc func() (key []byte, err error)

+ type Reader struct

+ func BuildReader(rd io.ReaderAt, fileSize uint64) (*Reader, error)

+ func BuildReaderWithFile(f FileReaderAt) (*Reader, error)

+ func BuildReaderWithSeeker(rd ReaderAtSeeker) (*Reader, error)

+ func (r *Reader) Exists(key []byte) (bool, error)

+ func (r *Reader) Get(key []byte) ([]byte, bool, error)

+ func (r *Reader) GetValuePosition(key []byte) (idx, length int64, indexEntry *IndexEntry, indexEntryIdx int, err error)

+ func (r *Reader) GetValuePositionWithEntry(indexEntry *IndexEntry, indexEntryIdx int) (idx, length int64, err error)

+ func (r *Reader) GetWithEntry(indexEntry *IndexEntry, indexEntryIdx int) ([]byte, error)

+ func (r *Reader) ReadIndexEntry(indexEntryIdx uint64) (*IndexEntry, error)

+ func (r *Reader) ReadTo(key []byte, to io.Writer) (int, bool, error)

+ func (r *Reader) ScanPrefix(prefix []byte, cb func(key, value []byte) error) error

+ func (r *Reader) ScanPrefixEntries(prefix []byte, cb func(indexEntry *IndexEntry, indexEntryIdx int) error) error

+ func (r *Reader) ScanPrefixKeys(prefix []byte, cb func(key []byte) error) error

+ func (r *Reader) SearchIndexEntryWithKey(key []byte) (*IndexEntry, int, error)

+ func (r *Reader) SearchIndexEntryWithPrefix(prefix []byte, last bool) (*IndexEntry, int, error)

+ func (r *Reader) Size() uint64

+ type ReaderAtSeeker interface

+ type WriteValueFunc func(wr io.Writer, key []byte) (uint64, error)