- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for olleet (0.15 sec)
-
cni/pkg/repair/netns.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0) -
cmd/metrics-v3-handler.go
// returned for the requested path. // // FIXME: It currently only lists `minio_` prefixed metrics. func (h *metricsV3Server) listMetrics(path string) http.Handler { // First collect all matching MetricsGroup's matchingMG := make(map[collectorPath]*MetricsGroup) for _, collPath := range h.metricsData.collectorPaths { if collPath.isDescendantOf(path) { if v, ok := h.metricsData.mgMap[collPath]; ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 7.5K bytes - Viewed (0) -
cmd/metrics-v3-system-cpu.go
cpuNiceVal := math.Round(ts.Nice/tot*100*100) / 100 m.Set(sysCPUNice, cpuNiceVal) cpuStealVal := math.Round(ts.Steal/tot*100*100) / 100 m.Set(sysCPUSteal, cpuStealVal) // metrics-resource.go runs a job to collect resource metrics including their Avg values and // stores them in resourceMetricsMap. We can use it to get the Avg values of CPU idle and IOWait. cpuResourceMetrics, found := resourceMetricsMap[cpuSubsystem] if found {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 3K bytes - Viewed (0) -
cmd/api-router.go
// handlers. // // It is set per-"handler function registration" in the router to allow for // behavior modification via flags. // // This middleware always calls `collectAPIStats` to collect API stats. // // The passed in handler function must be a method of `objectAPIHandlers` for // the name displayed in logs and trace to be accurate. The name is extracted // via reflection. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0) -
cmd/metrics-resource.go
// Describe sends the super-set of all possible descriptors of metrics func (c *minioResourceCollector) Describe(ch chan<- *prometheus.Desc) { ch <- c.desc } // Collect is called by the Prometheus registry when collecting metrics. func (c *minioResourceCollector) Collect(out chan<- prometheus.Metric) { var wg sync.WaitGroup publish := func(in <-chan MetricV2) { defer wg.Done() for metric := range in {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0) -
cmd/site-replication.go
info.UserStats = make(map[string]map[string]srUserStatsSummary) info.GroupStats = make(map[string]map[string]srGroupStatsSummary) info.ILMExpiryRulesStats = make(map[string]map[string]srILMExpiryRuleStatsSummary) // collect user policy mapping replication status across sites if opts.Users || opts.Entity == madmin.SRUserEntity { for u, pslc := range userPolicyStats { if len(info.UserStats[u]) == 0 {
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/admin-router.go
// checking of object layer availability are all enabled. Use flags to modify // this behavior. func adminMiddleware(f http.HandlerFunc, flags ...hFlag) http.HandlerFunc { // Collect all flags with bitwise-OR and assign operator var handlerFlags hFlag for _, flag := range flags { handlerFlags |= flag } // Get name of the handler using reflection.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0) -
istioctl/pkg/util/configdump/route.go
routeDump, err := w.GetRouteConfigDump() if err != nil { return nil, err } drc := routeDump.GetDynamicRouteConfigs() lastUpdated := time.Unix(0, 0) // get the oldest possible timestamp for i := range drc { if drc[i].LastUpdated != nil { drLastUpdated := drc[i].LastUpdated.AsTime() if drLastUpdated.After(lastUpdated) { lastUpdated = drLastUpdated } } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 3.2K bytes - Viewed (0) -
src/cmd/asm/internal/asm/asm.go
) // TODO: configure the architecture var testOut *strings.Builder // Gathers output when testing. // append adds the Prog to the end of the program-thus-far. // If doLabel is set, it also defines the labels collect for this Prog. func (p *Parser) append(prog *obj.Prog, cond string, doLabel bool) { if cond != "" { switch p.arch.Family { case sys.ARM: if !arch.ARMConditionCodes(prog, cond) {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Feb 21 14:34:57 GMT 2024 - 25.3K bytes - Viewed (0) -
cmd/storage-rest-server.go
if !s.checkID(params.DiskID) { return grid.NewRemoteErr(errDiskNotFound) } if params.Cache == nil { return grid.NewRemoteErrString("NSScannerHandler: provided cache is nil") } // Collect updates, stream them before the full cache is sent. updates := make(chan dataUsageEntry, 1) var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() for update := range updates {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0)