- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 173 for discoveryv1 (0.15 sec)
-
cmd/kubeadm/app/cmd/upgrade/common.go
fakeclient := apiclient.NewDryRunClientWithOpts(dryRunOpts) // As we know the return of Discovery() of the fake clientset is of type *fakediscovery.FakeDiscovery // we can convert it to that struct. fakeclientDiscovery, ok := fakeclient.Discovery().(*fakediscovery.FakeDiscovery) if !ok { return nil, errors.New("couldn't set fake discovery's server version") } // Lastly, set the right server version to be used
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 08:34:39 UTC 2024 - 10.1K bytes - Viewed (0) -
pkg/registry/discovery/endpointslice/strategy_test.go
Hints: &discovery.EndpointHints{ ForZones: []discovery.ForZone{{Name: "zone-a-old"}}, }, }, { Hints: &discovery.EndpointHints{ ForZones: []discovery.ForZone{{Name: "zone-b-old"}}, }, }, }, }, newEPS: &discovery.EndpointSlice{ Endpoints: []discovery.Endpoint{ { Hints: &discovery.EndpointHints{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 27.3K bytes - Viewed (0) -
pkg/proxy/endpointslicecache_test.go
initialSlice: &discovery.EndpointSlice{ ObjectMeta: objMeta, Ports: []discovery.EndpointPort{port443}, Endpoints: []discovery.Endpoint{endpoint1, endpoint2}, }, updatedSlice: &discovery.EndpointSlice{ ObjectMeta: objMeta, Ports: []discovery.EndpointPort{port443}, Endpoints: []discovery.Endpoint{endpoint1, endpoint2}, }, expectChanged: false,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 24.9K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier_test.go
}), ) populateEndpointSlices(proxier, makeTestEndpointSlice(svcPortName.Namespace, svcPortName.Name, 1, func(eps *discovery.EndpointSlice) { eps.AddressType = discovery.AddressTypeIPv4 eps.Endpoints = []discovery.Endpoint{{ Addresses: []string{epIpAddressRemote}, }} eps.Ports = []discovery.EndpointPort{{ Name: ptr.To(svcPortName.Port), Port: ptr.To(int32(svcPort)),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 28 14:30:51 UTC 2024 - 30.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) -
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) -
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) -
cmd/kubeadm/app/cmd/join.go
) flagSet.BoolVar( &cfg.Discovery.BootstrapToken.UnsafeSkipCAVerification, options.TokenDiscoverySkipCAHash, false, "For token-based discovery, allow joining without --discovery-token-ca-cert-hash pinning.", ) // discovery via kube config file flag flagSet.StringVar( &cfg.Discovery.File.KubeConfigPath, options.FileDiscovery, "",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 15:33:38 UTC 2024 - 25.2K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/join_test.go
}, { name: "pass if file discovery is set", flags: map[string]string{ options.FileDiscovery: "https://foo", }, validate: func(t *testing.T, data *joinData) { // validate that file discovery settings are set into join data if data.cfg.Discovery.File == nil || data.cfg.Discovery.File.KubeConfigPath != "https://foo" { t.Error("Invalid data.cfg.Discovery.File") } }, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 12:26:20 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/xds/delta_test.go
// See the License for the specific language governing permissions and // limitations under the License. package xds_test import ( "fmt" "reflect" "testing" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" "istio.io/istio/pilot/pkg/features" "istio.io/istio/pilot/pkg/model" v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pilot/test/xds" "istio.io/istio/pilot/test/xdstest"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0)