Documentation ¶
Index ¶
- type PebbleDBConfig
- type PebbleShardOption
- type Store
- func (s *Store) Batch() *pebble.Batch
- func (s *Store) BuildColumnFamilyKey(cf byte, key []byte) []byte
- func (s *Store) Close() error
- func (s *Store) GetBytes(key []byte) ([]byte, error)
- func (s *Store) GetColumnFamily(cf string) byte
- func (s *Store) GetIterator() *pebble.Iterator
- func (s *Store) GetWo() *pebble.WriteOptions
- func (s *Store) LoadSnapShotFromReader(reader io.Reader, stopChan <-chan struct{}) error
- func (s *Store) NewSnapshotDir() (string, error)
- func (s *Store) SaveSnapShotToWriter(path string, writer io.Writer, stopChan <-chan struct{}) error
- func (s *Store) Write(b *pebble.Batch) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PebbleDBConfig ¶
type PebbleDBConfig struct { KVLRUCacheSize int64 KVWriteBufferSize int KVMaxWriteBufferNumber int KVLevel0FileNumCompactionTrigger int KVLevel0StopWritesTrigger int KVMaxBytesForLevelBase int64 KVTargetFileSizeBase int64 KVTargetFileSizeMultiplier int64 KVNumOfLevels int KVMaxOpenFiles int KVMaxConcurrentCompactions int KVBlockSize int KVMaxManifestFileSize int64 KVBytesPerSync int KVWALBytesPerSync int }
type PebbleShardOption ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
func (*Store) BuildColumnFamilyKey ¶
func (*Store) GetColumnFamily ¶
func (*Store) GetIterator ¶
func (*Store) GetWo ¶
func (s *Store) GetWo() *pebble.WriteOptions
func (*Store) LoadSnapShotFromReader ¶
func (*Store) NewSnapshotDir ¶
func (*Store) SaveSnapShotToWriter ¶
Click to show internal directories.
Click to hide internal directories.