Search Options

Results per page
Sort
Preferred Languages
Advance

Results 521 - 530 of 932 for erre (0.04 sec)

  1. internal/bucket/lifecycle/expiration.go

    	var dateStr string
    	err := d.DecodeElement(&dateStr, &startElement)
    	if err != nil {
    		return err
    	}
    	// While AWS documentation mentions that the date specified
    	// must be present in ISO 8601 format, in reality they allow
    	// users to provide RFC 3339 compliant dates.
    	expDate, err := time.Parse(time.RFC3339, dateStr)
    	if err != nil {
    		return errLifecycleInvalidDate
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 21 20:28:34 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  2. cmd/server-startup-msg.go

    	newAPIEndpoints = make([]string, len(apiEndpoints))
    	// Check all API endpoints for standard ports and strip them.
    	for i, apiEndpoint := range apiEndpoints {
    		_, err := xnet.ParseHTTPURL(apiEndpoint)
    		if err != nil {
    			continue
    		}
    		u, err := url.Parse(apiEndpoint)
    		if err != nil {
    			continue
    		}
    		if host == "" && isIPv6(u.Hostname()) {
    			// Skip all IPv6 endpoints
    			continue
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 23 14:11:35 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  3. internal/kms/secret-key.go

    		sealingKey := mac.Sum(nil)
    
    		block, err := aes.NewCipher(sealingKey)
    		if err != nil {
    			return nil, err
    		}
    		aead, err = cipher.NewGCM(block)
    		if err != nil {
    			return nil, err
    		}
    	case kms.ChaCha20:
    		sealingKey, err := chacha20.HChaCha20(s.key, iv)
    		if err != nil {
    			return nil, err
    		}
    		aead, err = chacha20poly1305.New(sealingKey)
    		if err != nil {
    			return nil, err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  4. cmd/site-replication-utils.go

    		return errServerNotInitialized
    	}
    	info, err := globalSiteReplicationSys.GetClusterInfo(ctx)
    	if err != nil {
    		return err
    	}
    	if !info.Enabled {
    		return nil
    	}
    	for _, peer := range info.Sites {
    		if peer.DeploymentID == globalDeploymentID() {
    			continue
    		}
    		rs, err := loadSiteResyncMetadata(ctx, objAPI, peer.DeploymentID)
    		if err != nil {
    			return err
    		}
    		sm.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  5. internal/s3select/sql/jsonpath_test.go

    		result = append(result, parsedVal.Value)
    	}
    	if err := dec.Err(); err != nil {
    		return nil, err
    	}
    	return result, nil
    }
    
    func TestJsonpathEval(t *testing.T) {
    	f, err := os.Open(filepath.Join("jsondata", "books.json"))
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	b, err := io.ReadAll(f)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	p := participle.MustBuild(
    		&JSONPath{},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  6. cmd/data-usage_test.go

    	for _, f := range files {
    		err := os.MkdirAll(filepath.Dir(filepath.Join(base, bucket, f.name)), os.ModePerm)
    		if err != nil {
    			t.Fatal(err)
    		}
    		err = os.WriteFile(filepath.Join(base, bucket, f.name), make([]byte, f.size), os.ModePerm)
    		if err != nil {
    			t.Fatal(err)
    		}
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  7. cmd/tier.go

    func (config *TierConfigMgr) Remove(ctx context.Context, tier string, force bool) error {
    	d, err := config.getDriver(ctx, tier)
    	if err != nil {
    		if errors.Is(err, errTierNotFound) {
    			return nil
    		}
    		return err
    	}
    	if !force {
    		if inuse, err := d.InUse(ctx); err != nil {
    			return err
    		} else if inuse {
    			return errTierBackendNotEmpty
    		}
    	}
    	config.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  8. internal/grid/muxclient.go

    	}
    }
    
    func (m *muxClient) pong(msg pongMsg) {
    	if msg.NotFound || msg.Err != nil {
    		err := errors.New("remote terminated call")
    		if msg.Err != nil {
    			err = fmt.Errorf("remove pong failed: %v", &msg.Err)
    		}
    		m.addResponse(Response{Err: err})
    		return
    	}
    	atomic.StoreInt64(&m.LastPong, time.Now().UnixNano())
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  9. cmd/xl-storage-free-version_test.go

    			}
    		}
    	}
    
    	// Simulate scanner removing free-version
    	freefi := newtierfi
    	for _, fvID := range fvIDs {
    		freefi.VersionID = fvID
    		_, err = xl.DeleteVersion(freefi)
    		fatalErr(err)
    	}
    	report()
    
    	// Check number of free-versions
    	freeVersions, err = xl.listFreeVersions(newtierfi.Volume, newtierfi.Name)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Mar 02 05:11:03 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  10. cmd/sftp-server.go

    			}, nil
    		}
    
    		if !errors.Is(err, errNoSuchServiceAccount) {
    			return nil, err
    		}
    
    		lookupResult, targetGroups, err = globalIAMSys.LDAPConfig.Bind(user, string(pass))
    		if err != nil {
    			return nil, err
    		}
    
    	} else if key != nil {
    
    		lookupResult, targetGroups, err = globalIAMSys.LDAPConfig.LookupUserDN(user)
    		if err != nil {
    			return nil, err
    		}
    
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 20 20:00:29 UTC 2024
    - 16K bytes
    - Viewed (0)
Back to top