- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 315 for ENDPOINT (0.1 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)