- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 244 for Meleti (0.18 sec)
-
cmd/peer-rest-server.go
globalEventNotifier.RemoveNotification(bucketName) globalBucketConnStats.delete(bucketName) globalBucketHTTPStats.delete(bucketName) if localMetacacheMgr != nil { localMetacacheMgr.deleteBucketCache(bucketName) } return } // GetAllBucketStatsHandler - fetches bucket replication stats for all buckets from this peer.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
// appears in outDatedDisks. tamperedIndex = index dErr := erasureDisks[index].Delete(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1"), DeleteOptions{ Recursive: false, Immediate: false, }) if dErr != nil { t.Fatalf("Failed to delete %s - %v", filepath.Join(object, "part.1"), dErr) } break } case corruptPart:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 23K bytes - Viewed (1) -
cmd/peer-rest-client.go
})) return err } // DeleteBucketMetadata - Delete bucket metadata func (client *peerRESTClient) DeleteBucketMetadata(bucket string) error { _, err := deleteBucketMetadataRPC.Call(context.Background(), client.gridConn(), grid.NewMSSWith(map[string]string{ peerRESTBucket: bucket, })) return err } // DeletePolicy - delete a specific canned policy.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
cmd/tier-last-day-stats_gen.go
zb0004, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } if (*z) == nil { (*z) = make(DailyAllTierStats, zb0004) } else if len((*z)) > 0 { for key := range *z { delete((*z), key) } } var field []byte _ = field for zb0004 > 0 { zb0004-- var zb0001 string var zb0002 lastDayTierStats zb0001, err = dc.ReadString() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/admin-heal-ops.go
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) -
cmd/etcd.go
} func deleteKeyEtcd(ctx context.Context, client *etcd.Client, key string) error { timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() _, err := client.Delete(timeoutCtx, key) etcdLogIf(ctx, err) return etcdErrToErr(err, client.Endpoints()) } func readKeyEtcd(ctx context.Context, client *etcd.Client, key string) ([]byte, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.9K bytes - Viewed (0) -
cmd/site-replication.go
return wrapSRErr(err) } case change.Delete != nil: // skip overwrite of local update if peer sent stale info if !updatedAt.IsZero() { if sa, _, err := globalIAMSys.getServiceAccount(ctx, change.Delete.AccessKey); err == nil && sa.UpdatedAt.After(updatedAt) { return nil } } if err := globalIAMSys.DeleteServiceAccount(ctx, change.Delete.AccessKey, true); err != nil { return wrapSRErr(err)
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) -
cmd/iam-etcd-store.go
} func (ies *IAMEtcdStore) addUser(ctx context.Context, user string, userType IAMUserType, u UserIdentity, m map[string]UserIdentity) error { if u.Credentials.IsExpired() { // Delete expired identity. deleteKeyEtcd(ctx, ies.client, getUserIdentityPath(user, userType)) deleteKeyEtcd(ctx, ies.client, getMappedPolicyPath(user, userType, false)) return nil } if u.Credentials.AccessKey == "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
func (p *podNetnsCache) Take(uid string) Netns { // lock current pod map p.mu.Lock() defer p.mu.Unlock() if ns, ok := p.currentPodCache[uid]; ok { delete(p.currentPodCache, uid) // already in cache return ns.Netns } return nil } func openNetnsInRoot(hostMountsPath string) func(nspath string) (NetnsCloser, error) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
internal/s3select/csv/record.go
func (r *Record) Reset() { if len(r.columnNames) > 0 { r.columnNames = r.columnNames[:0] } if len(r.csvRecord) > 0 { r.csvRecord = r.csvRecord[:0] } for k := range r.nameIndexMap { delete(r.nameIndexMap, k) } } // Clone the record. func (r *Record) Clone(dst sql.Record) sql.Record { other, ok := dst.(*Record) if !ok { other = &Record{} } if len(other.columnNames) > 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Sep 13 00:00:59 GMT 2022 - 4.1K bytes - Viewed (0)