Method stopByMethod

internal/idlewatcher/watcher.go:497–540

()

}

func (w *Watcher) stopByMethod() error {
	// no need singleflight here because it will only be called once every tick.

	// if the container is not running, skip and stop dependencies.
	if !w.running() {
		if err := w.stopDependencies(); err != nil {
			return w.newWatcherError(err)
		}
		return nil
	}

	cfg := w.cfg
	ctx, cancel := context.WithTimeout(context.Background(), cfg.StopTimeout)
	defer cancel()

	// stop itself first.
	var err error
	p := w.provider.Load()
	if p == nil {
		return errors.New("provider not set")
	}
	switch cfg.StopMethod {
	case types.ContainerStopMethodPause:
		err = p.ContainerPause(ctx)
	case types.ContainerStopMethodStop:
		err = p.ContainerStop(ctx, cfg.StopSignal, int(math.Ceil(cfg.StopTimeout.Seconds())))
	case types.ContainerStopMethodKill:
		err = p.ContainerKill(ctx, cfg.StopSignal)
	default:
		err = w.newWatcherError(fmt.Errorf("unexpected stop method: %q", cfg.StopMethod))
	}

	if err != nil {
		return w.newWatcherError(err)
	}

	w.l.Info().Msg("container stopped")

	// then stop dependencies.
	if err := w.stopDependencies(); err != nil {
		return w.newWatcherError(err)
	}
	return nil
}

func (w *Watcher) resetIdleTimer() {
	w.idleTicker.Reset(w.cfg.IdleTimeout)