- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 259 for Cool (0.18 sec)
-
cmd/batch-expire.go
VersionID: exp.VersionID, }, } toDel = append(toDel, od) oiCache.Add(od, &exp.ObjectInfo) } var done bool // DeleteObject(deletePrefix: true) to expire all versions of an object for _, exp := range toExpireAll { var success bool for attempts := 1; attempts <= retryAttempts; attempts++ { select { case <-ctx.Done(): done = true default: }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cmd/erasure-server-pool-rebalance.go
) //go:generate msgp -file $GOFILE -unexported // rebalanceStats contains per-pool rebalance statistics like number of objects, // versions and bytes rebalanced out of a pool type rebalanceStats struct { InitFreeSpace uint64 `json:"initFreeSpace" msg:"ifs"` // Pool free space at the start of rebalance InitCapacity uint64 `json:"initCapacity" msg:"ic"` // Pool capacity at the start of rebalance
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/peer-rest-client.go
func (client *peerRESTClient) LocalStorageInfo(metrics bool) (info StorageInfo, err error) { resp, err := localStorageInfoRPC.Call(context.Background(), client.gridConn(), grid.NewMSSWith(map[string]string{ peerRESTMetrics: strconv.FormatBool(metrics), })) return resp.ValueOrZero(), err } // ServerInfo - fetch server information for a remote node. func (client *peerRESTClient) ServerInfo(metrics bool) (info madmin.ServerProperties, err error) {
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/iam-etcd-store.go
func (ies *IAMEtcdStore) loadMappedPolicyWithRetry(ctx context.Context, name string, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy], retries int) error { return ies.loadMappedPolicy(ctx, name, userType, isGroup, m) } func (ies *IAMEtcdStore) loadMappedPolicy(ctx context.Context, name string, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy]) error { var p MappedPolicy
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) -
internal/config/storageclass/storage-class.go
type Config struct { Standard StorageClass `json:"standard"` RRS StorageClass `json:"rrs"` Optimize string `json:"optimize"` inlineBlock int64 initialized bool } // UnmarshalJSON - Validate SS and RRS parity when unmarshalling JSON. func (sCfg *Config) UnmarshalJSON(data []byte) error { type Alias Config aux := &struct { *Alias }{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.8K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
// MessageWriter is a writer for displaying messages to users. MessageWriter io.Writer // XdsViaAgents accesses Istiod via the tap service of each agent. // This is only used in `proxy-status` command. XdsViaAgents bool // XdsViaAgentsLimit is the maximum number of pods being visited by istioctl, // when `XdsViaAgents` is true. This is only used in `proxy-status` command. // 0 means that there is no limit. XdsViaAgentsLimit int }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
internal/config/api/api.go
DeleteCleanupInterval time.Duration `json:"delete_cleanup_interval"` EnableODirect bool `json:"enable_odirect"` GzipObjects bool `json:"gzip_objects"` RootAccess bool `json:"root_access"` SyncEvents bool `json:"sync_events"` ObjectMaxVersions int64 `json:"object_max_versions"` }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 01:08:07 GMT 2024 - 11.1K bytes - Viewed (1) -
istioctl/pkg/writer/envoy/configdump/listener.go
type ListenerFilter struct { Address string Port uint32 Type string Verbose bool } // Verify returns true if the passed listener matches the filter fields func (l *ListenerFilter) Verify(listener *listener.Listener) bool { if l.Address == "" && l.Port == 0 && l.Type == "" { return true } if l.Address != "" {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
istioctl/pkg/workload/workload_test.go
app: foo bar: baz template: ports: grpc: 3550 http: 8080 serviceAccount: test ` ) type testcase struct { description string expectedException bool args []string expectedOutput string namespace string } func TestWorkloadGroupCreate(t *testing.T) { cases := []testcase{ {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
internal/dsync/dsync_test.go
// Borrowed from mutex_test.go func HammerMutex(m *DRWMutex, loops int, cdone chan bool) { for i := 0; i < loops; i++ { m.Lock(id, source) m.Unlock(context.Background()) } cdone <- true } // Borrowed from mutex_test.go func TestMutex(t *testing.T) { loops := 200 if testing.Short() { loops = 5 } c := make(chan bool) m := NewDRWMutex(ds, "test") for i := 0; i < 10; i++ {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0)