(ctx context.Context)
| 300 | } |
| 301 | |
| 302 | func (t *task) Pause(ctx context.Context) error { |
| 303 | ctx, span := tracing.StartSpan(ctx, "task.Pause", |
| 304 | tracing.WithAttribute("task.id", t.ID()), |
| 305 | ) |
| 306 | defer span.End() |
| 307 | _, err := t.client.TaskService().Pause(ctx, &tasks.PauseTaskRequest{ |
| 308 | ContainerID: t.id, |
| 309 | }) |
| 310 | return errgrpc.ToNative(err) |
| 311 | } |
| 312 | |
| 313 | func (t *task) Resume(ctx context.Context) error { |
| 314 | ctx, span := tracing.StartSpan(ctx, "task.Resume", |
no test coverage detected