Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for getEndpoints (0.07 sec)

  1. cmd/erasure.go

    	getDisks func() []StorageAPI
    
    	// getLockers returns list of remote and local lockers.
    	getLockers func() ([]dsync.NetLocker, string)
    
    	// getEndpoints returns list of endpoint belonging this set.
    	// some may be local and some remote.
    	getEndpoints func() []Endpoint
    
    	// getEndpoints returns list of endpoint strings belonging this set.
    	// some may be local and some remote.
    	getEndpointStrings func() []string
    
    	// Locker mutex map.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  2. cmd/endpoint-ellipses.go

    // Endpoint set represents parsed ellipses values, also provides
    // methods to get the sets of endpoints.
    type endpointSet struct {
    	argPatterns []ellipses.ArgPattern
    	endpoints   []string   // Endpoints saved from previous GetEndpoints().
    	setIndexes  [][]uint64 // All the sets.
    }
    
    // Supported set sizes this is used to find the optimal
    // single set size.
    var setSizes = []uint64{2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  3. cmd/erasure-healing.go

    	dryRun := opts.DryRun
    	scanMode := opts.ScanMode
    
    	storageDisks := er.getDisks()
    	storageEndpoints := er.getEndpoints()
    
    	defer func() {
    		er.auditHealObject(ctx, bucket, object, versionID, result, err)
    	}()
    
    	if globalTrace.NumSubscribers(madmin.TraceHealing) > 0 {
    		startTime := time.Now()
    		defer func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  4. cmd/erasure-sets.go

    				poolIndex:          poolIdx,
    				setDriveCount:      setDriveCount,
    				defaultParityCount: defaultParityCount,
    				getDisks:           s.GetDisks(i),
    				getLockers:         s.GetLockers(i),
    				getEndpoints:       s.GetEndpoints(i),
    				getEndpointStrings: s.GetEndpointStrings(i),
    				nsMutex:            mutex,
    			}
    		}(i)
    	}
    
    	wg.Wait()
    
    	// start cleanup stale uploads go-routine.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  5. cmd/erasure-server-pool-rebalance.go

    	disks, _ := set.getOnlineDisksWithHealing(false)
    	if len(disks) == 0 {
    		return fmt.Errorf("no online drives found for set with endpoints %s", set.getEndpoints())
    	}
    
    	// However many we ask, versions must exist on ~50%
    	listingQuorum := (set.setDriveCount + 1) / 2
    
    	// How to resolve partial results.
    	resolver := metadataResolutionParams{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-decom.go

    	disks, _ := set.getOnlineDisksWithHealing(false)
    	if len(disks) == 0 {
    		return fmt.Errorf("no online drives found for set with endpoints %s", set.getEndpoints())
    	}
    
    	// However many we ask, versions must exist on ~50%
    	listingQuorum := (set.setDriveCount + 1) / 2
    
    	// How to resolve partial results.
    	resolver := metadataResolutionParams{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/envoy/configdump/endpoint.go

    	return ep.GetHealthStatus()
    }
    
    func retrieveEndpointPort(ep *endpoint.LbEndpoint) uint32 {
    	return ep.GetEndpoint().GetAddress().GetSocketAddress().GetPortValue()
    }
    
    func retrieveEndpointAddresses(ep *endpoint.LbEndpoint) []string {
    	addrs := []*core.Address{ep.GetEndpoint().GetAddress()}
    	for _, a := range ep.GetEndpoint().GetAdditionalAddresses() {
    		addrs = append(addrs, a.GetAddress())
    	}
    	result := make([]string, 0, len(addrs))
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 22 09:57:29 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top