MCPcopy
hub / github.com/containerd/containerd / Status

Method Status

client/task.go:324–340  ·  view source on GitHub ↗
(ctx context.Context)

Source from the content-addressed store, hash-verified

322}
323
324func (t *task) Status(ctx context.Context) (Status, error) {
325 r, err := t.client.TaskService().Get(ctx, &tasks.GetRequest{
326 ContainerID: t.id,
327 })
328 if err != nil {
329 return Status{}, errgrpc.ToNative(err)
330 }
331 status := ProcessStatus(strings.ToLower(r.Process.Status.String()))
332 exitStatus := r.Process.ExitStatus
333 exitTime := protobuf.FromTimestamp(r.Process.ExitedAt)
334
335 return Status{
336 Status: status,
337 ExitStatus: exitStatus,
338 ExitTime: exitTime,
339 }, nil
340}
341
342func (t *task) Wait(ctx context.Context) (<-chan ExitStatus, error) {
343 c := make(chan ExitStatus, 1)

Callers 3

DeleteMethod · 0.95
CheckpointMethod · 0.95
MetricsMethod · 0.95

Calls 5

FromTimestampFunction · 0.92
ProcessStatusTypeAlias · 0.85
TaskServiceMethod · 0.80
GetMethod · 0.65
StringMethod · 0.45

Tested by

no test coverage detected