docker

func (*DockerOrchestrator) CreateNetwork ¶

func (d *DockerOrchestrator) CreateNetwork(ctx context.Context, name string) (string, error)

func (*DockerOrchestrator) EnsureImage ¶

func (d *DockerOrchestrator) EnsureImage(ctx context.Context, imageName string) error

EnsureImage pulls imageName if it is not present in the local Docker image cache. Call this explicitly for infrastructure images before starting their containers. Do NOT call this for app/migration images — those must be built locally.

func (*DockerOrchestrator) GetContainerInspect ¶

func (d *DockerOrchestrator) GetContainerInspect(ctx context.Context, id string) (types.ContainerJSON, error)

func (*DockerOrchestrator) PullImage ¶

func (d *DockerOrchestrator) PullImage(ctx context.Context, imageName string) error

func (*DockerOrchestrator) RemoveNetwork ¶

func (d *DockerOrchestrator) RemoveNetwork(ctx context.Context, id string) error

func (*DockerOrchestrator) StartContainer ¶

func (d *DockerOrchestrator) StartContainer(ctx context.Context, config *container.Config, hostConfig *container.HostConfig, networkingConfig *network.NetworkingConfig, containerName string) (string, error)

func (*DockerOrchestrator) StopAndRemoveContainer ¶

func (d *DockerOrchestrator) StopAndRemoveContainer(ctx context.Context, id string) error

func (*DockerOrchestrator) StreamLogs ¶

func (d *DockerOrchestrator) StreamLogs(ctx context.Context, id string, stdout io.Writer, stderr io.Writer) error

func (*DockerOrchestrator) WaitForContainer ¶

func (d *DockerOrchestrator) WaitForContainer(ctx context.Context, id string) (<-chan container.WaitResponse, <-chan error)

func (*DockerOrchestrator) WaitHTTP ¶

func (d *DockerOrchestrator) WaitHTTP(ctx context.Context, url string, timeout time.Duration) error

func (*DockerOrchestrator) WaitTCPInternal ¶

func (d *DockerOrchestrator) WaitTCPInternal(ctx context.Context, networkName, address string, timeout time.Duration) error

WaitTCPInternal waits for a TCP service to be available. Uses direct TCP dial from host instead of spawning Alpine containers. The address parameter should be in "host:port" format (e.g., "localhost:3306").