- Sort Score
- Result 10 results
- Languages All
Results 801 - 810 of 1,020 for err (0.13 sec)
-
cmd/metrics-v3-cache.go
} func newDataUsageInfoCache() *cachevalue.Cache[DataUsageInfo] { loadDataUsage := func(ctx context.Context) (u DataUsageInfo, err error) { objLayer := newObjectLayerFn() if objLayer == nil { return } // Collect cluster level object metrics. u, err = loadDataUsageFromBackend(GlobalContext, objLayer) return } return cachevalue.NewFromFunc(1*time.Minute, cachevalue.Opts{ReturnLastGood: true},
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu May 09 00:51:34 UTC 2024 - 8.1K bytes - Viewed (0) -
cmd/local-locker.go
} func (l *localLocker) Unlock(_ context.Context, args dsync.LockArgs) (reply bool, err error) { if len(args.Resources) > maxDeleteList { return false, fmt.Errorf("internal error: localLocker.Unlock called with more than %d resources", maxDeleteList) } l.mutex.Lock() defer l.mutex.Unlock() err = nil for _, resource := range args.Resources { lri, ok := l.lockMap[resource]
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 10.7K bytes - Viewed (0) -
internal/config/lambda/event/targetlist.go
list.RLock() defer list.RUnlock() arn, err := ParseARN(arnStr) if err != nil { return nil, err } id, found := list.targets[arn.TargetID] if !found { return nil, &ErrARNNotFound{} } return id, nil } // TargetIDResult returns result of Remove/Send operation, sets err if // any for the associated TargetID type TargetIDResult struct {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Mar 07 16:12:41 UTC 2023 - 4.3K bytes - Viewed (0) -
schema/callbacks_test.go
return nil } func (UserWithCallback) AfterCreate(*gorm.DB) error { return nil } func TestCallback(t *testing.T) { user, err := schema.Parse(&UserWithCallback{}, &sync.Map{}, schema.NamingStrategy{}) if err != nil { t.Fatalf("failed to parse user with callback, got error %v", err) } for _, str := range []string{"BeforeSave", "AfterCreate"} {
Registered: Sun Oct 27 09:35:08 UTC 2024 - Last Modified: Thu Jan 06 07:02:53 UTC 2022 - 939 bytes - Viewed (0) -
internal/config/etcd/etcd_test.go
} for _, testCase := range testCases { testCase := testCase t.Run(testCase.s, func(t *testing.T) { endpoints, secure, err := parseEndpoints(testCase.s) if err != nil && testCase.success { t.Errorf("expected to succeed but failed with %s", err) } if !testCase.success && err == nil { t.Error("expected failure but succeeded instead") } if testCase.success {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 2.1K bytes - Viewed (0) -
istioctl/pkg/multicluster/cluster.go
// (see https://docs.google.com/document/d/1F__vEKeI41P7PPUCMM9PVPYY34pyrvQI5rbTJVnS5c4) func clusterUID(client kubernetes.Interface) (types.UID, error) { kubeSystem, err := client.CoreV1().Namespaces().Get(context.TODO(), "kube-system", metav1.GetOptions{}) if err != nil { return "", err } return kubeSystem.UID, nil
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Fri Sep 02 03:11:58 UTC 2022 - 1.1K bytes - Viewed (0) -
internal/bucket/lifecycle/noncurrentversion.go
MaxNoncurrentVersions int `xml:"MaxNoncurrentVersions,omitempty"` } var val noncurrentExpiration err := d.DecodeElement(&val, &startElement) if err != nil { return err } if val.MaxNoncurrentVersions > 0 { val.NewerNoncurrentVersions = val.MaxNoncurrentVersions } *n = NoncurrentVersionExpiration{ XMLName: val.XMLName,
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Dec 14 17:41:44 UTC 2021 - 5.3K bytes - Viewed (0) -
internal/bucket/versioning/versioning.go
// ParseConfig - parses data in given reader to VersioningConfiguration. func ParseConfig(reader io.Reader) (*Versioning, error) { var v Versioning if err := xml.NewDecoder(reader).Decode(&v); err != nil { return nil, err } if err := v.Validate(); err != nil { return nil, err } return &v, nil
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
cmd/tier-sweeper.go
ObjName string VersionID string TierName string } func deleteObjectFromRemoteTier(ctx context.Context, objName, rvID, tierName string) error { w, err := globalTierConfigMgr.getDriver(ctx, tierName) if err != nil { return err } return w.Remove(ctx, objName, remoteVersionID(rvID))
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Apr 17 05:09:58 UTC 2024 - 4.7K bytes - Viewed (0) -
cni/pkg/util/podutil.go
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 4.7K bytes - Viewed (0)