- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 438 for onDone (0.51 sec)
-
cmd/server-startup-msg.go
if storageInfo.Backend.Type == madmin.Erasure { if offlineDisks.Sum() > 0 { mcMessage = "Use `mc admin info` to look for latest server/drive info\n" } diskInfo := fmt.Sprintf(" %d Online, %d Offline. ", onlineDisks.Sum(), offlineDisks.Sum()) msg += color.Blue("Status:") + fmt.Sprintf(getFormatStr(len(diskInfo), 8), diskInfo) if len(mcMessage) > 0 { msg = fmt.Sprintf("%s %s", mcMessage, msg) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6.8K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/invocation/GradleLifecycleSupportedTypesIntegrationTest.groovy
"ConcurrentHashMap<String, Integer>" | "new ConcurrentHashMap([a: 1, b: 2])" | "[a:1, b:2]" "EnumMap<SomeEnum, String>" | enumMapToString() | "[One:one, Two:two]" "ArrayDeque<String>" | "['a', 'b', 'c'] as ArrayDeque" | "[a, b, c]" "byte[]" | "[Byte.MIN_VALUE, Byte.MAX_VALUE]" | "[-128, 127]"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 23 17:40:52 UTC 2024 - 14K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
retries++ // after 20 retries start logging that servers are not reachable yet if retries >= 20 { logger.Info(fmt.Sprintf("Waiting for at least %d remote servers with valid configuration to be online", len(clnts)/2)) if len(offlineEndpoints) > 0 { logger.Info(fmt.Sprintf("Following servers are currently offline or unreachable %s", offlineEndpoints)) } if len(incorrectConfigs) > 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7.5K bytes - Viewed (0) -
docs/hu/docs/index.md
app = FastAPI() class Item(BaseModel): name: str price: float is_offer: Union[bool, None] = None @app.get("/") def read_root(): return {"Hello": "World"} @app.get("/items/{item_id}") def read_item(item_id: int, q: Union[str, None] = None): return {"item_id": item_id, "q": q} @app.put("/items/{item_id}") def update_item(item_id: int, item: Item):
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Mon Apr 29 05:18:04 UTC 2024 - 20.2K bytes - Viewed (0) -
internal/kms/secret-key.go
func (secretKey) APIs(ctx context.Context) ([]madmin.KMSAPI, error) { return nil, ErrNotSupported } // Status returns a set of endpoints and their KMS status. Since, the builtin KMS is not // external it returns "127.0.0.1: online". func (secretKey) Status(context.Context) (map[string]madmin.ItemState, error) { return map[string]madmin.ItemState{ "127.0.0.1": madmin.ItemOnline, }, nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/notification.go
} idx := xxhash.Sum64String(s) % uint64(len(peerClients)) return peerClients[idx] } // GetPeerOnlineCount gets the count of online and offline nodes. func (sys *NotificationSys) GetPeerOnlineCount() (nodesOnline, nodesOffline int) { nodesOnline = 1 // Self is always online. nodesOffline = 0 nodesOnlineIndex := make([]bool, len(sys.peerClients)) var wg sync.WaitGroup for idx, client := range sys.peerClients {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 44.9K bytes - Viewed (0) -
src/sync/mutex.go
fatal("sync: unlock of unlocked mutex") } if new&mutexStarving == 0 { old := new for { // If there are no waiters or a goroutine has already // been woken or grabbed the lock, no need to wake anyone. // In starvation mode ownership is directly handed off from unlocking // goroutine to the next waiter. We are not part of this chain, // since we did not observe mutexStarving when we unlocked the mutex above.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 8.4K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/preconditions/UnitTestPreconditions.groovy
@Override boolean isSatisfied() { return new Jdk21OrEarlier().satisfied } } static final class Online implements TestPrecondition { @Override boolean isSatisfied() { try { HttpURLConnection connection = (HttpURLConnection) new URL("http://google.com").openConnection();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 03:26:38 UTC 2024 - 16.3K bytes - Viewed (0) -
docs/metrics/prometheus/grafana/node/minio-node.json
"hide": false, "instant": true, "legendFormat": ".", "range": false, "refId": "B" } ], "title": "Total Online/Offline Drives", "type": "gauge" }, { "datasource": { "type": "prometheus", "uid": "${DS_PROMETHEUS}" }, "description": "", "fieldConfig": {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 13:24:37 UTC 2024 - 22.4K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
ssc.enqueueStatefulSet(set) return } // Otherwise, it's an orphan. Get a list of all matching controllers and sync // them to see if anyone wants to adopt it. sets := ssc.getStatefulSetsForPod(pod) if len(sets) == 0 { return } logger.V(4).Info("Orphan Pod created with labels", "pod", klog.KObj(pod), "labels", pod.Labels)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0)