Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 15 of 15 for runOnce (0.17 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_serving_content.go

    	klog.V(2).InfoS("Loaded a new cert/key pair", "name", c.Name())
    
    	for _, listener := range c.listeners {
    		listener.Enqueue()
    	}
    
    	return nil
    }
    
    // RunOnce runs a single sync loop
    func (c *DynamicCertKeyPairContent) RunOnce(ctx context.Context) error {
    	return c.loadCertKeyPair()
    }
    
    // Run starts the controller and blocks until context is killed.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go

    	if !ok {
    		return true
    	}
    	if !bytes.Equal(existing.caBundle, caBundle) {
    		return true
    	}
    
    	return false
    }
    
    // RunOnce runs a single sync loop
    func (c *ConfigMapCAController) RunOnce(ctx context.Context) error {
    	// Ignore the error when running once because when using a dynamically loaded ca file, because we think it's better to have nothing for
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

        tcpConnectsInFlight += plan
        val taskName = "$okHttpName connect ${routePlanner.address.url.redact()}"
        taskRunner.newQueue().schedule(
          object : Task(taskName) {
            override fun runOnce(): Long {
              val connectResult =
                try {
                  plan.connectTcp()
                } catch (e: Throwable) {
                  ConnectResult(plan, throwable = e)
                }
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/server_test.go

    		&nullCAContent{name: "client-ca"},
    		defaultCertProvider,
    		sniCerts,
    		nil, // TODO see how to plumb an event recorder down in here. For now this results in simply klog messages.
    	)
    	if err := dynamicCertificateController.RunOnce(); err != nil {
    		t.Fatal(err)
    	}
    	tlsConfig.GetConfigForClient = dynamicCertificateController.GetConfigForClient
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 12 18:29:15 UTC 2021
    - 6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller_test.go

    			// test data
    			target := newDefaultTarget()
    			fakeKubeClient := fake.NewSimpleClientset(scenario.cm)
    			target.client = fakeKubeClient
    
    			// act
    			ctx := context.TODO()
    			err := target.RunOnce(ctx)
    
    			if err != nil && !scenario.expectErr {
    				t.Errorf("got unexpected error %v", err)
    			}
    			if err == nil && scenario.expectErr {
    				t.Error("expected an error but didn't get one")
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 07 14:37:01 UTC 2022
    - 9.3K bytes
    - Viewed (0)
Back to top