(ctx context.Context)
| 247 | } |
| 248 | |
| 249 | func (t *task) Start(ctx context.Context) error { |
| 250 | ctx, span := tracing.StartSpan(ctx, tracing.Name("client.task", "Start"), |
| 251 | tracing.WithAttribute("task.id", t.ID()), |
| 252 | tracing.WithNamespace(ctx), |
| 253 | ) |
| 254 | defer span.End() |
| 255 | |
| 256 | r, err := t.client.TaskService().Start(ctx, &tasks.StartRequest{ |
| 257 | ContainerID: t.id, |
| 258 | }) |
| 259 | if err != nil { |
| 260 | if t.io != nil { |
| 261 | t.io.Cancel() |
| 262 | t.io.Close() |
| 263 | } |
| 264 | return errgrpc.ToNative(err) |
| 265 | } |
| 266 | span.SetAttributes(tracing.Attribute("task.pid", r.Pid)) |
| 267 | t.pid = r.Pid |
| 268 | return nil |
| 269 | } |
| 270 | |
| 271 | func (t *task) Kill(ctx context.Context, s syscall.Signal, opts ...KillOpts) error { |
| 272 | ctx, span := tracing.StartSpan(ctx, tracing.Name("client.task", "Kill"), |
nothing calls this directly
no test coverage detected