- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 234 for discoveryv1 (0.33 sec)
-
pkg/proxy/config/config_test.go
AddressType: discoveryv1.AddressTypeIPv4, Endpoints: []discoveryv1.Endpoint{{ Addresses: []string{"1.1.1.1"}, }, { Addresses: []string{"2.2.2.2"}, }}, Ports: []discoveryv1.EndpointPort{{Port: ptr.To[int32](80)}}, } endpoints2 := &discoveryv1.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{Namespace: "testnamespace", Name: "bar"}, AddressType: discoveryv1.AddressTypeIPv4, Endpoints: []discoveryv1.Endpoint{{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/proxy/config/config.go
import ( "context" "fmt" "sync" "time" v1 "k8s.io/api/core/v1" discoveryv1 "k8s.io/api/discovery/v1" networkingv1alpha1 "k8s.io/api/networking/v1alpha1" utilruntime "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/apimachinery/pkg/util/sets" v1informers "k8s.io/client-go/informers/core/v1" discoveryv1informers "k8s.io/client-go/informers/discovery/v1" networkingv1alpha1informers "k8s.io/client-go/informers/networking/v1alpha1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/controlplane/reconcilers/endpointsadapter_test.go
func generateEndpointsAndSlice(name, namespace string, ports []int, addresses []string) (*corev1.Endpoints, *discovery.EndpointSlice) { trueBool := true epSlice := &discovery.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{Name: name, Namespace: namespace}, AddressType: discovery.AddressTypeIPv4, } epSlice.Labels = map[string]string{discovery.LabelServiceName: name} subset := corev1.EndpointSubset{} for i, port := range ports {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 15.4K bytes - Viewed (0) -
pilot/pkg/xds/mesh_network_test.go
Port: w.port, Name: "http", Protocol: corev1.ProtocolTCP, }}, }, }, &discoveryv1.EndpointSlice{ ObjectMeta: baseMeta, Endpoints: []discoveryv1.Endpoint{{ Addresses: []string{w.ip}, Conditions: discoveryv1.EndpointConditions{}, Hostname: nil, TargetRef: &corev1.ObjectReference{ APIVersion: "v1", Kind: "Pod",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 24.6K bytes - Viewed (0) -
pkg/controlplane/reconcilers/instancecount_test.go
} for _, test := range reconcileTests { t.Run(test.testName, func(t *testing.T) { fakeClient := fake.NewSimpleClientset(test.initialState...) epAdapter := NewEndpointsAdapter(fakeClient.CoreV1(), fakeClient.DiscoveryV1()) reconciler := NewMasterCountEndpointReconciler(test.additionalMasters+1, epAdapter) err := reconciler.ReconcileEndpoints(test.serviceName, netutils.ParseIPSloppy(test.ip), test.endpointPorts, true) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 27 12:46:24 UTC 2022 - 14K bytes - Viewed (0) -
pkg/controlplane/reconcilers/lease_test.go
if err != nil { t.Errorf("unexpected error creating keys: %v", err) } clientset := fake.NewSimpleClientset(test.initialState...) epAdapter := NewEndpointsAdapter(clientset.CoreV1(), clientset.DiscoveryV1()) r := NewLeaseEndpointReconciler(epAdapter, fakeLeases) err = r.ReconcileEndpoints(test.serviceName, netutils.ParseIPSloppy(test.ip), test.endpointPorts, true) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 28.7K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler.go
// and delete. func (r *reconciler) reconcileByPortMapping( endpoints *corev1.Endpoints, existingSlices []*discovery.EndpointSlice, desiredSet endpointsliceutil.EndpointSet, endpointPorts []discovery.EndpointPort, addressType discovery.AddressType, ) (slicesByAction, totalsByAction) { slices := slicesByAction{} totals := totalsByAction{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 13.1K bytes - Viewed (0) -
pkg/config/schema/kubeclient/resources.gen.go
} case gvr.EndpointSlice: l = func(options metav1.ListOptions) (runtime.Object, error) { return c.Kube().DiscoveryV1().EndpointSlices(opts.Namespace).List(context.Background(), options) } w = func(options metav1.ListOptions) (watch.Interface, error) { return c.Kube().DiscoveryV1().EndpointSlices(opts.Namespace).Watch(context.Background(), options) } case gvr.Endpoints:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 13:57:51 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/controlplane/instance.go
"k8s.io/apiserver/pkg/endpoints/discovery" genericapiserver "k8s.io/apiserver/pkg/server" serverstorage "k8s.io/apiserver/pkg/server/storage" utilfeature "k8s.io/apiserver/pkg/util/feature" clientdiscovery "k8s.io/client-go/discovery" "k8s.io/client-go/kubernetes" corev1client "k8s.io/client-go/kubernetes/typed/core/v1" discoveryclient "k8s.io/client-go/kubernetes/typed/discovery/v1" "k8s.io/klog/v2"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.2K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller_test.go
name string endpointSlice *discovery.EndpointSlice expectedInList bool }{{ testName: "Service with matching EndpointSlice", namespace: "ns1", name: "svc1", endpointSlice: &discovery.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{ Name: "example-1", Namespace: "ns1", Labels: map[string]string{ discovery.LabelServiceName: "svc1",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 13.9K bytes - Viewed (0)