- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 154 for strnames (0.15 sec)
-
platforms/core-runtime/logging/src/integTest/groovy/org/gradle/internal/logging/console/jvm/AbstractConsoleJvmTestLoggingFunctionalTest.groovy
then: def taskOutput = getTaskOutput(result) matchesTaskOutput(taskOutput, testLogEventRegex(TestLogEvent.STARTED.consoleMarker)) } def "can group standard output streams with task if configured"() { given: buildFile << testLoggingStandardStream() file(JAVA_TEST_FILE_PATH) << javaTestClass { """ System.out.println("standard output");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 14:21:18 UTC 2024 - 8.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go
// justQueueStream skips the usual stream validation before // queueing the stream on the stream channel. func justQueueStream(streams chan httpstream.Stream) func(httpstream.Stream, <-chan struct{}) error { return func(stream httpstream.Stream, replySent <-chan struct{}) error { streams <- stream return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 02:21:50 UTC 2024 - 22.7K bytes - Viewed (0) -
pkg/kubeapiserver/options/authentication.go
"the authentication documentation for further details.") fs.StringVar(&o.OIDC.UsernamePrefix, oidcUsernamePrefixFlag, "", ""+ "If provided, all usernames will be prefixed with this value. If not provided, "+ "username claims other than 'email' are prefixed by the issuer URL to avoid "+ "clashes. To skip any prefixing, provide the value '-'.")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 22:40:22 UTC 2024 - 32.4K bytes - Viewed (0) -
subprojects/core-api/src/main/java/org/gradle/api/provider/ProviderFactory.java
* configuration model. Consequent builds will re-execute the process to obtain the output and * check if the cached model is still up-to-date. * * The process input and output streams cannot be configured. * * * @param action the configuration of the external process with the output stream * pre-configured. * @return an interface that allows lazy access to the process' output.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 09:14:21 UTC 2024 - 13.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableSortedMultiset.java
* * @since 33.2.0 (available since 21.0 in guava-jre) */ @SuppressWarnings({"AndroidJdkLibsChecker", "Java7ApiChecker"}) @IgnoreJRERequirement // Users will use this only if they're already using streams. public static <E> Collector<E, ?, ImmutableSortedMultiset<E>> toImmutableSortedMultiset( Comparator<? super E> comparator) { return toImmutableSortedMultiset(comparator, Function.identity(), e -> 1); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sun Jun 02 13:36:19 UTC 2024 - 35.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
client.listener.assertTextMessage(message) } /** One peer's streams, listener, and web socket in the test. */ private class TestStreams( client: Boolean, private val taskFaker: TaskFaker, private val sourcePipe: Pipe, private val sinkPipe: Pipe, ) : RealWebSocket.Streams(client, sourcePipe.source.buffer(), sinkPipe.sink.buffer()) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 01:59:58 UTC 2024 - 18.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/serving.go
"Examples: \"example.crt,example.key\" or \"foo.crt,foo.key:*.foo.com,foo.com\".") fs.IntVar(&s.HTTP2MaxStreamsPerConnection, "http2-max-streams-per-connection", s.HTTP2MaxStreamsPerConnection, ""+ "The limit that the server gives to clients for "+ "the maximum number of streams in an HTTP/2 connection. "+ "Zero means to use golang's default.") fs.BoolVar(&s.PermitPortSharing, "permit-port-sharing", s.PermitPortSharing,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 13:08:18 UTC 2024 - 15.9K bytes - Viewed (0) -
cmd/site-replication.go
var rmvEndpoints []string siteNames := rreq.SiteNames updatedPeers := make(map[string]madmin.PeerInfo) for _, pi := range info.Sites { updatedPeers[pi.DeploymentID] = pi peerMap[pi.Name] = pi if rreq.RemoveAll { siteNames = append(siteNames, pi.Name) } } for _, s := range siteNames { pinfo, ok := peerMap[s] if !ok {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
pkg/controlplane/apiserver/options/options_test.go
"--enable-logs-handler=false", "--etcd-keyfile=/var/run/kubernetes/etcd.key", "--etcd-certfile=/var/run/kubernetes/etcdce.crt", "--etcd-cafile=/var/run/kubernetes/etcdca.crt", "--http2-max-streams-per-connection=42", "--tracing-config-file=/var/run/kubernetes/tracing_config.yaml", "--proxy-client-cert-file=/var/run/kubernetes/proxy.crt", "--proxy-client-key-file=/var/run/kubernetes/proxy.key",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 10.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zerrors_linux_386.go
{57, "EBADSLT", "invalid slot"}, {59, "EBFONT", "bad font file format"}, {60, "ENOSTR", "device not a stream"}, {61, "ENODATA", "no data available"}, {62, "ETIME", "timer expired"}, {63, "ENOSR", "out of streams resources"}, {64, "ENONET", "machine is not on the network"}, {65, "ENOPKG", "package not installed"}, {66, "EREMOTE", "object is remote"}, {67, "ENOLINK", "link has been severed"}, {68, "EADV", "advertise error"},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 34.2K bytes - Viewed (0)