- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for krt (1.08 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)