- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,302 for deliver (0.92 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
case watch.Deleted: // Don't wrap Object for delete events - these are not to deliver any // events. Only wrap PrevObject. if object, err := newCachingObject(event.PrevObject); err == nil { // Update resource version of the object. // event.PrevObject is used to deliver DELETE watch events and // for them, we set resourceVersion to <current> instead of
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K 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) -
src/syscall/exec_linux.go
childTID uint64 // Where to store child TID, in child's memory (pid_t *) parentTID uint64 // Where to store child TID, in parent's memory (pid_t *) exitSignal uint64 // Signal to deliver to parent on child termination stack uint64 // Pointer to lowest byte of stack stackSize uint64 // Size of stack tls uint64 // Location of new TLS
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 07:45:37 UTC 2024 - 23K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
val doReadTimeout = doReadTimeout() if (doReadTimeout) { readTimeout.enter() } try { if (errorCode != null && !finished) { // Prepare to deliver an error. errorExceptionToDeliver = errorException ?: StreamResetException(errorCode!!) } if (closed) { throw IOException("stream closed")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
// For etcd watch we don't have an easy way to answer whether the watch // has already caught up. So in the initial version (given that watchcache // is by default enabled for all resources but Events), we just deliver // the initialization signal immediately. Improving this will be explored // in the future. utilflowcontrol.WatchInitialized(ctx) return wc, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0) -
src/net/http/transport.go
mu sync.Mutex // protects ctx, done and sending of the result ctx context.Context // context for dial, cleared after delivered or canceled cancelCtx context.CancelFunc done bool // true after delivered or canceled result chan connOrError // channel to deliver connection or error } type connOrError struct { pc *persistConn err error idleAt time.Time }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0)