- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,162 for endpoints2 (0.37 sec)
-
pkg/controlplane/reconcilers/instancecount_test.go
}{ { testName: "no existing endpoints", serviceName: "foo", ip: "1.2.3.4", endpointPorts: []corev1.EndpointPort{{Name: "foo", Port: 8080, Protocol: "TCP"}}, initialState: nil, expectCreate: makeEndpointsArray("foo", []string{"1.2.3.4"}, []corev1.EndpointPort{{Name: "foo", Port: 8080, Protocol: "TCP"}}), }, { testName: "existing endpoints satisfy", serviceName: "foo",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 27 12:46:24 UTC 2022 - 14K bytes - Viewed (0) -
pkg/registry/discovery/endpointslice/strategy.go
dropHints := !utilfeature.DefaultFeatureGate.Enabled(features.TopologyAwareHints) if dropHints { for _, ep := range oldEPS.Endpoints { if ep.Hints != nil { dropHints = false break } } } if dropHints { for i := range newEPS.Endpoints { if dropHints { newEPS.Endpoints[i].Hints = nil } } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 02 10:00:01 UTC 2023 - 7.6K bytes - Viewed (0) -
cmd/etcd.go
var errEtcdUnreachable = errors.New("etcd is unreachable, please check your endpoints") func etcdErrToErr(err error, etcdEndpoints []string) error { if err == nil { return nil } switch err { case context.DeadlineExceeded: return fmt.Errorf("%w %s", errEtcdUnreachable, etcdEndpoints) default: return fmt.Errorf("unexpected error %w from etcd, please check your endpoints %s", err, etcdEndpoints) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 2.9K bytes - Viewed (0) -
cmd/prepare-storage.go
) var printEndpointError = func() func(Endpoint, error, bool) { var mutex sync.Mutex printOnce := make(map[Endpoint]map[string]int) return func(endpoint Endpoint, err error, once bool) { reqInfo := (&logger.ReqInfo{}).AppendTags("endpoint", endpoint.String()) ctx := logger.SetReqInfo(GlobalContext, reqInfo) mutex.Lock() defer mutex.Unlock() m, ok := printOnce[endpoint] if !ok { m = make(map[string]int)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun May 19 08:06:49 UTC 2024 - 11.1K bytes - Viewed (0) -
internal/config/etcd/etcd_test.go
t.Run(testCase.s, func(t *testing.T) { endpoints, secure, err := parseEndpoints(testCase.s) if err != nil && testCase.success { t.Errorf("expected to succeed but failed with %s", err) } if !testCase.success && err == nil { t.Error("expected failure but succeeded instead") } if testCase.success { if !reflect.DeepEqual(endpoints, testCase.endpoints) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 2.1K bytes - Viewed (0) -
pilot/pkg/networking/core/loadbalancer/loadbalancer_test.go
if len(cluster.LoadAssignment.Endpoints) != len(tt.expected) { t.Fatalf("expected endpoints %d but got %d", len(cluster.LoadAssignment.Endpoints), len(tt.expected)) } for i := range cluster.LoadAssignment.Endpoints { // TODO Below assertions are not robust to ordering changes in cluster.LoadAssignment.Endpoints[i]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 23 05:38:57 UTC 2024 - 39.1K bytes - Viewed (0) -
cmd/endpoint_test.go
{SlashSeparator, Endpoint{}, -1, fmt.Errorf("empty or root endpoint is not supported")}, {`\`, Endpoint{}, -1, fmt.Errorf("empty or root endpoint is not supported")}, {"c://foo", Endpoint{}, -1, fmt.Errorf("invalid URL endpoint format")}, {"ftp://foo", Endpoint{}, -1, fmt.Errorf("invalid URL endpoint format")}, {"http://server/path?location", Endpoint{}, -1, fmt.Errorf("invalid URL endpoint format")},
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jan 13 07:53:03 UTC 2024 - 18.9K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/k8sresourcelock/endpointslock.go
type EndpointsLock struct { // EndpointsMeta should contain a Name and a Namespace of an // Endpoints object that the LeaderElector will attempt to lead. EndpointsMeta metav1.ObjectMeta Client corev1client.EndpointsGetter LockConfig ResourceLockConfig e *v1.Endpoints } // Get returns the election record from a Endpoints Annotation func (el *EndpointsLock) Get(ctx context.Context) (*LeaderElectionRecord, []byte, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Oct 11 16:58:48 UTC 2021 - 3.7K bytes - Viewed (0) -
staging/src/k8s.io/api/core/v1/annotation_key_constants.go
// // The "endpoints change trigger" here means any Pod or Service change that resulted in the // Endpoints object change. // // Given the definition of the "endpoints change trigger", please note that this annotation will // be set ONLY for endpoints object changes triggered by either Pod or Service change. If the // Endpoints object changes due to other reasons, this annotation won't be set (or updated if it's
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 18:46:31 UTC 2024 - 8.6K bytes - Viewed (0) -
common-protos/k8s.io/api/discovery/v1beta1/generated.proto
// * FQDN: Represents a Fully Qualified Domain Name. optional string addressType = 4; // endpoints is a list of unique endpoints in this slice. Each slice may // include a maximum of 1000 endpoints. // +listType=atomic repeated Endpoint endpoints = 2; // ports specifies the list of network ports exposed by each endpoint in // this slice. Each port must have a unique name. When ports is empty, it
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 8K bytes - Viewed (0)