- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 216 for strnames (0.19 sec)
-
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/models/ProjectStateStore.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.cc.impl.models import org.gradle.cache.internal.streams.BlockAddress import org.gradle.cache.internal.streams.ValueStore import org.gradle.internal.cc.impl.CheckedFingerprint import org.gradle.internal.cc.impl.ConfigurationCacheStateStore import org.gradle.internal.cc.impl.StateType
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 6.3K bytes - Viewed (0) -
pilot/pkg/xds/ads_test.go
switch c.ev { case model.EventAdd: if len(c.svcIndexes) > 0 { addService(c.ns, c.svcIndexes...) } if len(c.svcNames) > 0 { addServiceByNames(c.ns, c.svcNames...) } if len(c.instIndexes) > 0 { for _, instIndex := range c.instIndexes { addServiceInstance(host.Name(instIndex.name), instIndex.indexes...) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 30.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/secure_serving.go
// use the overridden concurrent streams setting or make the default of 250 explicit so we can size MaxUploadBufferPerConnection appropriately if s.HTTP2MaxStreamsPerConnection > 0 { http2Options.MaxConcurrentStreams = uint32(s.HTTP2MaxStreamsPerConnection) } else { // match http2.initialMaxConcurrentStreams used by clients // this makes it so that a malicious client can only open 400 streams before we forcibly close the connection
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 10.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableListMultimap.java
* Returns a {@link Collector} that accumulates elements into an {@code ImmutableListMultimap} * whose keys and values are the result of applying the provided mapping functions to the input * elements. * * <p>For streams with defined encounter order (as defined in the Ordering section of the {@link * java.util.stream} Javadoc), that order is preserved, but entries are <a * href="ImmutableMultimap.html#iteration">grouped by key</a>. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sun Jun 02 13:36:19 UTC 2024 - 17.5K bytes - Viewed (0) -
platforms/jvm/plugins-groovy/src/main/java/org/gradle/api/tasks/GroovyRuntime.java
} } }; } private static List<File> collectJarsFromClasspath(Iterable<File> classpath, Set<String> jarNames) { return stream(classpath.spliterator(), false) .filter(file -> jarNames.contains(file.getName())) .collect(toList()); } private static Set<String> groovyJarNamesFor(VersionNumber groovyVersion) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 12 18:44:49 UTC 2023 - 9.4K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
// item in this list nevertheless constitutes user error. setNames := []string{} for _, s := range sets { setNames = append(setNames, s.Name) } utilruntime.HandleError( fmt.Errorf( "user error: more than one StatefulSet is selecting pods with labels: %+v. Sets: %v", pod.Labels, setNames)) } return sets }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
platforms/software/security/src/main/java/org/gradle/plugins/signing/signatory/Signatory.java
*/ @Internal String getName(); /** * Exhausts {@code toSign}, and writes the signature to {@code signatureDestination}. The caller is responsible for closing the streams, though the output WILL be flushed. * * @param toSign The source of the data to be signed * @param destination Where the signature will be written to */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Oct 11 12:16:09 UTC 2023 - 1.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/ExchangeCodec.kt
interface ExchangeCodec { /** The connection or CONNECT tunnel that owns this codec. */ val carrier: Carrier /** Returns an output stream where the request body can be streamed. */ @Throws(IOException::class) fun createRequestBody( request: Request, contentLength: Long, ): Sink /** This should update the HTTP engine's sentRequestMillis field. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3K bytes - Viewed (0) -
analysis/analysis-api-standalone/tests/org/jetbrains/kotlin/analysis/api/standalone/fir/test/cases/session/builder/sessionBuilderTestUtils.kt
import java.nio.file.Path import java.nio.file.Paths import java.time.LocalDateTime import java.time.ZoneOffset import kotlin.io.path.absolutePathString import kotlin.io.path.extension import kotlin.streams.asSequence internal fun testDataPath(path: String): Path { return Paths.get("analysis/analysis-api-standalone/testData/sessionBuilder").resolve(path) } fun KtCallExpression.assertIsCallOf(callableId: CallableId) {
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed Jun 05 16:16:39 UTC 2024 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/doc.go
// which is sent as the first byte of the message. The second byte is the channel // id. This CLOSE signal is handled by the websocket server by closing the stream, // allowing the other streams to complete transmission if necessary, and gracefully // shutdown the connection. // // Example client session: // // CONNECT http://server.com with subprotocol "v5.channel.k8s.io"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 05 18:37:18 UTC 2023 - 2.9K bytes - Viewed (0)