- Sort Score
- Result 10 results
- Languages All
Results 231 - 240 of 1,271 for Range (0.04 sec)
-
cmd/tier-last-day-stats.go
merged.UpdatedAt = cm.UpdatedAt } for i := range cl.Bins { merged.Bins[i] = cl.Bins[i].add(cm.Bins[i]) } return merged } // DailyAllTierStats is used to aggregate last day tier stats across MinIO servers type DailyAllTierStats map[string]lastDayTierStats func (l DailyAllTierStats) merge(m DailyAllTierStats) { for tier, st := range m { l[tier] = l[tier].merge(st) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/workload/workload_test.go
}, "ipv6": { "internalIP": "fd00:10:96::1", "ingressIP": "fd00:10:96::2", }, } for _, dir := range files { if !dir.IsDir() { continue } testdir := path.Join("testdata/vmconfig", dir.Name()) t.Cleanup(func() { for k := range generated { os.Remove(path.Join(testdir, k)) } }) t.Run(dir.Name(), func(t *testing.T) {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 01 20:04:20 UTC 2024 - 14.6K bytes - Viewed (0) -
cmd/erasure-multipart.go
var wg sync.WaitGroup for _, disk := range er.getLocalDisks() { if disk != nil { wg.Add(1) go func(disk StorageAPI) { defer wg.Done() er.cleanupStaleUploadsOnDisk(ctx, disk) }(disk) } } wg.Wait() } func (er erasureObjects) deleteAll(ctx context.Context, bucket, prefix string) { var wg sync.WaitGroup for _, disk := range er.getDisks() { if disk == nil { continue
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 44.7K bytes - Viewed (0) -
schema/schema_test.go
{Name: "ManagerID", DBName: "manager_id", BindNames: []string{"ManagerID"}, DataType: schema.Uint, Size: 64}, {Name: "Active", DBName: "active", BindNames: []string{"Active"}, DataType: schema.Bool}, } for i := range fields { checkSchemaField(t, user, &fields[i], func(f *schema.Field) { f.Creatable = true f.Updatable = true f.Readable = true }) } // check relations relations := []Relation{ {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Jun 20 12:19:31 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/data-scanner_test.go
es.workers.Store(&workers) globalExpiryState = es var wg sync.WaitGroup wg.Add(1) expired := make([]ObjectToDelete, 0, 5) go func() { defer wg.Done() workers := globalExpiryState.workers.Load() for t := range (*workers)[0] { if t, ok := t.(newerNoncurrentTask); ok { expired = append(expired, t.versions...) } } }() lc := lifecycle.Lifecycle{ Rules: []lifecycle.Rule{ { ID: "max-versions",
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 03 11:18:58 UTC 2024 - 6.9K bytes - Viewed (0) -
cmd/erasure-sets.go
g := errgroup.WithNErrs(len(s.sets)) for index := range s.sets { index := index g.Go(func() error { storageInfos[index] = s.sets[index].StorageInfo(ctx) return nil }, index) } // Wait for the go routines. g.Wait() for _, lstorageInfo := range storageInfos { storageInfo.Disks = append(storageInfo.Disks, lstorageInfo.Disks...) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (1) -
istioctl/pkg/writer/ztunnel/configdump/services.go
}) fmt.Fprintln(w, "NAMESPACE\tSERVICE NAME\tSERVICE VIP\tWAYPOINT\tENDPOINTS") for _, svc := range svcs { ips := []string{} for _, addr := range svc.Addresses { _, ip, _ := strings.Cut(addr, "/") ips = append(ips, ip) } allEndpoints := len(svc.Endpoints) healthyEndpoints := 0 for _, ep := range svc.Endpoints { w, f := workloadsByUID[ep.WorkloadUID] if !f { continue }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Jul 24 09:07:30 UTC 2024 - 3.2K bytes - Viewed (0) -
helm-releases/minio-5.0.2.tgz
{{- if .Values.consoleIngress.ingressClassName }} ingressClassName: {{ .Values.consoleIngress.ingressClassName }} {{- end }} {{- if .Values.consoleIngress.tls }} tls: {{- range .Values.consoleIngress.tls }} - hosts: {{- range .hosts }} - {{ . | quote }} {{- end }} secretName: {{ .secretName }} {{- end }} {{- end }} rules: {{- range .Values.consoleIngress.hosts }} - http: paths: - path: {{ $ingressPath }} {{- if semverCompare ">=1.19-0" $.Capabilities.KubeVersion.GitVersion }} pathType: Prefix backend:...
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Dec 18 07:57:10 UTC 2022 - 20.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/idn/IdnaMappingTable.kt
* * **b3a**: b3 + 0x80 * * **b2b3**: (b2 << 7) + b3 * * b0 * -- * * The inclusive start of the range. We get the first 14 bits of this code point from the section * and the last 7 bits from this byte. * * The end of the range is not encoded, but can be inferred by looking at the start of the range * that follows. * * b1 * -- *
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Apr 02 11:39:58 UTC 2024 - 9K bytes - Viewed (0) -
internal/event/targetlist.go
list.RLock() defer list.RUnlock() targets := []Target{} for _, tgt := range list.targets { targets = append(targets, tgt) } return targets } // List - returns available target IDs. func (list *TargetList) List() []TargetID { list.RLock() defer list.RUnlock() keys := []TargetID{} for k := range list.targets { keys = append(keys, k) } return keys }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.2K bytes - Viewed (0)