Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 59 for Initial (0.14 sec)

  1. internal/grid/muxclient.go

    func (m *muxClient) RequestStateless(h HandlerID, req []byte, out chan<- Response) {
    	if m.init {
    		out <- Response{Err: errors.New("mux client already used")}
    	}
    	m.init = true
    
    	// Try to grab an initial block.
    	m.singleResp = false
    	msg := message{
    		Op:         OpConnectMux,
    		Handler:    h,
    		Flags:      FlagEOF,
    		Payload:    req,
    		DeadlineMS: uint32(m.deadline.Milliseconds()),
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  2. pilot/pkg/xds/delta.go

    	// 3. Envoy sends CDS request and we respond with clusters.
    	// 4. Envoy detects a change in cluster state and tries to warm those clusters but never sends
    	//    an EDS request for them.
    	// 5. Therefore, any initial CDS request should always trigger an EDS response
    	// 	  to let Envoy finish cluster warming.
    	// Refer to https://github.com/envoyproxy/envoy/issues/13009 for some more details on this type of issues.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  3. pilot/test/xds/fake.go

    	cg.ServiceEntryRegistry.ResyncEDS()
    
    	// Send an update. This ensures that even if there are no configs provided, the push context is
    	// initialized.
    	s.ConfigUpdate(&model.PushRequest{Full: true})
    
    	// Wait until initial updates are committed
    	c := s.InboundUpdates.Load()
    	retry.UntilOrFail(t, func() bool {
    		return s.CommittedUpdates.Load() >= c
    	}, retry.Delay(time.Millisecond))
    
    	// Mark ourselves ready
    	s.CachesSynced()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 16:08:52 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  4. pkg/controlplane/apiserver/options/options_test.go

    		"--audit-webhook-batch-throttle-burst=44",
    		"--audit-webhook-truncate-enabled=true",
    		"--audit-webhook-truncate-max-batch-size=43",
    		"--audit-webhook-truncate-max-event-size=42",
    		"--audit-webhook-initial-backoff=2s",
    		"--audit-webhook-version=audit.k8s.io/v1",
    		"--authentication-token-webhook-cache-ttl=3m",
    		"--authentication-token-webhook-config-file=/token-webhook-config",
    		"--authorization-mode=AlwaysDeny,RBAC",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  5. analysis/analysis-api/src/org/jetbrains/kotlin/analysis/api/types/KtType.kt

         *
         * Types are always expanded to their final form. That is, if we have a chain of type alias expansions, the [KaType] only represents the
         * final expanded type, and its [abbreviatedType] the initial type alias application. For example:
         *
         * ```
         * typealias Inner = String
         * typealias Outer = Inner
         *
         * val outer: Outer = ""
         * ```
         *
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Mon Jun 10 20:18:28 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  6. cmd/kube-apiserver/app/options/options_test.go

    		"--audit-webhook-batch-throttle-burst=44",
    		"--audit-webhook-truncate-enabled=true",
    		"--audit-webhook-truncate-max-batch-size=43",
    		"--audit-webhook-truncate-max-event-size=42",
    		"--audit-webhook-initial-backoff=2s",
    		"--audit-webhook-version=audit.k8s.io/v1",
    		"--authentication-token-webhook-cache-ttl=3m",
    		"--authentication-token-webhook-config-file=/token-webhook-config",
    		"--authorization-mode=AlwaysDeny,RBAC",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  7. cluster/gce/windows/k8s-node-setup.psm1

      Set_CurrentShellEnvironmentVar "POD_CIDR" ${pod_cidr}
    }
    
    # Adds an initial HNS network on the Windows node which forces the creation of
    # a virtual switch and the "management" interface that will be used to
    # communicate with the rest of the Kubernetes cluster without NAT.
    #
    # Note that adding the initial HNS network may cause connectivity to the GCE
    # metadata server to be lost due to a Windows bug.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 21:13:22 UTC 2024
    - 88.3K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go

    			transformer.prefix = []byte(string(transformer.prefix) + " ")
    			return transformer
    		})
    	_, initial := testPropagateStore(ctx, t, store, input)
    	revertTransformer()
    
    	// this update should write the canonical value to etcd because the new serialization differs
    	// from the stored serialization
    	input.ResourceVersion = initial.ResourceVersion
    	out := &example.Pod{}
    	err := store.GuaranteedUpdate(ctx, key, out, true, nil,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 91.4K bytes
    - Viewed (0)
  9. internal/grid/handlers.go

    		Handle StatelessHandlerFn
    		// OutCapacity is the output capacity on the caller.
    		// If <= 0 capacity will be 1.
    		OutCapacity int
    	}
    
    	// StreamHandlerFn must process a request with an optional initial payload.
    	// It must keep consuming from 'in' until it returns.
    	// 'in' and 'out' are independent.
    	// The handler should never close out.
    	// Buffers received from 'in'  can be recycled with PutByteBuffer.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  10. src/cmd/go/internal/modget/get.go

    			// packages imported by the main module does not change, and the query
    			// result for the module containing each such package also does not change
    			// (it is always relative to the initial build list, before applying
    			// queries). So the only way that the result of an "all" query can change
    			// is if some matching package moves from one module in the build list
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 18:26:32 UTC 2024
    - 66.5K bytes
    - Viewed (0)
Back to top