Search Options

Results per page
Sort
Preferred Languages
Advance

Results 951 - 960 of 1,423 for Func (0.06 sec)

  1. cmd/metacache-server-pool.go

    	"github.com/minio/minio/internal/grid"
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    func renameAllBucketMetacache(epPath string) error {
    	// Rename all previous `.minio.sys/buckets/<bucketname>/.metacache` to
    	// to `.minio.sys/tmp/` for deletion.
    	return readDirFn(pathJoin(epPath, minioMetaBucket, bucketMetaPrefix), func(name string, typ os.FileMode) error {
    		if typ == os.ModeDir {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. cmd/scannermetric_string.go

    // Code generated by "stringer -type=scannerMetric -trimprefix=scannerMetric data-scanner-metric.go"; DO NOT EDIT.
    
    package cmd
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[scannerMetricReadMetadata-0]
    	_ = x[scannerMetricCheckMissing-1]
    	_ = x[scannerMetricSaveUsage-2]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 25 05:15:31 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  3. cmd/bitrot_test.go

    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"io"
    	"testing"
    )
    
    func testBitrotReaderWriterAlgo(t *testing.T, bitrotAlgo BitrotAlgorithm) {
    	tmpDir := t.TempDir()
    
    	volume := "testvol"
    	filePath := "testfile"
    
    	disk, err := newLocalXLStorage(tmpDir)
    	if err != nil {
    		t.Fatal(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  4. istioctl/pkg/util/configdump/util.go

    	ecds      configTypeURL = "type.googleapis.com/envoy.admin.v3.EcdsConfigDump"
    )
    
    // getSection takes a TypeURL and returns the types.Any from the config dump corresponding to that URL
    func (w *Wrapper) getSection(sectionTypeURL configTypeURL) (*anypb.Any, error) {
    	var dumpAny *anypb.Any
    	for _, conf := range w.Configs {
    		if conf.TypeUrl == string(sectionTypeURL) {
    			dumpAny = conf
    		}
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sun Dec 24 08:16:26 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  5. cmd/admin-bucket-handlers.go

    // ----------
    // Places a quota configuration on the specified bucket. The quota
    // specified in the quota configuration will be applied by default
    // to enforce total quota for the specified bucket.
    func (a adminAPIHandlers) PutBucketQuotaConfigHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.SetBucketQuotaAdminAction)
    	if objectAPI == nil {
    		return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  6. internal/ringbuffer/ring_buffer_test.go

    		t.Errorf("Read error: got %T, want testError1", err)
    	}
    }
    
    func TestRingBufferCloseErrorUnblocks(t *testing.T) {
    	const sz = 100
    	rb := New(sz).SetBlocking(true)
    
    	testCancel := func(fn func()) {
    		t.Helper()
    		defer timeout(5 * time.Second)()
    		rb.Reset()
    		done := make(chan struct{})
    		go func() {
    			defer close(done)
    			time.Sleep(10 * time.Millisecond)
    			fn()
    		}()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  7. internal/config/identity/ldap/config.go

    type Config struct {
    	LDAP ldap.Config
    
    	stsExpiryDuration time.Duration // contains converted value
    }
    
    // Enabled returns if LDAP is enabled.
    func (l *Config) Enabled() bool {
    	return l.LDAP.Enabled
    }
    
    // Clone returns a cloned copy of LDAP config.
    func (l *Config) Clone() Config {
    	if l == nil {
    		return Config{}
    	}
    	cfg := Config{
    		LDAP:              l.LDAP.Clone(),
    		stsExpiryDuration: l.stsExpiryDuration,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 07 12:59:47 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. internal/bucket/encryption/bucket-sse-config.go

    // Algo returns the SSE algorithm specified by the SSE configuration.
    func (b *BucketSSEConfig) Algo() Algorithm {
    	for _, rule := range b.Rules {
    		return rule.DefaultEncryptionAction.Algorithm
    	}
    	return ""
    }
    
    // KeyID returns the KMS key ID specified by the SSE configuration.
    // If the SSE configuration does not specify SSE-KMS it returns an
    // empty key ID.
    func (b *BucketSSEConfig) KeyID() string {
    	for _, rule := range b.Rules {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 4.9K bytes
    - Viewed (0)
  9. internal/config/heal/heal.go

    // -1 for not enabled
    //
    //	0 for contiunous bitrot scanning
    //
    // >0 interval duration between cycles
    func (opts Config) BitrotScanCycle() (d time.Duration) {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.cache.bitrotCycle
    }
    
    // Clone safely the heal configuration
    func (opts Config) Clone() (int, time.Duration, string) {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  10. logger/sql.go

    func ExplainSQL(sql string, numericPlaceholder *regexp.Regexp, escaper string, avars ...interface{}) string {
    	var (
    		convertParams func(interface{}, int)
    		vars          = make([]string, len(avars))
    	)
    
    	convertParams = func(v interface{}, idx int) {
    		switch v := v.(type) {
    		case bool:
    			vars[idx] = strconv.FormatBool(v)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Mar 21 08:00:02 UTC 2024
    - 5K bytes
    - Viewed (0)
Back to top