api

type AdminClient interface {
	// Port returns the Envoy admin API port.
	Port() int

	// Get returns the content at the given path or an error if != 200
	Get(ctx context.Context, path string) ([]byte, error)

	// IsReady returns nil if Envoy is ready to accept requests, or an error otherwise.
	//
	// This is a convenience form of Get on the /ready endpoint.
	IsReady(ctx context.Context) error

	// AwaitReady polls IsReady until it succeeds or the context is cancelled.
	// On timeout/cancellation, returns the last error from IsReady if available,
	// otherwise returns the context error.
	AwaitReady(ctx context.Context, tickDuration time.Duration) error

	// NewListenerRequest creates an HTTP request against a named listener.
	// Similar to http.NewRequestWithContext, but targets the specified listener (e.g., "main").
	// The path parameter should include the path, query, and fragment (e.g., "/path?query#fragment").
	NewListenerRequest(ctx context.Context, name, method, path string, body io.Reader) (*http.Request, error)
}

type RunMiddlewareKey struct{}

type RunOpts struct {
	ConfigHome       string
	DataHome         string
	StateHome        string
	RuntimeDir       string
	RunID            string // Optional: custom run identifier for StateDir and RuntimeDir paths
	EnvoyVersion     string
	EnvoyVersionsURL string
	Out              io.Writer
	EnvoyOut         io.Writer
	EnvoyErr         io.Writer
	EnvoyPath        string      // Internal: path to the Envoy binary (for tests).
	StartupHook      StartupHook // Experimental: custom startup hook
}

type StartupHook func(ctx context.Context, adminClient AdminClient, runID string) error