Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for krt (0.35 sec)

  1. pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go

    	Waypoints krt.Collection[Waypoint],
    	WorkloadServices krt.Collection[model.ServiceInfo],
    	WorkloadEntries krt.Collection[*networkingclient.WorkloadEntry],
    	ServiceEntries krt.Collection[*networkingclient.ServiceEntry],
    	AllPolicies krt.Collection[model.WorkloadAuthorization],
    	Namespaces krt.Collection[*v1.Namespace],
    ) krt.Collection[model.WorkloadInfo] {
    	WorkloadServicesNamespaceIndex := krt.NewNamespaceIndex(WorkloadServices)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 16:51:29 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  2. pkg/kube/krt/collection_test.go

    }
    
    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))
    		return slices.Map(pods, func(pod SimplePod) SimpleEndpoint {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 04:22:19 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go

    type workloadsCollection struct {
    	krt.Collection[model.WorkloadInfo]
    	ByAddress        *krt.Index[model.WorkloadInfo, networkAddress]
    	ByServiceKey     *krt.Index[model.WorkloadInfo, string]
    	ByOwningWaypoint *krt.Index[model.WorkloadInfo, networkAddress]
    }
    
    type waypointsCollection struct {
    	krt.Collection[Waypoint]
    }
    
    type servicesCollection struct {
    	krt.Collection[model.ServiceInfo]
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 19 17:19:41 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  4. pkg/kube/krt/README.md

    Example computing a list of service endpoints, similar to the Kubernetes core endpoints controller:
    
    ```go
    Endpoints := krt.NewManyCollection[Endpoint](func(ctx krt.HandlerContext, svc *v1.Service) (res []Endpoint) {
        for _, c := range krt.Fetch(ctx, Pods, krt.FilterLabel(svc.Spec.Selector)) {
          res = append(res, Endpoint{Service: svc.Name, Pod: pod.Name, IP: pod.status.PodIP})
        }
        return res
    }) // Results in a Collection[Endpoint]
    ```
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Dec 18 17:21:50 UTC 2023
    - 11.8K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/ambient/waypoints.go

    	return w.GetNamespace() + "/" + w.GetName()
    }
    
    func WaypointsCollection(
    	Gateways krt.Collection[*v1beta1.Gateway],
    	GatewayClasses krt.Collection[*v1beta1.GatewayClass],
    	Pods krt.Collection[*v1.Pod],
    ) krt.Collection[Waypoint] {
    	podsByNamespace := krt.NewNamespaceIndex(Pods)
    	return krt.NewCollection(Gateways, func(ctx krt.HandlerContext, gateway *v1beta1.Gateway) *Waypoint {
    		if len(gateway.Status.Addresses) == 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 18:02:28 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/kube/controller/ambient/workloads_test.go

    	"istio.io/istio/pilot/pkg/model"
    	"istio.io/istio/pkg/config/labels"
    	"istio.io/istio/pkg/config/mesh"
    	"istio.io/istio/pkg/config/schema/kind"
    	"istio.io/istio/pkg/kube/krt"
    	"istio.io/istio/pkg/kube/krt/krttest"
    	"istio.io/istio/pkg/network"
    	"istio.io/istio/pkg/slices"
    	"istio.io/istio/pkg/test/util/assert"
    	"istio.io/istio/pkg/workloadapi"
    	"istio.io/istio/pkg/workloadapi/security"
    )
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 16:51:29 UTC 2024
    - 20.3K bytes
    - Viewed (0)
  7. pkg/kube/krt/collection.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 krt
    
    import (
    	"fmt"
    	"sync"
    
    	"istio.io/istio/pkg/kube/controllers"
    	istiolog "istio.io/istio/pkg/log"
    	"istio.io/istio/pkg/maps"
    	"istio.io/istio/pkg/ptr"
    	"istio.io/istio/pkg/slices"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 23:33:56 UTC 2024
    - 19.4K bytes
    - Viewed (0)
Back to top