- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,209 for endpointId (0.28 sec)
-
pkg/kubelet/cm/devicemanager/endpoint.go
plugin "k8s.io/kubernetes/pkg/kubelet/cm/devicemanager/plugin/v1beta1" ) // endpoint maps to a single registered device plugin. It is responsible // for managing gRPC communications with the device plugin and caching // device states reported by the device plugin. type endpoint interface { getPreferredAllocation(available, mustInclude []string, size int) (*pluginapi.PreferredAllocationResponse, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 02 11:05:20 UTC 2022 - 3.9K bytes - Viewed (0) -
pkg/proxy/util/endpoints.go
limitations under the License. */ package util import ( "net" "k8s.io/klog/v2" netutils "k8s.io/utils/net" ) // IPPart returns just the IP part of an IP or IP:port or endpoint string. If the IP // part is an IPv6 address enclosed in brackets (e.g. "[fd00:1::5]:9999"), // then the brackets are stripped as well. func IPPart(s string) string { if ip := netutils.ParseIPSloppy(s); ip != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 1.3K bytes - Viewed (0) -
pkg/proxy/conntrack/cleanup.go
if svcInfo, ok := svcPortMap[epSvcPair.ServicePortName]; ok { endpointIP := proxyutil.IPPart(epSvcPair.Endpoint) nodePort := svcInfo.NodePort() var err error if nodePort != 0 { err = ct.ClearEntriesForPortNAT(endpointIP, nodePort, v1.ProtocolUDP) if err != nil { klog.ErrorS(err, "Failed to delete nodeport-related endpoint connections", "servicePortName", epSvcPair.ServicePortName) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 18:09:05 UTC 2024 - 5.2K bytes - Viewed (0) -
pilot/pkg/xds/eds_test.go
verifyLocalityPriorities(asdc2Locality, endpoints2["outbound|80||locality.cluster.local"].GetEndpoints(), t) // No outlier detection specified for this cluster, so we shouldn't apply priority. verifyNoLocalityPriorities(endpoints1["outbound|80||locality-no-outlier-detection.cluster.local"].GetEndpoints(), t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
cmd/endpoint-ellipses_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "fmt" "reflect" "testing" "github.com/minio/pkg/v3/ellipses" ) // Tests create endpoints with ellipses and without. func TestCreateServerEndpoints(t *testing.T) { testCases := []struct { serverAddr string args []string success bool }{ // Invalid input. {"", []string{}, false},
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.2K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
return !ok } // truncateEndpoints by best effort will distribute the endpoints over the subsets based on the proportion // of endpoints per subset and will prioritize Ready Endpoints over NotReady Endpoints. func truncateEndpoints(endpoints *v1.Endpoints) bool { totalReady := 0 totalNotReady := 0 for _, subset := range endpoints.Subsets { totalReady += len(subset.Addresses)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
releasenotes/notes/headless-endpoint-update.yaml
apiVersion: release-notes/v2 kind: bug-fix area: networking issue: - 26617 releaseNotes: - |
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 19 15:10:39 UTC 2020 - 198 bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/HEAD/core.v1.Endpoints.yaml
apiVersion: v1 kind: Endpoints metadata: annotations: annotationsKey: annotationsValue creationTimestamp: "2008-01-01T01:01:01Z" deletionGracePeriodSeconds: 10 deletionTimestamp: "2009-01-01T01:01:01Z" finalizers: - finalizersValue generateName: generateNameValue generation: 7 labels: labelsKey: labelsValue managedFields: - apiVersion: apiVersionValue fieldsType: fieldsTypeValue fieldsV1: {}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 06 21:25:20 UTC 2022 - 1.5K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/v1.29.0/core.v1.Endpoints.json
{ "kind": "Endpoints", "apiVersion": "v1", "metadata": { "name": "nameValue", "generateName": "generateNameValue", "namespace": "namespaceValue", "selfLink": "selfLinkValue", "uid": "uidValue", "resourceVersion": "resourceVersionValue", "generation": 7, "creationTimestamp": "2008-01-01T01:01:01Z", "deletionTimestamp": "2009-01-01T01:01:01Z", "deletionGracePeriodSeconds": 10, "labels": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 04:12:07 UTC 2023 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/v1.29.0/core.v1.Endpoints.yaml
apiVersion: v1 kind: Endpoints metadata: annotations: annotationsKey: annotationsValue creationTimestamp: "2008-01-01T01:01:01Z" deletionGracePeriodSeconds: 10 deletionTimestamp: "2009-01-01T01:01:01Z" finalizers: - finalizersValue generateName: generateNameValue generation: 7 labels: labelsKey: labelsValue managedFields: - apiVersion: apiVersionValue fieldsType: fieldsTypeValue fieldsV1: {}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 04:12:07 UTC 2023 - 1.5K bytes - Viewed (0)