- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 95 for remove (0.16 sec)
-
cmd/os-instrumented.go
func Lstat(name string) (info os.FileInfo, err error) { defer updateOSMetrics(osMetricLstat, name)(err) return os.Lstat(name) } // Remove captures time taken to call os.Remove func Remove(deletePath string) (err error) { defer updateOSMetrics(osMetricRemove, deletePath)(err) return os.Remove(deletePath) } // Stat captures time taken to call os.Stat func Stat(name string) (info os.FileInfo, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 01:09:38 GMT 2024 - 6.3K bytes - Viewed (0) -
cmd/xl-storage-meta-inline.go
// If not found, just return. if !found { return false } // Reserialize... x.serialize(plSize, keys, vals) return true } // remove will remove one or more keys. // Returns true if any key was found. func (x *xlMetaInlineData) remove(keys ...string) bool { in := x.afterVersion() sz, buf, _ := msgp.ReadMapHeaderBytes(in) newKeys := make([][]byte, 0, sz) newVals := make([][]byte, 0, sz)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
cmd/tier-handlers.go
) var ( // error returned when remote tier already exists errTierAlreadyExists = AdminError{ Code: "XMinioAdminTierAlreadyExists", Message: "Specified remote tier already exists", StatusCode: http.StatusConflict, } // error returned when remote tier is not found errTierNotFound = AdminError{ Code: "XMinioAdminTierNotFound", Message: "Specified remote tier was not found",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 19:52:44 GMT 2024 - 7.5K bytes - Viewed (0) -
internal/crypto/error.go
// ErrIncompatibleEncryptionMethod indicates that both SSE-C headers and SSE-S3 headers were specified, and are incompatible // The client needs to remove the SSE-S3 header or the SSE-C headers ErrIncompatibleEncryptionMethod = Errorf("Server side encryption specified with both SSE-C and SSE-S3 headers")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 4.4K bytes - Viewed (0) -
cmd/tier-sweeper.go
} // 1. If bucket versioning is disabled, remove the remote object. // 2. If bucket versioning is suspended and // a. version id is specified, remove its remote object. // b. version id is not specified, remove null version's remote object if it exists. // 3. If bucket versioning is enabled and // a. version id is specified, remove its remote object.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 4.7K bytes - Viewed (0) -
cmd/signature-v4-utils.go
// Adding a *TODO* to remove this later when Golang server // doesn't filter out the 'Expect' header. extractedSignedHeaders.Set(header, "100-continue") case "host": // Go http server removes "host" from Request.Header extractedSignedHeaders.Set(header, r.Host) case "transfer-encoding": // Go http server removes "host" from Request.Header
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 18:56:45 GMT 2024 - 9K bytes - Viewed (0) -
buildscripts/verify-healing.sh
done } function perform_test() { start_port=$2 start_minio_3_node 120 $start_port echo "Testing Distributed Erasure setup healing of drives" echo "Remove the contents of the disks belonging to '${1}' node" rm -rf ${WORK_DIR}/${1}/*/ set -x start_minio_3_node 120 $start_port check_heal ${1} rv=$? if [ "$rv" == "1" ]; then
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:55:41 GMT 2024 - 4.2K bytes - Viewed (1) -
cmd/erasure-heal_test.go
staleDisks[j] = badDisk{nil} } staleWriters := make([]io.Writer, len(staleDisks)) for i, disk := range staleDisks { if disk == nil { continue } os.Remove(pathJoin(disk.String(), "testbucket", "testobject")) staleWriters[i] = newBitrotWriter(disk, "", "testbucket", "testobject", erasure.ShardFileSize(test.size), test.algorithm, erasure.ShardSize()) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.9K bytes - Viewed (0) -
internal/event/targetlist.go
} // TargetIDResult returns result of Remove/Send operation, sets err if // any for the associated TargetID type TargetIDResult struct { // ID where the remove or send were initiated. ID TargetID // Stores any error while removing a target or while sending an event. Err error } // Remove - closes and removes targets by given target IDs. func (list *TargetList) Remove(targetIDSet TargetIDSet) { list.Lock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
cmd/warm-backend.go
startOffset int64 length int64 } // WarmBackend provides interface to be implemented by remote tier backends type WarmBackend interface { Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (io.ReadCloser, error) Remove(ctx context.Context, object string, rv remoteVersionID) error InUse(ctx context.Context) (bool, error)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.9K bytes - Viewed (0)