- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 244 for reregistering (0.16 sec)
-
pkg/kubelet/pluginmanager/reconciler/reconciler.go
if dswPlugin.SocketPath == registeredPlugin.SocketPath && dswPlugin.Timestamp != registeredPlugin.Timestamp { klog.V(5).InfoS("An updated version of plugin has been found, unregistering the plugin first before reregistering", "plugin", registeredPlugin) unregisterPlugin = true break } } } if unregisterPlugin {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 6.2K bytes - Viewed (0) -
pkg/kubelet/util/manager/manager.go
limitations under the License. */ package manager import ( v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/types" ) // Manager is the interface for registering and unregistering // objects referenced by pods in the underlying cache and // extracting those from that cache if needed. type Manager interface { // Get object by its namespace and name.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 10 02:22:52 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/handler.go
klog.V(2).InfoS("Registering plugin at endpoint", "plugin", pluginName, "endpoint", endpoint) return s.connectClient(pluginName, endpoint) } func (s *server) DeRegisterPlugin(pluginName string) { klog.V(2).InfoS("Deregistering plugin", "plugin", pluginName) client := s.getClient(pluginName) if client != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/operationexecutor/operation_executor.go
package operationexecutor import ( "time" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/cache" "k8s.io/kubernetes/pkg/util/goroutinemap" ) // OperationExecutor defines a set of operations for registering and unregistering // a plugin that are executed with a NewGoRoutineMap which // prevents more than one operation from being triggered on the same socket path. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 4.4K bytes - Viewed (0) -
pkg/kubelet/secret/secret_manager.go
"k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/watch" "k8s.io/utils/clock" ) // Manager manages Kubernetes secrets. This includes retrieving // secrets or registering/unregistering them via Pods. type Manager interface { // Get secret by secret namespace and name. GetSecret(namespace, name string) (*v1.Secret, error) // WARNING: Register/UnregisterPod functions should be efficient,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 5.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/buildtree/BuildInclusionCoordinator.java
} finally { if (added) { registering.remove(build); } } } private void doRegisterSubstitutions(CompositeBuildParticipantBuildState build) { registering.add(build); try { substitutionRegistry.registerSubstitutionsFor(build); } finally { registering.remove(build); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 4.6K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/kotlinDsl/containers-delegated-properties/kotlin/build.gradle.kts
plugins { `java-library` } // tag::delegated-properties[] val check by tasks.existing val myTask1 by tasks.registering val compileJava by tasks.existing(JavaCompile::class) val myCopy1 by tasks.registering(Copy::class) val assemble by tasks.existing { dependsOn(myTask1) // <1> } val myTask2 by tasks.registering { description = "Some meaningful words" } val test by tasks.existing(Test::class) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 579 bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/test/kotlin/org/gradle/kotlin/dsl/TaskContainerExtensionsTest.kt
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 7.9K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/NamedDomainObjectContainerExtensions.kt
} /** * Property delegate for registering new elements in the container. * * `tasks { val rebuild by registering }` * * @param T the domain object type * @param C the concrete container type */ inline val <T : Any, C : NamedDomainObjectContainer<T>> C.registering: RegisteringDomainObjectDelegateProvider<out C> get() = RegisteringDomainObjectDelegateProvider.of(this)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 19 22:09:44 UTC 2024 - 15.6K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/tasks/shouldRunAfterWithCycle/kotlin/build.gradle.kts
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 323 bytes - Viewed (0)