- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for setInfo (0.13 sec)
-
cmd/erasure-server-pool.go
reqInfo := (&logger.ReqInfo{}).AppendTags("maintenance", strconv.FormatBool(opts.Maintenance)) type setInfo struct { online int healing int } var drivesHealing int erasureSetUpCount := make([][]setInfo, len(z.serverPools)) for i := range z.serverPools { erasureSetUpCount[i] = make([]setInfo, len(z.serverPools[i].sets)) } storageInfo := z.StorageInfo(ctx, false)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 82.5K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/operationexecutor/operation_generator.go
} defer conn.Close() ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel() infoResp, err := client.GetInfo(ctx, ®isterapi.InfoRequest{}) if err != nil { return fmt.Errorf("RegisterPlugin error -- failed to get plugin info using RPC GetInfo at socket %s, err: %v", socketPath, err) } handler, ok := pluginHandlers[infoResp.Type] if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 7.1K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/windows/security_windows.go
return Token(^uintptr(6 - 1)) } // Close releases access to access token. func (t Token) Close() error { return CloseHandle(Handle(t)) } // getInfo retrieves a specified type of information about an access token. func (t Token) getInfo(class uint32, initSize int) (unsafe.Pointer, error) { n := uint32(initSize) for { b := make([]byte, n) e := GetTokenInformation(t, class, &b[0], uint32(len(b)), &n)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 52.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/registry/PersistentDaemonRegistry.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 8.9K bytes - Viewed (0) -
cmd/kubeadm/app/util/runtime/runtime.go
defer cancel() status, err := runtime.impl.Status(ctx, runtime.runtimeService, true) if err != nil { return "", errors.Wrap(err, "failed to get runtime status") } infoConfig, ok := status.GetInfo()["config"] if !ok { return "", errors.Errorf("no 'config' field in CRI info: %+v", status) } type config struct { SandboxImage string `json:"sandboxImage,omitempty"` } c := config{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 06:33:22 UTC 2024 - 8.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFile.java
qreq); return resp.getInfo(clazz); } Trans2QueryFSInformationResponse response = new Trans2QueryFSInformationResponse(th.getConfig(), level); th.send(new Trans2QueryFSInformation(th.getConfig(), level), response); return response.getInfo(clazz); } @Override public void mkdir () throws SmbException {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Thu May 23 01:50:13 UTC 2024 - 82.3K bytes - Viewed (1) -
cmd/peer-rest-server.go
madminBgHealState = grid.NewJSONPool[madmin.BgHealState]() madminCPUs = grid.NewJSONPool[madmin.CPUs]() madminMemInfo = grid.NewJSONPool[madmin.MemInfo]() madminNetInfo = grid.NewJSONPool[madmin.NetInfo]() madminOSInfo = grid.NewJSONPool[madmin.OSInfo]() madminPartitions = grid.NewJSONPool[madmin.Partitions]() madminProcInfo = grid.NewJSONPool[madmin.ProcInfo]()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 52.1K bytes - Viewed (0) -
cmd/admin-handlers.go
localNetInfo := madmin.GetNetInfo(globalLocalNodeName, globalInternodeInterface) healthInfo.Sys.NetInfo = append(healthInfo.Sys.NetInfo, localNetInfo) peerNetInfos := globalNotificationSys.GetNetInfo(healthCtx) for _, n := range peerNetInfos { anonymizeAddr(&n) healthInfo.Sys.NetInfo = append(healthInfo.Sys.NetInfo, n) } partialWrite(healthInfo) } } getAndWriteOSInfo := func() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
cmd/notification.go
sys.addNodeErr(&reply[index], sys.peerClients[index], err) } } return reply } // GetNetInfo - Network information func (sys *NotificationSys) GetNetInfo(ctx context.Context) []madmin.NetInfo { reply := make([]madmin.NetInfo, len(sys.peerClients)) g := errgroup.WithNErrs(len(sys.peerClients)) for index, client := range sys.peerClients { if client == nil { continue } index := index
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 44.9K bytes - Viewed (0) -
cmd/peer-rest-client.go
return resp.ValueOrZero(), err } // GetNetInfo - fetch network information for a remote node. func (client *peerRESTClient) GetNetInfo(ctx context.Context) (info madmin.NetInfo, err error) { resp, err := getNetInfoRPC.Call(ctx, client.gridConn(), grid.NewMSS()) return resp.ValueOrZero(), err } // GetPartitions - fetch disk partition information for a remote node.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 26.1K bytes - Viewed (0)