- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,495 for Id (0.02 sec)
-
internal/event/target/webhook.go
if err := queueStore.Open(); err != nil { cancel() return nil, fmt.Errorf("unable to initialize the queue store of Webhook `%s`: %w", id, err) } } target := &WebhookTarget{ id: event.TargetID{ID: id, Name: "webhook"}, args: args, loggerOnce: loggerOnce, transport: transport, store: queueStore, cancel: cancel, cancelCh: ctx.Done(), }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
n.Lock() defer n.Unlock() oldDefaultNetwork := n.network n.network = network.ID(nw) return oldDefaultNetwork != n.network } func (n *networkManager) networkFromSystemNamespace() network.ID { n.RLock() defer n.RUnlock() return n.network } func (n *networkManager) networkFromMeshNetworks(endpointIP string) network.ID { n.RLock() defer n.RUnlock() if n.networkFromMeshConfig != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/provider/providers.go
package provider // ID defines underlying platform supporting service registry type ID string const ( // Mock is a service registry that contains 2 hard-coded test services Mock ID = "Mock" // Kubernetes is a service registry backed by k8s API server Kubernetes ID = "Kubernetes" // External is a service registry for externally provided ServiceEntries External ID = "External" )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 20 16:41:15 UTC 2022 - 1K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
"fmt" "runtime" "sync/atomic" "testing" "time" ) const ( id = "1234-5678" source = "main.go" ) func testSimpleWriteLock(t *testing.T, duration time.Duration) (locked bool) { drwm1 := NewDRWMutex(ds, "simplelock") ctx1, cancel1 := context.WithCancel(context.Background()) if !drwm1.GetRLock(ctx1, cancel1, id, source, Options{Timeout: time.Second}) { panic("Failed to acquire read lock") }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 9.7K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/tighten.go
top := changed[0] changed = changed[1:] mem := startMem[top.ID] for i, p := range top.Preds { pb := p.b if endMem[pb.ID] != nil { continue } if mem.Op == OpPhi && mem.Block == top { endMem[pb.ID] = mem.Args[i] } else { endMem[pb.ID] = mem } if startMem[pb.ID] == nil { startMem[pb.ID] = endMem[pb.ID] changed = append(changed, pb) } } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 16 01:01:38 UTC 2023 - 7.7K bytes - Viewed (0) -
cmd/kubeadm/app/util/staticpod/utils_linux.go
pod, usersAndGroups.Users.ID(kubeadmconstants.KubeControllerManagerUserName), usersAndGroups.Groups.ID(kubeadmconstants.KubeControllerManagerUserName), usersAndGroups.Groups.ID(kubeadmconstants.ServiceAccountKeyReadersGroupName), users.UpdatePathOwnerAndPermissions, cfg, ) case kubeadmconstants.KubeScheduler: return runKubeSchedulerAsNonRoot( pod, usersAndGroups.Users.ID(kubeadmconstants.KubeSchedulerUserName),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 14:41:12 UTC 2023 - 8.4K bytes - Viewed (0) -
src/internal/coverage/pkid.go
// registered list: // slot: 0 path='internal/cpu' hard-coded id: 1 // slot: 1 path='internal/goarch' hard-coded id: 2 // slot: 2 path='internal/runtime/atomic' hard-coded id: 3 // slot: 3 path='internal/goos' // slot: 4 path='runtime/internal/sys' hard-coded id: 5 // slot: 5 path='internal/abi' hard-coded id: 4 // slot: 6 path='runtime/internal/math' hard-coded id: 6 // slot: 7 path='internal/bytealg' hard-coded id: 7
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 3.1K bytes - Viewed (0) -
pkg/kubelet/prober/results/results_manager.go
updates: make(chan Update, 20), } } func (m *manager) Get(id kubecontainer.ContainerID) (Result, bool) { m.RLock() defer m.RUnlock() result, found := m.cache[id] return result, found } func (m *manager) Set(id kubecontainer.ContainerID, result Result, pod *v1.Pod) { if m.setInternal(id, result) { m.updates <- Update{id, result, pod.UID} } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 13 07:12:54 UTC 2019 - 3.4K bytes - Viewed (0) -
pkg/kubelet/cm/helpers.go
continue } podUID := podSandboxMap[c.PodSandboxId] containerMap.Add(podUID, c.Metadata.Name, c.Id) if c.State == runtimeapi.ContainerState_CONTAINER_RUNNING { klog.V(4).InfoS("Container reported running", "podSandboxId", c.PodSandboxId, "podUID", podUID, "containerName", c.Metadata.Name, "containerId", c.Id) runningSet.Insert(c.Id) } } return containerMap, runningSet
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 2.8K bytes - Viewed (0) -
src/crypto/tls/boring_test.go
t.Errorf("client offered disallowed version %#x", v) } } for _, id := range hello.cipherSuites { if !isBoringCipherSuite(id) { t.Errorf("client offered disallowed suite %#x", id) } } for _, id := range hello.supportedCurves { if !isBoringCurve(id) { t.Errorf("client offered disallowed curve %d", id) } } for _, sigHash := range hello.supportedSignatureAlgorithms {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:45:37 UTC 2024 - 19.4K bytes - Viewed (0)