hashdb

Documentation

Index

• Constants
• type DB
  • func AsyncHashDB(ctx context.Context, constructor func(context.Context) (DB, error)) DB
  • func New(backend backends.Backend) DB
  • func Open(ctx context.Context, backend backends.Backend) (DB, error)

Constants

const HashPrefix = "hash/"

const SmallHashsetSuffix = ".hs"

const SmallHashsetThreshold = 64 * 1024

Types

type DB

type DB interface {
	Close() error
	Coalesce(context.Context) error
	Flush(context.Context) error
	Has(ctx context.Context, hash string) (exists bool, err error)
	Iterate(context.Context,
		func(ctx context.Context, hash, hashset string, data *manifest.Stream) error) error
	Lookup(ctx context.Context, hash string) (*manifest.Stream, error)
	Put(ctx context.Context, hash string, data *manifest.Stream) error
	Split(context.Context) error
}

func AsyncHashDB

func AsyncHashDB(ctx context.Context, constructor func(context.Context) (DB, error)) DB

func New

func New(backend backends.Backend) DB

func Open

func Open(ctx context.Context, backend backends.Backend) (DB, error)