- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 158 for ep (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go
} dbMetricsMonitorsMu.Lock() defer dbMetricsMonitorsMu.Unlock() ctx, cancel := context.WithCancel(context.Background()) for _, ep := range client.Endpoints() { if _, found := dbMetricsMonitors[ep]; found { continue } dbMetricsMonitors[ep] = struct{}{} endpoint := ep klog.V(4).Infof("Start monitoring storage db size metric for endpoint %s with polling interval %v", endpoint, interval)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 07:56:39 UTC 2024 - 15.1K bytes - Viewed (0) -
analysis/analysis-api-standalone/analysis-api-fir-standalone-base/src/org/jetbrains/kotlin/analysis/api/standalone/base/project/structure/FirStandaloneServiceRegistrar.kt
} @Suppress("TestOnlyProblems") override fun registerProjectModelServices(project: MockProject, disposable: Disposable) { with(PsiElementFinder.EP.getPoint(project)) { registerExtension(JavaElementFinder(project), disposable) registerExtension(PsiElementFinderImpl(project), disposable) } }
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed May 22 06:28:34 UTC 2024 - 2.2K bytes - Viewed (0) -
src/crypto/tls/testdata/Client-TLSv12-Ed25519
000000c0 35 31 35 32 31 33 38 30 31 5a 30 12 31 10 30 0e |515213801Z0.1.0.| 000000d0 06 03 55 04 0a 13 07 41 63 6d 65 20 43 6f 30 2a |..U....Acme Co0*| 000000e0 30 05 06 03 2b 65 70 03 21 00 3f e2 15 2e e6 e3 |0...+ep.!.?.....| 000000f0 ef 3f 4e 85 4a 75 77 a3 64 9e ed e0 bf 84 2c cc |.?N.Juw.d.....,.| 00000100 92 26 8f fa 6f 34 83 aa ec 8f a3 4d 30 4b 30 0e |.&..o4.....M0K0.|
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:33:38 UTC 2024 - 5K bytes - Viewed (0) -
src/crypto/tls/testdata/Server-TLSv12-Ed25519
000000a0 35 32 31 33 38 30 31 5a 30 12 31 10 30 0e 06 03 |5213801Z0.1.0...| 000000b0 55 04 0a 13 07 41 63 6d 65 20 43 6f 30 2a 30 05 |U....Acme Co0*0.| 000000c0 06 03 2b 65 70 03 21 00 3f e2 15 2e e6 e3 ef 3f |..+ep.!.?......?| 000000d0 4e 85 4a 75 77 a3 64 9e ed e0 bf 84 2c cc 92 26 |N.Juw.d.....,..&| 000000e0 8f fa 6f 34 83 aa ec 8f a3 4d 30 4b 30 0e 06 03 |..o4.....M0K0...|
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 25 00:13:30 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/apis/core/fuzzer/fuzzer.go
ct.TerminationMessagePolicy = "File" }, func(ep *core.EphemeralContainer, c fuzz.Continue) { c.FuzzNoCustom(ep) // fuzz self without calling this function again ep.EphemeralContainerCommon.TerminationMessagePath = "/" + ep.TerminationMessagePath // Must be non-empty ep.EphemeralContainerCommon.TerminationMessagePolicy = "File" },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 04:32:01 UTC 2024 - 18.5K bytes - Viewed (0) -
pilot/pkg/xds/eds_sh_test.go
} for addr, weight := range expected.weights { var match *endpoint.LbEndpoint for _, ep := range lbEndpoints { if ep.GetEndpoint().Address.GetSocketAddress().Address == addr { match = ep break } } if match == nil { t.Fatalf("couldn't find endpoint with address %s: found %v", addr, getLbEndpointAddrs(lbEndpoints)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 10.8K bytes - Viewed (0) -
cmd/bucket-listobjects-handlers.go
if len(globalProxyEndpoints) == 0 { return false } if index < 0 || index >= len(globalProxyEndpoints) { return false } ep := globalProxyEndpoints[index] if ep.IsLocal { return false } return proxyRequest(ctx, w, r, ep) } // ListObjectsV1Handler - GET Bucket (List Objects) Version 1. // --------------------------
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 11.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/feature/feature_support_checker_test.go
// Mock Etcd client mockClient := &MockEtcdClient{EndpointVersion: round.endpointsVersion} ctx := context.Background() for _, ep := range mockClient.Endpoints() { err := testFeatureSupportChecker.clientSupportsRequestWatchProgress(ctx, mockClient, ep) assert.Equal(t, round.expectedError, err) } supported := testFeatureSupportChecker.Supports(storage.RequestWatchProgress)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
} if svcInfo.SessionAffinityType() == v1.ServiceAffinityClientIP { // Generate the per-endpoint affinity sets for _, ep := range allLocallyReachableEndpoints { epInfo, ok := ep.(*endpointInfo) if !ok { proxier.logger.Error(nil, "Failed to cast endpointsInfo", "endpointsInfo", ep) continue } // Create a set to store current affinity mappings. As
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pkg/registry/core/endpoint/storage/storage.go
var _ rest.ShortNamesProvider = &REST{} // ShortNames implements the ShortNamesProvider interface. Returns a list of short names for a resource. func (r *REST) ShortNames() []string { return []string{"ep"}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:19 UTC 2022 - 2.2K bytes - Viewed (0)