minio/cmd/erasure-demo/fs.go

package main

import (
	"bytes"
	"encoding/json"
	"io"
	"os"
	"path"

	"github.com/minio-io/minio/pkgs/storage"
	"github.com/minio-io/minio/pkgs/storage/fsstorage"
)

func fsGetList(config inputConfig) (io.Reader, error) {
	var objectStorage storage.ObjectStorage
	rootDir := path.Join(config.rootDir, config.storageDriver)
	objectStorage, _ = fsstorage.NewStorage(rootDir, config.blockSize)
	objectList, err := objectStorage.List()
	if err != nil {
		return nil, err
	}
	var objectListBytes []byte
	if objectListBytes, err = json.Marshal(objectList); err != nil {
		return nil, err
	}
	objectListBuffer := bytes.NewBuffer(objectListBytes)
	return objectListBuffer, nil
}

func fsGet(config inputConfig, objectPath string) (io.Reader, error) {
	var objectStorage storage.ObjectStorage
	rootDir := path.Join(config.rootDir, config.storageDriver)
	objectStorage, _ = fsstorage.NewStorage(rootDir, config.blockSize)
	object, err := objectStorage.Get(objectPath)
	if err != nil {
		return nil, err
	}
	return object, nil
}

func fsPut(config inputConfig, objectPath string, reader io.Reader) error {
	var err error
	rootDir := path.Join(config.rootDir, config.storageDriver)
	if err := os.MkdirAll(config.rootDir, 0700); err != nil {
		return err
	}
	var objectStorage storage.ObjectStorage
	objectStorage, _ = fsstorage.NewStorage(rootDir, config.blockSize)
	if err = objectStorage.Put(objectPath, reader); err != nil {
		return err
	}
	return nil
}