- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for un (0.22 sec)
-
istioctl/pkg/validate/validate.go
Group: un.GroupVersionKind().Group, Version: un.GroupVersionKind().Version, Kind: un.GroupVersionKind().Kind, } schema, exists := collections.Pilot.FindByGroupVersionAliasesKind(gvk) if exists { obj, err := convertObjectFromUnstructured(schema, un, "") if err != nil { return nil, fmt.Errorf("cannot parse proto message: %v", err) } if err = checkFields(un); err != nil { return nil, err
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jan 22 17:58:52 GMT 2024 - 15K bytes - Viewed (0) -
internal/grid/trace.go
"strings" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/pubsub" ) // TraceParamsKey allows to pass trace parameters to the request via context. // This is only needed when un-typed requests are used. // MSS, map[string]string types are preferred, but any struct with exported fields will work. type TraceParamsKey struct{} // traceRequests adds request tracing to the connection.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 02 22:54:54 GMT 2024 - 4K bytes - Viewed (0) -
cmd/admin-heal-ops.go
healRunningStatus = "running" healStoppedStatus = "stopped" healFinishedStatus = "finished" ) const ( // a heal sequence with this many un-consumed heal result // items blocks until heal-status consumption resumes or is // aborted due to timeout. maxUnconsumedHealResultItems = 1000 // if no heal-results are consumed (via the heal-status API)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
internal/hash/checksum.go
return xhttp.AmzChecksumCRC32C case c.Is(ChecksumSHA1): return xhttp.AmzChecksumSHA1 case c.Is(ChecksumSHA256): return xhttp.AmzChecksumSHA256 } return "" } // RawByteLen returns the size of the un-encoded checksum. func (c ChecksumType) RawByteLen() int { switch { case c.Is(ChecksumCRC32): return 4 case c.Is(ChecksumCRC32C): return 4 case c.Is(ChecksumSHA1): return sha1.Size
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.9K bytes - Viewed (0) -
cmd/globals.go
Timeout: 5 * time.Second, } globalForwarder *handlers.Forwarder globalTierConfigMgr *TierConfigMgr globalConsoleSrv *consoleapi.Server // handles service freeze or un-freeze S3 API calls. globalServiceFreeze atomic.Value // Only needed for tracking globalServiceFreezeCnt int32 globalServiceFreezeMu sync.Mutex // Updates.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
cmd/xl-storage.go
continue } if err = Rename(pathJoin(currentDataPath, entry), pathJoin(legacyDataPath, entry)); err != nil { // Any failed rename calls un-roll previous transaction. s.deleteFile(dstVolumeDir, legacyDataPath, true, false) return res, osErrToFileErr(err) } } } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
istioctl/pkg/validate/validate_test.go
service.istio.io/canonical-revision: v1 spec: replicas: 1 ` ) func fromYAML(in string) *unstructured.Unstructured { var un unstructured.Unstructured if err := yaml.Unmarshal([]byte(in), &un); err != nil { panic(err) } return &un } func TestValidateResource(t *testing.T) { cases := []struct { name string in string valid bool warn bool }{ {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jul 25 08:08:36 GMT 2023 - 21.5K bytes - Viewed (0) -
internal/ioutil/ioutil.go
// closing 'w'. if err = disk.DisableDirectIO(file); err != nil { return written, err } // buf is not aligned, hence use writeUnaligned() // for the remainder un, err = w.Write(buf[len(buf)-remain:]) nw += int64(un) } if nw > 0 { written += nw } if err != nil { return written, err } if nw != int64(len(buf)) { return written, io.ErrShortWrite
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
internal/cachevalue/cache_test.go
t2, _ := cache.Get() if !t1.Equal(t2) { t.Fatalf("expected time to be equal: %s != %s", t1, t2) } time.Sleep(3 * time.Second) t3, _ := cache.Get() if t1.Equal(t3) { t.Fatalf("expected time to be un-equal: %s == %s", t1, t3) } } func BenchmarkCache(b *testing.B) { cache := New[time.Time]() cache.InitOnce(1*time.Millisecond, Opts{}, func() (time.Time, error) { return time.Now(), nil }, )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 17:09:09 GMT 2024 - 1.5K bytes - Viewed (0) -
internal/ioutil/read_file.go
// as an error to be reported. // // passes NOATIME flag for reads on Unix systems to avoid atime updates. func ReadFile(name string) ([]byte, error) { // Don't wrap with un-needed buffer. // Don't use os.ReadFile, since it doesn't pass NO_ATIME when present. f, err := OsOpenFile(name, readMode, 0o666) if err != nil { return nil, err } defer f.Close() st, err := f.Stat()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 09 18:17:51 GMT 2023 - 2.3K bytes - Viewed (0)