- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for Kast (0.24 sec)
-
cmd/tier-last-day-stats_gen.go
Krishnan Parthasarathi <******@****.***> 1711041695 -0700
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/consolelogger.go
} lastN = make([]log.Info, last) sys.RLock() sys.logBuf.Do(func(p interface{}) { if p != nil { lg, ok := p.(log.Info) if ok && lg.SendLog(node, logKind) { lastN[cnt%last] = lg cnt++ } } }) sys.RUnlock() // send last n console log messages in order filtered by node if cnt > 0 { for i := 0; i < last; i++ { entry := lastN[(cnt+i)%last] if (entry == log.Info{}) {
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) -
internal/cachevalue/cache.go
type Opts struct { // When set to true, return the last cached value // even if updating the value errors out. // Returns the last good value AND the error. ReturnLastGood bool // If CacheError is set, errors will be cached as well // and not continuously try to update. // Should not be combined with ReturnLastGood. CacheError bool // If NoWait is set, Get() will return the last good value,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 16:00:42 GMT 2024 - 4.2K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
var multiXdsOpts multixds.Options statusCmd := &cobra.Command{ Use: "proxy-status [<type>/]<name>[.<namespace>]", Short: "Retrieves the synchronization status of each Envoy in the mesh", Long: ` Retrieves last sent and last acknowledged xDS sync from Istiod to each Envoy in the mesh `, Example: ` # Retrieve sync status for all Envoys in a mesh istioctl proxy-status # Retrieve sync status for Envoys in a specific namespace
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 6.2K bytes - Viewed (0) -
cmd/net.go
} ipList = set.NewStringSet() for _, addr := range addrs { ipList.Add(addr) } return ipList, err } // sortIPs - sort ips based on higher octets. // The logic to sort by last octet is implemented to // prefer CIDRs with higher octets, this in-turn skips the // localhost/loopback address to be not preferred as the // first ip on the list. Subsequently this list helps us print
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/erasure-utils.go
} // Skip until offset. block = block[offset:] // Reset the offset for next iteration to read everything // from subsequent blocks. offset = 0 // We have written all the blocks, write the last remaining block. if write < int64(len(block)) { n, err := dst.Write(block[:write]) if err != nil { return 0, err } totalWritten += int64(n) break } // Copy the block.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 3.1K bytes - Viewed (0) -
cmd/data-usage-utils.go
TotalUsedCapacity uint64 `json:"usedCapacity,omitempty"` TotalFreeCapacity uint64 `json:"freeCapacity,omitempty"` // LastUpdate is the timestamp of when the data usage info was last updated. // This does not indicate a full scan. LastUpdate time.Time `json:"lastUpdate"` // Objects total count across all buckets ObjectsTotalCount uint64 `json:"objectsCount"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/metrics-v3-handler.go
isListingRequest := r.Form.Has("list") buckets := []string{} if strings.HasPrefix(pathComponents, "/bucket/") { // bucket specific metrics, extract the bucket name from the path. // it's the last part of the path. e.g. /bucket/api/<bucket-name> bucketIdx := strings.LastIndex(pathComponents, "/") buckets = append(buckets, pathComponents[bucketIdx+1:]) // remove bucket from pathComponents as it is dyanamic and
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/s3select/csv/reader.go
if r.err == nil { r.err = io.EOF } return r.readCloser.Close() } // nextSplit will attempt to skip a number of bytes and // return the buffer until the next newline occurs. // The last block will be sent along with an io.EOF. func (r *Reader) nextSplit(skip int, dst []byte) ([]byte, error) { if cap(dst) < skip { dst = make([]byte, 0, skip+1024) } dst = dst[:skip] if skip > 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
cmd/tier-last-day-stats.go
func (l *lastDayTierStats) addStats(ts tierStats) { now := time.Now() l.forwardTo(now) nowIdx := now.Hour() l.Bins[nowIdx] = l.Bins[nowIdx].add(ts) } // forwardTo moves time to t, clearing entries between last update and t. func (l *lastDayTierStats) forwardTo(t time.Time) { if t.IsZero() { t = time.Now() } since := t.Sub(l.UpdatedAt).Hours() // within the hour since l.UpdatedAt if since < 1 { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 2.8K bytes - Viewed (0)