- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 258 for from (0.21 sec)
-
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) -
internal/http/server.go
httpServer.MaxHeaderBytes = DefaultMaxHeaderBytes return httpServer } // SetMinIOVersion -- MinIO version from the main package is set here func SetMinIOVersion(version string) { GlobalMinIOVersion = version } // SetDeploymentID -- Deployment Id from the main package is set here func SetDeploymentID(deploymentID string) { GlobalDeploymentID = deploymentID
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
internal/event/target/nats.go
} } if n.QueueDir != "" { if !filepath.IsAbs(n.QueueDir) { return errors.New("queueDir path should be absolute") } } return nil } // To obtain a nats connection from args. func (n NATSArgs) connectNats() (*nats.Conn, error) { connOpts := []nats.Option{nats.Name("Minio Notification"), nats.MaxReconnects(-1)} if n.Username != "" && n.Password != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/bucket-targets.go
) type arnTarget struct { Client *TargetClient lastRefresh time.Time } // arnErrs represents number of errors seen for a ARN and if update is in progress // to refresh remote targets from bucket metadata. type arnErrs struct { count int64 updateInProgress bool bucket string } // BucketTargetSys represents bucket targets subsystem type BucketTargetSys struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0)