MCPcopy
hub / github.com/cilium/cilium / Watch

Method Watch

pkg/allocator/allocator.go:1091–1091  ·  view source on GitHub ↗
(ctx context.Context, onSync func(context.Context))

Source from the content-addressed store, hash-verified

1089 NumEntries() int
1090 Synced() bool
1091 Watch(ctx context.Context, onSync func(context.Context))
1092}
1093
1094func (a *Allocator) NewRemoteCache(remoteName string, remoteAlloc *Allocator) RemoteIDCache {

Callers 13

TestWatchRemoteKVStoreFunction · 0.65
newHubbleDynamicExporterFunction · 0.65
newCRDStatusFixtureFunction · 0.65
RunMethod · 0.65
RunMethod · 0.65
RegisterMethod · 0.65
WatchMethod · 0.65
WatchMethod · 0.65
WatchMethod · 0.65
augmentTrackerFunction · 0.65
newFixtureFunction · 0.65
newPeerConfigTestFixtureFunction · 0.65

Implementers 4

remoteCachepkg/allocator/allocator.go
NoopRemoteIDCachepkg/identity/cache/noop_allocator.go
restartableWatchStorepkg/kvstore/store/watchstore.go
IPIdentityWatcherpkg/ipcache/kvstore.go

Calls

no outgoing calls

Tested by 4

TestWatchRemoteKVStoreFunction · 0.52
newCRDStatusFixtureFunction · 0.52
newFixtureFunction · 0.52
newPeerConfigTestFixtureFunction · 0.52