Documentation
¶
Overview ¶
Package synced provides tools for tracking if k8s resources have been initially sychronized with the k8s apiserver.
Index ¶
- func AgentCRDResourceNames() []string
- func AllCRDResourceNames() []string
- func CRDResourceName(crd string) string
- func SyncCRDs(ctx context.Context, crdNames []string, rs *Resources, ag *APIGroups) error
- type APIGroups
- type Resources
- func (r *Resources) BlockWaitGroupToSyncResources(stop <-chan struct{}, swg *lock.StoppableWaitGroup, ...)
- func (r *Resources) CancelWaitGroupToSyncResources(resourceName string)
- func (r *Resources) SetEventTimestamp(resource string)
- func (r *Resources) WaitForCacheSync(resourceNames ...string)
- func (r *Resources) WaitForCacheSyncWithTimeout(timeout time.Duration, resourceNames ...string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AgentCRDResourceNames ¶
func AgentCRDResourceNames() []string
AgentCRDResourceNames returns a list of all CRD resource names the Cilium agent needs to wait to be registered before initializing any k8s watchers.
func AllCRDResourceNames ¶ added in v1.9.0
func AllCRDResourceNames() []string
AllCRDResourceNames returns a list of all CRD resource names that the clustermesh-apiserver or testsuite may register.
func CRDResourceName ¶
Types ¶
type APIGroups ¶
APIGroups is a lockable map to hold which k8s API Groups we have enabled/in-use Note: We can replace it with a Go 1.9 map once we require that version
type Resources ¶
Resources maps resource names to channels that are closed upon initial sync with k8s.
func (*Resources) BlockWaitGroupToSyncResources ¶
func (r *Resources) BlockWaitGroupToSyncResources( stop <-chan struct{}, swg *lock.StoppableWaitGroup, hasSyncedFunc cache.InformerSynced, resourceName string, )
BlockWaitGroupToSyncResources ensures that anything which waits on waitGroup waits until all objects of the specified resource stored in Kubernetes are received by the informer and processed by controller. Fatally exits if syncing these initial objects fails. If the given stop channel is closed, it does not fatal. Once the k8s caches are synced against k8s, k8sCacheSynced is also closed.
func (*Resources) CancelWaitGroupToSyncResources ¶
func (*Resources) SetEventTimestamp ¶
func (*Resources) WaitForCacheSync ¶
WaitForCacheSync waits for all K8s resources represented by resourceNames to have their K8s caches synchronized.
func (*Resources) WaitForCacheSyncWithTimeout ¶
func (r *Resources) WaitForCacheSyncWithTimeout(timeout time.Duration, resourceNames ...string) error
WaitForCacheSyncWithTimeout waits for K8s resources represented by resourceNames to be synced. For every resource type, if an event happens after starting the wait, the timeout will be pushed out to be the time of the last event plus the timeout duration.