- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for TransformationMulti (0.26 sec)
-
pkg/kube/krt/core.go
// TransformationSingle represents a one-to-one relationship between I and O. TransformationSingle[I, O any] func(ctx HandlerContext, i I) *O // TransformationMulti represents a one-to-many relationship between I and O. TransformationMulti[I, O any] func(ctx HandlerContext, i I) []O ) // Key is a string, but with a type associated to avoid mixing up keys type Key[O any] string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/kube/krt/collection.go
func NewManyCollection[I, O any](c Collection[I], hf TransformationMulti[I, O], opts ...CollectionOption) Collection[O] { o := buildCollectionOptions(opts...) if o.name == "" { o.name = fmt.Sprintf("ManyCollection[%v,%v]", ptr.TypeName[I](), ptr.TypeName[O]()) } return newManyCollection[I, O](c, hf, o) } func newManyCollection[I, O any](cc Collection[I], hf TransformationMulti[I, O], opts collectionOptions) Collection[O] {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 19.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/services.go
return WorkloadServices } func (a *index) serviceEntryServiceBuilder( Waypoints krt.Collection[Waypoint], Namespaces krt.Collection[*v1.Namespace], ) krt.TransformationMulti[*networkingclient.ServiceEntry, model.ServiceInfo] { return func(ctx krt.HandlerContext, s *networkingclient.ServiceEntry) []model.ServiceInfo { waypoint := fetchWaypointForService(ctx, Waypoints, Namespaces, s.ObjectMeta)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 12:29:55 UTC 2024 - 7.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go
AuthorizationPolicies krt.Collection[model.WorkloadAuthorization], PeerAuths krt.Collection[*securityclient.PeerAuthentication], Waypoints krt.Collection[Waypoint], Namespaces krt.Collection[*v1.Namespace], ) krt.TransformationMulti[*networkingclient.ServiceEntry, model.WorkloadInfo] { return func(ctx krt.HandlerContext, se *networkingclient.ServiceEntry) []model.WorkloadInfo { eps := se.Spec.Endpoints
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 20.9K bytes - Viewed (0)