- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 190 for Sall (2.93 sec)
-
cmd/metrics-v3-handler.go
} // listMetrics - returns a handler that lists all the metrics that could be // 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)
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) -
internal/http/listener.go
type httpListener struct { opts TCPOptions listeners []net.Listener // underlying TCP listeners. acceptCh chan acceptResult // channel where all TCP listeners write accepted connection. ctx context.Context ctxCanceler context.CancelFunc } // start - starts separate goroutine for each TCP listener. A valid new connection is passed to httpListener.acceptCh.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/os-rename_linux.go
// You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "syscall" ) // RenameSys is low level call in case of Linux this uses syscall.Rename() directly. func RenameSys(src, dst string) (err error) { return syscall.Rename(src, dst)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 01:09:38 GMT 2024 - 999 bytes - Viewed (0) -
internal/config/drive/help.go
MaxTimeout = "max_timeout" // HelpDrive is help for drive HelpDrive = config.HelpKVS{ config.HelpKV{ Key: MaxTimeout, Type: "string", Description: "set per call max_timeout for the drive, defaults to 2 minutes", Optional: true, }, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 27 17:15:06 GMT 2023 - 1.1K bytes - Viewed (0) -
src/cmd/asm/main.go
// Copyright 2014 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package main import ( "bufio" "flag" "fmt" "internal/buildcfg" "log" "os" "cmd/asm/internal/arch" "cmd/asm/internal/asm" "cmd/asm/internal/flags" "cmd/asm/internal/lex" "cmd/internal/bio" "cmd/internal/obj" "cmd/internal/objabi" )
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Aug 29 07:48:38 GMT 2023 - 2.7K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint_test.go
}, expectedOutFile: "default-gateway", }, { name: "all namespaces gateways", args: strings.Split("list -A", " "), gateways: []*gateway.Gateway{ makeGateway(constants.DefaultNamespaceWaypoint, "default", true, true), makeGateway(constants.DefaultNamespaceWaypoint, "fake", true, true), }, expectedOutFile: "all-gateway", }, { name: "have both managed and unmanaged gateways",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 04 15:53:09 GMT 2024 - 4.4K bytes - Viewed (0) -
cmd/config.go
"github.com/minio/minio/internal/kms" ) const ( minioConfigPrefix = "config" minioConfigBucket = minioMetaBucket + SlashSeparator + minioConfigPrefix kvPrefix = ".kv" // Captures all the previous SetKV operations and allows rollback. minioConfigHistoryPrefix = minioConfigPrefix + "/history" // MinIO configuration file. minioConfigFile = "config.json" )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Aug 23 10:07:06 GMT 2023 - 6K bytes - Viewed (0) -
cmd/leak-detect_test.go
return } // wait a test again will deadline. if UTCNow().Before(deadline) { time.Sleep(leakDetectPauseTimeMs * time.Millisecond) continue } // after the deadline time report all the difference in the latest snapshot compared with the initial one. for _, g := range leaked { t.Errorf("Leaked goroutine: %v", g) } return } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.2K bytes - Viewed (0) -
cmd/consolelogger.go
sync.RWMutex pubsub *pubsub.PubSub[log.Info, madmin.LogMask] console *console.Target nodeName string logBuf *ring.Ring } // NewConsoleLogger - creates new HTTPConsoleLoggerSys with all nodes subscribed to // the console logging pub sub system func NewConsoleLogger(ctx context.Context, w io.Writer) *HTTPConsoleLoggerSys { return &HTTPConsoleLoggerSys{ pubsub: pubsub.New[log.Info, madmin.LogMask](8),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
cmd/metrics-realtime.go
} func collectRemoteMetrics(ctx context.Context, types madmin.MetricType, opts collectMetricsOpts) (m madmin.RealtimeMetrics) { if !globalIsDistErasure { return } all := globalNotificationSys.GetMetrics(ctx, types, opts) for _, remote := range all { m.Merge(&remote) } return m
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 10 16:28:08 GMT 2024 - 6.1K bytes - Viewed (0)