- Sort Score
- Num 10 results
- Language All
Results 411 - 420 of 2,773 for Errorf (0.05 seconds)
-
internal/logger/target/console/console.go
func (c *Target) Validate() error { return nil } // Endpoint returns the backend endpoint func (c *Target) Endpoint() string { return "" } func (c *Target) String() string { return "console" } // Send log message 'e' to console func (c *Target) Send(e any) error { entry, ok := e.(log.Entry) if !ok { return fmt.Errorf("Uexpected log entry structure %#v", e) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3.9K bytes - Click Count (0) -
internal/config/crypto.go
func Decrypt(k *kms.KMS, ciphertext io.Reader, associatedData kms.Context) (io.Reader, error) { const ( MaxMetadataSize = 1 << 20 // max. size of the metadata Version = 1 ) var header [5]byte if _, err := io.ReadFull(ciphertext, header[:]); err != nil { return nil, err } if header[0] != Version { return nil, fmt.Errorf("config: unknown ciphertext version %d", header[0]) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri May 16 14:27:42 GMT 2025 - 4.7K bytes - Click Count (0) -
cmd/tier.go
case tierConfigFormat: default: return nil, fmt.Errorf("tierConfigInit: unknown format: %d", format) } cfg := NewTierConfigMgr() switch version := binary.LittleEndian.Uint16(data[2:4]); version { case tierConfigV1, tierConfigVersion: if _, decErr := cfg.UnmarshalMsg(data[4:]); decErr != nil { return nil, decErr } default: return nil, fmt.Errorf("tierConfigInit: unknown version: %d", version) }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.6K bytes - Click Count (0) -
cmd/background-heal-ops.go
res, err := objAPI.HealFormat(ctx, opts.DryRun) // return any error, ignore error returned when disks have // already healed. if err != nil && err != errNoHealRequired { return madmin.HealResultItem{}, err } return res, nil
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 4.6K bytes - Click Count (0) -
docs/debugging/reorder-disks/main.go
} 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) if err != nil { return err }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 5.4K bytes - Click Count (0) -
internal/config/lambda/parse.go
if err == nil && !yes { err = ErrTargetsOffline } if err != nil { return fmt.Errorf("error (%s): %w", target.ID(), err) } } return nil } func fetchSubSysTargets(ctx context.Context, cfg config.Config, subSys string, transport *http.Transport) (targets []event.Target, err error) { if err := checkValidLambdaKeysForSubSys(subSys, cfg[subSys]); err != nil { return nil, err }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 6K bytes - Click Count (0) -
internal/http/response-recorder.go
} } // ErrNotImplemented when a functionality is not implemented var ErrNotImplemented = errors.New("not implemented") // ReadFrom implements support for calling internal io.ReaderFrom implementations // returns an error if the underlying ResponseWriter does not implement io.ReaderFrom func (lrw *ResponseRecorder) ReadFrom(r io.Reader) (int64, error) { if lrw.ReaderFrom != nil { n, err := lrw.ReaderFrom.ReadFrom(r)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 5.5K bytes - Click Count (0) -
internal/bucket/lifecycle/filter_test.go
"testing" "github.com/dustin/go-humanize" ) // TestUnsupportedFilters checks if parsing Filter xml with // unsupported elements returns appropriate errors func TestUnsupportedFilters(t *testing.T) { testCases := []struct { inputXML string expectedErr error }{ { // Filter with And tags inputXML: ` <Filter> <And> <Prefix>key-prefix</Prefix> </And> </Filter>`,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 27 00:01:20 GMT 2024 - 7.2K bytes - Click Count (0) -
cmd/kms-handlers_test.go
adminTestBed.router.ServeHTTP(rec, req) t.Logf("HTTP req: %s, resp code: %d, resp body: %s", req.URL.String(), rec.Code, rec.Body.String()) // Check status code if rec.Code != test.wantStatusCode { t.Errorf("want status code %d, got %d", test.wantStatusCode, rec.Code) } // Check returned key list is correct if test.wantKeyNames != nil { keys := []madmin.KMSKeyInfo{}
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 22.3K bytes - Click Count (0) -
cmd/metacache-server-pool.go
return entries, nil } } else { err = fmt.Errorf("invalid pool/set") o.pool, o.set = 0, 0 } } if IsErr(err, []error{ nil, context.Canceled, context.DeadlineExceeded, // io.EOF is expected and should be returned but no need to log it. io.EOF, }...) { // Expected good errors we don't need to return error. return entries, err } entries.truncate(0)Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 12.9K bytes - Click Count (0)