bucketstore

Documentation

Index

• Variables
• type Bucket
  • func OpenStore(kind, path string, cfg *Config) (*Bucket, error)
• type BucketStore
• type Config
• type Loader
• type OverStore

Variables

var Backends = make(map[string]Loader)

var EBadRequest = errors.New("Bad Request")

var EDiskFailure = errors.New("Disk Failure")

var EExists = errors.New("Object exists")

var ENoBucket = errors.New("No such bucket")

var EOutOfStorage = errors.New("Out of Storage")

var ETemporaryFailure = errors.New("Temporary Failure")

Types

type Bucket

type Bucket struct {
	Store BucketStore
	Uuid  string
}

func OpenStore

func OpenStore(kind, path string, cfg *Config) (*Bucket, error)

type BucketStore

type BucketStore interface {
	Put(id, overv, head, body []byte, expire time.Time) error
	Get(id []byte, overv, head, body *bufferex.Binary) (ok bool, e error)
	Expire(expire time.Time) error
	FreeStorage() (int64, error)
}

type Config

type Config struct {
	MaxSpace int64 // Max. Storage consuption in bytes.
	MaxFiles int   // Max. number of file descriptors
}

type Loader

type Loader func(path string, cfg *Config) (BucketStore, error)

type OverStore

type OverStore interface {
	Submit(id, overv, head, body []byte, expire time.Time) (bucket bufferex.Binary, err error)
	OverPut(bucket []byte, id, overv, head, body []byte, expire time.Time) error
	OverGet(bucket []byte, id []byte, overv, head, body *bufferex.Binary) (ok bool, e error)
	OverExpire(bucket []byte, expire time.Time) error
	OverFreeStorage(bucket []byte) (int64, error)
}