- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 63 for souring (0.14 sec)
-
internal/grid/grid.go
func WriterToChannel(ctx context.Context, ch chan<- []byte) io.Writer { return &writerWrapper{ch: ch, ctx: ctx} } // bytesOrLength returns small (<=100b) byte slices as string, otherwise length. func bytesOrLength(b []byte) string { if len(b) > 100 { return fmt.Sprintf("%d bytes", len(b)) } return fmt.Sprint(b)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
) //go:generate msgp -file $GOFILE -unexported // healingTracker is used to persist healing information during a heal. type healingTracker struct { disk StorageAPI `msg:"-"` mu *sync.RWMutex `msg:"-"` ID string PoolIndex int SetIndex int DiskIndex int Path string Endpoint string Started time.Time LastUpdate time.Time ObjectsTotalCount uint64 ObjectsTotalSize uint64
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.7K bytes - Viewed (0) -
internal/etag/etag.go
// take a look at the package documentation. type ETag []byte // String returns the string representation of the ETag. // // The returned string is a hex representation of the // binary ETag with an optional '-<part-number>' suffix. func (e ETag) String() string { if e.IsMultipart() { return hex.EncodeToString(e[:16]) + string(e[16:]) } return hex.EncodeToString(e) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 13.3K bytes - Viewed (0) -
cmd/http-stats.go
func (stats *HTTPAPIStats) Get(api string) int { if stats == nil { return 0 } stats.RLock() defer stats.RUnlock() val, ok := stats.apiStats[api] if ok { return val } return 0 } // Load returns the recorded stats. func (stats *HTTPAPIStats) Load(toLower bool) map[string]int { if stats == nil { return map[string]int{} } stats.RLock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 11.4K bytes - Viewed (0) -
cmd/server-main.go
// - The returned List needs to be deduplicated as well. func getServerListenAddrs() []string { // Use a string set to avoid duplication addrs := set.NewStringSet() // Listen on local interface to receive requests from Console for _, ip := range mustGetLocalIPs() { if ip != nil && ip.IsLoopback() { addrs.Add(net.JoinHostPort(ip.String(), globalMinioPort)) } } host, _ := mustSplitHostPort(globalMinioAddr)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 34.9K bytes - Viewed (1) -
cmd/metacache-stream.go
// Returns the first error the occurred during the writing if any. func (w *metacacheBlockWriter) Close() error { w.wg.Wait() return w.streamErr } type metacacheBlock struct { data []byte n int First string `json:"f"` Last string `json:"l"` EOS bool `json:"eos,omitempty"` } func (b metacacheBlock) headerKV() map[string]string { json := jsoniter.ConfigCompatibleWithStandardLibrary
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle_test.go
testCases := []struct { inputConfig string objectName string objectTags string objectModTime time.Time isDelMarker bool hasManyVersions bool expectedAction Action isNoncurrent bool objectSuccessorModTime time.Time versionID string }{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 53.2K bytes - Viewed (0) -
cmd/erasure-healing.go
} if result.After.Drives != nil { opts.Tags = map[string]interface{}{"drives-result": result.After.Drives} } auditLogInternal(ctx, opts) } // Heals an object by re-writing corrupt/missing erasure blocks. func (er *erasureObjects) healObject(ctx context.Context, bucket string, object string, versionID string, opts madmin.HealOpts) (result madmin.HealResultItem, err error) { dryRun := opts.DryRun
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/erasure-sets.go
return func() ([]dsync.NetLocker, string) { lockers := make([]dsync.NetLocker, len(s.erasureLockers[setIndex])) copy(lockers, s.erasureLockers[setIndex]) return lockers, s.erasureLockOwner } } func (s *erasureSets) GetEndpointStrings(setIndex int) func() []string { return func() []string { eps := make([]string, s.setDriveCount)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5) -
cmd/healingmetric_string.go
_ = x[healingMetricCheckAbandonedParts-2] } const _healingMetric_name = "BucketObjectCheckAbandonedParts" var _healingMetric_index = [...]uint8{0, 6, 12, 31} func (i healingMetric) String() string { if i >= healingMetric(len(_healingMetric_index)-1) { return "healingMetric(" + strconv.FormatInt(int64(i), 10) + ")" } return _healingMetric_name[_healingMetric_index[i]:_healingMetric_index[i+1]]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 28 18:20:55 GMT 2022 - 789 bytes - Viewed (0)