- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 244 for based (0.04 sec)
-
cmd/erasure-common.go
mu.Unlock() }() } wg.Wait() return newDisks } func (er erasureObjects) getOnlineLocalDisks() (newDisks []StorageAPI) { disks := er.getOnlineDisks() // Based on the random shuffling return back randomized disks. r := rand.New(rand.NewSource(time.Now().UnixNano())) for _, i := range r.Perm(len(disks)) { if disks[i] != nil && disks[i].IsLocal() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
pkg/kubelet/util/manager/cache_based_manager.go
} // cacheBasedManager keeps a store with objects necessary // for registered pods. Different implementations of the store // may result in different semantics for freshness of objects // (e.g. ttl-based implementation vs watch-based implementation). type cacheBasedManager struct { objectStore Store getReferencedObjects func(*v1.Pod) sets.Set[string] lock sync.Mutex registeredPods map[objectKey]*v1.Pod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 8.3K bytes - Viewed (0) -
platforms/core-runtime/instrumentation-agent-services/src/main/java/org/gradle/internal/instrumentation/agent/AgentStatus.java
*/ @ServiceScope(Scope.Global.class) public interface AgentStatus { /** * Checks if the agent-based bytecode instrumentation is enabled for the current JVM process. * * @return {@code true} if the agent instrumentation should be used */ boolean isAgentInstrumentationEnabled(); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 2K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/TapiAgentInstrumentationCrossVersionSpec.groovy
@TargetGradleVersion("current") class TapiAgentInstrumentationCrossVersionSpec extends ToolingApiSpecification { private String buildOutput def setup() { // TODO(mlopatkin) Figure a way to have agent-based instrumentation in the embedded TAPI mode. toolingApi.requireDaemons() } def "agent is enabled in TAPI by default"() { withDumpAgentStatusTask() when: runDumpTaskWithTapi()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 3K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/FirSyntheticFunctionInterfaceSourceProvider.kt
import org.jetbrains.kotlin.name.FqName import org.jetbrains.kotlin.name.Name import org.jetbrains.kotlin.name.StandardClassIds import org.jetbrains.kotlin.psi.KtClassOrObject //todo introduce LibraryModificationTracker based cache? internal object FirSyntheticFunctionInterfaceSourceProvider { fun findPsi(fir: FirDeclaration): PsiElement? { return when (fir) { is FirSimpleFunction -> provideSourceForInvokeFunction(fir)
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Thu Jun 06 17:44:50 UTC 2024 - 2.5K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheDirectoryPluginIntegrationTest.groovy
* limitations under the License. */ package org.gradle.internal.cc.impl class ConfigurationCacheDirectoryPluginIntegrationTest extends AbstractConfigurationCacheIntegrationTest { def "directory based plugins are instrumented and violations are reported"() { generateExternalPlugin("first", "FirstPlugin", "first.property") generateExternalPlugin("second", "SecondPlugin", "second.property")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 2.8K bytes - Viewed (0) -
src/run.bash
# execution. Defaults to 1, unless GO_BUILDER_NAME is also specified, # in which case it defaults to 10. # # GO_BUILDER_NAME: the name of the Go builder that's running the tests. # Some tests are conditionally enabled or disabled based on the builder # name or the builder name being non-empty. # # GO_TEST_SHORT: if set to a non-empty, false-ish string, run tests in "-short=false" mode. # This environment variable is an internal implementation detail between the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 15:02:23 UTC 2024 - 1.7K bytes - Viewed (0) -
pilot/pkg/xds/xdsgen.go
g = s.Generators["api"] // default to "MCP" generators - any type supported by store } } return g } // Push an XDS resource for the given connection. Configuration will be generated // based on the passed in generator. Based on the updates field, generators may // choose to send partial or even no response if there are no changes. func (s *DiscoveryServer) pushXds(con *Connection, w *model.WatchedResource, req *model.PushRequest) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container_windows.go
wcr := m.calculateWindowsResources(container.Resources.Limits.Cpu(), container.Resources.Limits.Memory()) return wcr } // calculateWindowsResources will create the windowsContainerResources type based on the provided CPU and memory resource requests, limits func (m *kubeGenericRuntimeManager) calculateWindowsResources(cpuLimit, memoryLimit *resource.Quantity) *runtimeapi.WindowsContainerResources {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 8K bytes - Viewed (0) -
docs/en/docs/how-to/nosql-databases-couchbase.md
You can adapt it to any other NoSQL database like: * **MongoDB** * **Cassandra** * **CouchDB** * **ArangoDB** * **ElasticSearch**, etc. !!! tip
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat May 18 23:43:13 UTC 2024 - 6K bytes - Viewed (0)