- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 355 for Id (0.05 sec)
-
pilot/pkg/serviceregistry/kube/controller/multicluster.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
src/crypto/tls/cipher_suites.go
// (e.g. "TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256"), or a fallback representation // of the ID value if the cipher suite is not implemented by this package. func CipherSuiteName(id uint16) string { for _, c := range CipherSuites() { if c.ID == id { return c.Name } } for _, c := range InsecureCipherSuites() { if c.ID == id { return c.Name } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 25.5K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_gc.go
// Containers in known state could be running, we should try // to stop it before removal. id := kubecontainer.ContainerID{ Type: cgc.manager.runtimeName, ID: containers[i].id, } message := "Container is in unknown state, try killing it before removal" if err := cgc.manager.killContainer(ctx, nil, id, containers[i].name, message, reasonUnknown, nil, nil); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 15.3K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
return nil, err } var h healingTracker _, err = h.UnmarshalMsg(b) if err != nil { return nil, err } if h.ID != diskID && h.ID != "" { return nil, fmt.Errorf("loadHealingTracker: drive id mismatch expected %s, got %s", h.ID, diskID) } h.disk = disk h.ID = diskID h.mu = &sync.RWMutex{} return &h, nil } // newHealingTracker will create a new healing tracker for the disk.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 15:12:32 UTC 2024 - 14.5K bytes - Viewed (0) -
internal/dsync/drwmutex.go
isReadLock := false return dm.lockBlocking(ctx, cancel, id, source, isReadLock, opts) } // RLock holds a read lock on dm. // // If one or more read locks are already in use, it will grant another lock. // Otherwise the calling go routine blocks until the mutex is available. func (dm *DRWMutex) RLock(id, source string) { isReadLock := true
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.7K bytes - Viewed (0) -
src/runtime/traceruntime.go
// Careful: don't use the event writer. We never want status or in-progress events // to trigger more in-progress events. w.w = w.w.writeProcStatus(uint64(pp.id), traceProcSyscallAbandoned, pp.trace.inSweep) } w.commit(traceEvProcSteal, traceArg(pp.id), pp.trace.nextSeq(tl.gen), traceArg(mStolenFrom)) } // HeapAlloc emits a HeapAlloc event. func (tl traceLocker) HeapAlloc(live uint64) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 25.7K bytes - Viewed (0) -
pkg/volume/util/fsquota/quota_linux_test.go
} func (v testVolumeQuota) SetQuotaOnDir(dir string, id common.QuotaID, _ int64) error { odir, ok := testIDQuotaMap[id] if ok && dir != odir { return fmt.Errorf("ID %v is already in use", id) } oid, ok := testQuotaIDMap[dir] if ok && id != oid { return fmt.Errorf("directory %s already has a quota applied", dir) } testQuotaIDMap[dir] = id testIDQuotaMap[id] = dir return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 20.7K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1_test.go
Nodes: []*podresourcesapi.NUMANode{ { ID: 0, }, }, }, }, { ResourceName: "resource-mm", DeviceIds: []string{"devMM"}, Topology: &podresourcesapi.TopologyInfo{ Nodes: []*podresourcesapi.NUMANode{ { ID: 0, }, { ID: 1, }, }, }, }, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 45.9K bytes - Viewed (0) -
pkg/kubelet/logs/container_log_manager.go
ok = true id := key resp, err := c.runtimeService.ContainerStatus(ctx, id, false) if err != nil { klog.ErrorS(err, "Failed to get container status", "worker", worker, "containerID", id) return } if resp.GetStatus() == nil { klog.ErrorS(err, "Container status is nil", "worker", worker, "containerID", id) return } path := resp.GetStatus().GetLogPath()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 15K bytes - Viewed (0) -
internal/event/target/amqp.go
queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil { return nil, fmt.Errorf("unable to initialize the queue store of AMQP `%s`: %w", id, err) } } target := &AMQPTarget{ id: event.TargetID{ID: id, Name: "amqp"}, args: args, loggerOnce: loggerOnce,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 10K bytes - Viewed (0)