- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 99 for mange (0.12 sec)
-
cmd/test-utils_test.go
return nil, nil, err } // Wait up to 10 seconds for disks to come online. pools := obj.(*erasureServerPools) t := time.Now() for _, pool := range pools.serverPools { for _, sets := range pool.erasureDisks { for _, s := range sets { if !s.IsLocal() { for { if s.IsOnline() { break } time.Sleep(100 * time.Millisecond)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/endpoint-ellipses.go
return layout, errInvalidArgument } for _, list := range pools { var endpointsList endpointsList for _, arg := range list.args { switch { case ellipses.HasList(arg): patterns, err := ellipses.FindListPatterns(arg) if err != nil { return layout, err } for _, exp := range patterns.Expand() { for _, ep := range exp { if err := endpointsList.add(ep); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/site-replication.go
allPolicies := set.NewStringSet() for _, sri := range sris { for b := range sri.Buckets { allBuckets.Add(b) } for u := range sri.UserInfoMap { allUsers.Add(u) } for g := range sri.GroupDescMap { allGroups.Add(g) } for p := range sri.Policies { allPolicies.Add(p) } for u := range sri.UserPolicies { allUserWPolicies.Add(u) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
migrator/migrator.go
} var ( parseIndexes = stmt.Schema.ParseIndexes() parseCheckConstraints = stmt.Schema.ParseCheckConstraints() ) for _, dbName := range stmt.Schema.DBNames { var foundColumn gorm.ColumnType for _, columnType := range columnTypes { if columnType.Name() == dbName { foundColumn = columnType break } } if foundColumn == nil {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Apr 26 07:15:49 GMT 2024 - 29K bytes - Viewed (0) -
cmd/erasure-metadata.go
h.Reset() } } metaHashCountMap := make(map[string]int) for _, hash := range metaHashes { if hash == "" { continue } metaHashCountMap[hash]++ } maxHash := "" maxCount := 0 for hash, count := range metaHashCountMap { if count > maxCount { maxCount = count maxHash = hash } } if maxCount < quorum {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 19.2K bytes - Viewed (1) -
cmd/metrics-v3-handler.go
if len(matchingMG) == 0 { return nil } var metrics []metricDisplay for _, collectorPath := range h.metricsData.collectorPaths { if mg, ok := matchingMG[collectorPath]; ok { var commonLabels []string for k := range mg.ExtraLabels { commonLabels = append(commonLabels, k) } for _, d := range mg.Descriptors { labels := slices.Clone(d.VariableLabels) labels = append(labels, commonLabels...)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 7.5K bytes - Viewed (0) -
cmd/bucket-replication.go
compareMeta1 := make(map[string]string) for k, v := range oi1.UserDefined { var found bool for _, prefix := range compareKeys { if !stringsHasPrefixFold(k, prefix) { continue } found = true break } if found { compareMeta1[strings.ToLower(k)] = v } } compareMeta2 := make(map[string]string) for k, v := range oi2.Metadata { var found bool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
internal/http/listener.go
for { conn, err := listener.Accept() send(acceptResult{conn, err, idx}) } } // Start separate goroutine for each TCP listener to handle connection. for idx, tcpListener := range listener.listeners { go handleListener(idx, tcpListener) } } // Accept - reads from httpListener.acceptCh for one of previously accepted TCP connection and returns the same.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
} return errors.Join(consErr...) } func (s *NetServer) buildZtunnelSnapshot(ambientPodUIDs map[types.UID]*corev1.Pod) error { // first add all the pods as empty: for uid := range ambientPodUIDs { s.currentPodSnapshot.Ensure(string(uid)) } // populate full pod snapshot from cgroups return s.scanProcForPodsAndCache(ambientPodUIDs) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
istioctl/pkg/writer/ztunnel/configdump/certificates.go
for _, secret := range secretDump { if strings.Contains(secret.State, "Unavailable") { secret.State = "Unavailable" } if len(secret.CertChain) == 0 { fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\t%v\t%v\n", secret.Identity, valueOrNA(""), secret.State, false, valueOrNA(""), valueOrNA(""), valueOrNA("")) } else { for i, ca := range secret.CertChain { t := "Intermediate" if i == 0 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 25 16:38:16 GMT 2024 - 3.2K bytes - Viewed (0)