funcd

Oct 13, 2026

Changes in this version

type Option

+ func WithBridgeAddress(addr netip.Addr) Option

+ func WithEphemeralProviderStorage() Option

+ func WithProviderStorage(root string) Option

+ func WithSQLCallTimeout(d time.Duration) Option

+ func WithSQLChangeFeedPort(port int) Option

+ func WithSQLDatabaseQuota(maxPerNamespace int) Option

+ func WithSQLProviderRuntime(r provider.Runtime) Option

Oct 11, 2026

Changes in this version

+ func DefaultLivenessTimeout(supervisionPeriod time.Duration) time.Duration

type Option

+ func WithBackupParent(p *backup.GenRef) Option

+ func WithBlobStoreURL(url string) Option

+ func WithHold(h *hold.Hold) Option

+ func WithMasterLocation(masterSecretFile, dataDir string) Option

+ func WithMasterSecret(secret []byte) Option

+ func WithPlatformBackup(r *runner.Runner) Option

type Pacing

+ LivenessTimeout time.Duration

+ StorageProbeInterval time.Duration

+ StorageProbeTimeout time.Duration

Oct 10, 2026

Changes in this version

type Option

+ func WithAppRevisionHistory(n int) Option

type Pacing

+ AppUpgradeTimeout time.Duration

Oct 8, 2026

Changes in this version

type Option

+ func WithNormalizedLogFields() Option

Oct 5, 2026

Changes in this version

type Option

+ func WithFunclogMaxRecordBytes(n int) Option

+ func WithPacing(p Pacing) Option

+ type Pacing struct

+ ActivationTimeout time.Duration

+ ArtifactPollInterval time.Duration

+ BootTimeout time.Duration

+ BucketRecheckInterval time.Duration

+ DefaultRetryBackoff time.Duration

+ DeliveryBackoffInitial time.Duration

+ DeliveryBackoffMax time.Duration

+ DrainGrace time.Duration

+ DrainPollInterval time.Duration

+ EnginePollInterval time.Duration

+ EngineProbeTimeout time.Duration

+ HandOutSettle time.Duration

+ ReclaimInterval time.Duration

+ ReferentPollInterval time.Duration

+ RetryBackoffMax time.Duration

+ RouteResyncInterval time.Duration

+ ShutdownTimeout time.Duration

+ SupervisionPeriod time.Duration

+ WorkerSyncInterval time.Duration

Oct 5, 2026

Changes in this version

type Option

+ func WithPoolManifestDir(dir string) Option

Oct 5, 2026

Changes in this version

+ type Credential struct

+ Namespaces []string

+ Role string

+ Token string

type Option

+ func WithBootBackoff(initial, limit time.Duration) Option

+ func WithCredentials(creds ...Credential) Option

+ func WithDefaultInvokeTimeout(d time.Duration) Option

+ func WithGCSweepInterval(d time.Duration) Option

+ func WithNestedInFlightCap(n int) Option

+ func WithSensorDelivery(maxInFlight, maxInFlightPerTarget, maxQueuedPerSensor int) Option

+ func WithWorkflowMaxStepsInFlight(n int) Option

Oct 3, 2026

Changes in this version

type Platform

+ func (p *Platform) WaitS3Gateway(ctx context.Context) error

Oct 2, 2026

Changes in this version

type Option

+ func WithNodePlatform(p v1.OCIPlatform) Option

Sep 27, 2026

Changes in this version

+ const DevToken

+ type LogLine struct

+ Attrs map[string]string

+ Body string

+ Function string

+ Invocation string

+ Namespace string

+ Replica string

+ Severity string

+ Time time.Time

+ type LogObserver func(LogLine)

+ type Option func(*config) error

+ func InMemory() Option

+ func Production() Option

+ func WithArtifactStore(dir string) Option

+ func WithAuthorizer(a auth.Authorizer) Option

+ func WithBlob(b blob.Bucket) Option

+ func WithBlobPollInterval(d time.Duration) Option

+ func WithBus(b bus.Bus) Option

+ func WithCatalogExtensionDir(dir string) Option

+ func WithCatalogProviderRuntime(r provider.Runtime) Option

+ func WithCatalogProxyHost(host string) Option

+ func WithContainerExecution(imageFor func(runtime string) string) Option

+ func WithDataPlaneAddr(addr string) Option

+ func WithDeadLetterQueue(dataDir string, deliveryAttempts int, retention time.Duration, maxEntries int) Option

+ func WithDevAuth(token string, namespaces ...string) Option

+ func WithEdgeAuth() Option

+ func WithEdgeObservability(cfg observ.Config) Option

+ func WithEdgeShaping(cfg shape.Config) Option

+ func WithEgressGateway(gatewayPort, dnsForwarderPort uint16, dnsUpstream netip.AddrPort) Option

+ func WithEgressIsolation(mgr network.Manager, p network.Policy) Option

+ func WithFunclog(segmentMaxAge time.Duration, segmentMaxBytes int) Option

+ func WithGateway(g gateway.Gateway) Option

+ func WithInvokeSocketDir(dir string) Option

+ func WithKVStore(kv kvstore.KV) Option

+ func WithKVStoreQuota(maxPerNamespace int) Option

+ func WithLimits(cfg limit.Config) Option

+ func WithListenAddr(addr string) Option

+ func WithLogCompaction(window, interval, retention time.Duration) Option

+ func WithLogObserver(obs LogObserver) Option

+ func WithLogger(l *slog.Logger) Option

+ func WithMaterializer(m function.Materializer) Option

+ func WithPoolLimit(limit int) Option

+ func WithPoolShim(cmd ...string) Option

+ func WithPoolShimFor(runtimeFamily string, cmd ...string) Option

+ func WithRuntime(r runtime.Runtime) Option

+ func WithRuntimeShim(cmd ...string) Option

+ func WithRuntimeShimFor(runtimeFamily string, cmd ...string) Option

+ func WithS3Gateway(listenAddr, endpoint string, maxUploadBytes int64, ...) Option

+ func WithSiteDefaultIndex(index string) Option

+ func WithStore(s store.Store) Option

+ func WithTLS(spec edgetls.Spec) Option

+ func WithTelemetry(t *observability.Telemetry) Option

+ func WithWorkflow(dataDir string, defaultStepTimeout, retention time.Duration, defaultRetry int, ...) Option

+ func WithWorkflowContractResolver(r workflow.ContractResolver) Option

+ func WithoutFunclog() Option

+ func WithoutFunclogTraces() Option

+ func WithoutLogCompaction() Option

+ type Platform struct

+ func New(opts ...Option) (*Platform, error)

+ func (p *Platform) Addr() string

+ func (p *Platform) DataPlaneAddr() string

+ func (p *Platform) EgressWorkerIndex() *egress.MemoryWorkerIndex

+ func (p *Platform) Providers() *provider.Catalog

+ func (p *Platform) Run(ctx context.Context) error

+ func (p *Platform) Shutdown(ctx context.Context) error