- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 63 for bucketOf (0.32 sec)
-
cmd/erasure-healing-common.go
// parts. This is considered an outdated disk, since // it needs healing too. verifyResp, verifyErr = onlineDisk.VerifyFile(ctx, bucket, object, meta) default: verifyResp, verifyErr = onlineDisk.CheckParts(ctx, bucket, object, meta) } for p := range latestMeta.Parts { if verifyErr != nil { dataErrsByPart[p][i] = convPartErrToInt(verifyErr) } else {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 12.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/metrics/metrics.go
Subsystem: subsystem, Name: "read_wait_seconds", Help: "Histogram of time spent waiting for a watch cache to become fresh.", StabilityLevel: compbasemetrics.ALPHA, Buckets: []float64{0.005, 0.025, 0.05, 0.1, 0.2, 0.4, 0.6, 0.8, 1.0, 1.25, 1.5, 2, 3}, }, []string{"resource"}) ) var registerMetrics sync.Once // Register all metrics. func Register() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 07:39:23 UTC 2024 - 7.5K bytes - Viewed (0) -
cmd/storage-datatypes_gen.go
field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "Bucket": z.Bucket, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Bucket") return } case "Prefix": z.Prefix, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Prefix") return
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 130.6K bytes - Viewed (0) -
cmd/iam-store.go
} // GetBucketUsers - returns users (not STS or service accounts) that have access // to the bucket. User is included even if a group policy that grants access to // the bucket is disabled. func (store *IAMStoreSys) GetBucketUsers(bucket string) (map[string]madmin.UserInfo, error) { if bucket == "" { return nil, errInvalidArgument } cache := store.rlock() defer store.runlock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 75.8K bytes - Viewed (0) -
cmd/xl-storage-format-utils_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "slices" "sort" "testing" "time" "github.com/minio/minio/internal/bucket/lifecycle" xhttp "github.com/minio/minio/internal/http" ) func Test_hashDeterministicString(t *testing.T) { tests := []struct { name string arg map[string]string }{ { name: "zero",
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 22:18:44 UTC 2024 - 7.1K bytes - Viewed (0) -
settings.gradle.kts
} /** * Defines the testing module, for project helping test Gradle. */ fun testing(moduleConfiguration: ProjectScope.() -> Unit) = ProjectScope("testing").moduleConfiguration() /** * Defines a bucket of unassigned projects. */ fun unassigned(moduleConfiguration: ProjectScope.() -> Unit) = ProjectScope("subprojects").moduleConfiguration() class ProjectScope( private val basePath: String ) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:14 UTC 2024 - 16.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
cacher.bookmarkWatchers.popExpiredWatchersThreadUnsafe() if len(cacher.bookmarkWatchers.watchersBuckets) != 0 { numWatchers := 0 for bucketID, v := range cacher.bookmarkWatchers.watchersBuckets { numWatchers += len(v) t.Errorf("there are %v watchers at bucket Id %v with start Id %v", len(v), bucketID, cacher.bookmarkWatchers.startBucketID) } t.Errorf("unexpected bookmark watchers %v", numWatchers) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
internal/kms/config.go
const ( EnvKESEndpoint = "MINIO_KMS_KES_ENDPOINT" // One or multiple KES endpoints, separated by ',' EnvKESDefaultKey = "MINIO_KMS_KES_KEY_NAME" // The default key name used for IAM data and when no key ID is specified on a bucket EnvKESAPIKey = "MINIO_KMS_KES_API_KEY" // Access credential for KES - API keys and private key / certificate are mutually exclusive
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 12 14:31:26 UTC 2024 - 13.9K bytes - Viewed (0) -
cmd/iam.go
return updatedAt, nil } // ListBucketUsers - list all users who can access this 'bucket' func (sys *IAMSys) ListBucketUsers(ctx context.Context, bucket string) (map[string]madmin.UserInfo, error) { if !sys.Initialized() { return nil, errServerNotInitialized } select { case <-sys.configLoaded: return sys.store.GetBucketUsers(bucket) case <-ctx.Done(): return nil, ctx.Err() } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 71.9K bytes - Viewed (0) -
cluster/gce/upgrade.sh
echo "" echo ' Version number or publication is either a proper version number' echo ' (e.g. "v1.0.6", "v1.2.0-alpha.1.881+376438b69c7612") or a version' echo ' publication of the form <bucket>/<version> (e.g. "release/stable",' echo ' "ci/latest-1"). Some common ones are:' echo ' - "release/stable"' echo ' - "release/latest"' echo ' - "ci/latest"'
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 25.2K bytes - Viewed (0)