Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewManyCollection (0.2 sec)

  1. pkg/kube/krt/collection.go

    	}
    	return newManyCollection[I, O](c, hm, o)
    }
    
    // NewManyCollection transforms a Collection[I] to a Collection[O] by applying the provided transformation function.
    // This applies for one-to-many relationships between I and O.
    // For zero-to-one, use NewSingleton. For one-to-one, use NewCollection.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 23:33:56 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  2. pkg/kube/krt/README.md

    * `func(input I) *O` via `NewCollection`
        * This generates a one-to-one mapping of input to output. An example would be a transformation from a `Pod` type to a generic `Workload` type.
    * `func(input I) []O` via `NewManyCollection`
        * This generates a one-to-many mapping of input to output. An example would be a transformation from a `Service` to a _set_ of `Endpoint` types.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Dec 18 17:21:50 UTC 2023
    - 11.8K bytes
    - Viewed (0)
  3. pkg/kube/krt/collection_test.go

    	return slices.Join("/", s.Namespace+"/"+s.Service+"/"+s.Pod)
    }
    
    func SimpleEndpointsCollection(pods krt.Collection[SimplePod], services krt.Collection[SimpleService]) krt.Collection[SimpleEndpoint] {
    	return krt.NewManyCollection[SimpleService, SimpleEndpoint](services, func(ctx krt.HandlerContext, svc SimpleService) []SimpleEndpoint {
    		pods := krt.Fetch(ctx, pods, krt.FilterLabel(svc.Selector))
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 04:22:19 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go

    		a.workloadEntryWorkloadBuilder(MeshConfig, AuthorizationPolicies, PeerAuths, Waypoints, WorkloadServices, WorkloadServicesNamespaceIndex, Namespaces),
    		krt.WithName("WorkloadEntryWorkloads"),
    	)
    	ServiceEntryWorkloads := krt.NewManyCollection(
    		ServiceEntries,
    		a.serviceEntryWorkloadBuilder(MeshConfig, AuthorizationPolicies, PeerAuths, Waypoints, Namespaces),
    		krt.WithName("ServiceEntryWorkloads"),
    	)
    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