manager

Documentation

Index

• func NewCreate(reservationMap *common.ReservationMap) *create
• type Cluster
  • func NewCluster(managerAddresses []string) (Cluster, error)
• type Dfs
  • func NewDfs(metadata data.Metadata, cluster Cluster) Dfs

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