Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 315 for ENDPOINT (0.05 sec)

  1. cmd/erasure.go

    	disks := er.getDisks()
    	endpoints := er.getEndpoints()
    
    	var localDisks []StorageAPI
    	var localEndpoints []Endpoint
    
    	for i, endpoint := range endpoints {
    		if endpoint.IsLocal {
    			localDisks = append(localDisks, disks[i])
    			localEndpoints = append(localEndpoints, endpoint)
    		}
    	}
    
    	return getStorageInfo(localDisks, localEndpoints, metrics)
    }
    
    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/site-replication-metrics.go

    	XferRateLrg *XferStats `json:"largeTransferRate" msg:"lt"`
    	// transfer rate for small uploads
    	XferRateSml *XferStats `json:"smallTransferRate" msg:"st"`
    	// Endpoint is the replication target endpoint
    	Endpoint string `json:"-"`
    	// Secure is true if the replication target endpoint is secure
    	Secure bool `json:"-"`
    }
    
    func (sr *SRStats) update(st replStat, dID string) {
    	sr.lock.Lock()
    	defer sr.lock.Unlock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  3. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/TunnelingUnixSocket.java

      }
    
      @Override public void connect(SocketAddress endpoint) throws IOException {
        this.inetSocketAddress = (InetSocketAddress) endpoint;
        super.connect(new UnixSocketAddress(path), 0);
      }
    
      @Override public void connect(SocketAddress endpoint, int timeout) throws IOException {
        this.inetSocketAddress = (InetSocketAddress) endpoint;
        super.connect(new UnixSocketAddress(path), timeout);
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Feb 12 16:33:52 UTC 2019
    - 1.9K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    type storageRESTClient struct {
    	endpoint   Endpoint
    	restClient *rest.Client
    	gridConn   *grid.Subroute
    	diskID     atomic.Pointer[string]
    
    	diskInfoCache *cachevalue.Cache[DiskInfo]
    }
    
    // Retrieve location indexes.
    func (client *storageRESTClient) GetDiskLoc() (poolIdx, setIdx, diskIdx int) {
    	return client.endpoint.PoolIdx, client.endpoint.SetIdx, client.endpoint.DiskIdx
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  5. cmd/lock-rest-client.go

    	return c.call(ctx, lockRPCForceUnlock, &args)
    }
    
    func newLockAPI(endpoint Endpoint) dsync.NetLocker {
    	if endpoint.IsLocal {
    		return globalLockServer
    	}
    	return newlockRESTClient(endpoint)
    }
    
    // Returns a lock rest client.
    func newlockRESTClient(ep Endpoint) *lockRESTClient {
    	return &lockRESTClient{globalLockGrid.Load().Connection(ep.GridHost())}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  6. docs/site-replication/gen-oidc-sts-cred.go

    	"os"
    
    	cr "github.com/minio/minio-go/v7/pkg/credentials"
    	cmd "github.com/minio/minio/cmd"
    )
    
    func main() {
    	ctx := context.Background()
    
    	endpoint := os.Getenv("MINIO_ENDPOINT")
    	if endpoint == "" {
    		log.Fatalf("Please specify a MinIO server endpoint environment variable like:\n\n\texport MINIO_ENDPOINT=http://localhost:9000")
    	}
    
    	appParams := cmd.OpenIDClientAppParams{
    		ClientID:     "minio-client-app",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 29 01:27:09 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  7. internal/logger/legacy.go

    		return
    	}
    	scfg[config.AuditWebhookSubSys][k] = config.KVS{
    		config.KV{
    			Key:   config.Enable,
    			Value: config.EnableOn,
    		},
    		config.KV{
    			Key:   Endpoint,
    			Value: args.Endpoint.String(),
    		},
    		config.KV{
    			Key:   AuthToken,
    			Value: args.AuthToken,
    		},
    	}
    }
    
    // SetLoggerHTTP helper for migrating older config to newer KV format.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 03 09:47:07 UTC 2023
    - 2K bytes
    - Viewed (0)
  8. internal/logger/target/http/http.go

    	return "minio-http-" + h.config.Name
    }
    
    // Type - returns type of the target
    func (h *Target) Type() types.TargetType {
    	return types.TargetHTTP
    }
    
    // Endpoint returns the backend endpoint
    func (h *Target) Endpoint() string {
    	return h.config.Endpoint.String()
    }
    
    func (h *Target) String() string {
    	return h.config.Name
    }
    
    // IsOnline returns true if the target is reachable using a cached value
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  9. 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`.
    - MinIO exports Prometheus compatible data by default which is node centric as an authorized endpoint at `/minio/v2/metrics/node`.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 12 15:49:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/GeneralRange.java

      }
    
      /**
       * Returns everything above the endpoint relative to the specified comparator, with the specified
       * endpoint behavior.
       */
      static <T extends @Nullable Object> GeneralRange<T> downTo(
          Comparator<? super T> comparator, @ParametricNullness T endpoint, BoundType boundType) {
        return new GeneralRange<>(comparator, true, endpoint, boundType, false, null, OPEN);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 21:19:52 UTC 2024
    - 10.8K bytes
    - Viewed (0)
Back to top