Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 831 for Initial (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. platforms/software/version-control/src/integTest/groovy/org/gradle/vcs/internal/AbstractSourceDependencyMultiprojectIntegrationTest.groovy

            buildB.buildFile << """
                allprojects {
                    apply plugin: 'java'
                    group = 'org.test'
                    version = '1.0'
                }
            """
            repo.commit('initial')
            buildFile << """
                apply plugin: 'base'
    
                repositories { maven { url "${mavenRepo.uri}" } }
    
                configurations {
                    conf
                }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 02 20:50:18 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  10. 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)
Back to top