- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 357 for ENDPOINT (0.07 sec)
-
common-protos/k8s.io/api/admissionregistration/v1beta1/generated.proto
repeated k8s.io.api.admissionregistration.v1.RuleWithOperations rules = 3; // FailurePolicy defines how unrecognized errors from the admission endpoint are handled - // allowed values are Ignore or Fail. Defaults to Ignore. // +optional optional string failurePolicy = 4; // matchPolicy defines how the "rules" list is used to match incoming requests.
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 22.6K bytes - Viewed (0) -
architecture/networking/pilot.md
Requests come from the client specifically asking for a set of resources. This could be requesting the initial set of resources on a new connection, or from a new dependency. For example, a push of `Cluster X` referencing `Endpoint Y` may lead to a request for `Endpoint Y` if it is not already known to the client.
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Feb 07 17:53:24 UTC 2024 - 19.1K bytes - Viewed (0) -
guava/src/com/google/common/graph/ImmutableGraph.java
* <p>If this graph is directed, {@code endpoints} must be ordered. * * <p>If either or both endpoints are not already present in this graph, this method will * silently {@link #addNode(Object) add} each missing endpoint to the graph. * * @return this {@code Builder} object * @throws IllegalArgumentException if the introduction of the edge would violate {@link * #allowsSelfLoops()}
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Feb 01 16:30:37 UTC 2022 - 7.1K bytes - Viewed (0) -
cmd/format-erasure.go
continue } wg.Add(1) go func(disk StorageAPI) { defer wg.Done() disk.Close() }(disk) } 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))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 23.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallKotlinTest.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 8.4K bytes - Viewed (0) -
internal/config/lambda/parse.go
} clientKeyEnv := target.EnvWebhookClientKey if k != config.Default { clientKeyEnv = clientKeyEnv + config.Default + k } webhookArgs := target.WebhookArgs{ Enable: enabled, Endpoint: *url, Transport: transport, AuthToken: env.Get(authEnv, kv.Get(target.WebhookAuthToken)), ClientCert: env.Get(clientCertEnv, kv.Get(target.WebhookClientCert)),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
guava/src/com/google/common/graph/ValueGraph.java
* by {@code endpoints}), if one is present; otherwise, returns {@code Optional.empty()}. * * <p>If this graph is directed, the endpoints must be ordered. * * @throws IllegalArgumentException if either endpoint is not an element of this graph * @throws IllegalArgumentException if the endpoints are unordered and the graph is directed * @since 27.1 */ Optional<V> edgeValue(EndpointPair<N> endpoints); /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 10 15:41:27 UTC 2024 - 16K bytes - Viewed (0) -
cmd/admin-handlers-site-replication.go
opts.EnableILMExpiryReplication = r.Form.Get("enableILMExpiryReplication") == "true" return } // SRPeerEdit - PUT /minio/admin/v3/site-replication/peer/edit // // used internally to tell current cluster to update endpoint for peer func (a adminAPIHandlers) SRPeerEdit(w http.ResponseWriter, r *http.Request) { ctx := r.Context() objectAPI, _ := validateAdminReq(ctx, w, r, policy.SiteReplicationAddAction) if objectAPI == nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.4K bytes - Viewed (0) -
cmd/warm-backend-azure.go
} return nil } func (conf azureConf) NewClient() (clnt *azblob.Client, clntErr error) { if err := conf.Validate(); err != nil { return nil, err } ep := conf.Endpoint if ep == "" { ep = fmt.Sprintf("https://%s.blob.core.windows.net", conf.AccountName) } if conf.IsSPEnabled() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 7K bytes - Viewed (0) -
cmd/bucket-replication.go
} } // if checked bucket, then check the ready is unnecessary if !opts.CheckRemoteBucket && opts.CheckReady { endpoint := clnt.EndpointURL().String() if errInt, ok := opts.checkReadyErr.Load(endpoint); !ok { err = checkRemoteEndpoint(ctx, clnt.EndpointURL()) opts.checkReadyErr.Store(endpoint, err) } else { if errInt == nil { err = nil } else { err = errInt.(error) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 06:49:55 UTC 2024 - 116.1K bytes - Viewed (0)