Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 411 - 420 of 2,773 for Errorf (0.37 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top