- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 601 for syncAt (0.12 sec)
-
pkg/kube/krt/singleton_test.go
cms := krt.Fetch(ctx, ConfigMaps) return ptr.Of(slices.Join(",", slices.Map(cms, func(c *corev1.ConfigMap) string { return config.NamespacedName(c).String() })...)) }, ) ConfigMapNames.AsCollection().Synced().WaitUntilSynced(stop) tt := assert.NewTracker[string](t) ConfigMapNames.Register(TrackerHandler[string](tt)) tt.WaitOrdered("add/") assert.Equal(t, *ConfigMapNames.Get(), "") cmt.Create(&corev1.ConfigMap{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 11 08:27:29 UTC 2024 - 2.9K bytes - Viewed (0) -
internal/http/server.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Feb 09 21:25:16 UTC 2024 - 7.7K bytes - Viewed (0) -
pkg/kube/kclient/delayed.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package kclient import ( "sync" "sync/atomic" klabels "k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/client-go/tools/cache" "istio.io/istio/pkg/kube/controllers" "istio.io/istio/pkg/kube/kubetypes"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 31 02:32:59 UTC 2023 - 3.5K bytes - Viewed (0) -
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) -
cmd/kube-controller-manager/app/options/serviceaccountcontroller.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 04:54:33 UTC 2019 - 2.2K 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/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) -
platforms/native/language-native/src/integTest/groovy/org/gradle/language/cpp/AbstractCppPublishingIntegrationTest.groovy
} } @Override ExecutableFixture executable(Object path) { ExecutableFixture executable = super.executable(path) // Executables synced from a binary repo lose their executable bit executable.file.setExecutable(true) executable } Map<String, String> machine(String os, String architecture) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 20:20:03 UTC 2023 - 6.4K 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/kube/namespace/filter.go
d.discoveryNamespaces.Delete(ns.Name) } // AddHandler registers a handler on namespace, which will be triggered when namespace selected or deselected. // If the namespaces have been synced, trigger the new added handler. func (d *discoveryNamespacesFilter) AddHandler(f func(added, removed sets.String)) { d.lock.Lock() defer d.lock.Unlock() d.handlers = append(d.handlers, f) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 17:12:52 UTC 2024 - 9.3K bytes - Viewed (0)