- Sort Score
- Result 10 results
- Languages All
Results 371 - 380 of 1,214 for Func (0.08 sec)
-
cmd/erasure-server-pool-rebalance_gen.go
"github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *rebalSaveOpts) DecodeMsg(dc *msgp.Reader) (err error) { { var zb0001 uint8 zb0001, err = dc.ReadUint8() if err != nil { err = msgp.WrapError(err) return } (*z) = rebalSaveOpts(zb0001) } return } // EncodeMsg implements msgp.Encodable func (z rebalSaveOpts) EncodeMsg(en *msgp.Writer) (err error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 26.8K bytes - Viewed (0) -
internal/bucket/lifecycle/noncurrentversion.go
func (n NoncurrentVersionExpiration) IsNull() bool { return n.IsDaysNull() && n.NewerNoncurrentVersions == 0 } // IsDaysNull returns true if days field is null func (n NoncurrentVersionExpiration) IsDaysNull() bool { return n.NoncurrentDays == ExpirationDays(0) } // Validate returns an error with wrong value func (n NoncurrentVersionExpiration) Validate() error { if !n.set {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Dec 14 17:41:44 UTC 2021 - 5.3K bytes - Viewed (0) -
internal/s3select/progress.go
var bz2Limiter = pbzip2.CreateConcurrencyPool((runtime.GOMAXPROCS(0) + 1) / 2) func (r *countUpReader) Read(p []byte) (n int, err error) { n, err = r.reader.Read(p) atomic.AddInt64(&r.bytesRead, int64(n)) return n, err } func (r *countUpReader) BytesRead() int64 { if r == nil { return 0 } return atomic.LoadInt64(&r.bytesRead) } func newCountUpReader(reader io.Reader) *countUpReader { return &countUpReader{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 4.3K bytes - Viewed (0) -
src/archive/tar/tar_test.go
type fileInfoNames struct{} func (f *fileInfoNames) Name() string { return "tmp" } func (f *fileInfoNames) Size() int64 { return 0 } func (f *fileInfoNames) Mode() fs.FileMode { return 0777 } func (f *fileInfoNames) ModTime() time.Time { return time.Time{} } func (f *fileInfoNames) IsDir() bool { return false } func (f *fileInfoNames) Sys() any { return nil
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Jul 25 00:25:45 UTC 2024 - 23.9K bytes - Viewed (0) -
cmd/storage-rest_test.go
} return restClient } func TestStorageRESTClientDiskInfo(t *testing.T) { restClient := newStorageRESTHTTPServerClient(t) testStorageAPIDiskInfo(t, restClient) } func TestStorageRESTClientStatInfoFile(t *testing.T) { restClient := newStorageRESTHTTPServerClient(t) testStorageAPIStatInfoFile(t, restClient) } func TestStorageRESTClientListDir(t *testing.T) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 22 07:04:48 UTC 2024 - 11.5K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
// Endpoint - return kafka target func (h *Target) Endpoint() string { return "kafka" } // String - kafka string func (h *Target) String() string { return "kafka" } // Stats returns the target statistics. func (h *Target) Stats() types.TargetStats { h.logChMu.RLock() queueLength := len(h.logCh) h.logChMu.RUnlock() return types.TargetStats{ TotalMessages: atomic.LoadInt64(&h.totalMessages),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10.2K bytes - Viewed (0) -
internal/lock/lock_windows.go
// paths or paths containing .. elements. For now, // \\server\share paths are not converted to // \\?\UNC\server\share paths because the rules for doing so // are less well-specified. if len(path) >= 2 && path[:2] == `\\` { // Don't canonicalize UNC paths. return path } if !filepath.IsAbs(path) { // Relative path return path } const prefix = `\\?`
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 18 18:08:15 UTC 2023 - 7.9K bytes - Viewed (0) -
tests/hooks_test.go
return } func (s *Product) BeforeSave(tx *gorm.DB) (err error) { if s.Code == "dont_save" { err = errors.New("can't save") } s.BeforeSaveCallTimes = s.BeforeSaveCallTimes + 1 return } func (s *Product) AfterFind(tx *gorm.DB) (err error) { s.AfterFindCallTimes = s.AfterFindCallTimes + 1 return } func (s *Product) AfterCreate(tx *gorm.DB) (err error) {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Mon Jun 17 03:59:06 UTC 2024 - 16.7K bytes - Viewed (0) -
docs/debugging/reorder-disks/main.go
} result[s[2]] = s[9] } if err := scanner.Err(); err != nil { return nil, err } return result, nil } func getDiskUUIDMap() (map[string]string, error) { result := make(map[string]string) err := filepath.Walk("/dev/disk/by-uuid/", func(path string, info os.FileInfo, err error) error { if err != nil { return err } realPath, err := filepath.EvalSymlinks(path)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.4K bytes - Viewed (0) -
internal/crypto/sse.go
// and no Type. func IsRequested(h http.Header) (Type, bool) { switch { case S3.IsRequested(h): return S3, true case S3KMS.IsRequested(h): return S3KMS, true case SSEC.IsRequested(h): return SSEC, true default: return nil, false } } // Requested returns whether any type of encryption is requested. func Requested(h http.Header) bool {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 30 15:26:43 UTC 2022 - 4.4K bytes - Viewed (0)