Versions in this module Expand all Collapse all v0 v0.22.0 Aug 3, 2026 Changes in this version + func ResolveRegistryTag(ctx context.Context, ref computev1alpha1.BundleRef) (string, error) + type ServiceReconcilerOption func(*ServiceReconciler) + func WithTagResolver(resolve TagResolver) ServiceReconcilerOption + type TagResolver func(context.Context, computev1alpha1.BundleRef) (string, error) v0.21.0 Jul 30, 2026 Changes in this version + const DefaultEgressDir + const DefaultImageBaseDir + const DefaultListenAddr + const DefaultRootDir + const EgressFullPassRequestName + func EgressSocketPath(dir, tenant string) string + func Run() error + type BundleFetcher interface + Bundle func(ctx context.Context, b computev1alpha1.BundleRef) (computev1alpha1.BundleManifest, map[string][]byte, error) + type ControlServer struct + func NewControlServer(store *Store) *ControlServer + func (c *ControlServer) Close() error + func (c *ControlServer) Handler() http.Handler + func (c *ControlServer) Listen(addr string) (string, error) + func (c *ControlServer) Serve(ctx context.Context) error + type EgressControlServer struct + func NewEgressControlServer(tenant string, applier host.EgressApplier, dnsApplier host.DNSApplier) *EgressControlServer + func (s *EgressControlServer) ApplyDNS(ctx context.Context, req *workerdv1.ApplyDNSRequest) (*workerdv1.ApplyDNSResponse, error) + func (s *EgressControlServer) ApplyEgress(ctx context.Context, req *workerdv1.ApplyEgressRequest) (*workerdv1.ApplyEgressResponse, error) + func (s *EgressControlServer) Close() error + func (s *EgressControlServer) Listen(path string) error + func (s *EgressControlServer) Serve(ctx context.Context) error + type EgressPlan struct + Gateways []GatewayEgressPlan + Routes []RouteEgressPlan + Services []ServiceEgressPlan + func CompileEgress(services []ServiceEgressInput, gateways []computev1alpha1.EgressGateway, ...) *EgressPlan + func (p *EgressPlan) WireConfigs() []*workerdv1.ServiceEgressConfig + type EgressPusher struct + func NewEgressPusher(egressDir string) *EgressPusher + func (p *EgressPusher) ReconcileWithClient(ctx context.Context, tenant string, c client.Client, _ ctrl.Request) (ctrl.Result, error) + func (p *EgressPusher) StopTenant(tenant string) + func (p *EgressPusher) TenantReconciler(tenant string, c client.Client) reconcile.Func + type EgressStatusReconciler struct + func NewEgressStatusReconciler(c client.Client) *EgressStatusReconciler + func (r *EgressStatusReconciler) Reconcile(ctx context.Context, _ reconcile.Request) (ctrl.Result, error) + func (r *EgressStatusReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error + type GatewayEgressPlan struct + AttachedRoutes map[string]int32 + Message string + Name string + Ready bool + Reason string + type ResidentBuilder interface + NewResident func(tenant, controlHostAddr string) (host.ResidentRuntime, error) + type ResidentManager struct + func NewResidentManager(factory ResidentBuilder, controlAddr string, opts ...ResidentManagerOption) *ResidentManager + func SetupResidents(ctx context.Context, cfg host.ResidentConfig, controlAddr string, ...) (*ResidentManager, error) + func (m *ResidentManager) Close(ctx context.Context) error + func (m *ResidentManager) EnsureTenant(ctx context.Context, tenant string, c client.Client) (*host.ResidentInstance, error) + func (m *ResidentManager) ReconcileWithClient(ctx context.Context, tenant string, c client.Client, req ctrl.Request) (ctrl.Result, error) + func (m *ResidentManager) StopTenant(ctx context.Context, tenant string) error + func (m *ResidentManager) TenantReconciler(tenant string, c client.Client) reconcile.Func + type ResidentManagerOption func(*ResidentManager) + func WithEgressDir(dir string) ResidentManagerOption + type ResidentReconciler struct + func NewResidentReconciler(c client.Client, resident host.ResidentRuntime, store *Store) *ResidentReconciler + func (r *ResidentReconciler) Reconcile(ctx context.Context, req reconcile.Request) (ctrl.Result, error) + type Resolver struct + func NewResolver(c client.Client) *Resolver + func (r *Resolver) Resolve(ctx context.Context, id string) (host.WorkerDefinition, error) + type RouteEgressPlan struct + Name string + Parents []gwapiv1.RouteParentStatus + type ServiceEgressInput struct + Egress *computev1alpha1.ServiceEgress + Name string + type ServiceEgressPlan struct + Config *workerdv1.ServiceEgressConfig + Gateway string + Message string + Name string + Ready bool + Reason string + type ServiceReconciler struct + func NewServiceReconciler(c client.Client) *ServiceReconciler + func (r *ServiceReconciler) Reconcile(ctx context.Context, req reconcile.Request) (ctrl.Result, error) + func (r *ServiceReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error + type Store struct + func NewStore(resolver *Resolver) *Store + func (s *Store) Get(ctx context.Context, id string) (host.WorkerDefinition, error) + func (s *Store) Invalidate(id string) + func (s *Store) Warm(ctx context.Context, id string) (host.WorkerDefinition, error)
Go to main page