storage

May 8, 2022

Changes in this version

type BlockConfig

+ ReadBufSize int

Jan 25, 2022

Changes in this version

type DiskConfig

+ LockFile string

Jan 17, 2022

Changes in this version

+ var ErrAlreadyLocked = errorString("store/storage: storage lock already open")

+ var ErrClosed = errorString("store/storage: closed")

+ func IsLockKey(key string) bool

+ type Lock struct

+ func (f *Lock) Add()

+ func (f *Lock) Close() error

+ func (f *Lock) Closed() bool

+ func (f *Lock) Done()

Dec 17, 2021

Changes in this version

+ const LockFile

type BlockStorage

+ func (st *BlockStorage) Close() error

type DiskStorage

+ func (st *DiskStorage) Close() error

+ type LockableFile struct

+ func OpenLock(path string) (*LockableFile, error)

+ func (f *LockableFile) Lock() error

+ func (f *LockableFile) Unlock() error

type MemoryStorage

+ func (st *MemoryStorage) Close() error

type Storage

+ Close func() error

Nov 26, 2021

Changes in this version

+ type MemoryStorage struct

+ func OpenMemory(size int) *MemoryStorage

+ func (st *MemoryStorage) Clean() error

+ func (st *MemoryStorage) ReadBytes(key string) ([]byte, error)

+ func (st *MemoryStorage) ReadStream(key string) (io.ReadCloser, error)

+ func (st *MemoryStorage) Remove(key string) error

+ func (st *MemoryStorage) Stat(key string) (bool, error)

+ func (st *MemoryStorage) WalkKeys(opts WalkKeysOptions) error

+ func (st *MemoryStorage) WriteBytes(key string, b []byte) error

+ func (st *MemoryStorage) WriteStream(key string, r io.Reader) error

Oct 5, 2021

Changes in this version

+ var DefaultBlockConfig = &BlockConfig

+ var DefaultDiskConfig = &DiskConfig

+ var ErrAlreadyExists = errorString("store/storage: key already exists")

+ var ErrInvalidKey = errorString("store/storage: invalid key")

+ var ErrNotFound = errorString("store/storage: key not found")

+ type BlockConfig struct

+ BlockSize int

+ Compression Compressor

+ Overwrite bool

+ WriteBufSize int

+ type BlockStorage struct

+ func OpenBlock(path string, cfg *BlockConfig) (*BlockStorage, error)

+ func (st *BlockStorage) Clean() error

+ func (st *BlockStorage) ReadBytes(key string) ([]byte, error)

+ func (st *BlockStorage) ReadStream(key string) (io.ReadCloser, error)

+ func (st *BlockStorage) Remove(key string) error

+ func (st *BlockStorage) Stat(key string) (bool, error)

+ func (st *BlockStorage) WalkKeys(opts *WalkKeysOptions) error

+ func (st *BlockStorage) WriteBytes(key string, value []byte) error

+ func (st *BlockStorage) WriteStream(key string, r io.Reader) error

+ type Compressor interface

+ Reader func(io.Reader) (io.ReadCloser, error)

+ Writer func(io.Writer) (io.WriteCloser, error)

+ func GZipCompressor() Compressor

+ func GZipCompressorLevel(level int) Compressor

+ func NoCompression() Compressor

+ func SnappyCompressor() Compressor

+ func ZLibCompressor() Compressor

+ func ZLibCompressorLevel(level int) Compressor

+ func ZLibCompressorLevelDict(level int, dict []byte) Compressor

+ type DiskConfig struct

+ Compression Compressor

+ Overwrite bool

+ Transform KeyTransform

+ WriteBufSize int

+ type DiskStorage struct

+ func OpenFile(path string, cfg *DiskConfig) (*DiskStorage, error)

+ func (st *DiskStorage) Clean() error

+ func (st *DiskStorage) ReadBytes(key string) ([]byte, error)

+ func (st *DiskStorage) ReadStream(key string) (io.ReadCloser, error)

+ func (st *DiskStorage) Remove(key string) error

+ func (st *DiskStorage) Stat(key string) (bool, error)

+ func (st *DiskStorage) WalkKeys(opts *WalkKeysOptions) error

+ func (st *DiskStorage) WriteBytes(key string, value []byte) error

+ func (st *DiskStorage) WriteStream(key string, r io.Reader) error

+ type KeyTransform interface

+ KeyToPath func(string) string

+ PathToKey func(string) string

+ func NopTransform() KeyTransform

+ type Storage interface

+ Clean func() error

+ ReadBytes func(key string) ([]byte, error)

+ ReadStream func(key string) (io.ReadCloser, error)

+ Remove func(key string) error

+ Stat func(key string) (bool, error)

+ WalkKeys func(opts *WalkKeysOptions) error

+ WriteBytes func(key string, value []byte) error

+ WriteStream func(key string, r io.Reader) error

+ type StorageEntry interface

+ Key func() string

+ type WalkKeysOptions struct

+ WalkFn func(StorageEntry)