- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for Mooring (0.2 sec)
-
cmd/object-api-interface.go
// IndexCB will return any index created but the compression. // Object must have been read at this point. IndexCB func() []byte // InclFreeVersions indicates that free versions need to be included // when looking up a version by fi.VersionID InclFreeVersions bool // SkipFreeVersion skips adding a free version when a tiered version is // being 'replaced' // Note: Used only when a tiered object is being expired.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 16.9K bytes - Viewed (0) -
src/archive/zip/writer.go
_, err = io.Copy(fw, r) return err } // RegisterCompressor registers or overrides a custom compressor for a specific // method ID. If a compressor for a given method is not found, [Writer] will // default to looking up the compressor at the package level. func (w *Writer) RegisterCompressor(method uint16, comp Compressor) { if w.compressors == nil { w.compressors = make(map[uint16]Compressor) } w.compressors[method] = comp
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 04 14:28:57 GMT 2024 - 19.3K bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
} // hashOrder - hashes input key to return consistent // hashed integer slice. Returned integer order is salted // with an input key. This results in consistent order. // NOTE: collisions are fine, we are not looking for uniqueness // in the slices returned. func hashOrder(key string, cardinality int) []int { if cardinality <= 0 { // Returns an empty int slice for cardinality < 0. return nil }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 11.3K bytes - Viewed (0) -
internal/config/identity/ldap/ldap.go
return "", false, errors.New("no Base DNs given") } // Check that DN exists in the LDAP directory. validatedDN, err := xldap.LookupDN(conn, dn) if err != nil { return "", false, fmt.Errorf("Error looking up DN %s: %w", dn, err) } if validatedDN == "" { return "", false, nil } // This will not return an error as the argument is validated to be a DN. pdn, _ := ldap.ParseDN(validatedDN)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 9.9K bytes - Viewed (0) -
cmd/object-handlers_test.go
} func testAPINewMultipartHandlerParallel(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler, credentials auth.Credentials, t *testing.T, ) { // used for storing the uploadID's parsed on concurrent HTTP requests for NewMultipart upload on the same object. testUploads := struct { sync.Mutex uploads []string }{} objectName := "test-object-new-multipart-parallel"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0) -
internal/grid/handlers.go
} h.ignoreNilConn = true return h } // WithSharedResponse indicates it is unsafe to reuse the response // when it has been returned on a handler. // This will disable automatic response recycling/pooling. // Typically this is used when the response sharing part of its data structure. func (h *SingleHandler[Req, Resp]) WithSharedResponse() *SingleHandler[Req, Resp] { h.sharedResp = true return h }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26.9K bytes - Viewed (0) -
cmd/iam-store.go
now := UTCNow().Round(time.Millisecond) d.UpdateDate = now if d.CreateDate.IsZero() { d.CreateDate = now } d.Policy = p } // parseJSON parses both the old and the new format for storing policy // definitions. // // The on-disk format of policy definitions has changed (around early 12/2021) // from policy.Policy to PolicyDoc. To avoid a migration, loading supports // both the old and the new formats.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cni/pkg/cmd/root.go
registerStringParameter(constants.RepairInitTerminationMsg, "", "The expected termination message for the init container when crash-looping because of CNI misconfiguration") registerIntegerParameter(constants.RepairInitExitCode, iptables.ValidationErrorCode, "Expected exit code for the init container when crash-looping because of CNI misconfiguration") registerStringParameter(constants.RepairLabelSelectors, "",
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
cmd/erasure-server-pool.go
storageLogIf(ctx, fmt.Errorf("reached end of serverPools (total: %v, atTotal: %v, choose: %v)", total, atTotal, choose)) return -1 } // getServerPoolsAvailableSpace will return the available space of each pool after storing the content. // If there is not enough space the pool will return 0 bytes available. // The size of each will be multiplied by the number of sets. // Negative sizes are seen as 0 bytes.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 80.1K bytes - Viewed (0) -
cmd/object-handlers.go
reader = rd if buf != nil { reader = io.TeeReader(rd, buf) } actualSize := size var idxCb func() []byte if isCompressible(r.Header, object) && size > minCompressibleSize { // Storing the compression metadata. metadata[ReservedMetadataPrefix+"compression"] = compressionAlgorithmV2 metadata[ReservedMetadataPrefix+"actual-size"] = strconv.FormatInt(size, 10)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 125K bytes - Viewed (0)