(ctx context.Context, s syscall.Signal, opts ...KillOpts)
| 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"), |
| 273 | tracing.WithAttribute("task.id", t.ID()), |
| 274 | tracing.WithAttribute("task.pid", int(t.Pid())), |
| 275 | tracing.WithNamespace(ctx), |
| 276 | ) |
| 277 | defer span.End() |
| 278 | |
| 279 | var i KillInfo |
| 280 | for _, o := range opts { |
| 281 | if err := o(ctx, &i); err != nil { |
| 282 | return err |
| 283 | } |
| 284 | } |
| 285 | |
| 286 | span.SetAttributes( |
| 287 | tracing.Attribute("task.exec.id", i.ExecID), |
| 288 | tracing.Attribute("task.exec.killall", i.All), |
| 289 | ) |
| 290 | _, err := t.client.TaskService().Kill(ctx, &tasks.KillRequest{ |
| 291 | Signal: uint32(s), |
| 292 | ContainerID: t.id, |
| 293 | ExecID: i.ExecID, |
| 294 | All: i.All, |
| 295 | }) |
| 296 | if err != nil { |
| 297 | return errgrpc.ToNative(err) |
| 298 | } |
| 299 | return nil |
| 300 | } |
| 301 | |
| 302 | func (t *task) Pause(ctx context.Context) error { |
| 303 | ctx, span := tracing.StartSpan(ctx, "task.Pause", |
nothing calls this directly
no test coverage detected