- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 605 for disovery (0.13 sec)
-
pkg/proxy/ipvs/proxier_test.go
emptyEndpointSlices := []*discovery.EndpointSlice{ makeTestEndpointSlice("ns1", "ep1", 1, func(*discovery.EndpointSlice) {}), } subset1 := func(eps *discovery.EndpointSlice) { eps.AddressType = discovery.AddressTypeIPv4 eps.Endpoints = []discovery.Endpoint{{ Addresses: []string{"1.1.1.1"}, }} eps.Ports = []discovery.EndpointPort{{ Name: ptr.To("p11"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
return nil, err } return map[string]*discovery.DiscoveryResponse{ CpInfo(response).ID: response, }, nil } } return nil, err } return mapShards(responses) } func mapShards(responses []*discovery.DiscoveryResponse) (map[string]*discovery.DiscoveryResponse, error) { retval := map[string]*discovery.DiscoveryResponse{} for _, response := range responses {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 13.6K bytes - Viewed (0) -
cmd/kubeadm/app/discovery/discovery_test.go
}, { name: "file Discovery with a path", d: kubeadm.JoinConfiguration{ Discovery: kubeadm.Discovery{ File: &kubeadm.FileDiscovery{ KubeConfigPath: "notnil", }, }, }, expect: false, }, { name: "file Discovery with an url", d: kubeadm.JoinConfiguration{ Discovery: kubeadm.Discovery{ File: &kubeadm.FileDiscovery{ KubeConfigPath: "https://localhost", },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 2K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta.go
p.connectedMutex.Unlock() } func (p *XdsProxy) forwardDeltaToTap(resp *discovery.DeltaDiscoveryResponse) { select { // Convert back to a SotW response case p.tapResponseChannel <- &discovery.DiscoveryResponse{ VersionInfo: resp.SystemVersionInfo, Resources: slices.Map(resp.Resources, (*discovery.Resource).GetResource), Canary: false, TypeUrl: resp.TypeUrl,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 11.7K bytes - Viewed (0) -
security/pkg/nodeagent/sds/sdsservice_test.go
s.Verify(s.Connect().RequestResponseAck(t, &discovery.DiscoveryRequest{ResourceNames: []string{testResourceName}}), expectCert) s.Verify(s.Connect().RequestResponseAck(t, &discovery.DiscoveryRequest{ResourceNames: []string{testResourceName}}), expectCert) }) t.Run("unsubscribe", func(t *testing.T) { s := setupSDS(t) c := s.Connect() res := c.RequestResponseAck(t, &discovery.DiscoveryRequest{ResourceNames: []string{testResourceName}})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 17 20:12:58 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/adsc/delta_test.go
) type mockDeltaXdsServer struct{} var deltaHandler func(stream discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error func (t *mockDeltaXdsServer) StreamAggregatedResources(discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error { return nil } func (t *mockDeltaXdsServer) DeltaAggregatedResources(delta discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 13.9K bytes - Viewed (0) -
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/controller/endpointslicemirroring/reconciler_test.go
}}, }}, existingEndpointSlices: []*discovery.EndpointSlice{{ ObjectMeta: metav1.ObjectMeta{ Name: "test-ep-1", }, AddressType: discovery.AddressTypeIPv4, Ports: []discovery.EndpointPort{{ Name: pointer.String("http"), Port: pointer.Int32(80), Protocol: &protoTCP, }}, Endpoints: []discovery.Endpoint{{ Addresses: []string{"10.0.0.1"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 42.7K 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)