- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 403 for Make (0.15 sec)
-
cmd/notification.go
} // GetLastDayTierStats fetches per-tier stats of the last 24hrs from all peers func (sys *NotificationSys) GetLastDayTierStats(ctx context.Context) DailyAllTierStats { errs := make([]error, len(sys.allPeerClients)) lastDayStats := make([]DailyAllTierStats, len(sys.allPeerClients)) var wg sync.WaitGroup for index := range sys.peerClients { if sys.peerClients[index] == nil { continue } wg.Add(1)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/data-usage-cache.go
e.ObjVersions.add(summary.versions) if e.ReplicationStats == nil { e.ReplicationStats = &replicationAllStats{ Targets: make(map[string]replicationStats), } } else if e.ReplicationStats.Targets == nil { e.ReplicationStats.Targets = make(map[string]replicationStats) } e.ReplicationStats.ReplicaSize += uint64(summary.replicaSize) e.ReplicationStats.ReplicaCount += uint64(summary.replicaCount)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
cmd/peer-s3-client.go
return nil }, idx) } errs := g.Wait() // The list of buckets in a map to avoid duplication resultMap := make(map[string]BucketInfo) for poolIdx := 0; poolIdx < sys.poolsCount; poolIdx++ { perPoolErrs := make([]error, 0, len(sys.peerClients)) for i, client := range sys.peerClients { if slices.Contains(client.GetPools(), poolIdx) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
.github/workflows/iam-integrations.yaml
go run docs/iam/access-manager-plugin.go & make test-iam - name: Test MinIO Old Version data to IAM import current version if: matrix.ldap == 'ldaphost:389' env: _MINIO_LDAP_TEST_SERVER: ${{ matrix.ldap }} run: | make test-iam-ldap-upgrade-import - name: Test LDAP for automatic site replication
Others - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:49:53 GMT 2024 - 4.2K bytes - Viewed (0) -
cmd/erasure.go
} return } func getOnlineOfflineDisksStats(disksInfo []madmin.Disk) (onlineDisks, offlineDisks madmin.BackendDisks) { onlineDisks = make(madmin.BackendDisks) offlineDisks = make(madmin.BackendDisks) for _, disk := range disksInfo { ep := disk.Endpoint if _, ok := offlineDisks[ep]; !ok { offlineDisks[ep] = 0 } if _, ok := onlineDisks[ep]; !ok {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
.github/workflows/replication.yaml
sudo sysctl net.ipv6.conf.all.disable_ipv6=0 sudo sysctl net.ipv6.conf.default.disable_ipv6=0 make test-decom - name: Test ILM run: | sudo sysctl net.ipv6.conf.all.disable_ipv6=0 sudo sysctl net.ipv6.conf.default.disable_ipv6=0 make test-ilm - name: Test Config File run: | sudo sysctl net.ipv6.conf.all.disable_ipv6=0
Others - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 12:48:19 GMT 2024 - 1.8K bytes - Viewed (0) -
src/cmd/api/main_test.go
ok = false // broke compatibility } case len(required) == 0 || (len(features) > 0 && required[0] > features[0]): newFeature := take(&features) fmt.Fprintf(w, "+%s\n", newFeature) ok = false // feature not in api/next/* default: take(&required) take(&features) } } return ok } // aliasReplacer applies type aliases to earlier API files,
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Apr 09 20:48:51 GMT 2024 - 31.4K bytes - Viewed (0) -
cmd/admin-heal-ops.go
Summary: healNotStartedStatus, HealSettings: hs, }, traverseAndHealDoneCh: make(chan error), cancelCtx: cancel, ctx: ctx, scannedItemsMap: make(map[madmin.HealItemType]int64), healedItemsMap: make(map[madmin.HealItemType]int64), healFailedItemsMap: make(map[string]int64), } } // getScannedItemsCount - returns a count of all scanned items
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/storage-rest-client.go
// transport is already down. return "", errDiskNotFound } // This call should never be over the network, this is always // a cached value - caller should make sure to use this // function on a fresh disk or make sure to look at the error // from a different networked call to validate the GetDiskID() return *client.diskID.Load(), nil } func (client *storageRESTClient) SetDiskID(id string) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/xl-storage-meta-inline.go
func (x *xlMetaInlineData) remove(keys ...string) bool { in := x.afterVersion() sz, buf, _ := msgp.ReadMapHeaderBytes(in) newKeys := make([][]byte, 0, sz) newVals := make([][]byte, 0, sz) var removeKey func(s []byte) bool // Copy if big number of compares... if len(keys) > 5 && sz > 5 { mKeys := make(map[string]struct{}, len(keys)) for _, key := range keys { mKeys[key] = struct{}{} }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0)