- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 114 for tagged (0.15 sec)
-
cmd/bootstrap-peer-server.go
} } else { onlineServers++ } mu.Unlock() }(clnt) } wg.Wait() select { case <-ctx.Done(): return ctx.Err() default: // Sleep and stagger to avoid blocked CPU and thundering // herd upon start up sequence. time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond)))) retries++
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
docs/sts/web-identity.md
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 19.2K bytes - Viewed (1) -
cmd/object-handlers.go
}) } // ObjectTagSet key value tags type ObjectTagSet struct { Tags []tags.Tag `xml:"Tag"` } type objectTagging struct { XMLName xml.Name `xml:"Tagging"` TagSet *ObjectTagSet `xml:"TagSet"` } // GetObjectTaggingHandler - GET object tagging func (api objectAPIHandlers) GetObjectTaggingHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "GetObjectTagging")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/erasure-server-pool.go
// minioMetaTmpDeletedBucket + unique uuid, // Note that set distribution is ignored so it should only be used in cases where // data is not distributed across sets. Errors are logged but individual // disk failures are not returned. func (z *erasureServerPools) deleteAll(ctx context.Context, bucket, prefix string) { for _, servers := range z.serverPools { for _, set := range servers.sets {
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/metrics-v2.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
cmd/bucket-replication.go
) for _, err := range errs { if err == nil { taggedCount++ continue } if err != nil { terr = err } } // don't return error if at least one target was tagged successfully if taggedCount == 0 && terr != nil { proxy.Err = terr } return proxy } // proxyGetTaggingToRepTarget proxies get tagging requests to remote targets for
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
internal/bucket/lifecycle/filter.go
const ( nonePred predType = iota prefixPred andPred tagPred sizeLtPred sizeGtPred ) var predCount int var pType predType if !f.And.isEmpty() { pType = andPred predCount++ } if f.Prefix.set { pType = prefixPred predCount++ } if !f.Tag.IsEmpty() { pType = tagPred predCount++ } if f.ObjectSizeGreaterThan != 0 { pType = sizeGtPred
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 00:01:20 GMT 2024 - 6.2K bytes - Viewed (0) -
internal/hash/reader.go
func (r *Reader) ActualSize() int64 { return r.actualSize } // ETag returns the ETag computed by an underlying etag.Tagger. // If the underlying io.Reader does not implement etag.Tagger // it returns nil. func (r *Reader) ETag() etag.ETag { if t, ok := r.src.(etag.Tagger); ok { return t.ETag() } return nil } // MD5Current returns the MD5 checksum of the content
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 10.8K bytes - Viewed (0) -
internal/event/target/postgresql.go
} // ID - returns target ID. func (target *PostgreSQLTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target. func (target *PostgreSQLTarget) Name() string { return target.ID().String() } // Store returns any underlying store if set. func (target *PostgreSQLTarget) Store() event.TargetStore { return target.store }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0) -
internal/event/target/amqp.go
headers["minio-event"] = eventData.EventName.String() if err = ch.ExchangeDeclare(target.args.Exchange, target.args.ExchangeType, target.args.Durable, target.args.AutoDeleted, target.args.Internal, target.args.NoWait, nil); err != nil { return err } if err = ch.Publish(target.args.Exchange, target.args.RoutingKey, target.args.Mandatory, target.args.Immediate, amqp091.Publishing{ Headers: headers,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0)