- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 53 for Op (0.14 sec)
-
cmd/object-handlers.go
srcInfo.UserDefined[xhttp.AmzBucketReplicationStatus] = rs } op := replication.ObjectReplicationType if srcInfo.metadataOnly { op = replication.MetadataReplicationType } if dsc := mustReplicate(ctx, dstBucket, dstObject, srcInfo.getMustReplicateOptions(op, dstOpts)); dsc.ReplicateAny() { srcInfo.UserDefined[ReservedMetadataPrefixLower+ReplicationStatus] = dsc.PendingStatus()
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) -
internal/http/request-recorder.go
LogBody bool // internal recording buffer buf bytes.Buffer // total bytes read including header size bytesRead int } // Close is a no operation closer func (r *RequestRecorder) Close() error { // no-op return nil } // Read reads from the internal reader and counts/save the body in the memory func (r *RequestRecorder) Read(p []byte) (n int, err error) { n, err = r.Reader.Read(p) r.bytesRead += n
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 12 21:37:19 GMT 2023 - 1.8K bytes - Viewed (0) -
cmd/os_unix.go
"fmt" "os" "strings" "sync" "syscall" "unsafe" "golang.org/x/sys/unix" ) func access(name string) error { if err := unix.Access(name, unix.F_OK); err != nil { return &os.PathError{Op: "lstat", Path: name, Err: err} } return nil } // openFileWithFD return 'fd' based file descriptor func openFileWithFD(name string, flag int, perm os.FileMode) (fd int, err error) { switch flag & writeMode {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.3K bytes - Viewed (0) -
docs/sts/etcd.md
--initial-cluster s1=http://0.0.0.0:2380 \ --initial-cluster-token tkn \ --initial-cluster-state new ``` You may also setup etcd with TLS following this documentation [here](https://coreos.com/etcd/docs/latest/op-guide/security.html) ### 3. Setup MinIO with etcd MinIO server expects environment variable for etcd as `MINIO_ETCD_ENDPOINTS`, this environment variable takes many comma separated entries. ```
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 3.4K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
if len(logger.AuditTargets()) == 0 { return } op := auditTierOp{ Tier: tier, OutputBytes: bytes, } if err == nil { since := time.Since(startTime) op.TimeToResponseNS = since.Nanoseconds() globalTierMetrics.Observe(tier, since) globalTierMetrics.logSuccess(tier) } else { op.Error = err.Error() globalTierMetrics.logFailure(tier) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/warm-backend-azure.go
if strings.EqualFold(az.StorageClass, string(t)) { return t } } return azblob.AccessTierType("") } // FIXME: add support for remote version ID in Azure remote tier and remove // this. Currently it's a no-op. func (az *warmBackendAzure) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) { blobURL := az.serviceURL.NewContainerURL(az.Bucket).NewBlockBlobURL(az.getDest(object))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 05 16:44:08 GMT 2024 - 7.8K bytes - Viewed (1) -
internal/logger/logrotate.go
return os.Remove(oldLgFile) } func (w *Writer) rotate() error { if w.f != nil { if err := w.closeCurrentFile(); err != nil { return err } // This function is a no-op if opts.Compress is false // writes an error in JSON form to stderr, if we cannot // compress. if err := w.compress(); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 11:38:40 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/lock/lock_windows.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 7.9K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
if tgt.Empty() { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrRemoteTargetNotFoundError, err), r.URL) return } for _, op := range ops { switch op { case madmin.CredentialsUpdateType: if !globalSiteReplicationSys.isEnabled() { // credentials update is possible only in bucket replication. User will never // know the site replicator creds.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cmd/bucket-replication.go
} func (o ObjectInfo) getMustReplicateOptions(op replication.Type, opts ObjectOptions) mustReplicateOptions { return getMustReplicateOptions(o.UserDefined, o.UserTags, o.ReplicationStatus, op, opts) } func getMustReplicateOptions(userDefined map[string]string, userTags string, status replication.StatusType, op replication.Type, opts ObjectOptions) mustReplicateOptions { meta := cloneMSS(userDefined)
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)