- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 289 for from (0.13 sec)
-
internal/config/identity/openid/openid.go
} for k, v := range r.ProviderCfgs { cfg.ProviderCfgs[k] = v } for k, v := range r.roleArnPolicyMap { cfg.roleArnPolicyMap[k] = v } return cfg } // LookupConfig lookup jwks from config, override with any ENVs. func LookupConfig(s config.Config, transport http.RoundTripper, closeRespFn func(io.ReadCloser), serverRegion string) (c Config, err error) { openIDClientTransport := http.DefaultTransport
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 16 04:42:31 GMT 2023 - 16.5K bytes - Viewed (0) -
cmd/admin-handler-utils.go
} return toAPIError(ctx, fmt.Errorf("error exporting %s from %s with: %w", entity, fname, err)) } // wraps import error for more context func importError(ctx context.Context, err error, fname, entity string) APIError { if entity == "" { return toAPIError(ctx, fmt.Errorf("error importing %s with: %w", fname, err)) } return toAPIError(ctx, fmt.Errorf("error importing %s from %s with: %w", entity, fname, err)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 8.2K bytes - Viewed (0) -
cmd/erasure-object.go
if err != nil { return oi, err } ctx = lkctx.Context() defer lk.Unlock(lkctx) } // Read metadata associated with the object from all disks. storageDisks := er.getDisks() var metaArr []FileInfo var errs []error // Read metadata associated with the object from all disks. if srcOpts.VersionID != "" { metaArr, errs = readAllFileInfo(ctx, storageDisks, "", srcBucket, srcObject, srcOpts.VersionID, true, false)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/erasure-server-pool.go
return mtime1.After(mtime2) }) defPool := PoolObjInfo{Index: -1} for _, pinfo := range poolObjInfos { // skip all objects from suspended pools if asked by the // caller. if opts.SkipDecommissioned && z.IsSuspended(pinfo.Index) { continue } // Skip object if it's from pools participating in a rebalance operation. if opts.SkipRebalancing && z.IsPoolRebalancing(pinfo.Index) { continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/license-update.go
resp, err := globalSubnetConfig.Post(url, nil) if err != nil { subnetLogIf(ctx, fmt.Errorf("error from %s: %w", url, err)) return } r := gjson.Parse(resp).Get("license_v2") if r.Index == 0 { internalLogIf(ctx, fmt.Errorf("license not found in response from %s", url)) return } lic := r.String() if lic == globalSubnetConfig.License { // license hasn't changed. return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/sts-handlers_test.go
}) if err != nil { c.Fatalf("Error initializing client: %v", err) } // Validate that the client from sts creds can access the bucket. c.mustListObjects(ctx, minioClient, bucket) // Validate that the client from STS creds cannot upload any object as // it is denied by the plugin. c.mustNotUpload(ctx, minioClient, bucket) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
cmd/tier-journal.go
// journal only to process existing journal entries made from previous versions. func (t *TierJournal) Init(ctx context.Context) error { for _, diskPath := range globalEndpoints.LocalDisksPaths() { t.diskPath = diskPath go t.deletePending(ctx) // for existing journal entries from previous MinIO versions go t.processEntries(ctx) // for newer journal entries circa free-versions return nil
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
internal/event/target/webhook.go
return err } // Delete the event from store. return target.store.Del(key.Name) } // Close - does nothing and available for interface compatibility. func (target *WebhookTarget) Close() error { target.cancel() return nil } func (target *WebhookTarget) init() error { return target.initOnce.Do(target.initWebhook) } // Only called from init()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 20 22:40:07 GMT 2023 - 8.5K bytes - Viewed (0) -
internal/bucket/lifecycle/rule.go
return r.NoncurrentVersionTransition.Validate() } // GetPrefix - a rule can either have prefix under <rule></rule>, <filter></filter> // or under <filter><and></and></filter>. This method returns the prefix from the // location where it is available. func (r Rule) GetPrefix() string { if p := r.Prefix.String(); p != "" { return p } if p := r.Filter.Prefix.String(); p != "" { return p }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 5.5K bytes - Viewed (0) -
internal/kms/policy-manager.go
// DescribePolicy describes a policy by returning its metadata. // e.g. who created the policy at which point in time. DescribePolicy(ctx context.Context, policy string) (*kes.PolicyInfo, error) // GetPolicy gets a policy from KMS. GetPolicy(ctx context.Context, policy string) (*kes.Policy, error) // ListPolicies lists all policies. ListPolicies(ctx context.Context) (*kes.ListIter[string], error)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 1.3K bytes - Viewed (0)