store

Documentation

Index

• func NewFSBlockStore(path string, defaultHashAPI uint32, jobAPI lib.Longtail_JobAPI) (lib.BlockStoreAPI, error)
• func NewGCSBlockStore(u *url.URL, defaultHashAPI lib.Longtail_HashAPI, maxBlockSize uint32, ...) (lib.BlockStoreAPI, error)
• type FileStorage
  • func NewFSFileStorage() (FileStorage, error)
  • func NewGCSFileStorage(u *url.URL) (FileStorage, error)

Functions

func NewFSBlockStore

func NewFSBlockStore(path string, defaultHashAPI uint32, jobAPI lib.Longtail_JobAPI) (lib.BlockStoreAPI, error)

NewFSBlockStore ...

func NewGCSBlockStore

func NewGCSBlockStore(u *url.URL, defaultHashAPI lib.Longtail_HashAPI, maxBlockSize uint32, maxChunksPerBlock uint32) (lib.BlockStoreAPI, error)

NewGCSBlockStore ...

Types

type FileStorage

type FileStorage interface {
	ReadFromPath(ctx context.Context, path string) ([]byte, error)
	WriteToPath(ctx context.Context, path string, data []byte) error
	Close()
}

func NewFSFileStorage

func NewFSFileStorage() (FileStorage, error)

NewFSFileStorage ...

func NewGCSFileStorage

func NewGCSFileStorage(u *url.URL) (FileStorage, error)

NewGCSFileStorage ...