controller

type ContainerRuntime interface {
	// ExecNamespace creates and starts a new edge-runtime container for a namespace.
	ExecNamespace(ctx context.Context, id string, eszipDir string, servicePort, controlPort int) error

	// StopExec stops the execution of a container.
	StopExec(ctx context.Context, id string) error

	// DeleteExec deletes a container.
	DeleteExec(ctx context.Context, id string) error

	// ExecStatus returns the status of a container.
	ExecStatus(ctx context.Context, id string) (edgefunc.Status, error)

	// ListExecs returns all container executions.
	ListExecs(ctx context.Context) ([]edgefunc.Status, error)

	// Network returns the network manager for the runtime.
	Network() *network.Network
}

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

type EdgeControllerOption func(*EdgeController)

type FunctionDeployer interface {
	// Deploy deploys an EdgeFunctionRevision to the appropriate runtime.
	Deploy(ctx context.Context, namespace Namespace, rev *extensionsv1alpha2.EdgeFunctionRevision) error

	// Undeploy removes a function from its runtime.
	Undeploy(ctx context.Context, namespace Namespace, functionID FunctionID) error

	// GetFunctionStatus returns the status of a deployed function.
	GetFunctionStatus(ctx context.Context, namespace Namespace, functionID FunctionID) (*FunctionInfo, error)
}

type FunctionHealthStatus struct {
	Ready bool   `json:"ready"`
	Error string `json:"error,omitempty"`
}

type FunctionID string

type FunctionInfo struct {
	// FunctionID is the unique identifier for this function.
	FunctionID FunctionID

	// FunctionName is the human-readable name of the function.
	FunctionName string

	// RevisionRef is the EdgeFunctionRevision ref (e.g., hash of the code).
	RevisionRef string

	// EszipPath is the path to the eszip file inside the container.
	EszipPath string

	// Ready indicates whether the function has been bootstrapped and is ready to serve.
	Ready bool

	// ColdStartMs is the cold start time in milliseconds (from /_internal/ready response).
	ColdStartMs int64

	// LoadedAt is when the function was loaded into the runtime.
	LoadedAt time.Time
}

type FunctionRouter interface {
	// Resolve returns the FunctionID for a given function name in a namespace.
	// Returns the currently active revision's function ID.
	Resolve(ctx context.Context, namespace Namespace, functionName string) (FunctionID, error)

	// SetActiveRevision sets the active function ID for a function name.
	SetActiveRevision(ctx context.Context, namespace Namespace, functionName string, functionID FunctionID) error

	// GetRuntimeAddress returns the address and service port for a namespace's runtime.
	GetRuntimeAddress(ctx context.Context, namespace Namespace) (address netip.Addr, port int, err error)

	// RemoveFunction removes a function name mapping.
	RemoveFunction(ctx context.Context, namespace Namespace, functionName string) error
}

type HealthResponse struct {
	Functions map[string]FunctionHealthStatus `json:"functions"`
}

type Namespace string

type ReadyRequest struct {
	FunctionID string `json:"function_id"`
}

type ReadyResponse struct {
	Ready       bool  `json:"ready"`
	ColdStartMs int64 `json:"cold_start_ms"`
}

type RuntimeClient interface {
	// Upload registers a new function with the runtime.
	Upload(ctx context.Context, req UploadRequest) error

	// Ready bootstraps a worker for the function and returns readiness status.
	Ready(ctx context.Context, functionID string) (*ReadyResponse, error)

	// Health returns the health status of all functions in the runtime.
	Health(ctx context.Context) (*HealthResponse, error)

	// DeleteFunction unloads a function from the runtime.
	DeleteFunction(ctx context.Context, functionID string) error
}

type RuntimeInfo struct {
	// Namespace this runtime belongs to.
	Namespace Namespace

	// ContainerID is the container identifier (e.g., "edge-runtime-{namespace}").
	ContainerID string

	// Address is the IPv4 address of the runtime container.
	Address netip.Addr

	// ControlPort is the port for the control API (default 9000).
	ControlPort int

	// ServicePort is the port for serving requests (default 8080).
	ServicePort int

	// EszipDir is the host directory where eszip files are stored for this runtime.
	EszipDir string

	// Functions maps function IDs to their info for functions loaded in this runtime.
	Functions map[FunctionID]*FunctionInfo

	// CreatedAt is when the runtime was created.
	CreatedAt time.Time
	// contains filtered or unexported fields
}

type RuntimeManager interface {
	// EnsureRuntime ensures a runtime exists for the given namespace.
	// Creates one if it doesn't exist.
	EnsureRuntime(ctx context.Context, namespace Namespace) (*RuntimeInfo, error)

	// GetRuntime returns the runtime info for a namespace, or nil if not exists.
	GetRuntime(ctx context.Context, namespace Namespace) (*RuntimeInfo, error)

	// TerminateRuntime stops and removes the runtime for a namespace.
	TerminateRuntime(ctx context.Context, namespace Namespace) error

	// ListRuntimes returns all active runtimes.
	ListRuntimes(ctx context.Context) ([]*RuntimeInfo, error)
}

type RuntimeManagerOption func(*runtimeManagerImpl)

type UploadRequest struct {
	FunctionID   string `json:"function_id"`
	FunctionName string `json:"function_name"`
	EszipPath    string `json:"eszip_path"`
}