- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 208 for discoveryv1 (0.22 sec)
-
pilot/cmd/pilot-discovery/app/cmd.go
Title: "Istio Pilot Discovery", Section: "pilot-discovery CLI", Manual: "Istio Pilot Discovery", })) rootCmd.AddCommand(requestCmd) return rootCmd } func newDiscoveryCommand() *cobra.Command { return &cobra.Command{ Use: "discovery", Short: "Start Istio proxy discovery service.", Args: cobra.ExactArgs(0),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/kube/client_factory.go
package kube import ( "path/filepath" "regexp" "strings" "time" "k8s.io/apimachinery/pkg/api/meta" "k8s.io/client-go/discovery" diskcached "k8s.io/client-go/discovery/cached/disk" "k8s.io/client-go/discovery/cached/memory" "k8s.io/client-go/dynamic" "k8s.io/client-go/kubernetes" "k8s.io/client-go/rest" "k8s.io/client-go/restmapper" "k8s.io/client-go/tools/clientcmd"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 15 21:30:37 UTC 2023 - 5.8K bytes - Viewed (0) -
cmd/kubeadm/app/discovery/file/file.go
if err := kubeconfigutil.EnsureCertificateAuthorityIsEmbedded(currentCluster); err != nil { return nil, err } // If the discovery file config contains authentication credentials if kubeconfigutil.HasAuthenticationCredentials(config) { klog.V(1).Info("[discovery] Using authentication credentials from the discovery file for validating TLS connection")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:55 UTC 2024 - 6.7K bytes - Viewed (0) -
pilot/pkg/xds/debug_test.go
ads := s.ConnectADS() ads.RequestResponseAck(t, &discovery.DiscoveryRequest{TypeUrl: v3.ClusterType}) ads.RequestResponseAck(t, &discovery.DiscoveryRequest{TypeUrl: v3.ListenerType}) ads.RequestResponseAck(t, &discovery.DiscoveryRequest{ TypeUrl: v3.EndpointType, ResourceNames: []string{"outbound|9080||app2.default.svc.cluster.local"}, }) ads.RequestResponseAck(t, &discovery.DiscoveryRequest{ TypeUrl: v3.RouteType,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 7.8K bytes - Viewed (0) -
pkg/apis/discovery/install/install.go
*/ // Package install installs the discovery API group, making it available as // an option to all of the API encoding/decoding machinery. package install import ( "k8s.io/apimachinery/pkg/runtime" utilruntime "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/kubernetes/pkg/api/legacyscheme" "k8s.io/kubernetes/pkg/apis/discovery" v1 "k8s.io/kubernetes/pkg/apis/discovery/v1" "k8s.io/kubernetes/pkg/apis/discovery/v1beta1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 06:31:58 UTC 2024 - 1.4K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/v1beta4/conversion.go
err := autoConvert_v1beta4_JoinConfiguration_To_kubeadm_JoinConfiguration(in, out, s) out.Discovery.Timeout = in.Timeouts.Discovery.DeepCopy() return err } // Convert_kubeadm_Discovery_To_v1beta4_Discovery is required because there is no Discovery.Timeout in v1beta4 func Convert_kubeadm_Discovery_To_v1beta4_Discovery(in *kubeadm.Discovery, out *Discovery, s conversion.Scope) error { return autoConvert_kubeadm_Discovery_To_v1beta4_Discovery(in, out, s)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 13 06:41:07 UTC 2024 - 3.5K bytes - Viewed (0) -
pilot/pkg/xds/deltaadstest.go
return case resp := <-a.responses: a.t.Fatalf("got unexpected response: %v", resp) } } func (a *DeltaAdsTest) fillInRequestDefaults(req *discovery.DeltaDiscoveryRequest) *discovery.DeltaDiscoveryRequest { if req == nil { req = &discovery.DeltaDiscoveryRequest{} } if req.TypeUrl == "" { req.TypeUrl = a.Type } if req.Node == nil { req.Node = &core.Node{ Id: a.ID,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/proxy/metaproxier/meta_proxier.go
// is observed. func (proxier *metaProxier) OnEndpointSliceAdd(endpointSlice *discovery.EndpointSlice) { switch endpointSlice.AddressType { case discovery.AddressTypeIPv4: proxier.ipv4Proxier.OnEndpointSliceAdd(endpointSlice) case discovery.AddressTypeIPv6: proxier.ipv6Proxier.OnEndpointSliceAdd(endpointSlice) default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 21 14:28:37 UTC 2024 - 5.9K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta_test.go
} func deltaStream(t *testing.T, conn *grpc.ClientConn) discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesClient { t.Helper() adsClient := discovery.NewAggregatedDiscoveryServiceClient(conn) downstream, err := adsClient.DeltaAggregatedResources(ctx) if err != nil { t.Fatal(err) } return downstream }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 04:48:02 UTC 2024 - 6.3K bytes - Viewed (0) -
pilot/pkg/xds/adstest.go
return case resp := <-a.responses: t.Fatalf("got unexpected response: %v", resp) } } func (a *AdsTest) fillInRequestDefaults(req *discovery.DiscoveryRequest) *discovery.DiscoveryRequest { if req == nil { req = &discovery.DiscoveryRequest{} } if req.TypeUrl == "" { req.TypeUrl = a.Type } if req.Node == nil { req.Node = &core.Node{ Id: a.ID,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6K bytes - Viewed (0)