- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for reply (0.13 sec)
-
cmd/notification.go
for index, err := range g.Wait() { if err != nil { sys.addNodeErr(&reply[index], sys.peerClients[index], err) } } return reply } // GetNetInfo - Network information func (sys *NotificationSys) GetNetInfo(ctx context.Context) []madmin.NetInfo { reply := make([]madmin.NetInfo, len(sys.peerClients)) g := errgroup.WithNErrs(len(sys.peerClients)) for index, client := range sys.peerClients { if client == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
// Note that url.Parse does the unescaping cpSrcPath = u.Path } srcBucket, srcObject := path2BucketObject(cpSrcPath) // If source object is empty or bucket is empty, reply back invalid copy source. if srcObject == "" || srcBucket == "" { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidCopySource), r.URL) return } if vid != "" && vid != nullVersionID {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
internal/rest/client.go
var ErrClientClosed = errors.New("rest client is closed") // Call - make a REST call with context. func (c *Client) Call(ctx context.Context, method string, values url.Values, body io.Reader, length int64) (reply io.ReadCloser, err error) { switch atomic.LoadInt32(&c.connected) { case closed: // client closed, this is usually a manual process // so return a local error as client is closed
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cmd/object-api-datatypes.go
// by the Content-Type header field. ContentEncoding string // Date and time at which the object is no longer able to be cached Expires time.Time // Cache-Control - Specifies caching behavior along the request/reply chain CacheControl string // Specify object storage class StorageClass string ReplicationStatusInternal string ReplicationStatus replication.StatusType // User-Defined metadata
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0) -
cmd/object-api-utils.go
decLength = length length = oi.Size - off // For negative length we read everything. if decLength < 0 { decLength = actualSize - decOff } // Reply back invalid range if the input offset and length fall out of range. if decOff > actualSize || decOff+decLength > actualSize { return nil, 0, 0, errInvalidRange } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
internal/bucket/object/lock/lock.go
) const ( ntpServerEnv = "MINIO_NTP_SERVER" ) var ntpServer = env.Get(ntpServerEnv, "") // UTCNowNTP - is similar in functionality to UTCNow() // but only used when we do not wish to rely on system // time. func UTCNowNTP() (time.Time, error) { // ntp server is disabled if ntpServer == "" { return time.Now().UTC(), nil } return ntp.Time(ntpServer) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 17.1K bytes - Viewed (0) -
internal/logger/target/http/http.go
// support reading multiple events on a stream for example // like : Splunk HTTP Event collector, if you are unsure // set this to '1'. batchSize int payloadType string // store to persist and replay the logs to the target // to avoid missing events when the target is down. store store.Store[interface{}] storeCtxCancel context.CancelFunc initQueueOnce once.Init config Config
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0) -
cmd/erasure-healing.go
// notFoundPartsErrs is ignored since // - delete marker does not have any parts dataBlocks := (len(errs) + 1) / 2 return validMeta, notFoundMetaErrs > dataBlocks } // TODO: It is possible to replay the object via just single // xl.meta file, considering quorum number of data-dirs are still // present on other drives. // // However this requires a bit of a rewrite, leave this up for // future work.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 33.1K bytes - Viewed (0)