Provide new cli options for 'put' command

- --protection-level
  - --block-size
This commit is contained in:
Harshavardhana 2014-12-11 22:56:10 -08:00
parent 429836593b
commit f71b323e32
2 changed files with 16 additions and 6 deletions

View File

@ -18,7 +18,7 @@ func erasureGetList(config inputConfig) (io.Reader, error) {
func erasureGet(config inputConfig, objectPath string) (io.Reader, error) {
var objectStorage storage.ObjectStorage
rootDir := path.Join(config.rootDir, config.storageDriver)
objectStorage, err := es.NewStorage(rootDir, 10, 6, 1024*1024)
objectStorage, err := es.NewStorage(rootDir, config.k, config.m, config.blockSize)
if err != nil {
return nil, err
}
@ -36,7 +36,7 @@ func erasurePut(config inputConfig, objectPath string, reader io.Reader) error {
return err
}
var objectStorage storage.ObjectStorage
if objectStorage, err = es.NewStorage(rootDir, 10, 6, 1024*1024); err != nil {
if objectStorage, err = es.NewStorage(rootDir, config.k, config.m, config.blockSize); err != nil {
return err
}
if err = objectStorage.Put(objectPath, reader); err != nil {

View File

@ -69,8 +69,8 @@ func main() {
},
cli.StringFlag{
Name: "driver",
Value: "fs",
Usage: "fs",
Value: "erasure",
Usage: "erasure",
},
},
},
@ -84,10 +84,20 @@ func main() {
Value: getMinioDir(),
Usage: "",
},
cli.StringFlag{
Name: "protection-level",
Value: "10,6",
Usage: "data,parity",
},
cli.StringFlag{
Name: "block-size",
Value: "1M",
Usage: "Size of blocks. Examples: 1K, 1M, full",
},
cli.StringFlag{
Name: "driver",
Value: "fs",
Usage: "fs",
Value: "erasure",
Usage: "erasure",
},
},
},