- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for Mooring (0.21 sec)
-
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 May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
src/archive/zip/reader.go
} } } return nil } // RegisterDecompressor registers or overrides a custom decompressor for a // specific method ID. If a decompressor for a given method is not found, // [Reader] will default to looking up the decompressor at the package level. func (r *Reader) RegisterDecompressor(method uint16, dcomp Decompressor) { if r.decompressors == nil { r.decompressors = make(map[uint16]Decompressor) }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 27.7K bytes - Viewed (0) -
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 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
internal/grid/types.go
"math" "net/url" "sort" "strings" "sync" "github.com/tinylib/msgp/msgp" ) // Recycler will override the internal reuse in typed handlers. // When this is supported, the handler will not do internal pooling of objects, // call Recycle() when the object is no longer needed. // The recycler should handle nil pointers. type Recycler interface { Recycle() } // MSS is a map[string]string that can be serialized.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
internal/s3select/select.go
size int64 // actual object size regardless of compression/encryption offset int64 reader io.ReadCloser // reader can be closed idempotently multiple times closerOnce sync.Once // Error storing reader.Close() closerErr error } // NewObjectReadSeekCloser creates a new ObjectReadSeekCloser. func NewObjectReadSeekCloser(segmentReader ObjectSegmentReaderFn, actualSize int64) *ObjectReadSeekCloser {
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/object-multipart-handlers.go
for k, v := range encMetadata { metadata[k] = v } // Ensure that metadata does not contain sensitive information crypto.RemoveSensitiveEntries(metadata) if isCompressible(r.Header, object) { // Storing the compression metadata. metadata[ReservedMetadataPrefix+"compression"] = compressionAlgorithmV2 } opts, err := putOptsFromReq(ctx, r, bucket, object, metadata) 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) -
internal/etag/etag.go
// An S3 implementation has to remember the content MD5 of objects // in case of SSE-S3. However, storing the ETag of an encrypted // object in plaintext may reveal some information about the object. // For example, two objects with the same ETag are identical with // a very high probability. // // Therefore, an S3 implementation may encrypt an ETag before storing // it. In this case, the stored ETag may not be a well-formed S3 ETag.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 13.3K bytes - Viewed (0) -
src/bufio/scan_test.go
}() for count := 0; s.Scan(); count++ { if count > 1000 { t.Fatal("looping") } } if s.Err() != nil { t.Fatal("after scan:", s.Err()) } } func TestBlankLines(t *testing.T) { s := NewScanner(strings.NewReader(strings.Repeat("\n", 1000))) for count := 0; s.Scan(); count++ { if count > 2000 { t.Fatal("looping") } } if s.Err() != nil { t.Fatal("after scan:", s.Err()) }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Sep 22 16:22:42 GMT 2023 - 14.3K bytes - Viewed (0) -
cni/pkg/install/install.go
// so that no file modifications are missed while and after checking // note: we create a file watcher for each invocation, otherwise when we write to the directories // we would get infinite looping of events // // Additionally, fsnotify will lose existing watches on atomic copies (due to overwrite/rename), // so we have to re-watch after re-copy to make sure we always have fresh watches.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 17K bytes - Viewed (0)