- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,037 for syncAt (0.12 sec)
-
pilot/pkg/xds/debug.go
return false } userIP, _ := netip.ParseAddr(ip) return userIP.IsLoopback() } // Syncz dumps the synchronization status of all Envoys connected to this Pilot instance func (s *DiscoveryServer) Syncz(w http.ResponseWriter, req *http.Request) { namespace := req.URL.Query().Get("namespace") syncz := make([]SyncStatus, 0) for _, con := range s.SortedClients() { node := con.proxy
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0) -
pilot/pkg/config/memory/controller.go
func (c *Controller) RegisterEventHandler(kind config.GroupVersionKind, f model.EventHandler) { c.monitor.AppendEventHandler(kind, f) } // HasSynced return whether store has synced // It can be controlled externally (such as by the data source), // otherwise it'll always consider synced. func (c *Controller) HasSynced() bool { if c.hasSynced != nil { return c.hasSynced() } return true } func (c *Controller) Run(stop <-chan struct{}) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 26 13:54:32 UTC 2023 - 4.7K bytes - Viewed (0) -
pkg/kube/multicluster/cluster.go
switch a { case Add: return "Add" case Update: return "Update" } return "Unknown" } // Run starts the cluster's informers and waits for caches to sync. Once caches are synced, we mark the cluster synced. // This should be called after each of the handlers have registered informers, and should be run in a goroutine. func (c *Cluster) Run(mesh mesh.Watcher, handlers []handler, action ACTION) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 3.8K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/options_test.go
"--concurrent-deployment-syncs=10", "--concurrent-horizontal-pod-autoscaler-syncs=10", "--concurrent-statefulset-syncs=15", "--concurrent-endpoint-syncs=10", "--concurrent-ephemeralvolume-syncs=10", "--concurrent-service-endpoint-syncs=10", "--concurrent-gc-syncs=30", "--concurrent-namespace-syncs=20", "--concurrent-job-syncs=10", "--concurrent-cron-job-syncs=10", "--concurrent-replicaset-syncs=10",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 02:59:09 UTC 2024 - 55.1K bytes - Viewed (0) -
src/internal/trace/summary.go
name string } // Event feeds a single event into the stats summarizer. func (s *Summarizer) Event(ev *Event) { if s.syncTs == 0 { s.syncTs = ev.Time() } s.lastTs = ev.Time() switch ev.Kind() { // Record sync time for the RangeActive events. case EventSync: s.syncTs = ev.Time() // Handle state transitions. case EventStateTransition: st := ev.StateTransition()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 20.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/internalversion/types.go
// and the bookmark event is send when the state is synced // to a `resourceVersion` at least as fresh as the one provided by the ListOptions. // If `resourceVersion` is unset, this is interpreted as "consistent read" and the // bookmark event is send when the state is synced at least to the moment // when request started being processed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 01 09:55:40 UTC 2023 - 4.5K bytes - Viewed (0) -
hack/_update-generated-proto-bindings-dockerized.sh
if [ "$#" == 0 ]; then echo "usage: $0 <api_dir>..." exit 1 fi kube::protoc::check_protoc for api; do # This can't use `git ls-files` because it runs in a container without the # .git dir synced. protos=() kube::util::read-array protos < <( \ find "${api}" -type f -name "api.proto") if [ "${#protos[@]}" == 0 ]; then echo "ERROR: no 'api.proto' files under '${api}'" exit 1
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:07:04 UTC 2024 - 1.5K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/hpacontroller.go
fs.DurationVar(&o.HorizontalPodAutoscalerSyncPeriod.Duration, "horizontal-pod-autoscaler-sync-period", o.HorizontalPodAutoscalerSyncPeriod.Duration, "The period for syncing...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun May 19 09:49:23 UTC 2024 - 3.8K bytes - Viewed (0) -
cmd/metrics-v3-cluster-iam.go
syncFailuresMD = NewCounterMD(syncFailures, "Number of failed IAM data syncs since server start.") syncSuccessesMD = NewCounterMD(syncSuccesses, "Number of successful IAM data syncs since server start.") ) // loadClusterIAMMetrics - `MetricsLoaderFn` for cluster IAM metrics.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 02 08:20:42 UTC 2024 - 4.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go
See the License for the specific language governing permissions and limitations under the License. */ package generic import ( "context" goerrors "errors" "fmt" "sync" "sync/atomic" "time" corev1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/errors" "k8s.io/apimachinery/pkg/api/meta" "k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/runtime"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 23:07:34 UTC 2024 - 15.2K bytes - Viewed (0)