- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 831 for Initial (0.2 sec)
-
pkg/kube/krt/singleton.go
func (d dummyValue) ResourceName() string { return "" } type StaticSingleton[T any] interface { Singleton[T] Set(*T) } func NewStatic[T any](initial *T) StaticSingleton[T] { val := new(atomic.Pointer[T]) val.Store(initial) x := &static[T]{ val: val, id: nextUID(), eventHandlers: &handlers[T]{}, } return collectionAdapter[T]{x} }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 4.2K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
name string invariants func(set *apps.StatefulSet, om *fakeObjectManager) error initial func() *apps.StatefulSet update func(set *apps.StatefulSet) *apps.StatefulSet validate func(set *apps.StatefulSet, pods []*v1.Pod) error } testFn := func(test *testcase, t *testing.T) { set := test.initial() client := fake.NewSimpleClientset(set) om, _, ssc := setupController(client)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/util.go
} return uint64(currentResourceVersion), nil } // AnnotateInitialEventsEndBookmark adds a special annotation to the given object // which indicates that the initial events have been sent. // // Note that this function assumes that the obj's annotation // field is a reference type (i.e. a map). func AnnotateInitialEventsEndBookmark(obj runtime.Object) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:05:06 UTC 2024 - 4.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/StaleDaemonAddressException.java
* limitations under the License. */ package org.gradle.launcher.daemon.client; /** * Thrown when connected to a stale daemon address. * * This is thrown instead of using an initial handshake on the connection, to avoid the latency of a round trip to the * daemon before starting the build. */ public class StaleDaemonAddressException extends DaemonConnectionException {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1K bytes - Viewed (0) -
samples/bookinfo/src/productpage/templates/index.html
{% block metas %} <meta charset="utf-8"> <meta http-equiv="X-UA-Compatible" content="IE=edge"> <meta name="viewport" content="width=device-width, initial-scale=1"> {% endblock %} {% block styles %} <style> table { color: #333; background: white; border: 1px solid grey; font-size: 12pt; border-collapse: collapse; width: 100%; } table thead th, table tfoot th {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 14:48:01 UTC 2024 - 1.5K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/ManualEvictionInMemoryCache.java
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.function.Function; public class ManualEvictionInMemoryCache<K, V> implements Cache<K, V> { // Use 256 as initial size to start out with enough concurrency. private final ConcurrentMap<K, V> map = new ConcurrentHashMap<>(256); @Override public V get(K key, Function<? super K, ? extends V> factory) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 1.5K bytes - Viewed (0) -
pkg/kubeapiserver/authorizer/reload.go
switch configuredAuthorizer.Type { case authzconfig.AuthorizerType(modes.ModeNode): if r.nodeAuthorizer == nil { return nil, nil, fmt.Errorf("authorizer type Node is not allowed if it was not enabled at initial server startup") } authorizers = append(authorizers, authorizationmetrics.InstrumentedAuthorizer(string(configuredAuthorizer.Type), configuredAuthorizer.Name, r.nodeAuthorizer))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:01:15 UTC 2024 - 9.3K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/BootstrapDns.kt
*/ package okhttp3.dnsoverhttps import java.net.InetAddress import java.net.UnknownHostException import okhttp3.Dns /** * Internal Bootstrap DNS implementation for handling initial connection to DNS over HTTPS server. * * Returns hardcoded results for the known host. */ internal class BootstrapDns( private val dnsHostname: String, private val dnsServers: List<InetAddress>, ) : Dns {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.3K bytes - Viewed (0) -
platforms/software/version-control/src/integTest/groovy/org/gradle/vcs/internal/AbstractSourceDependencyMultiprojectIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 02 20:50:18 UTC 2024 - 8.1K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/filelock/LockStateSerializer.java
* single byte that describes the version. * an implementation protocol should increment the value when protocol changes in an incompatible way */ byte getVersion(); /** * Returns the initial state for a lock file with this format. */ LockState createInitialState(); /** * writes the state data */ void write(DataOutput lockFileAccess, LockState lockState) throws IOException;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 1.4K bytes - Viewed (0)