- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 83 for addressTypes (2.72 sec)
-
okhttp/src/test/java/okhttp3/SocksProxy.kt
val reserved = fromSource.readByte() and 0xff if (reserved != 0) throw ProtocolException("unexpected reserved: $reserved") val addressType = fromSource.readByte() and 0xff val toAddress = when (addressType) { ADDRESS_TYPE_IPV4 -> { InetAddress.getByAddress(fromSource.readByteArray(4L)) } ADDRESS_TYPE_DOMAIN_NAME -> {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 7.7K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/v1.29.0/discovery.k8s.io.v1.EndpointSlice.yaml
addressType: addressTypeValue apiVersion: discovery.k8s.io/v1 endpoints: - addresses: - addressesValue conditions: ready: true serving: true terminating: true deprecatedTopology: deprecatedTopologyKey: deprecatedTopologyValue hints: forZones: - name: nameValue hostname: hostnameValue nodeName: nodeNameValue targetRef: apiVersion: apiVersionValue fieldPath: fieldPathValue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 04:12:07 UTC 2023 - 1.5K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler.go
func (r *reconciler) reconcileByPortMapping( endpoints *corev1.Endpoints, existingSlices []*discovery.EndpointSlice, desiredSet endpointsliceutil.EndpointSet, endpointPorts []discovery.EndpointPort, addressType discovery.AddressType, ) (slicesByAction, totalsByAction) { slices := slicesByAction{} totals := totalsByAction{} // If no endpoints are desired, mark existing slices for deletion and // return.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 13.1K bytes - Viewed (0) -
pilot/pkg/xds/workload_test.go
expect := buildExpect(t) s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ KubernetesObjects: []runtime.Object{mkPod("pod", "sa", "127.0.0.1", "not-node")}, }) ads := s.ConnectDeltaADS().WithType(v3.AddressType).WithMetadata(model.NodeMetadata{NodeName: "node"}) ads.Request(&discovery.DeltaDiscoveryRequest{ ResourceNamesSubscribe: []string{"*"}, ResourceNamesUnsubscribe: []string{"*"}, }) ads.ExpectEmptyResponse()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
common-protos/k8s.io/api/discovery/v1/generated.proto
// Endpoint represents a single logical "backend" implementing a service. message Endpoint { // addresses of this endpoint. The contents of this field are interpreted // according to the corresponding EndpointSlice addressType field. Consumers // must handle different types of addresses in the context of their own // capabilities. This must contain at least one address but no more than
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 8K bytes - Viewed (0) -
staging/src/k8s.io/api/discovery/v1beta1/generated.proto
// Endpoint represents a single logical "backend" implementing a service. message Endpoint { // addresses of this endpoint. The contents of this field are interpreted // according to the corresponding EndpointSlice addressType field. Consumers // must handle different types of addresses in the context of their own // capabilities. This must contain at least one address but no more than
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 8K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/v1.29.0/discovery.k8s.io.v1.EndpointSlice.json
"apiVersion": "apiVersionValue", "time": "2004-01-01T01:01:01Z", "fieldsType": "fieldsTypeValue", "fieldsV1": {}, "subresource": "subresourceValue" } ] }, "addressType": "addressTypeValue", "endpoints": [ { "addresses": [ "addressesValue" ], "conditions": { "ready": true, "serving": true, "terminating": true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 04:12:07 UTC 2023 - 2.1K bytes - Viewed (0) -
pkg/controlplane/reconcilers/endpointsadapter_test.go
_, epSlice4IP := generateEndpointsAndSlice("foo", "testing", []int{80}, []string{"10.1.2.7", "10.1.2.8"}) // "IP" is a deprecated address type, ensuring that it is handled properly. epSlice4IP.AddressType = discovery.AddressType("IP") _, epSlice4IPv4 := generateEndpointsAndSlice("foo", "testing", []int{80}, []string{"10.1.2.7", "10.1.2.8"}) testCases := map[string]struct { expectedError error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/proxy/endpointschangetracker.go
func (ect *EndpointsChangeTracker) EndpointSliceUpdate(endpointSlice *discovery.EndpointSlice, removeSlice bool) bool { if !supportedEndpointSliceAddressTypes.Has(endpointSlice.AddressType) { klog.V(4).InfoS("EndpointSlice address type not supported by kube-proxy", "addressType", endpointSlice.AddressType) return false } // This should never happen if endpointSlice == nil { klog.ErrorS(nil, "Nil endpointSlice passed to EndpointSliceUpdate")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 13.2K bytes - Viewed (0) -
pkg/proxy/nftables/proxier_test.go
}), ) populateEndpointSlices(fp, makeTestEndpointSlice("ns1", "svc1", 1, func(eps *discovery.EndpointSlice) { if tc.family == v1.IPv4Protocol { eps.AddressType = discovery.AddressTypeIPv4 } else { eps.AddressType = discovery.AddressTypeIPv6 } eps.Endpoints = []discovery.Endpoint{{ Addresses: []string{epIP1}, NodeName: nil, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 173.5K bytes - Viewed (0)