- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 335 for Discover (0.24 sec)
-
pkg/controller/endpointslicemirroring/utils_test.go
tweakEndpoint func(ep *v1.Endpoints) expectedSlice discovery.EndpointSlice }{ { name: "create slice from endpoints", tweakEndpoint: func(ep *v1.Endpoints) { }, expectedSlice: discovery.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{ Labels: map[string]string{ discovery.LabelServiceName: endpoints.Name, discovery.LabelManagedBy: controllerName, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 23 15:40:23 UTC 2022 - 7.5K bytes - Viewed (0) -
cmd/kube-controller-manager/app/core_test.go
func (m TestClientBuilder) ClientOrDie(name string) clientset.Interface { return m.clientset } func (m TestClientBuilder) DiscoveryClient(name string) (discovery.DiscoveryInterface, error) { return m.clientset.Discovery(), nil } func (m TestClientBuilder) DiscoveryClientOrDie(name string) discovery.DiscoveryInterface { ret, err := m.DiscoveryClient(name) if err != nil { panic(err) } return ret }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 11:28:01 UTC 2023 - 5.1K bytes - Viewed (0) -
pkg/xds/server_test.go
// See the License for the specific language governing permissions and // limitations under the License. package xds import ( "testing" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" "istio.io/istio/pkg/model" ) type TestProxy struct { WatchedResources map[string]*WatchedResource } func (p *TestProxy) DeleteWatchedResource(url string) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 4.8K 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/controller/endpointslicemirroring/reconciler_helpers.go
// types. type multiAddrTypePortMapKey map[discovery.AddressType]addrTypePortMapKey // initPorts initializes ports for a subset and address type and returns the // corresponding addrTypePortMapKey. func (d *desiredCalc) initPorts(subsetPorts []v1.EndpointPort) multiAddrTypePortMapKey { endpointPorts := epPortsToEpsPorts(subsetPorts) addrTypes := []discovery.AddressType{discovery.AddressTypeIPv4, discovery.AddressTypeIPv6}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/clientset.go
apiextensionsv1beta1 "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1" discovery "k8s.io/client-go/discovery" rest "k8s.io/client-go/rest" flowcontrol "k8s.io/client-go/util/flowcontrol" ) type Interface interface { Discovery() discovery.DiscoveryInterface ApiextensionsV1() apiextensionsv1.ApiextensionsV1Interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 21:36:26 UTC 2023 - 4.4K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/utils.go
func newAddrTypePortMapKey(endpointPorts []discovery.EndpointPort, addrType discovery.AddressType) addrTypePortMapKey { pmk := fmt.Sprintf("%s-%s", addrType, endpointsliceutil.NewPortMapKey(endpointPorts)) return addrTypePortMapKey(pmk) } func (pk addrTypePortMapKey) addressType() discovery.AddressType { if strings.HasPrefix(string(pk), string(discovery.AddressTypeIPv6)) { return discovery.AddressTypeIPv6 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 8.8K 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/apis/discovery/v1beta1/defaults_test.go
protoUDP := v1.ProtocolUDP tests := map[string]struct { original *discovery.EndpointSlice expected *discovery.EndpointSlice }{ "should set appropriate defaults": { original: &discovery.EndpointSlice{Ports: []discovery.EndpointPort{{ Port: utilpointer.Int32(80), }}}, expected: &discovery.EndpointSlice{ Ports: []discovery.EndpointPort{{ Name: &emptyStr, Protocol: &protoTCP,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 08 12:14:37 UTC 2023 - 2K bytes - Viewed (0) -
pilot/pkg/model/xds_cache.go
} func (d DisabledCache) Get(entry XdsCacheEntry) *discovery.Resource { return nil } func (d DisabledCache) Clear(s sets.Set[ConfigKey]) { } func (d DisabledCache) ClearAll() { } func (d DisabledCache) Keys(t string) []any { return nil } func (d DisabledCache) Snapshot() []*discovery.Resource { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 02 07:02:05 UTC 2023 - 6.1K bytes - Viewed (0)