manager

package
v0.0.0-...-3d8c618 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 22, 2020 License: GPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCreate

func NewCreate(reservationMap *common.ReservationMap) *create

Types

type Cluster

type Cluster interface {
	Create(size uint64, reader io.Reader) (common.DataChunks, error)
	CreateShadow(chunks common.DataChunks) error
	Read(chunks common.DataChunks, writer io.Writer, begins int64, ends int64) error
	Delete(chunks common.DataChunks) ([]string, []string, error)
}

func NewCluster

func NewCluster(managerAddresses []string) (Cluster, error)

type Dfs

type Dfs interface {
	CreateFolder(folderPath string) error
	CreateFile(path string, mime string, size uint64, contentReader io.Reader, overwrite bool) error

	Read(paths []string, join bool,
		folderHandler func(folder *common.Folder) error,
		fileHandler func(file *common.File, streamHandler func(writer io.Writer, begins int64, ends int64) error) error) error
	Size(folderPath string) (uint64, error)

	Move(sources []string, target string, join bool, overwrite bool) error
	Copy(sources []string, target string, join bool, overwrite bool) error
	Delete(path string, killZombies bool) error
}

func NewDfs

func NewDfs(metadata data.Metadata, cluster Cluster) Dfs

Jump to

Keyboard shortcuts

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