mirror of
https://github.com/sablierapp/sablier.git
synced 2025-12-24 14:31:51 +01:00
edbf7d9d15
* test(kubernetes): use testcontainers for test
* fix(kubernetes): get state properly reports the workload as down when scaled to 0
* refactor(kubernetes): split provider in multiple files
* refactor(provider): use Instance prefix for actions
* test(testcontainers): use provider.PullImage
* squash
* Revert "test(testcontainers): use provider.PullImage"
This reverts commit 6f958c48a5.
* test: add random generator thread safety
32 lines
1.1 KiB
Go
32 lines
1.1 KiB
Go
package docker
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"github.com/docker/docker/api/types/container"
|
|
"log/slog"
|
|
)
|
|
|
|
func (p *DockerClassicProvider) InstanceStop(ctx context.Context, name string) error {
|
|
p.l.DebugContext(ctx, "stopping container", slog.String("name", name))
|
|
err := p.Client.ContainerStop(ctx, name, container.StopOptions{})
|
|
if err != nil {
|
|
p.l.ErrorContext(ctx, "cannot stop container", slog.String("name", name), slog.Any("error", err))
|
|
return fmt.Errorf("cannot stop container %s: %w", name, err)
|
|
}
|
|
|
|
p.l.DebugContext(ctx, "waiting for container to stop", slog.String("name", name))
|
|
waitC, errC := p.Client.ContainerWait(ctx, name, container.WaitConditionNotRunning)
|
|
select {
|
|
case <-waitC:
|
|
p.l.DebugContext(ctx, "container stopped", slog.String("name", name))
|
|
return nil
|
|
case err := <-errC:
|
|
p.l.ErrorContext(ctx, "cannot wait for container to stop", slog.String("name", name), slog.Any("error", err))
|
|
return fmt.Errorf("cannot wait for container %s to stop: %w", name, err)
|
|
case <-ctx.Done():
|
|
p.l.ErrorContext(ctx, "context cancelled while waiting for container to stop", slog.String("name", name))
|
|
return ctx.Err()
|
|
}
|
|
}
|