- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 61 for listo (0.12 sec)
-
cmd/erasure-metadata-utils_test.go
} } } // Test for reduceErrs, reduceErr reduces collection // of errors into a single maximal error with in the list. func TestReduceErrs(t *testing.T) { canceledErrs := make([]error, 0, 5) for i := 0; i < 5; i++ { canceledErrs = append(canceledErrs, fmt.Errorf("error %d: %w", i, context.Canceled)) } // List all of all test cases to validate various cases of reduce errors. testCases := []struct { errs []error
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
istioctl/pkg/tag/revision.go
} func ListRevisionDescriptions(client kube.CLIClient) (map[string]*RevisionDescription, error) { revisions := map[string]*RevisionDescription{} // Get a list of control planes which are installed in remote clusters // In this case, it is possible that they only have webhooks installed. webhooks, err := Webhooks(context.Background(), client) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Jan 28 13:16:05 GMT 2023 - 4.5K bytes - Viewed (0) -
cmd/xl-storage-format-v2.go
return FileInfo{}, errFileVersionNotFound } fi.NumVersions = nonFreeVersions return fi, err } // ListVersions lists current versions, and current deleted // versions returns error for unexpected entries. // showPendingDeletes is set to true if ListVersions needs to list objects marked deleted // but waiting to be replicated func (x xlMetaV2) ListVersions(volume, path string, allParts bool) ([]FileInfo, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 05:07:37 GMT 2024 - 63.6K bytes - Viewed (1) -
cmd/iam-object-store.go
if err == errConfigNotFound { err = errNoSuchGroup } return err } // helper type for listIAMConfigItems type itemOrErr struct { Item string Err error } // Lists objects in the minioMetaBucket at the given path prefix. All returned // items have the pathPrefix removed from their names. func listIAMConfigItems(ctx context.Context, objAPI ObjectLayer, pathPrefix string) <-chan itemOrErr {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 19.9K bytes - Viewed (0) -
cmd/peer-s3-server.go
buckets = make([]BucketInfo, 0, 32) healBuckets := map[string]VolInfo{} // lists all unique buckets across drives. if err := listAllBuckets(ctx, localDrives, healBuckets, quorum); err != nil { return nil, err } // include deleted buckets in listBuckets output deletedBuckets := map[string]VolInfo{} if opts.Deleted { // lists all deleted buckets across drives.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 8.4K bytes - Viewed (0) -
cmd/api-resources_test.go
// You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "net/url" "testing" ) // Test list objects resources V2. func TestListObjectsV2Resources(t *testing.T) { testCases := []struct { values url.Values prefix, token, startAfter, delimiter string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 7.1K bytes - Viewed (0) -
cmd/event-notification.go
return arns } region := globalSite.Region for targetID, target := range evnot.targetList.TargetMap() { // httpclient target is part of ListenNotification // which doesn't need to be listed as part of the ARN list // This list is only meant for external targets, filter // this out pro-actively. if !strings.HasPrefix(targetID.ID, "httpclient+") { if onlyActive { if _, err := target.IsActive(); err != nil { continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.8K bytes - Viewed (0) -
cmd/ftp-server-driver.go
} objInfo, err := clnt.StatObject(context.Background(), bucket, object, minio.StatObjectOptions{}) if err != nil { if minio.ToErrorResponse(err).Code == "NoSuchKey" { // dummy return to satisfy LIST (stat -> list) behavior. return &minioFileInfo{ p: pathClean(object), info: minio.ObjectInfo{Key: object}, isDir: true, }, nil } return nil, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 13.6K bytes - Viewed (0) -
internal/config/notify/help.go
package notify import ( "github.com/minio/minio/internal/config" "github.com/minio/minio/internal/event/target" ) const ( formatComment = `'namespace' reflects current bucket/object list and 'access' reflects a journal of object operations, defaults to 'namespace'` queueDirComment = `staging dir for undelivered messages e.g. '/home/events'`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 18.8K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers.go
// Create a map of updated set of rules in request updatedRules := make(map[string]lifecycle.Rule, len(bucketLifecycle.Rules)) for _, rule := range bucketLifecycle.Rules { updatedRules[rule.ID] = rule } // Get list of rules for the bucket from disk meta, err := globalBucketMetadataSys.GetConfigFromDisk(ctx, bucket) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } expiryRuleRemoved := false
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 17:48:06 GMT 2023 - 7K bytes - Viewed (0)