- Sort Score
- Result 10 results
- Languages All
Results 781 - 790 of 963 for nil (0.96 sec)
-
internal/kms/context.go
// key-value pairs as canonical JSON object. The sort order // is based on the un-escaped keys. It never returns an error. func (c Context) MarshalText() ([]byte, error) { if len(c) == 0 { return []byte{'{', '}'}, nil } // Pre-allocate a buffer - 128 bytes is an arbitrary // heuristic value that seems like a good starting size. b := bytes.NewBuffer(make([]byte, 0, 128)) if len(c) == 1 { for k, v := range c {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 6K bytes - Viewed (0) -
internal/disk/stat_bsd.go
"syscall" ) // GetInfo returns total and free bytes available in a directory, e.g. `/`. func GetInfo(path string, _ bool) (info Info, err error) { s := syscall.Statfs_t{} err = syscall.Statfs(path, &s) if err != nil { return Info{}, err } reservedBlocks := s.Bfree - s.Bavail info = Info{ Total: uint64(s.Bsize) * (s.Blocks - reservedBlocks), Free: uint64(s.Bsize) * s.Bavail, Files: s.Files, Ffree: s.Ffree,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Feb 26 19:34:50 UTC 2024 - 1.7K bytes - Viewed (0) -
internal/http/close.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package http import ( "io" xioutil "github.com/minio/minio/internal/ioutil" ) // DrainBody close non nil response with any response Body. // convenient wrapper to drain any remaining data on response body. // // Subsequently this allows golang http RoundTripper // to reuse the same connection for future requests.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 1.7K bytes - Viewed (0) -
internal/config/browser/browser.go
HSTSIncludeSubdomains: true, HSTSPreload: true, ReferrerPolicy: "strict-origin-when-cross-origin", } if err = config.CheckValidKeys(config.BrowserSubSys, kvs, DefaultKVS); err != nil { return cfg, err } hstsIncludeSubdomains := env.Get(EnvBrowserHSTSIncludeSubdomains, kvs.GetWithDefault(browserHSTSIncludeSubdomains, DefaultKVS)) == config.EnableOn
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Jun 21 00:58:58 UTC 2024 - 5.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/DcerpcConstants.java
*/ int DCERPC_MAYBE = 0x40; /* `maybe' call semantics requested */ /** * Object UUID flag - if true, a non-nil object UUID is present */ int DCERPC_OBJECT_UUID = 0x80; /* if true, a non-nil object UUID */Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.2K bytes - Viewed (0) -
cmd/metrics-v3-system-memory.go
) // loadMemoryMetrics - `MetricsLoaderFn` for node memory metrics. func loadMemoryMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { memMetrics, err := c.memoryMetrics.Get() if err != nil { metricsLogIf(ctx, err) return err } m.Set(memTotal, float64(memMetrics.Total)) m.Set(memUsed, float64(memMetrics.Used)) usedPerc := float64(memMetrics.Used) * 100 / float64(memMetrics.Total)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Apr 17 05:10:25 UTC 2024 - 2.2K bytes - Viewed (0) -
internal/http/request-recorder.go
// 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 if r.LogBody { r.buf.Write(p[:n]) } if err != nil { return n, err } return n, err }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Apr 12 21:37:19 UTC 2023 - 1.8K bytes - Viewed (0) -
internal/amztime/iso8601_time.go
func ISO8601Parse(iso8601 string) (t time.Time, err error) { for _, layout := range []string{ iso8601TimeFormat, iso8601TimeFormatLong, time.RFC3339, } { t, err = time.Parse(layout, iso8601) if err == nil { return t, nil } } return t, err
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Jan 16 23:38:33 UTC 2023 - 1.9K bytes - Viewed (0) -
src/cmd/asm/internal/asm/line_test.go
for i, test := range tests { arch, ctxt := setArch(goarch) tokenizer := lex.NewTokenizer("", strings.NewReader(test.input+"\n"), nil) parser := NewParser(ctxt, arch, tokenizer) err := tryParse(t, func() { parser.Parse() }) switch { case err == nil: t.Errorf("#%d: %q: want error %q; have none", i, test.input, test.error) case !strings.Contains(err.Error(), test.error):Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Tue Aug 29 07:48:38 UTC 2023 - 1.9K bytes - Viewed (0) -
internal/logger/target/kafka/kafka_scram_client_contrib.go
func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) { x.Client, err = x.NewClient(userName, password, authzID) if err != nil { return err } x.ClientConversation = x.NewConversation() return nil } // Step takes a string provided from a server (or just an empty string for the // very first conversation step) and attempts to move the authentication
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 3.3K bytes - Viewed (0)