- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 71 for Franke (0.15 sec)
-
cmd/metrics-v3-api.go
for name, value := range httpStats.CurrentS3Requests.APIStats { m.Set(apiRequestsInFlightTotal, float64(value), "name", name, "type", "s3") } for name, value := range httpStats.TotalS3Requests.APIStats { m.Set(apiRequestsTotal, float64(value), "name", name, "type", "s3") } for name, value := range httpStats.TotalS3Errors.APIStats {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 9.2K bytes - Viewed (0) -
cmd/metacache-bucket.go
}) // Keep first metacacheMaxEntries... for _, cache := range remainCaches[metacacheMaxEntries:] { if time.Since(cache.lastHandout) > metacacheMaxClientWait { remove[cache.id] = struct{}{} } } } } for id := range remove { b.deleteCache(id) } } // updateCacheEntry will update a cache. // Returns the updated status.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.6K bytes - Viewed (0) -
internal/bucket/replication/replication.go
rules := c.FilterActionableRules(obj) for _, rule := range rules { if rule.Status == Disabled { continue } if c.RoleArn != "" { arns = append(arns, c.RoleArn) // use legacy RoleArn if present return arns } if _, ok := tgtsMap[rule.Destination.ARN]; !ok { tgtsMap[rule.Destination.ARN] = struct{}{} } } for k := range tgtsMap { arns = append(arns, k) } return arns
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 8.9K bytes - Viewed (0) -
cmd/erasure-metadata_test.go
{6, -1}, } // Setup. fi := newFileInfo("test-object", 8, 8) fi.Erasure.Index = 1 if !fi.IsValid() { t.Fatalf("unable to get xl meta") } // Test them. for _, testCase := range testCases { if testCase.expectedIndex > -1 { partNumString := strconv.Itoa(testCase.partNum) fi.AddObjectPart(testCase.partNum, "etag."+partNumString, int64(testCase.partNum+humanize.MiByte), ActualSize, UTCNow(), nil, nil)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/main.go
DESCRIPTION: {{.Description}} USAGE: {{.HelpName}} {{if .VisibleFlags}}[FLAGS] {{end}}COMMAND{{if .VisibleFlags}}{{end}} [ARGS...] COMMANDS: {{range .VisibleCommands}}{{join .Names ", "}}{{ "\t" }}{{.Usage}} {{end}}{{if .VisibleFlags}} FLAGS: {{range .VisibleFlags}}{{.}} {{end}}{{end}} VERSION: {{.Version}} ` func newApp(name string) *cli.App {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/metrics-v3-cache.go
now := time.Now().UTC() prevDriveIOStatsMu.Lock() if prevDriveIOStats != nil { duration := now.Sub(prevDriveIOStatsRefreshedAt) if duration.Seconds() > 1 { for d, cs := range currentStats { if ps, found := prevDriveIOStats[d]; found { v.ioStats[d] = getDriveIOStatMetrics(getDiffStats(ps, cs), duration) } } } } prevDriveIOStats = currentStats
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 7.9K bytes - Viewed (0) -
cmd/event-notification.go
// GetARNList - returns available ARNs. func (evnot *EventNotifier) GetARNList(onlyActive bool) []string { arns := []string{} if evnot == nil { return arns } region := globalSite.Region for targetID, target := range evnot.targetList.TargetMap() { // httpclient target is part of ListenNotification // which doesn't need to be listed as part of the ARN list // This list is only meant for external targets, filter // this out pro-actively.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.8K bytes - Viewed (0) -
cmd/server-startup-msg.go
if len(apiEndpoints) == 1 { return apiEndpoints } newAPIEndpoints = make([]string, len(apiEndpoints)) // Check all API endpoints for standard ports and strip them. for i, apiEndpoint := range apiEndpoints { _, err := xnet.ParseHTTPURL(apiEndpoint) if err != nil { continue } u, err := url.Parse(apiEndpoint) if err != nil { continue } if host == "" && isIPv6(u.Hostname()) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 09 03:07:08 GMT 2024 - 6.8K bytes - Viewed (0) -
cmd/metrics-v2_test.go
}, { val: 0.61, label: labels[3], }, { val: 0.79, label: labels[2], }, } ticker := time.NewTicker(1 * time.Millisecond) defer ticker.Stop() for _, obs := range observations { // Send observations once every 1ms, to simulate delay between // observations. This is to test the channel based // synchronization used internally. select { case <-ticker.C:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 2.3K bytes - Viewed (0) -
internal/config/server.go
package config // Opts holds MinIO configuration options type Opts struct { FTP struct { Address string `yaml:"address"` PassivePortRange string `yaml:"passive-port-range"` } `yaml:"ftp"` SFTP struct { Address string `yaml:"address"` SSHPrivateKey string `yaml:"ssh-private-key"` } `yaml:"sftp"` } // ServerConfigVersion struct is used to extract the version
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 1.9K bytes - Viewed (0)