- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 442 for inNode (0.23 sec)
-
pkg/registry/registrytest/node.go
func (r *NodeRegistry) CreateNode(ctx context.Context, node *api.Node) error { r.Lock() defer r.Unlock() r.Node = node.Name r.Nodes.Items = append(r.Nodes.Items, *node) return r.Err } func (r *NodeRegistry) UpdateNode(ctx context.Context, node *api.Node) error { r.Lock() defer r.Unlock() for i, item := range r.Nodes.Items { if item.Name == node.Name { r.Nodes.Items[i] = *node return r.Err } } return r.Err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 23:13:50 UTC 2024 - 2.8K bytes - Viewed (0) -
platforms/core-configuration/core-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/core/SerializedLambdaParametersCheckingCodec.kt
import org.gradle.internal.serialize.graph.decodeBean import org.gradle.internal.serialize.graph.logUnsupported import org.objectweb.asm.Type import org.objectweb.asm.Type.getArgumentTypes import java.lang.invoke.SerializedLambda import kotlin.reflect.KClass /** * In encoding a [SerializedLambda], this codec checks if the lambda parameter types are allowed in the configuration cache.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 3.4K bytes - Viewed (0) -
hack/make-rules/test-cmd.sh
kube::log::status "Building kube-apiserver" make -C "${KUBE_ROOT}" WHAT="cmd/kube-apiserver" # Start kube-apiserver kube::log::status "Starting kube-apiserver" # Admission Controllers to invoke prior to persisting objects in cluster ENABLE_ADMISSION_PLUGINS="LimitRanger,ResourceQuota"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 09:10:14 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/proxy/node.go
// OnNodeAdd is a handler for Node creates. func (n *NodeEligibleHandler) OnNodeAdd(node *v1.Node) { n.HealthServer.SyncNode(node) } // OnNodeUpdate is a handler for Node updates. func (n *NodeEligibleHandler) OnNodeUpdate(_, node *v1.Node) { n.HealthServer.SyncNode(node) } // OnNodeDelete is a handler for Node deletes. func (n *NodeEligibleHandler) OnNodeDelete(node *v1.Node) { n.HealthServer.SyncNode(node) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/support/KotlinScriptHost.kt
import org.gradle.groovy.scripts.ScriptSource import org.gradle.internal.service.ServiceRegistry import org.gradle.kotlin.dsl.accessors.ProjectAccessorsClassPathGenerator import org.gradle.kotlin.dsl.invoke import org.gradle.util.internal.ConfigureUtil.configureByMap import java.io.File class KotlinScriptHost<out T : Any> internal constructor( val target: T, val scriptSource: ScriptSource,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 01 13:09:45 UTC 2024 - 4.6K bytes - Viewed (0) -
cni/pkg/nodeagent/fakes_test.go
type fakeNs struct { closed *atomic.Bool fd uintptr inode uint64 } func newFakeNs(fd uintptr) *fakeNs { // the fake inode is the fd! magic. return &fakeNs{closed: &atomic.Bool{}, fd: fd, inode: uint64(fd)} } func newFakeNsInode(fd uintptr, inode uint64) *fakeNs { return &fakeNs{closed: &atomic.Bool{}, fd: fd, inode: inode} } // Fd returns the file descriptor func (f *fakeNs) Fd() uintptr {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 3.9K bytes - Viewed (0) -
docs/en/docs/advanced/websockets.md
If you need something easy to integrate with FastAPI but that is more robust, supported by Redis, PostgreSQL or others, check <a href="https://github.com/encode/broadcaster" class="external-link" target="_blank">encode/broadcaster</a>. ## More info To learn more about the options, check Starlette's documentation for:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu May 02 22:37:31 UTC 2024 - 6.2K bytes - Viewed (0) -
tools/istio-iptables/pkg/README.md
# istio-iptables This is an `iptables` wrapper library for Istio. It is similar in basic concept to [](https://github.com/kubernetes-sigs/iptables-wrappers) but Istio needs to invoke `iptables` from a more varied set of contexts than K8s, and so cannot simply rely on "default" binary aliases to `iptables`/`iptables-save`/`iptables-restore`
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 17:46:23 UTC 2024 - 3.7K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/PermissionHelperTest.java
public void test_encode() { assertNull(permissionHelper.encode(null)); assertNull(permissionHelper.encode("")); assertNull(permissionHelper.encode(" ")); assertNull(permissionHelper.encode("{user}")); assertNull(permissionHelper.encode("{role}")); assertNull(permissionHelper.encode("{group}")); assertNull(permissionHelper.encode("(allow)"));
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 5.9K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/HEAD/core.v1.Node.yaml
apiVersion: v1 kind: Node metadata: annotations: annotationsKey: annotationsValue creationTimestamp: "2008-01-01T01:01:01Z" deletionGracePeriodSeconds: 10 deletionTimestamp: "2009-01-01T01:01:01Z" finalizers: - finalizersValue generateName: generateNameValue generation: 7 labels: labelsKey: labelsValue managedFields: - apiVersion: apiVersionValue fieldsType: fieldsTypeValue fieldsV1: {}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 13 23:06:39 UTC 2024 - 2.9K bytes - Viewed (0)