gotfs

package

Go to main page

Versions in this module

v0

v0.0.4

Jul 21, 2022

Changes in this version

+ const DefaultMeanBlobSizeData

+ const DefaultMeanBlobSizeMetadata

+ func SplitPath(p string) []string

type Operator

+ func (o *Operator) ForEachLeaf(ctx context.Context, s cadata.Store, root Root, p string, ...) error

+ func (o *Operator) MaxInfo(ctx context.Context, ms cadata.Store, root Root, span Span) (string, *Info, error)

+ func (o *Operator) MeanBlobSizeData() int

+ func (o *Operator) MeanBlobSizeMetadata() int

+ func (o *Operator) Populate(ctx context.Context, s Store, root Root, mdSet, dataSet cadata.Set) error

+ func (o *Operator) Sync(ctx context.Context, srcMeta, srcData, dstMeta, dstData Store, root Root) error

type Option

+ func WithSalt(salt *[32]byte) Option

+ type Reader = gotlob.Reader

+ type Span = gotkv.Span

v0.0.3

Jun 25, 2022

Changes in this version

+ const DefaultAverageBlobSizeInfo

+ type Info struct

+ Labels map[string]string

+ Mode uint32

+ func (*Info) Descriptor() ([]byte, []int)

+ func (*Info) ProtoMessage()

+ func (x *Info) GetLabels() map[string]string

+ func (x *Info) GetMode() uint32

+ func (x *Info) ProtoReflect() protoreflect.Message

+ func (x *Info) Reset()

+ func (x *Info) String() string

type Operator

+ func (o *Operator) GetDirInfo(ctx context.Context, s Store, x Root, p string) (*Info, error)

+ func (o *Operator) GetFileInfo(ctx context.Context, s Store, x Root, p string) (*Info, error)

+ func (o *Operator) GetInfo(ctx context.Context, s Store, x Root, p string) (*Info, error)

+ func (o *Operator) PutInfo(ctx context.Context, s Store, x Root, p string, md *Info) (*Root, error)

v0.0.2

Dec 28, 2021

Changes in this version

type FileReader

+ func (fr *FileReader) Seek(offset int64, whence int) (int64, error)

v0.0.1

Dec 20, 2021

Changes in this version

+ const DefaultAverageBlobSizeData

+ const DefaultAverageBlobSizeMetadata

+ const DefaultMaxBlobSize

+ const DefaultMinBlobSizeData

+ const MaxPathLen

+ const Sep

+ var File_models_proto protoreflect.FileDescriptor

+ func Dump(ctx context.Context, s Store, root Root, w io.Writer) error

+ func Equal(a, b Root) bool

+ func IsEmpty(root Root) bool

+ func Populate(ctx context.Context, s Store, root Root, mdSet, dataSet cadata.Set) error

+ func SpanForPath(p string) gotkv.Span

+ func Sync(ctx context.Context, dst, src Store, root Root, ...) error

+ type Builder struct

+ func (b *Builder) BeginFile(p string, mode os.FileMode) error

+ func (b *Builder) Finish() (*Root, error)

+ func (b *Builder) IsFinished() bool

+ func (b *Builder) Mkdir(p string, mode os.FileMode) error

+ func (b *Builder) Write(data []byte) (int, error)

+ func (b *Builder) WriteExtents(ctx context.Context, exts []*Extent) error

+ type DirEnt struct

+ Mode os.FileMode

+ Name string

+ type Extent struct

+ Length uint32

+ Offset uint32

+ Ref []byte

+ func (*Extent) Descriptor() ([]byte, []int)

+ func (*Extent) ProtoMessage()

+ func (x *Extent) GetLength() uint32

+ func (x *Extent) GetOffset() uint32

+ func (x *Extent) GetRef() []byte

+ func (x *Extent) ProtoReflect() protoreflect.Message

+ func (x *Extent) Reset()

+ func (x *Extent) String() string

+ type ExtentDiffFn = func(p string, offset uint64, left, right *Extent) error

+ type FileReader struct

+ func (fr *FileReader) Read(buf []byte) (int, error)

+ type Metadata struct

+ Labels map[string]string

+ Mode uint32

+ func (*Metadata) Descriptor() ([]byte, []int)

+ func (*Metadata) ProtoMessage()

+ func (x *Metadata) GetLabels() map[string]string

+ func (x *Metadata) GetMode() uint32

+ func (x *Metadata) ProtoReflect() protoreflect.Message

+ func (x *Metadata) Reset()

+ func (x *Metadata) String() string

+ type MetadataDiffFn = func(p string, left, right *Metadata) error

+ type Operator struct

+ func NewOperator(opts ...Option) Operator

+ func (o *Operator) AddPrefix(root Root, p string) Root

+ func (o *Operator) Check(ctx context.Context, s Store, root Root, checkData func(ref gdat.Ref) error) error

+ func (o *Operator) CreateExtents(ctx context.Context, ds Store, r io.Reader) ([]*Extent, error)

+ func (o *Operator) CreateFile(ctx context.Context, ms, ds Store, x Root, p string, r io.Reader) (*Root, error)

+ func (o *Operator) CreateFileRoot(ctx context.Context, ms, ds Store, r io.Reader) (*Root, error)

+ func (o *Operator) CreateFileRootFromExtents(ctx context.Context, ms, ds Store, exts []*Extent) (*Root, error)

+ func (o *Operator) Diff(ctx context.Context, s cadata.Store, lRoot, rRoot Root, metaFn MetadataDiffFn, ...) error

+ func (o *Operator) DiffPaths(ctx context.Context, s cadata.Store, prev, next Root, ...) error

+ func (o *Operator) ForEach(ctx context.Context, s cadata.Store, root Root, p string, ...) error

+ func (o *Operator) ForEachFile(ctx context.Context, s cadata.Store, root Root, p string, ...) error

+ func (o *Operator) GetDirMetadata(ctx context.Context, s Store, x Root, p string) (*Metadata, error)

+ func (o *Operator) GetFileMetadata(ctx context.Context, s Store, x Root, p string) (*Metadata, error)

+ func (o *Operator) GetMetadata(ctx context.Context, s Store, x Root, p string) (*Metadata, error)

+ func (o *Operator) Graft(ctx context.Context, ms, ds cadata.Store, root Root, p string, branch Root) (*Root, error)

+ func (o *Operator) Mkdir(ctx context.Context, s Store, x Root, p string) (*Root, error)

+ func (o *Operator) MkdirAll(ctx context.Context, s Store, x Root, p string) (*Root, error)

+ func (o *Operator) NewBuilder(ctx context.Context, ms, ds Store) *Builder

+ func (o *Operator) NewEmpty(ctx context.Context, s Store) (*Root, error)

+ func (o *Operator) NewReader(ctx context.Context, ms, ds Store, x Root, p string) *FileReader

+ func (o *Operator) PutMetadata(ctx context.Context, s Store, x Root, p string, md *Metadata) (*Root, error)

+ func (o *Operator) ReadDir(ctx context.Context, s Store, x Root, p string, fn func(e DirEnt) error) error

+ func (o *Operator) ReadFileAt(ctx context.Context, ms, ds Store, x Root, p string, start uint64, buf []byte) (int, error)

+ func (o *Operator) RemoveAll(ctx context.Context, s Store, x Root, p string) (*Root, error)

+ func (o *Operator) Select(ctx context.Context, s cadata.Store, root Root, p string) (*Root, error)

+ func (o *Operator) SizeOfFile(ctx context.Context, s Store, x Root, p string) (uint64, error)

+ func (o *Operator) Splice(ctx context.Context, ms, ds Store, segs []Segment) (*Root, error)

+ type Option func(o *Operator)

+ func WithContentCacheSize(n int) Option

+ func WithMetaCacheSize(n int) Option

+ func WithSeed(seed *[32]byte) Option

+ type Ref = gotkv.Ref

+ type Root = gotkv.Root

+ type Segment struct

+ Root Root

+ Span gotkv.Span

+ func ChangesOnBase(base Root, changes []Segment) []Segment

+ func (s Segment) String() string

+ type Store = gotkv.Store

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL