Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 164 for endpoints (0.15 sec)

  1. cmd/bucket-targets.go

    					if result.Online {
    						lastOnline = time.Now()
    					}
    					l := prev.latency
    					l.update(time.Since(start))
    					m[result.Endpoint.Host] = epHealth{
    						Endpoint:        result.Endpoint.Host,
    						Scheme:          result.Endpoint.Scheme,
    						Online:          result.Online,
    						lastOnline:      lastOnline,
    						offlineDuration: offline,
    						lastHCAt:        time.Now(),
    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)
  2. cmd/bootstrap-peer-server.go

    	var clnts []*bootstrapRESTClient
    	for _, ep := range endpointServerPools {
    		for _, endpoint := range ep.Endpoints {
    			if endpoint.IsLocal {
    				continue
    			}
    			if seenClient.Contains(endpoint.Host) {
    				continue
    			}
    			seenClient.Add(endpoint.Host)
    			clnts = append(clnts, &bootstrapRESTClient{gm.Connection(endpoint.GridHost())})
    		}
    	}
    	return clnts
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  3. cmd/endpoint-ellipses.go

    }
    
    // Returns all the expanded endpoints, each argument is expanded separately.
    func (s *endpointSet) getEndpoints() (endpoints []string) {
    	if len(s.endpoints) != 0 {
    		return s.endpoints
    	}
    	for _, argPattern := range s.argPatterns {
    		for _, lbls := range argPattern.Expand() {
    			endpoints = append(endpoints, strings.Join(lbls, ""))
    		}
    	}
    	s.endpoints = endpoints
    	return endpoints
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  4. cmd/kms-handlers.go

    		return
    	}
    
    	status := madmin.KMSStatus{
    		Name:         stat.Name,
    		DefaultKeyID: stat.DefaultKey,
    		Endpoints:    make(map[string]madmin.ItemState, len(stat.Endpoints)),
    	}
    	for _, endpoint := range stat.Endpoints {
    		status.Endpoints[endpoint] = madmin.ItemOnline // TODO(aead): Implement an online check for mTLS
    	}
    
    	resp, err := json.Marshal(status)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  5. cmd/admin-server-info.go

    	network := make(map[string]string)
    	for _, ep := range endpointServerPools {
    		for _, endpoint := range ep.Endpoints {
    			if endpoint.IsLocal {
    				poolNumbers[endpoint.PoolIdx+1] = struct{}{}
    			}
    			nodeName := endpoint.Host
    			if nodeName == "" {
    				nodeName = addr
    			}
    			if endpoint.IsLocal {
    				// Only proceed for local endpoints
    				network[nodeName] = string(madmin.ItemOnline)
    				continue
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.8K bytes
    - Viewed (0)
  6. docs/metrics/prometheus/README.md

    - MinIO exports Prometheus compatible data by default as an authorized endpoint at `/minio/v2/metrics/cluster`. 
    - MinIO exports Prometheus compatible data by default which is bucket centric as an authorized endpoint at `/minio/v2/metrics/bucket`.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 15:49:30 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  7. helm/minio/values.yaml

        interval: ~
        # Scrape timeout, for example `scrapeTimeout: 10s`
        scrapeTimeout: ~
    
    ## ETCD settings: https://github.com/minio/minio/blob/master/docs/sts/etcd.md
    ## Define endpoints to enable this section.
    etcd:
      endpoints: []
      pathPrefix: ""
      corednsPathPrefix: ""
      clientCert: ""
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 10:14:37 GMT 2024
    - 18.4K bytes
    - Viewed (0)
  8. cmd/etcd.go

    var errEtcdUnreachable = errors.New("etcd is unreachable, please check your endpoints")
    
    func etcdErrToErr(err error, etcdEndpoints []string) error {
    	if err == nil {
    		return nil
    	}
    	switch err {
    	case context.DeadlineExceeded:
    		return fmt.Errorf("%w %s", errEtcdUnreachable, etcdEndpoints)
    	default:
    		return fmt.Errorf("unexpected error %w from etcd, please check your endpoints %s", err, etcdEndpoints)
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 2.9K bytes
    - Viewed (0)
  9. internal/kms/kms.go

    type Status struct {
    	Name      string   // The name of the KMS
    	Endpoints []string // A set of the KMS endpoints
    
    	// DefaultKey is the key used when no explicit key ID
    	// is specified. It is empty if the KMS does not support
    	// a default key.
    	DefaultKey string
    
    	// Details provides more details about the KMS endpoint status.
    	// including uptime, version and available CPUs.
    	// Could be more in future.
    	Details kes.State
    }
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  10. cmd/format-erasure.go

    	}
    	wg.Wait()
    }
    
    // Initialize storage disks for each endpoint.
    // Errors are returned for each endpoint with matching index.
    func initStorageDisksWithErrors(endpoints Endpoints, opts storageOpts) ([]StorageAPI, []error) {
    	// Bootstrap disks.
    	storageDisks := make([]StorageAPI, len(endpoints))
    	g := errgroup.WithNErrs(len(endpoints))
    	for index := range endpoints {
    		index := index
    		g.Go(func() (err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
Back to top