- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 77 for requestKind (0.29 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress.go
utilruntime "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/klog/v2" "k8s.io/utils/clock" ) const ( // progressRequestPeriod determines period of requesting progress // from etcd when there is a request waiting for watch cache to be fresh. progressRequestPeriod = 100 * time.Millisecond )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 09:56:38 UTC 2024 - 3K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r86/ModelStreamingBuildAction.java
EclipseProject eclipseProject = controller.getModel(EclipseProject.class); GradleProject gradleProject = controller.getModel(GradleProject.class); // Intentionally sending models in an order different from requesting models controller.send(gradleProject); controller.send(eclipseProject); return new CustomModel(42); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 05 08:55:56 UTC 2024 - 1.3K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/isolated/ModelStreamingBuildAction.java
EclipseProject eclipseProject = controller.getModel(EclipseProject.class); GradleProject gradleProject = controller.getModel(GradleProject.class); // Intentionally sending models in an order different from requesting models controller.send(gradleProject); controller.send(eclipseProject); return new CustomModel(42); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/daemon-protocol/src/main/java/org/gradle/launcher/daemon/protocol/Command.java
* limitations under the License. */ package org.gradle.launcher.daemon.protocol; import java.io.Serializable; import java.util.UUID; /** * Represents the initial message sent to the daemon, requesting that the daemon do some work. */ public class Command extends Message implements Serializable { private final UUID identifier; private final byte[] token; public Command(UUID identifier, byte[] token) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 04:50:46 UTC 2024 - 1.5K bytes - Viewed (0) -
pkg/config/mesh/mesh.go
ph := proxyConfig.ProxyHeaders if ph != nil && orig != nil { ph.ForwardedClientCert = ptr.NonEmptyOrDefault(ph.ForwardedClientCert, orig.ForwardedClientCert) ph.RequestId = ptr.NonEmptyOrDefault(ph.RequestId, orig.RequestId) ph.AttemptCount = ptr.NonEmptyOrDefault(ph.AttemptCount, orig.AttemptCount) ph.Server = ptr.NonEmptyOrDefault(ph.Server, orig.Server)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 12K bytes - Viewed (0) -
tensorflow/cc/training/coordinator.cc
// TODO(yuefengz): deal with stragglers. { mutex_lock l(mu_); if (!should_stop_) { return Status(absl::StatusCode::kFailedPrecondition, "Joining coordinator without requesting to stop."); } } { mutex_lock l(runners_lock_); for (const auto& t : runners_) { ReportStatus(t->Join()); } runners_.clear(); } return GetStatus(); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 3.2K bytes - Viewed (0) -
internal/logger/message/audit/entry.go
entry.ReqQuery = reqQuery reqHeader := make(map[string]string, len(r.Header)) for k, v := range r.Header { reqHeader[k] = strings.Join(v, ",") } entry.ReqHeader = reqHeader wh := w.Header() entry.RequestID = wh.Get(xhttp.AmzRequestID) respHeader := make(map[string]string, len(wh)) for k, v := range wh { respHeader[k] = strings.Join(v, ",") } entry.RespHeader = respHeader
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.2K bytes - Viewed (0) -
internal/logger/logger.go
VersionID: ov.VersionID, }) } entry := log.Entry{ DeploymentID: deploymentID, Level: logKind, RemoteHost: req.RemoteHost, Host: req.Host, RequestID: req.RequestID, UserAgent: req.UserAgent, Time: time.Now().UTC(), API: &log.API{ Name: API, Args: &log.Args{ Bucket: req.BucketName, Object: req.ObjectName,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 12.4K bytes - Viewed (0) -
cmd/sts-handlers.go
}, UpdatedAt: updatedAt, })) } assumeRoleResponse := &AssumeRoleResponse{ Result: AssumeRoleResult{ Credentials: cred, }, } assumeRoleResponse.ResponseMetadata.RequestID = w.Header().Get(xhttp.AmzRequestID) writeSuccessResponseXML(w, encodeResponse(assumeRoleResponse)) } func (sts *stsAPIHandlers) AssumeRoleWithSSO(w http.ResponseWriter, r *http.Request) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 33.9K bytes - Viewed (0) -
platforms/software/build-init/src/test/groovy/org/gradle/buildinit/tasks/InitBuildSpec.groovy
when: def version = init.getJavaLanguageVersion(userQuestions, buildInitializer) then: version.asInt() == 11 } def "gets useful error when requesting invalid Java target"() { given: def userQuestions = Mock(UserQuestions) def buildInitializer = Mock(BuildInitializer) buildInitializer.supportsJavaTargets() >> true
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 08 20:10:43 UTC 2024 - 12.8K bytes - Viewed (0)