- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 370 for Chen (0.17 sec)
-
cmd/admin-handler-utils.go
) // validateAdminReq will validate request against and return whether it is allowed. // If any of the supplied actions are allowed it will be successful. // If nil ObjectLayer is returned, the operation is not permitted. // When nil ObjectLayer has been returned an error has always been sent to w. func validateAdminReq(ctx context.Context, w http.ResponseWriter, r *http.Request, actions ...policy.AdminAction) (ObjectLayer, auth.Credentials) {
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/xl-storage-disk-id-check.go
atomic.StoreInt64(h.lastSuccess, time.Now().UnixNano()) } // noopDoneFunc is a no-op done func. // Can be reused. var noopDoneFunc = func(_ *error) {} // TrackDiskHealth for this request. // When a non-nil error is returned 'done' MUST be called // with the status of the response, if it corresponds to disk health. // If the pointer sent to done is non-nil AND the error // is either nil or io.EOF the disk is considered good.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/encryption-v1_test.go
} if err == nil { if etag != test.ETag { t.Fatalf("Test %d: ETag mismatch: got %s - want %s", i, etag, test.ETag) } } } } // Tests for issue reproduced when getting the right encrypted // offset of the object. func TestGetDecryptedRange_Issue50(t *testing.T) { rs, err := parseRequestRangeSpec("bytes=594870256-594870263") if err != nil { t.Fatal(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Sep 24 04:17:08 GMT 2022 - 19.9K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
} } srcInfo.PutObjReader = pReader copyObjectPart := objectAPI.CopyObjectPart // Copy source object to destination, if source and destination // object is same then only metadata is updated. partInfo, err := copyObjectPart(ctx, srcBucket, srcObject, dstBucket, dstObject, uploadID, partID, startOffset, length, srcInfo, srcOpts, dstOpts) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
cmd/tier-journal.go
defer jd.Unlock() _, err = jd.file.Write(b) if err != nil { // Do not leak fd here, close the file properly. Fdatasync(jd.file) _ = jd.file.Close() jd.file = nil // reset to allow subsequent reopen when file/disk is available. } return err } // Close closes the active journal and renames it to read-only for pending // deletes processing. Note: calling Close on a closed journal is a no-op.
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/s3select/select.go
// End is the offset of the last byte that should be returned when Start // is set, otherwise it is the offset from EOF to start reading. End *uint64 `xml:"End"` } // Validate if the scan range is valid. func (s *ScanRange) Validate() error { if s == nil { return nil } if s.Start == nil && s.End == nil { // This parameter is optional, but when specified, it must not be empty.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
cmd/naughty-disk_test.go
// Programmed errors are stored in errors field. type naughtyDisk struct { // The real disk disk StorageAPI // Programmed errors: API call number => error to return errors map[int]error // The error to return when no error value is programmed defaultErr error // The current API call number callNR int // Data protection mu sync.Mutex }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 9.3K bytes - Viewed (0) -
docs/metrics/prometheus/README.md
Follow below steps to get started with MinIO monitoring using Prometheus. ### 1. Download Prometheus [Download the latest release](https://prometheus.io/download) of Prometheus for your platform, then extract it ```sh tar xvfz prometheus-*.tar.gz cd prometheus-* ```
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 15:49:30 GMT 2024 - 7.1K bytes - Viewed (0) -
internal/event/target/webhook.go
return false, store.ErrNotConnected } return false, err } defer conn.Close() return true, nil } // Save - saves the events to the store if queuestore is configured, // which will be replayed when the webhook connection is active. func (target *WebhookTarget) Save(eventData event.Event) error { if target.store != nil { return target.store.Put(eventData) } if err := target.init(); err != nil { return err
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) -
cmd/api-errors.go
}, ErrSiteReplicationPeerResp: { Code: "XMinioSiteReplicationPeerResp", Description: "Error received when contacting a peer site", HTTPStatusCode: http.StatusBadRequest, }, ErrSiteReplicationBackendIssue: { Code: "XMinioSiteReplicationBackendIssue", Description: "Error when requesting object layer backend", HTTPStatusCode: http.StatusServiceUnavailable, },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (7)