- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 102 for qmsg (0.55 sec)
-
cmd/server-startup-msg.go
msg += color.Blue("Status:") + fmt.Sprintf(getFormatStr(len(diskInfo), 8), diskInfo) if len(mcMessage) > 0 { msg = fmt.Sprintf("%s %s", mcMessage, msg) } } return msg } // Prints startup message of storage capacity and erasure information. func printStorageInfo(storageInfo StorageInfo) { if msg := getStorageInfoMsg(storageInfo); msg != "" { logger.Info(msg) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 03:07:08 GMT 2024 - 6.8K bytes - Viewed (0) -
internal/grid/msg_string.go
// Code generated by "stringer -type=Op -output=msg_string.go -trimprefix=Op msg.go"; DO NOT EDIT. package grid import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[OpConnect-1] _ = x[OpConnectResponse-2] _ = x[OpPing-3] _ = x[OpPong-4] _ = x[OpConnectMux-5] _ = x[OpMuxConnectError-6]
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 1.2K bytes - Viewed (0) -
cmd/server-startup-msg_test.go
{Endpoint: "http://127.0.0.1:9001/data/4/", State: madmin.DriveStateOffline}, } infoStorage.Backend.Type = madmin.Erasure if msg := getStorageInfoMsg(infoStorage); !strings.Contains(msg, "7 Online, 1 Offline") { t.Fatal("Unexpected storage info message, found:", msg) } } // Tests stripping standard ports from apiEndpoints. func TestStripStandardPorts(t *testing.T) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jun 20 00:53:08 GMT 2023 - 4K bytes - Viewed (0) -
internal/grid/msg_gen_test.go
Klaus Post <******@****.***> 1700528975 -0800
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 10.8K bytes - Viewed (0) -
istioctl/pkg/util/formatting/msg_threshold.go
Mitch Connors <******@****.***> 1637152085 -0800
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Wed Nov 17 12:28:05 GMT 2021 - 1.4K bytes - Viewed (0) -
cmd/metacache.go
ended time.Time `msg:"end"` started time.Time `msg:"st"` lastHandout time.Time `msg:"lh"` lastUpdate time.Time `msg:"u"` bucket string `msg:"b"` filter string `msg:"flt"` id string `msg:"id"` error string `msg:"err"` root string `msg:"root"` fileNotFound bool `msg:"fnf"` status scanStatus `msg:"stat"`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5K bytes - Viewed (0) -
cmd/data-usage-cache.go
type dataUsageEntry struct { Children dataUsageHashMap `msg:"ch"` // These fields do no include any children. Size int64 `msg:"sz"` Objects uint64 `msg:"os"` Versions uint64 `msg:"vs"` // Versions that are not delete markers. DeleteMarkers uint64 `msg:"dms"` ObjSizes sizeHistogram `msg:"szs"` ObjVersions versionsHistogram `msg:"vh"`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
cmd/storage-rest-common.go
storageRESTOrigVolume = "orig-volume" ) type nsScannerOptions struct { DiskID string `msg:"id"` ScanMode int `msg:"m"` Cache *dataUsageCache `msg:"c"` } type nsScannerResp struct { Update *dataUsageEntry `msg:"u"` Final *dataUsageCache `msg:"f"`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Feb 12 21:00:20 GMT 2024 - 2.9K bytes - Viewed (0) -
cmd/batch-handlers.go
mu sync.RWMutex `json:"-" msg:"-"` Version int `json:"-" msg:"v"` JobID string `json:"jobID" msg:"jid"` JobType string `json:"jobType" msg:"jt"` StartTime time.Time `json:"startTime" msg:"st"` LastUpdate time.Time `json:"lastUpdate" msg:"lu"` RetryAttempts int `json:"retryAttempts" msg:"ra"` Complete bool `json:"complete" msg:"cmp"`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 14:11:38 GMT 2024 - 55.2K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
if err != nil { panic(err) } // we should get 0 or 1 oob messages if len(msgs) != 0 { assert.Equal(t, len(msgs), 1) } var fdss []int for _, msg := range msgs { fds, err := unix.ParseUnixRights(&msg) if err != nil { panic(err) } fdss = append(fdss, fds...) } return m, fdss } func sendAck(c *net.UnixConn) { ack := &zdsapi.WorkloadResponse{
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0)