- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for IsProgressNotify (0.32 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/event.go
) type event struct { key string value []byte prevValue []byte rev int64 isDeleted bool isCreated bool isProgressNotify bool // isInitialEventsEndBookmark helps us keep track // of whether we have sent an annotated bookmark event. // // when this variable is set to true, // a special annotation will be added
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
err := wres.Err() // If there is an error on server (e.g. compaction), the channel will return it before closed. logWatchChannelErr(err) wc.sendError(err) return } if wres.IsProgressNotify() { wc.sendEvent(progressNotifyEvent(wres.Header.GetRevision())) metrics.RecordEtcdBookmark(wc.watcher.groupResource.String()) continue } for _, e := range wres.Events {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0)