- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,430 for Id (0.03 sec)
-
src/runtime/trace/annotation.go
// trace.WithRegion(ctx, "remainingWork", remainingWork) // }() func NewTask(pctx context.Context, taskType string) (ctx context.Context, task *Task) { pid := fromContext(pctx).id id := newID() userTaskCreate(id, pid, taskType) s := &Task{id: id} return context.WithValue(pctx, traceContextKey{}, s), s // We allocate a new task even when // the tracing is disabled because the context and task
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 20 00:47:09 UTC 2023 - 6.1K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/sysvshm_unix.go
// shared memory identifier id. func SysvShmAttach(id int, addr uintptr, flag int) ([]byte, error) { addr, errno := shmat(id, addr, flag) if errno != nil { return nil, errno } // Retrieve the size of the shared memory to enable slice creation var info SysvShmDesc _, err := SysvShmCtl(id, IPC_STAT, &info) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 16:12:58 UTC 2024 - 1.4K bytes - Viewed (0) -
plugin/pkg/auth/authenticator/token/bootstrap/bootstrap.go
// "system:bootstrappers" group and with the "system:bootstrap:(token-id)" username. // // All secrets must be of type "bootstrap.kubernetes.io/token". An example secret: // // apiVersion: v1 // kind: Secret // metadata: // # Name MUST be of form "bootstrap-token-( token id )". // name: bootstrap-token-( token id ) // namespace: kube-system // # Only secrets of this type will be evaluated.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 30 20:38:15 UTC 2023 - 5.1K bytes - Viewed (0) -
cmd/logging.go
logger.LogIf(ctx, "replication", err, errKind...) } func replLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) { logger.LogOnceIf(ctx, "replication", err, id, errKind...) } func iamLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) { logger.LogOnceIf(ctx, "iam", err, id, errKind...) } func iamLogIf(ctx context.Context, err error, errKind ...interface{}) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 7.2K bytes - Viewed (0) -
internal/grid/muxserver.go
func (m *muxServer) disconnect(msg string, locked bool) { if debugPrint { fmt.Println("Mux", m.ID, "disconnecting. Reason:", msg) } if msg != "" { m.send(message{Op: OpMuxServerMsg, MuxID: m.ID, Flags: FlagPayloadIsErr | FlagEOF, Payload: []byte(msg)}) } else { m.send(message{Op: OpDisconnectClientMux, MuxID: m.ID}) } // Unlock, since we are calling deleteMux, which will call close - which will lock recvMu.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/profile/prune.go
foundUser := false for i := len(sample.Location) - 1; i >= 0; i-- { id := sample.Location[i].ID if !prune[id] && !pruneBeneath[id] { foundUser = true continue } if !foundUser { continue } if prune[id] { sample.Location = sample.Location[i+1:] break } if pruneBeneath[id] { sample.Location = sample.Location[i:] break } } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 22 18:58:12 UTC 2022 - 5.5K bytes - Viewed (0) -
pkg/kubelet/container/cache.go
c.timestamp = ×tamp // Notify all the subscribers if the condition is met. for id := range c.subscribers { c.notify(id, *c.timestamp) } } func makeDefaultData(id types.UID) *data { return &data{status: &PodStatus{ID: id}, err: nil} } func (c *cache) get(id types.UID) *data { d, ok := c.pods[id] if !ok { // Cache should store *all* pod/container information known by the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 07:37:01 UTC 2023 - 6.6K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/numa_info_test.go
opts: PolicyOptions{ PreferClosestNUMA: true, }, }, { name: "positive test 4 nodes", topology: []cadvisorapi.Node{ { Id: 0, }, { Id: 1, }, { Id: 2, }, { Id: 3, }, }, expectedNUMAInfo: &NUMAInfo{ Nodes: []int{0, 1, 2, 3}, NUMADistances: NUMADistances{ 0: nil, 1: nil,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 16:52:14 UTC 2022 - 11.6K bytes - Viewed (0) -
internal/event/target/kafka.go
initOnce once.Init id event.TargetID args KafkaArgs client sarama.Client producer sarama.SyncProducer config *sarama.Config store store.Store[event.Event] batch *store.Batch[string, *sarama.ProducerMessage] loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *KafkaTarget) ID() event.TargetID { return target.id }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 15:02:59 UTC 2024 - 13.1K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle.go
// unique id to rules with empty ID. func ParseLifecycleConfigWithID(r io.Reader) (*Lifecycle, error) { var lc Lifecycle if err := xml.NewDecoder(r).Decode(&lc); err != nil { return nil, err } // assign a unique id for rules with empty ID for i := range lc.Rules { if lc.Rules[i].ID == "" { lc.Rules[i].ID = uuid.New().String() } } return &lc, nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 01:12:48 UTC 2024 - 17.9K bytes - Viewed (0)