storage

Documentation

Index

• func GetObjectMetaVersion(value []byte) (string, error)
• func GetObjectMetaVersion1(value []byte) (string, error)
• func GetObjectMetaVersion2(value []byte) (string, error)
• type BadgerLogger
  • func NewBadgerLogger(log *zap.Logger) *BadgerLogger
  • func (logger *BadgerLogger) Debugf(msg string, args ...interface{})
  • func (logger *BadgerLogger) Errorf(msg string, args ...interface{})
  • func (logger *BadgerLogger) Infof(msg string, args ...interface{})
  • func (logger *BadgerLogger) Warningf(msg string, args ...interface{})
• type KVS
  • func NewKVS(dir string, valueDir string, logger *zap.Logger) (*KVS, error)
  • func (k *KVS) Backup(w io.Writer) error
  • func (k *KVS) Close() error
  • func (k *KVS) Delete(key string) error
  • func (k *KVS) DeleteObject(itemKey, metaKey string, ifMatch, ifNoneMatch string, ...) error
  • func (k *KVS) Get(key string) ([]byte, error)
  • func (k *KVS) List(request *protobuf.ListRequest, stream protobuf.KVS_ListServer) error
  • func (k *KVS) RunGC(ctx context.Context, discardRatio float64)
  • func (k *KVS) ScheduleGC(ctx context.Context, interval time.Duration, discardRatio float64)
  • func (k *KVS) Set(key string, value []byte) error
  • func (k *KVS) SetObject(item, meta *protobuf.KeyValuePair, ifMatch, ifNoneMatch string, ...) error
  • func (k *KVS) Stats() map[string]string

Functions

func GetObjectMetaVersion

func GetObjectMetaVersion(value []byte) (string, error)

func GetObjectMetaVersion1

func GetObjectMetaVersion1(value []byte) (string, error)

func GetObjectMetaVersion2

func GetObjectMetaVersion2(value []byte) (string, error)

Types

type BadgerLogger

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

func NewBadgerLogger

func NewBadgerLogger(log *zap.Logger) *BadgerLogger

func (*BadgerLogger) Debugf

func (logger *BadgerLogger) Debugf(msg string, args ...interface{})

func (*BadgerLogger) Errorf

func (logger *BadgerLogger) Errorf(msg string, args ...interface{})

func (*BadgerLogger) Infof

func (logger *BadgerLogger) Infof(msg string, args ...interface{})

func (*BadgerLogger) Warningf

func (logger *BadgerLogger) Warningf(msg string, args ...interface{})

type KVS

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

func NewKVS

func NewKVS(dir string, valueDir string, logger *zap.Logger) (*KVS, error)

func (*KVS) Backup

func (k *KVS) Backup(w io.Writer) error

func (*KVS) Close

func (k *KVS) Close() error

func (*KVS) Delete

func (k *KVS) Delete(key string) error

func (*KVS) DeleteObject

func (k *KVS) DeleteObject(itemKey, metaKey string, ifMatch, ifNoneMatch string, ifModifiedSince, ifUnmodifiedSince int64) error

func (*KVS) Get

func (k *KVS) Get(key string) ([]byte, error)

func (*KVS) List

func (k *KVS) List(request *protobuf.ListRequest, stream protobuf.KVS_ListServer) error

func (*KVS) RunGC

func (k *KVS) RunGC(ctx context.Context, discardRatio float64)

func (*KVS) ScheduleGC

func (k *KVS) ScheduleGC(ctx context.Context, interval time.Duration, discardRatio float64)

func (*KVS) Set

func (k *KVS) Set(key string, value []byte) error

func (*KVS) SetObject

func (k *KVS) SetObject(item, meta *protobuf.KeyValuePair, ifMatch, ifNoneMatch string, ifModifiedSince, ifUnmodifiedSince int64) error

func (*KVS) Stats

func (k *KVS) Stats() map[string]string