Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for locality (0.15 sec)

  1. cmd/bucket-lifecycle.go

    	}
    	if lcEvent.Action.DeleteVersioned() {
    		opts.VersionID = oi.VersionID
    	}
    	tags := newLifecycleAuditEvent(src, lcEvent).Tags()
    	if lcEvent.Action.DeleteRestored() {
    		// delete locally restored copy of object or object version
    		// from the source, while leaving metadata behind. The data on
    		// transitioned tier lies untouched and still accessible
    		opts.Transition.ExpireRestored = true
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  2. internal/http/listener_test.go

    		case *net.IPNet:
    			ip = v.IP
    		case *net.IPAddr:
    			ip = v.IP
    		}
    
    		if ip.To4() != nil {
    			localIP4.Add(ip.String())
    		}
    	}
    
    	// Filter ipList by IPs those do not start with '127.'.
    	nonLoopBackIPs := localIP4.FuncMatch(func(ip string, matchString string) bool {
    		return !strings.HasPrefix(ip, "127.")
    	}, "")
    	if len(nonLoopBackIPs) == 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jun 12 16:09:28 GMT 2023
    - 11.8K bytes
    - Viewed (0)
  3. internal/dsync/drwmutex.go

    		for {
    			select {
    			case <-ctx.Done():
    				return
    			case <-refreshTimer.C:
    				noQuorum, err := refreshLock(ctx, dm.clnt, id, source, quorum)
    				if err == nil && noQuorum {
    					// Clean the lock locally and in remote nodes
    					forceUnlock(ctx, dm.clnt, id)
    					// Execute the caller lock loss callback
    					if lockLossCallback != nil {
    						lockLossCallback()
    					}
    					return
    				}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  4. cmd/endpoint.go

    				u := &url.URL{
    					Scheme: endpoint.Scheme,
    					Host:   endpoint.Host,
    				}
    				return u.String()
    			}
    		}
    	}
    	host := globalMinioHost
    	if host == "" {
    		host = sortIPs(localIP4.ToSlice())[0]
    	}
    	return fmt.Sprintf("%s://%s", getURLScheme(globalIsTLS), net.JoinHostPort(host, globalMinioPort))
    }
    
    // LocalDisksPaths returns the disk paths of the local disks
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 34.1K bytes
    - Viewed (0)
  5. docs/bucket/versioning/README.md

    simply of `DCE 1.1 v4 UUID 4` (random data based), UUIDs are 128 bit numbers which are intended to have a high likelihood of uniqueness over space and time and are computationally difficult to guess. They are globally unique identifiers which can be locally generated without contacting a global registration authority. UUIDs are intended as unique identifiers for both mass tagging objects with an extremely short lifetime and to reliably identifying very persistent objects across a network.
    
    When...
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 04 21:43:52 GMT 2023
    - 11.9K bytes
    - Viewed (1)
  6. cmd/endpoint_test.go

    	tempGlobalMinioPort := globalMinioPort
    	defer func() {
    		globalMinioPort = tempGlobalMinioPort
    	}()
    	globalMinioPort = "9000"
    
    	// Filter ipList by IPs those do not start with '127.'.
    	nonLoopBackIPs := localIP4.FuncMatch(func(ip string, matchString string) bool {
    		return !net.ParseIP(ip).IsLoopback()
    	}, "")
    	if len(nonLoopBackIPs) == 0 {
    		t.Fatalf("No non-loop back IP address found for this host")
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Jan 13 07:53:03 GMT 2024
    - 18.9K bytes
    - Viewed (1)
  7. cmd/signature-v4-parser_test.go

    		// "aws4_request" is the valid request version.
    		{
    			inputCredentialStr: generateCredentialStr(
    				"LOCALKEY/DEV/1",
    				sampleTimeStr,
    				"us-west-1",
    				"s3",
    				"aws4_request"),
    			expectedCredentials: generateCredentials(
    				t,
    				"LOCALKEY/DEV/1",
    				sampleTimeStr,
    				"us-west-1",
    				"s3",
    				"aws4_request"),
    			expectedErrCode: ErrNone,
    		},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 27.4K bytes
    - Viewed (0)
  8. docs/logging/README.md

    version          (string)    specify the version of the Kafka cluster
    comment          (sentence)  optionally add a comment to this setting
    ```
    
    Configure MinIO to send audit logs to locally running Kafka brokers
    
    ```
    mc admin config set myminio/ audit_kafka:target1 brokers=localhost:29092 topic=auditlog
    mc admin service restart myminio/
    ```
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Aug 15 23:04:20 GMT 2023
    - 9.9K bytes
    - Viewed (2)
  9. cmd/background-newdisks-heal-ops.go

    //  2. Only the node hosting the disk is responsible to perform the heal
    func monitorLocalDisksAndHeal(ctx context.Context, z *erasureServerPools) {
    	// Perform automatic disk healing when a disk is replaced locally.
    	diskCheckTimer := time.NewTimer(defaultMonitorNewDiskInterval)
    	defer diskCheckTimer.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-diskCheckTimer.C:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  10. cmd/erasure-sets.go

    	return s.getHashedSet(object).TransitionObject(ctx, bucket, object, opts)
    }
    
    // RestoreTransitionedObject - restore transitioned object content locally on this cluster.
    func (s *erasureSets) RestoreTransitionedObject(ctx context.Context, bucket, object string, opts ObjectOptions) error {
    	return s.getHashedSet(object).RestoreTransitionedObject(ctx, bucket, object, opts)
    }
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
Back to top