- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 1,199 for syncAt (0.13 sec)
-
pkg/kube/multicluster/clusterstore.go
// limitations under the License. package multicluster import ( "sync" "istio.io/istio/pkg/cluster" "istio.io/istio/pkg/log" "istio.io/istio/pkg/util/sets" ) // ClusterStore is a collection of clusters type ClusterStore struct { sync.RWMutex // keyed by secret key(ns/name)->clusterID remoteClusters map[string]map[cluster.ID]*Cluster clusters sets.String
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 07 15:01:12 UTC 2023 - 3.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/quota/v1/generic/evaluator.go
// short-circuit if already synced return true } if hasSynced() { // remember we synced cache.Store(true) return true } return false } } // protectedLister returns notReadyError if hasSynced returns false, otherwise delegates to delegate type protectedLister struct { hasSynced func() bool notReadyErr error delegate cache.GenericLister }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 05 00:02:47 UTC 2023 - 11.7K bytes - Viewed (0) -
releasenotes/notes/add-cluster-id-for-cluster-sync-metrics.yaml
Kebe <******@****.***> 1682963494 +0800
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 01 17:51:34 UTC 2023 - 1.1K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
defer gb.monitorLock.Unlock() if len(gb.monitors) == 0 { logger.V(4).Info("garbage controller monitor not synced: no monitors") return false } for resource, monitor := range gb.monitors { if !monitor.controller.HasSynced() { logger.V(4).Info("garbage controller monitor not yet synced", "resource", resource) return false } } return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
pkg/queue/instance_test.go
package queue import ( "errors" "sync" "testing" "time" "go.uber.org/atomic" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/test/util/retry" ) func TestOrdering(t *testing.T) { numValues := 1000 q := NewQueue(1 * time.Microsecond) stop := make(chan struct{}) defer close(stop) wg := sync.WaitGroup{} wg.Add(numValues) mu := sync.Mutex{} out := make([]int, 0)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jul 21 16:30:36 UTC 2023 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz/healthz.go
See the License for the specific language governing permissions and limitations under the License. */ package healthz import ( "bytes" "context" "fmt" "net/http" "reflect" "strings" "sync" "sync/atomic" "time" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/apiserver/pkg/endpoints/metrics" "k8s.io/apiserver/pkg/server/httplog"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
// services that happened since nftables was synced. For a single object, // changes are accumulated, i.e. previous is state from before all of them, // current is state after applying all of those. endpointsChanges *proxy.EndpointsChangeTracker serviceChanges *proxy.ServiceChangeTracker mu sync.Mutex // protects the following fields svcPortMap proxy.ServicePortMap
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pkg/kubelet/lifecycle/interfaces.go
} // PodSyncLoopHandler is invoked during each sync loop iteration. type PodSyncLoopHandler interface { // ShouldSync returns true if the pod needs to be synced. // This operation must return immediately as its called for each pod. // The provided pod should never be modified. ShouldSync(pod *v1.Pod) bool } // PodSyncLoopTarget maintains a list of handlers to pod sync loop. type PodSyncLoopTarget interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 22 17:25:57 UTC 2017 - 4K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
// rsListerSynced returns true if the pod store has been synced at least once. // Added as a member to the struct to allow injection for testing. rsListerSynced cache.InformerSynced rsIndexer cache.Indexer // A store of pods, populated by the shared informer passed to NewReplicaSetController podLister corelisters.PodLister // podListerSynced returns true if the pod store has been synced at least once.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator.go
cidrSets []*cidrset.CidrSet // nodeLister is able to list/get nodes and is populated by the shared informer passed to controller nodeLister corelisters.NodeLister // nodesSynced returns true if the node shared informer has been synced at least once. nodesSynced cache.InformerSynced broadcaster record.EventBroadcaster recorder record.EventRecorder // queues are where incoming work is placed to de-dup and to allow "easy"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (1)