controller

package

Go to main page

Versions in this module

v0

v0.22.0

Aug 3, 2026

v0.21.0

Jul 30, 2026

Changes in this version

+ const DefaultControlPort — linux/amd64

+ const DefaultServicePort — linux/amd64

+ type ContainerRuntime interface — linux/amd64

+ DeleteExec func(ctx context.Context, id string) error

+ ExecNamespace func(ctx context.Context, id string, eszipDir string, servicePort, controlPort int) error

+ ExecStatus func(ctx context.Context, id string) (edgefunc.Status, error)

+ ListExecs func(ctx context.Context) ([]edgefunc.Status, error)

+ Network func() *network.Network

+ StopExec func(ctx context.Context, id string) error

+ type EdgeController struct — linux/amd64

+ func NewEdgeController(runtimeManager RuntimeManager, functionDeployer FunctionDeployer, ...) *EdgeController

+ func NewEdgeControllerFromRuntime(runtime ContainerRuntime, eszipDir string, defaultNS Namespace) *EdgeController

+ func (c *EdgeController) Deploy(ctx context.Context, namespace Namespace, ...) error

+ func (c *EdgeController) FunctionDeployer() FunctionDeployer

+ func (c *EdgeController) FunctionRouter() FunctionRouter

+ func (c *EdgeController) GetFunctionStatus(ctx context.Context, namespace Namespace, functionID FunctionID) (*FunctionInfo, error)

+ func (c *EdgeController) GetRuntimeAddress(ctx context.Context, namespace Namespace) (netip.Addr, int, error)

+ func (c *EdgeController) ListRuntimes(ctx context.Context) ([]*RuntimeInfo, error)

+ func (c *EdgeController) ResolveFunctionID(ctx context.Context, namespace Namespace, functionName string) (FunctionID, error)

+ func (c *EdgeController) Resolver(next plugin.Handler) plugin.Handler

+ func (c *EdgeController) RuntimeManager() RuntimeManager

+ func (c *EdgeController) TerminateRuntime(ctx context.Context, namespace Namespace) error

+ func (c *EdgeController) Undeploy(ctx context.Context, namespace Namespace, functionID FunctionID) error

+ type EdgeControllerOption func(*EdgeController) — linux/amd64

+ func WithDefaultNamespace(ns Namespace) EdgeControllerOption

+ type FunctionDeployer interface — linux/amd64

+ Deploy func(ctx context.Context, namespace Namespace, ...) error

+ GetFunctionStatus func(ctx context.Context, namespace Namespace, functionID FunctionID) (*FunctionInfo, error)

+ Undeploy func(ctx context.Context, namespace Namespace, functionID FunctionID) error

+ func NewFunctionDeployer(runtimeManager RuntimeManager, router FunctionRouter) FunctionDeployer

+ type FunctionHealthStatus struct — linux/amd64

+ Error string

+ Ready bool

+ type FunctionID string — linux/amd64

+ type FunctionInfo struct — linux/amd64

+ ColdStartMs int64

+ EszipPath string

+ FunctionID FunctionID

+ FunctionName string

+ LoadedAt time.Time

+ Ready bool

+ RevisionRef string

+ type FunctionRouter interface — linux/amd64

+ GetRuntimeAddress func(ctx context.Context, namespace Namespace) (address netip.Addr, port int, err error)

+ RemoveFunction func(ctx context.Context, namespace Namespace, functionName string) error

+ Resolve func(ctx context.Context, namespace Namespace, functionName string) (FunctionID, error)

+ SetActiveRevision func(ctx context.Context, namespace Namespace, functionName string, ...) error

+ func NewFunctionRouter(runtimeManager RuntimeManager) FunctionRouter

+ type HealthResponse struct — linux/amd64

+ Functions map[string]FunctionHealthStatus

+ type Namespace string — linux/amd64

+ type ReadyRequest struct — linux/amd64

+ FunctionID string

+ type ReadyResponse struct — linux/amd64

+ ColdStartMs int64

+ Ready bool

+ type RuntimeClient interface — linux/amd64

+ DeleteFunction func(ctx context.Context, functionID string) error

+ Health func(ctx context.Context) (*HealthResponse, error)

+ Ready func(ctx context.Context, functionID string) (*ReadyResponse, error)

+ Upload func(ctx context.Context, req UploadRequest) error

+ func NewRuntimeClient(address netip.Addr, port int) RuntimeClient

+ func NewRuntimeClientWithURL(baseURL string) RuntimeClient

+ type RuntimeInfo struct — linux/amd64

+ Address netip.Addr

+ ContainerID string

+ ControlPort int

+ CreatedAt time.Time

+ EszipDir string

+ Functions map[FunctionID]*FunctionInfo

+ Namespace Namespace

+ ServicePort int

+ func (r *RuntimeInfo) DeleteFunction(id FunctionID)

+ func (r *RuntimeInfo) GetFunction(id FunctionID) (*FunctionInfo, bool)

+ func (r *RuntimeInfo) ListFunctions() []FunctionID

+ func (r *RuntimeInfo) SetFunction(id FunctionID, info *FunctionInfo)

+ type RuntimeManager interface — linux/amd64

+ EnsureRuntime func(ctx context.Context, namespace Namespace) (*RuntimeInfo, error)

+ GetRuntime func(ctx context.Context, namespace Namespace) (*RuntimeInfo, error)

+ ListRuntimes func(ctx context.Context) ([]*RuntimeInfo, error)

+ TerminateRuntime func(ctx context.Context, namespace Namespace) error

+ func NewRuntimeManager(containerRuntime ContainerRuntime, opts ...RuntimeManagerOption) RuntimeManager

+ type RuntimeManagerOption func(*runtimeManagerImpl) — linux/amd64

+ func WithBaseEszipDir(dir string) RuntimeManagerOption

+ type UploadRequest struct — linux/amd64

+ EszipPath string

+ FunctionID string

+ FunctionName string

v0.20.0

May 13, 2026

v0.19.3

May 8, 2026

v0.19.2

Apr 14, 2026

v0.19.1

Apr 14, 2026

v0.19.0

Apr 14, 2026

v0.18.1

Mar 31, 2026

v0.18.0

Mar 27, 2026

v0.17.0

Mar 24, 2026

v0.16.1

Mar 19, 2026

v0.16.0

Mar 18, 2026

v0.15.0

Mar 3, 2026

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL