c27ece409b
In the algorithm to check if an object requires healing, in addition to checking if all disks have xl.json present we should check if all parts of the object are present and have valid blake2b checksums. Also fixed a minor compilation error in heal-objects-list.go.
76 lines
2.1 KiB
Go
76 lines
2.1 KiB
Go
// +build ignore
|
|
|
|
package main
|
|
|
|
/*
|
|
* Minio Cloud Storage, (C) 2017 Minio, Inc.
|
|
*
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*
|
|
*/
|
|
|
|
import (
|
|
"fmt"
|
|
"log"
|
|
|
|
"github.com/minio/minio/pkg/madmin"
|
|
)
|
|
|
|
func main() {
|
|
|
|
// Note: YOUR-ACCESSKEYID, YOUR-SECRETACCESSKEY are
|
|
// dummy values, please replace them with original values.
|
|
|
|
// API requests are secure (HTTPS) if secure=true and insecure (HTTPS) otherwise.
|
|
// New returns an Minio Admin client object.
|
|
madmClnt, err := madmin.New("your-minio.example.com:9000", "YOUR-ACCESSKEYID", "YOUR-SECRETACCESSKEY", true)
|
|
if err != nil {
|
|
log.Fatalln(err)
|
|
}
|
|
|
|
bucket := "mybucket"
|
|
prefix := "myprefix"
|
|
|
|
// Create a done channel to control 'ListObjectsHeal' go routine.
|
|
doneCh := make(chan struct{})
|
|
// Indicate to our routine to exit cleanly upon return.
|
|
defer close(doneCh)
|
|
|
|
// Set true if recursive listing is needed.
|
|
isRecursive := true
|
|
// List objects that need healing for a given bucket and
|
|
// prefix.
|
|
healObjectsCh, err := madmClnt.ListObjectsHeal(bucket, prefix, isRecursive, doneCh)
|
|
if err != nil {
|
|
log.Fatalln(err)
|
|
}
|
|
|
|
for object := range healObjectsCh {
|
|
if object.Err != nil {
|
|
log.Fatalln(err)
|
|
return
|
|
}
|
|
|
|
if object.HealObjectInfo != nil {
|
|
switch healInfo := *object.HealObjectInfo; healInfo.Status {
|
|
case madmin.CanHeal:
|
|
fmt.Println(object.Key, " can be healed.")
|
|
case madmin.QuorumUnavailable:
|
|
fmt.Println(object.Key, " can't be healed until quorum is available.")
|
|
case madmin.Corrupted:
|
|
fmt.Println(object.Key, " can't be healed, not enough information.")
|
|
}
|
|
}
|
|
fmt.Println("object: ", object)
|
|
}
|
|
}
|