- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for QueryLastNonce (0.15 sec)
-
pilot/pkg/xds/eventhandler.go
// RegisterEvent notifies the implementer of an xDS ACK, and must be non-blocking RegisterEvent(conID string, eventType EventType, nonce string) RegisterDisconnect(s string, types sets.Set[EventType]) QueryLastNonce(conID string, eventType EventType) (noncePrefix string)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 1.3K bytes - Viewed (0) -
pilot/pkg/xds/debug.go
ProxyID: con.proxy.ID, ClusterVersion: s.getResourceVersion(s.StatusReporter.QueryLastNonce(con.ID(), v3.ClusterType), resourceID, knownVersions), ListenerVersion: s.getResourceVersion(s.StatusReporter.QueryLastNonce(con.ID(), v3.ListenerType), resourceID, knownVersions), RouteVersion: s.getResourceVersion(s.StatusReporter.QueryLastNonce(con.ID(), v3.RouteType), resourceID, knownVersions),
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/status/distribution/reporter.go
} } return res, nil } type distributionEvent struct { conID string distributionType xds.EventType nonce string } func (r *Reporter) QueryLastNonce(conID string, distributionType xds.EventType) (noncePrefix string) { key := GenStatusReporterMapKey(conID, distributionType) r.mu.RLock() defer r.mu.RUnlock() return r.status[key] }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 11.5K bytes - Viewed (0) -
pilot/pkg/xds/ads_test.go
s := xdsfake.NewFakeDiscoveryServer(t, xdsfake.FakeOptions{}) expectNonce := func(nonce, ty string) { t.Helper() assert.EventuallyEqual(t, func() string { return s.Discovery.StatusReporter.QueryLastNonce("test.default-1", ty) }, nonce[:xds.VersionLen]) } ledger := ledger.Make(time.Minute) ledger.Put("key", "value") // If there is no config, ledger would be empty s.Env().SetLedger(ledger)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 30.3K bytes - Viewed (0)