Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for TransformationMulti (0.26 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to top