Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 101 for _new (0.13 sec)

  1. buildscripts/minio-iam-ldap-upgrade-import-test.sh

    		echo "Failed to verify users: $users"
    		exit 1
    	fi
    
    	mc admin service stop new-minio
    }
    
    main() {
    	create_iam_content_in_old_minio
    
    	import_iam_content_in_new_minio
    
    	verify_iam_content_in_new_minio
    }
    
    Shell Script
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:49:53 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  2. cmd/erasure-common.go

    	"sync"
    	"time"
    
    	"github.com/minio/pkg/v2/sync/errgroup"
    )
    
    func (er erasureObjects) getOnlineDisks() (newDisks []StorageAPI) {
    	disks := er.getDisks()
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	for _, i := range r.Perm(len(disks)) {
    		i := i
    		wg.Add(1)
    		go func() {
    			defer wg.Done()
    			if disks[i] == nil {
    				return
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  3. cmd/bucket-targets.go

    func newHCClient() *madmin.AnonymousClient {
    	clnt, e := madmin.NewAnonymousClientNoEndpoint()
    	if e != nil {
    		bugLogIf(GlobalContext, errors.New("Unable to initialize health check client"))
    		return nil
    	}
    	clnt.SetCustomTransport(globalRemoteTargetTransport)
    	return clnt
    }
    
    // heartBeat performs liveness check on remote endpoints.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  4. cmd/globals.go

    	// global Trace system to send HTTP request/response
    	// and Storage/OS calls info to registered listeners.
    	globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
    
    	// global Listen system to send S3 API events to registered listeners
    	globalHTTPListen = pubsub.New[event.Event, pubsub.Mask](0)
    
    	// global console system to send console logs to
    	// registered listeners
    	globalConsoleSys *HTTPConsoleLoggerSys
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-rebalance.go

    			return index
    		}
    	}
    	return -1
    }
    
    // initRebalanceMeta initializes rebalance metadata for a new rebalance
    // operation and saves it in the object store.
    func (z *erasureServerPools) initRebalanceMeta(ctx context.Context, buckets []string) (arn string, err error) {
    	r := &rebalanceMeta{
    		ID:        shortuuid.New(),
    		PoolStats: make([]*rebalanceStats, len(z.serverPools)),
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  6. docs/debugging/xl-meta/main.go

    		cli.BoolFlag{
    			Usage: "combine inline data",
    			Name:  "combine",
    		},
    	}
    
    	app.Action = func(c *cli.Context) error {
    		ndjson := c.Bool("ndjson")
    		if c.Bool("data") && c.Bool("combine") {
    			return errors.New("cannot combine --data and --combine")
    		}
    		// file / version / file
    		filemap := make(map[string]map[string]string)
    		// versionID ->
    		combineFiles := make(map[string][]string)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:56:22 GMT 2024
    - 20.2K bytes
    - Viewed (1)
  7. cmd/sts-handlers_test.go

    	}
    
    	value, err := assumeRole.Retrieve()
    	if err != nil {
    		c.Fatalf("Expected to generate STS creds, got err: %#v", err)
    	}
    
    	// Check that the LDAP sts cred is actually working.
    	minioClient, err := minio.New(s.endpoint, &minio.Options{
    		Creds:     cr.NewStaticV4(value.AccessKeyID, value.SecretAccessKey, value.SessionToken),
    		Secure:    s.secure,
    		Transport: s.TestSuiteCommon.client.Transport,
    	})
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
  8. cmd/data-scanner_test.go

    		ModTime:     time.Now().Add(-31 * 24 * time.Hour),
    		Size:        100 << 20,
    		VersionID:   uuid.New().String(),
    		IsLatest:    true,
    		NumVersions: 4,
    	}
    	delMarker := ObjectInfo{
    		Name:         "foo-deleted",
    		ModTime:      time.Now().Add(-61 * 24 * time.Hour),
    		Size:         0,
    		VersionID:    uuid.New().String(),
    		IsLatest:     true,
    		DeleteMarker: true,
    		NumVersions:  4,
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  9. Makefile

    verify-healing-with-rewrite: ## verify healing to rewrite old xl.meta -> new xl.meta
    	@echo "Verify healing with rewrite"
    	@GORACE=history_size=7 CGO_ENABLED=1 go build -race -tags kqueue -trimpath --ldflags "$(LDFLAGS)" -o $(PWD)/minio 1>/dev/null
    	@(env bash $(PWD)/buildscripts/rewrite-old-new.sh)
    
    verify-healing-inconsistent-versions: ## verify resolving inconsistent versions
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:55:41 GMT 2024
    - 10.3K bytes
    - Viewed (1)
  10. cmd/xl-storage-disk-id-check.go

    			// Now we swap in a new.
    			newAcc := &AccElem{}
    			old := e.cached.Swap(newAcc)
    			var a AccElem
    			a.Size = atomic.LoadInt64(&old.Size)
    			a.Total = atomic.LoadInt64(&old.Total)
    			a.N = atomic.LoadInt64(&old.N)
    			e.mu.Lock()
    			e.lastMinuteLatency.addAll(t-1, a)
    			e.mu.Unlock()
    			acc = newAcc
    		} else {
    			// We may be able to grab the new accumulator by yielding.
    			runtime.Gosched()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
Back to top