- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for EndpointSubset (0.29 sec)
-
staging/src/k8s.io/client-go/applyconfigurations/core/v1/endpointsubset.go
Ports []EndpointPortApplyConfiguration `json:"ports,omitempty"` } // EndpointSubsetApplyConfiguration constructs an declarative configuration of the EndpointSubset type for use with // apply. func EndpointSubset() *EndpointSubsetApplyConfiguration { return &EndpointSubsetApplyConfiguration{} } // WithAddresses adds the given value to the Addresses field in the declarative configuration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 04 18:31:34 UTC 2021 - 3K bytes - Viewed (0) -
pkg/api/v1/endpoints/util_test.go
testCases := []struct { name string given []v1.EndpointSubset expect []v1.EndpointSubset }{ { name: "empty everything", given: []v1.EndpointSubset{{Addresses: []v1.EndpointAddress{}, Ports: []v1.EndpointPort{}}}, expect: []v1.EndpointSubset{}, }, { name: "empty addresses", given: []v1.EndpointSubset{{Addresses: []v1.EndpointAddress{}, Ports: []v1.EndpointPort{{Port: 111}}}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 27 01:24:22 UTC 2023 - 16.6K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
tests := []struct { name string subsets1 []v1.EndpointSubset subsets2 []v1.EndpointSubset expected bool }{ { name: "Subsets removed", subsets1: []v1.EndpointSubset{*es1, *es2}, subsets2: []v1.EndpointSubset{*es1}, expected: false, }, { name: "Ready Pod IP changed", subsets1: []v1.EndpointSubset{*es1, *es2},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
pkg/api/v1/endpoints/util.go
) // RepackSubsets takes a slice of EndpointSubset objects, expands it to the full // representation, and then repacks that into the canonical layout. This // ensures that code which operates on these objects can rely on the common // form for things like comparison. The result is a newly allocated slice. func RepackSubsets(subsets []v1.EndpointSubset) []v1.EndpointSubset {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 07 07:01:25 UTC 2018 - 8K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler_test.go
}{{ testName: "Endpoints with no subsets", subsets: []corev1.EndpointSubset{}, existingEndpointSlices: []*discovery.EndpointSlice{}, expectedNumSlices: 0, expectedClientActions: 0, expectedMetrics: &expectedMetrics{}, }, { testName: "Endpoints with no addresses", subsets: []corev1.EndpointSubset{{ Ports: []corev1.EndpointPort{{ Name: "http", Port: 80,
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/controller/endpointslicemirroring/endpointslicemirroring_controller_test.go
expectedNumActions int expectedNumSlices int }{{ testName: "Endpoints with no addresses", service: &v1.Service{}, endpoints: &v1.Endpoints{ Subsets: []v1.EndpointSubset{{ Ports: []v1.EndpointPort{{Port: 80}}, }}, }, endpointSlices: []*discovery.EndpointSlice{}, expectedNumActions: 0, expectedNumSlices: 0, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 13.9K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler.go
eventRecorder record.EventRecorder // maxEndpointsPerSubset references the maximum number of endpoints that // should be added to an EndpointSlice for an EndpointSubset. This allows // for a simple 1:1 mapping between EndpointSubset and EndpointSlice. maxEndpointsPerSubset int32 // metricsCache tracks values for total numbers of desired endpoints as well // as the efficiency of EndpointSlice endpoints distribution
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 13.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/proxy_test.go
} ports = append(ports, v1.EndpointPort{Name: p.Name, Port: p.TargetPort.IntVal}) } return []*v1.Endpoints{{ ObjectMeta: metav1.ObjectMeta{Namespace: svc.Namespace, Name: svc.Name}, Subsets: []v1.EndpointSubset{{ Addresses: []v1.EndpointAddress{{Hostname: "dummy-host", IP: "127.0.0.1"}}, Ports: ports, }}, }} } type expectation struct { url string error bool }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 07:16:27 UTC 2023 - 8.6K bytes - Viewed (0) -
pkg/registry/core/endpoint/storage/storage_test.go
return rest, server } func validNewEndpoints() *api.Endpoints { return &api.Endpoints{ ObjectMeta: metav1.ObjectMeta{ Name: "foo", Namespace: metav1.NamespaceDefault, }, Subsets: []api.EndpointSubset{{ Addresses: []api.EndpointAddress{{IP: "1.2.3.4"}}, Ports: []api.EndpointPort{{Port: 80, Protocol: "TCP"}}, }}, } } func TestCreate(t *testing.T) { storage, server := newStorage(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 12 20:55:35 UTC 2019 - 3.8K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/events.go
// InvalidIPAddress indicates that an IP address found in an Endpoints // resource is invalid. InvalidIPAddress = "InvalidIPAddress" // TooManyAddressesToMirror indicates that some addresses were not mirrored // due to an EndpointSubset containing more addresses to mirror than // MaxEndpointsPerSubset allows. TooManyAddressesToMirror = "TooManyAddressesToMirror"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 06 19:43:35 UTC 2020 - 1.3K bytes - Viewed (0)