Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 39 of 39 for Informer (0.14 sec)

  1. pkg/proxy/nftables/proxier.go

    	// Update healthz timestamp at beginning in case Sync() never succeeds.
    	if proxier.healthzServer != nil {
    		proxier.healthzServer.Updated(proxier.ipFamily)
    	}
    
    	// synthesize "last change queued" time as the informers are syncing.
    	metrics.SyncProxyRulesLastQueuedTimestamp.SetToCurrentTime()
    	proxier.syncRunner.Loop(wait.NeverStop)
    }
    
    func (proxier *Proxier) setInitialized(value bool) {
    	var initialized int32
    	if value {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  2. pkg/proxy/iptables/proxier.go

    	// Update healthz timestamp at beginning in case Sync() never succeeds.
    	if proxier.healthzServer != nil {
    		proxier.healthzServer.Updated(proxier.ipFamily)
    	}
    
    	// synthesize "last change queued" time as the informers are syncing.
    	metrics.SyncProxyRulesLastQueuedTimestamp.SetToCurrentTime()
    	proxier.syncRunner.Loop(wait.NeverStop)
    }
    
    func (proxier *Proxier) setInitialized(value bool) {
    	var initialized int32
    	if value {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  3. src/net/http/request.go

    	if value != "" {
    		return value
    	}
    	return def
    }
    
    // NOTE: This is not intended to reflect the actual Go version being used.
    // It was changed at the time of Go 1.1 release because the former User-Agent
    // had ended up blocked by some intrusion detection systems.
    // See https://codereview.appspot.com/7532043.
    const defaultUserAgent = "Go-http-client/1.1"
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 49.4K bytes
    - Viewed (0)
  4. src/crypto/tls/conn.go

    	handshakeCtx, cancel := context.WithCancel(ctx)
    	// Note: defer this before starting the "interrupter" goroutine
    	// so that we can tell the difference between the input being canceled and
    	// this cancellation. In the former case, we need to close the connection.
    	defer cancel()
    
    	if c.quic != nil {
    		c.quic.cancelc = handshakeCtx.Done()
    		c.quic.cancel = cancel
    	} else if ctx.Done() != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  5. pkg/proxy/ipvs/proxier.go

    	// Update healthz timestamp at beginning in case Sync() never succeeds.
    	if proxier.healthzServer != nil {
    		proxier.healthzServer.Updated(proxier.ipFamily)
    	}
    	// synthesize "last change queued" time as the informers are syncing.
    	metrics.SyncProxyRulesLastQueuedTimestamp.SetToCurrentTime()
    	proxier.syncRunner.Loop(wait.NeverStop)
    }
    
    func (proxier *Proxier) setInitialized(value bool) {
    	var initialized int32
    	if value {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  6. src/runtime/mgcpacer.go

    		// persistent accounting error, we'll deadlock here.
    	}
    
    	// Below we compute a goal from memoryLimit. There are a few things to be aware of.
    	// Firstly, the memoryLimit does not easily compare to the heap goal: the former
    	// is total mapped memory by the runtime that hasn't been released, while the latter is
    	// only heap object memory. Intuitively, the way we convert from one to the other is to
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 55.4K bytes
    - Viewed (0)
  7. cmd/admin-handlers-users.go

    		for attribKey, attribValue := range lookupResult.Attributes {
    			opts.claims[ldapAttribPrefix+attribKey] = attribValue
    		}
    
    		// NOTE: if not using LDAP, then internal IDP or open ID is
    		// being used - in the former, group info is enforced when
    		// generated credentials are used to make requests, and in the
    		// latter, a group notion is not supported.
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue May 28 17:19:04 UTC 2024
    - 78.6K bytes
    - Viewed (0)
  8. testing/performance/src/templates/native-dependents-resources/googleTest/libs/googleTest/1.7.0/include/gtest/gtest.h

    //   strings by content, use {ASSERT|EXPECT}_STR*().
    //
    //   3. {ASSERT|EXPECT}_EQ(expected, actual) is preferred to
    //   {ASSERT|EXPECT}_TRUE(expected == actual), as the former tells you
    //   what the actual value is when it fails, and similarly for the
    //   other comparisons.
    //
    //   4. Do not depend on the order in which {ASSERT|EXPECT}_??()
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 86.4K bytes
    - Viewed (0)
  9. platforms/documentation/docs/src/docs/userguide/releases/upgrading/upgrading_version_7.adoc

    Previously, `outputLocation` returned a value of type `Provider<? extends FileSystemLocation>`.
    
    This change makes the Report API more internally consistent, and allows for more idiomatic configuration of reporting tasks.
    
    The former, now `@Deprecated` usage:
    
    ```groovy
    tasks.named('test') {
        reports.junitXml.setDestination(layout.buildDirectory.file('reports/my-report-old').get().asFile) // DEPRECATED
    }
    
    ```
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Apr 01 15:00:23 UTC 2024
    - 87.7K bytes
    - Viewed (0)
Back to top