- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 549 for deliver (0.16 sec)
-
tests/integration/security/sds_ingress/ingress_test.go
// verify that TLS connection could establish to deliver HTTPS request. // (2) Rotates key/cert by deleting the secret generated in (1) and // replacing it a new secret with a different server key/cert. // (3) verify that client using older CA cert gets a 404 response // (4) verify that client using the newer CA cert is able to establish TLS connection // to deliver the HTTPS request. func TestSingleTlsGateway_SecretRotation(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 32.7K bytes - Viewed (0) -
src/os/signal/signal_test.go
// have been delivered by the OS. func quiesce() { // The kernel will deliver a signal as a thread returns // from a syscall. If the only active thread is sleeping, // and the system is busy, the kernel may not get around // to waking up a thread to catch the signal. // We try splitting up the sleep to give the kernel // many chances to deliver the signal. start := time.Now()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 15:34:56 UTC 2023 - 27.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher.go
close(c.done) } } func (c *cacheWatcher) nonblockingAdd(event *watchCacheEvent) bool { // if the bookmarkAfterResourceVersion hasn't been seen // we will try to deliver a bookmark event every second. // the following check will discard a bookmark event // if it is < than the bookmarkAfterResourceVersion // so that we don't pollute the input channel
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 12:22:41 UTC 2023 - 18.7K bytes - Viewed (0) -
src/image/jpeg/reader_test.go
f, err := os.Open(filename) if err != nil { return nil, err } defer f.Close() return Decode(f) } type eofReader struct { data []byte // deliver from Read without EOF dataEOF []byte // then deliver from Read with EOF on last chunk lenAtEOF int } func (r *eofReader) Read(b []byte) (n int, err error) { if len(r.data) > 0 { n = copy(b, r.data) r.data = r.data[n:]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 25 00:46:29 UTC 2024 - 24.4K bytes - Viewed (0) -
pkg/kubelet/config/config.go
// PodConfigNotificationSnapshot delivers the full configuration as a SET whenever // any change occurs. PodConfigNotificationSnapshot // PodConfigNotificationSnapshotAndUpdates delivers an UPDATE and DELETE message whenever pods are // changed, and a SET message if there are any additions or removals. PodConfigNotificationSnapshotAndUpdates
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 16.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go
if customReconciler != nil { err = customReconciler(namespace, name, newObj) } select { case reconciledObjects <- copied: case <-ctx.Done(): panic("timed out attempting to deliver reconcile event") } return err } waitForReconcile = func(obj runtime.Object) error { select { case reconciledObj := <-reconciledObjects: if reflect.DeepEqual(obj, reconciledObj) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
var oldest uint64 switch { case w.listResourceVersion > 0 && !w.removedEventSinceRelist: // If no event was removed from the buffer since last relist, the oldest watch // event we can deliver is one greater than the resource version of the list. oldest = w.listResourceVersion + 1 case size > 0: // If the previous condition is not satisfied: either some event was already
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0) -
internal/grid/muxclient.go
// Spawn simple disconnect if requests == nil { go m.handleOneWayStream(responseCh, responses) return &Stream{responses: responseCh, Requests: nil, ctx: m.ctx, cancel: m.cancelFn, muxID: m.MuxID}, nil } // Deliver responses and send unblocks back to the server. go m.handleTwowayResponses(responseCh, responses) go m.handleTwowayRequests(responses, requests)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
src/regexp/regexp.go
n := (1 + re.numSubexp) * 2 for len(a) < n { a = append(a, -1) } return a } // allMatches calls deliver at most n times // with the location of successive matches in the input text. // The input text is b if non-nil, otherwise s. func (re *Regexp) allMatches(s string, b []byte, n int, deliver func([]int)) { var end int if b == nil { end = len(s) } else { end = len(b) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 20:50:01 UTC 2024 - 38.5K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_traffic_policy.go
// where multiple endpoints in a cluster are terminated. In these scenarios the circuit breaker can kick // in before Pilot is able to deliver an updated endpoint list to Envoy, leading to client-facing 503s. MaxRetries: &wrapperspb.UInt32Value{Value: math.MaxUint32}, MaxRequests: &wrapperspb.UInt32Value{Value: math.MaxUint32},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 23 05:38:57 UTC 2024 - 20K bytes - Viewed (0)