- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for AsCollection (0.19 sec)
-
pilot/pkg/serviceregistry/kube/controller/ambient/policies.go
AuthzDerivedPolicies := krt.NewCollection(AuthzPolicies, func(ctx krt.HandlerContext, i *securityclient.AuthorizationPolicy) *model.WorkloadAuthorization { meshCfg := krt.FetchOne(ctx, MeshConfig.AsCollection()) pol := convertAuthorizationPolicy(meshCfg.GetRootNamespace(), i) if pol == nil { return nil } return &model.WorkloadAuthorization{ Authorization: pol,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 5.2K bytes - Viewed (0) -
pkg/kube/krt/join_test.go
) func TestJoinCollection(t *testing.T) { c1 := krt.NewStatic[Named](nil) c2 := krt.NewStatic[Named](nil) c3 := krt.NewStatic[Named](nil) j := krt.JoinCollection([]krt.Collection[Named]{c1.AsCollection(), c2.AsCollection(), c3.AsCollection()}) last := atomic.NewString("") j.Register(func(o krt.Event[Named]) { last.Store(o.Latest().ResourceName()) }) assert.EventuallyEqual(t, last.Load, "") c1.Set(&Named{"c1", "a"})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/kube/krt/recomputetrigger_test.go
"istio.io/istio/pkg/kube/krt" "istio.io/istio/pkg/ptr" "istio.io/istio/pkg/test/util/assert" ) func TestRecomputeTrigger(t *testing.T) { rt := krt.NewRecomputeTrigger() col1 := krt.NewStatic(ptr.Of("foo")).AsCollection() response := "foo" col2 := krt.NewCollection(col1, func(ctx krt.HandlerContext, i string) *string { rt.MarkDependant(ctx) return ptr.Of(response) }) tt := assert.NewTracker[string](t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 05:51:56 UTC 2024 - 1.3K bytes - Viewed (0) -
pkg/kube/krt/singleton.go
if len(res) == 0 { return nil } return &res[0] } func (c collectionAdapter[T]) Register(f func(o Event[T])) Syncer { return c.c.Register(f) } func (c collectionAdapter[T]) AsCollection() Collection[T] { return c.c } var _ Singleton[any] = &collectionAdapter[any]{} func NewSingleton[O any](hf TransformationEmpty[O], opts ...CollectionOption) Singleton[O] {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 4.2K bytes - Viewed (0) -
pkg/kube/krt/recomputetrigger.go
// MarkDependant marks the given context as depending on this trigger. This registers it to be recomputed when TriggerRecomputation // is called. func (r *RecomputeTrigger) MarkDependant(ctx HandlerContext) { _ = Fetch(ctx, r.inner.AsCollection())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 05:51:56 UTC 2024 - 2K bytes - Viewed (0) -
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(), "")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 11 08:27:29 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/kube/krt/index_test.go
pods := krt.Fetch(ctx, SimplePods, krt.FilterIndex(IPIndex, "1.2.3.5")) names := slices.Sort(slices.Map(pods, SimplePod.ResourceName)) return ptr.Of(strings.Join(names, ",")) }) Collection.AsCollection().Synced().WaitUntilSynced(stop) fetchSorted := func(ip string) []SimplePod { return slices.SortBy(IPIndex.Lookup(ip), func(t SimplePod) string { return t.ResourceName() }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/kube/krt/core.go
// Get returns the object, or nil if there is none. Get() *T // Register adds an event watcher to the object. Any time it changes, the handler will be called Register(f func(o Event[T])) Syncer AsCollection() Collection[T] } // Event represents a point in time change for a collection. type Event[T any] struct { // Old object, set on Update or Delete. Old *T // New object, set on Add or Update New *T
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 6.9K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/project/harness/Xpp3DomAttributePointer.java
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 2.2K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/project/harness/Xpp3DomNodePointer.java
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 3.3K bytes - Viewed (0)