- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 228 for discoveryv1 (0.2 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/api_test.go
endpoints1v2 := &discoveryv1.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{Namespace: "testnamespace", Name: "e1"}, AddressType: discoveryv1.AddressTypeIPv4, Endpoints: []discoveryv1.Endpoint{{ Addresses: []string{ "1.2.3.4", "4.3.2.1", }, }}, Ports: []discoveryv1.EndpointPort{{ Port: ptr.To[int32](8080), Protocol: ptr.To(v1.ProtocolTCP), }}, } endpoints2 := &discoveryv1.EndpointSlice{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/proxy/kubemark/hollow_proxy.go
func (*FakeProxier) OnServiceSynced() {} func (*FakeProxier) OnEndpointSliceAdd(slice *discoveryv1.EndpointSlice) {} func (*FakeProxier) OnEndpointSliceUpdate(oldSlice, slice *discoveryv1.EndpointSlice) {} func (*FakeProxier) OnEndpointSliceDelete(slice *discoveryv1.EndpointSlice) {} func (*FakeProxier) OnEndpointSlicesSynced() {}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 2.9K 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) -
pilot/pkg/xds/cds_test.go
Port: 80, }}, Selector: labels, ClusterIP: "9.9.9.9", }, } endpoint := &discoveryv1.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{ Name: service.Name, Namespace: service.Namespace, Labels: map[string]string{ discoveryv1.LabelServiceName: service.Name, }, }, Endpoints: []discoveryv1.Endpoint{{ Addresses: []string{pod.Status.PodIP}, TargetRef: &v1.ObjectReference{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 01 02:06:39 UTC 2024 - 9.2K 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/serviceregistry/serviceregistry_test.go
esps = append(esps, discovery.EndpointPort{ Name: &n.Name, Protocol: &n.Protocol, Port: &n.Port, AppProtocol: n.AppProtocol, }) } sliceEndpoint := []discovery.Endpoint{} for _, ip := range ips { sliceEndpoint = append(sliceEndpoint, discovery.Endpoint{ Addresses: []string{ip}, }) } endpointSlice := &discovery.EndpointSlice{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K 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/controller/endpointslice/endpointslice_controller_test.go
Labels: map[string]string{ discovery.LabelServiceName: "something-else", discovery.LabelManagedBy: controllerName, }, }, AddressType: discovery.AddressTypeIPv4, }, { ObjectMeta: metav1.ObjectMeta{ Name: "not-matching-2", Namespace: ns, Labels: map[string]string{ discovery.LabelServiceName: serviceName, discovery.LabelManagedBy: "something-else", }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K 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)