container

type Block struct {
	// contains filtered or unexported fields
}

type Bridge struct {
	Client       *http.Client
	BaseURL      string
	Timeout      time.Duration
	MaxBodyBytes int64
}

type CLIRunner struct {
	// Docker is the docker binary name or path (default "docker").
	Docker string
	// Run is optional; when set, tests can intercept command execution.
	// argv[0] is the docker binary. Returns stdout, stderr, error.
	Run func(ctx context.Context, name string, args ...string) (stdout, stderr string, err error)
}

type Config struct {
	Image         string
	Nested        map[string]any // opaque JSON for ASTRATE_FLOW_CONFIG
	ContainerPort int
	Timeout       time.Duration
	ReadyTimeout  time.Duration
}

type Instance interface {
	// BaseURL is the host URL to POST messages to (e.g. http://127.0.0.1:49152).
	BaseURL() string
	// ID is the docker container id (or a test fake id).
	ID() string
	// Stop stops and removes the container (best-effort).
	Stop(ctx context.Context) error
}

type Runner interface {
	Start(ctx context.Context, spec Spec) (Instance, error)
}

type Spec struct {
	Image string
	// ContainerPort is the HTTP port inside the container (default 8080).
	ContainerPort int
	// FlowConfigJSON is passed as ASTRATE_FLOW_CONFIG.
	FlowConfigJSON string
	// Labels are applied to the container (astrate.*).
	Labels map[string]string
	// Name is an optional docker container name (must be unique).
	Name string
}

type Waiter interface {
	// Wait blocks until the container exits (or ctx is cancelled) and returns
	// its exit code.
	Wait(ctx context.Context) (exitCode int, err error)
}