mount

Documentation

Index

• type DirectFileMount
  • func NewDirectFileMount(b backend.Backend, f *os.File, serverOptions *server.Options, ...) *DirectFileMount
  • func (d *DirectFileMount) Close() error
  • func (d *DirectFileMount) Open() (*os.File, error)
  • func (d *DirectFileMount) SwapBackend(b backend.Backend)
  • func (d *DirectFileMount) Sync() error
  • func (d *DirectFileMount) Wait() error
• type DirectPathMount
  • func NewDirectPathMount(b backend.Backend, f *os.File, serverOptions *server.Options, ...) *DirectPathMount
  • func (d *DirectPathMount) Close() error
  • func (d *DirectPathMount) Open() error
  • func (d *DirectPathMount) SwapBackend(b backend.Backend)
  • func (d *DirectPathMount) Sync() error
  • func (d *DirectPathMount) Wait() error
• type DirectSliceMount
  • func NewDirectSliceMount(b backend.Backend, f *os.File, serverOptions *server.Options, ...) *DirectSliceMount
  • func (d *DirectSliceMount) Close() error
  • func (d *DirectSliceMount) Open() ([]byte, error)
  • func (d *DirectSliceMount) SwapBackend(b backend.Backend)
  • func (d *DirectSliceMount) Sync() error
  • func (d *DirectSliceMount) Wait() error
• type ManagedFileMount
  • func NewManagedFileMount(ctx context.Context, remote backend.Backend, local backend.Backend, ...) *ManagedFileMount
  • func (m *ManagedFileMount) Close() error
  • func (m *ManagedFileMount) Open() (*os.File, error)
  • func (m *ManagedFileMount) Sync() error
  • func (m *ManagedFileMount) Wait() error
• type ManagedFileMountHooks
• type ManagedMountHooks
• type ManagedMountOptions
• type ManagedPathMount
  • func NewManagedPathMount(ctx context.Context, remote backend.Backend, local backend.Backend, ...) *ManagedPathMount
  • func (m *ManagedPathMount) Close() error
  • func (m *ManagedPathMount) Open() (string, int64, error)
  • func (m *ManagedPathMount) Sync() error
  • func (m *ManagedPathMount) Wait() error
• type ManagedSliceMount
  • func NewManagedSliceMount(ctx context.Context, remote backend.Backend, local backend.Backend, ...) *ManagedSliceMount
  • func (m *ManagedSliceMount) Close() error
  • func (m *ManagedSliceMount) Open() ([]byte, error)
  • func (m *ManagedSliceMount) Sync() error
  • func (m *ManagedSliceMount) Wait() error
• type ManagedSliceMountHooks

Types

type DirectFileMount

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

func NewDirectFileMount

func NewDirectFileMount(
	b backend.Backend,
	f *os.File,

	serverOptions *server.Options,
	clientOptions *client.Options,
) *DirectFileMount

func (*DirectFileMount) Close

func (d *DirectFileMount) Close() error

func (*DirectFileMount) Open

func (d *DirectFileMount) Open() (*os.File, error)

func (*DirectFileMount) SwapBackend

func (d *DirectFileMount) SwapBackend(b backend.Backend)

func (*DirectFileMount) Sync

func (d *DirectFileMount) Sync() error

func (*DirectFileMount) Wait

func (d *DirectFileMount) Wait() error

type DirectPathMount

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

func NewDirectPathMount

func NewDirectPathMount(
	b backend.Backend,
	f *os.File,

	serverOptions *server.Options,
	clientOptions *client.Options,
) *DirectPathMount

func (*DirectPathMount) Close

func (d *DirectPathMount) Close() error

func (*DirectPathMount) Open

func (d *DirectPathMount) Open() error

func (*DirectPathMount) SwapBackend

func (d *DirectPathMount) SwapBackend(b backend.Backend)

func (*DirectPathMount) Sync

func (d *DirectPathMount) Sync() error

func (*DirectPathMount) Wait

func (d *DirectPathMount) Wait() error

type DirectSliceMount

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

func NewDirectSliceMount

func NewDirectSliceMount(
	b backend.Backend,
	f *os.File,

	serverOptions *server.Options,
	clientOptions *client.Options,
) *DirectSliceMount

func (*DirectSliceMount) Close

func (d *DirectSliceMount) Close() error

func (*DirectSliceMount) Open

func (d *DirectSliceMount) Open() ([]byte, error)

func (*DirectSliceMount) SwapBackend

func (d *DirectSliceMount) SwapBackend(b backend.Backend)

func (*DirectSliceMount) Sync

func (d *DirectSliceMount) Sync() error

func (*DirectSliceMount) Wait

func (d *DirectSliceMount) Wait() error

type ManagedFileMount

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

func NewManagedFileMount

func NewManagedFileMount(
	ctx context.Context,

	remote backend.Backend,
	local backend.Backend,

	options *ManagedMountOptions,
	hooks *ManagedFileMountHooks,

	serverOptions *server.Options,
	clientOptions *client.Options,
) *ManagedFileMount

func (*ManagedFileMount) Close

func (m *ManagedFileMount) Close() error

func (*ManagedFileMount) Open

func (m *ManagedFileMount) Open() (*os.File, error)

func (*ManagedFileMount) Sync

func (m *ManagedFileMount) Sync() error

func (*ManagedFileMount) Wait

func (m *ManagedFileMount) Wait() error

type ManagedFileMountHooks

type ManagedFileMountHooks struct {
	OnChunkIsLocal func(off int64) error
}

type ManagedMountHooks

type ManagedMountHooks struct {
	OnBeforeSync func() error

	OnBeforeClose func() error

	OnChunkIsLocal func(off int64) error
}

type ManagedMountOptions

type ManagedMountOptions struct {
	ChunkSize int64

	PullWorkers  int64
	PullPriority func(off int64) int64
	PullFirst    bool

	PushWorkers  int64
	PushInterval time.Duration

	Verbose bool
}

type ManagedPathMount

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

func NewManagedPathMount

func NewManagedPathMount(
	ctx context.Context,

	remote backend.Backend,
	local backend.Backend,

	options *ManagedMountOptions,
	hooks *ManagedMountHooks,

	serverOptions *server.Options,
	clientOptions *client.Options,
) *ManagedPathMount

func (*ManagedPathMount) Close

func (m *ManagedPathMount) Close() error

func (*ManagedPathMount) Open

func (m *ManagedPathMount) Open() (string, int64, error)

func (*ManagedPathMount) Sync

func (m *ManagedPathMount) Sync() error

func (*ManagedPathMount) Wait

func (m *ManagedPathMount) Wait() error

type ManagedSliceMount

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

func NewManagedSliceMount

func NewManagedSliceMount(
	ctx context.Context,

	remote backend.Backend,
	local backend.Backend,

	options *ManagedMountOptions,
	hooks *ManagedSliceMountHooks,

	serverOptions *server.Options,
	clientOptions *client.Options,
) *ManagedSliceMount

func (*ManagedSliceMount) Close

func (m *ManagedSliceMount) Close() error

func (*ManagedSliceMount) Open

func (m *ManagedSliceMount) Open() ([]byte, error)

func (*ManagedSliceMount) Sync

func (m *ManagedSliceMount) Sync() error

func (*ManagedSliceMount) Wait

func (m *ManagedSliceMount) Wait() error

type ManagedSliceMountHooks

type ManagedSliceMountHooks struct {
	OnChunkIsLocal func(off int64) error
}