functions

Jul 18, 2026

Changes in this version

+ const TenantDBNotReady

+ const TenantNotActive

+ const TenantNotFound

+ const TenantRequired

+ const TenantScopeForbidden

+ var EmbeddedApitoFunctionsSDK string

+ var GlobalInvocationRegistry = NewInvocationRegistry()

+ func RegisterReadDataOps(g *EngineDataGateway, deps GatewayDeps, registry *InvocationRegistry)

+ func ResolveActiveSource(ctx context.Context, store ArtifactStore, fn *models.ApitoFunction) string

type DenoRuntimeProvider

+ Gateway FunctionDataGateway

+ Registry *InvocationRegistry

+ type GatewayBridge struct

+ InvocationID string

+ Token string

+ URL string

+ func StartGatewayBridge(ctx context.Context, gateway FunctionDataGateway, inv *InvocationContext) (*GatewayBridge, error)

+ func (b *GatewayBridge) Close()

+ type GatewayDeps interface

+ GetProjectDriver func(ctx context.Context, inv *InvocationContext) (interfaces.ProjectDBInterface, error)

+ NewParam func(inv *InvocationContext) *models.CommonSystemParams

+ ResolveModel func(inv *InvocationContext, modelArg string) (*models.ModelType, error)

+ type InvocationContext struct

+ Capabilities []string

+ DBCtx context.Context

+ Envelope *InvocationEnvelope

+ Gateway FunctionDataGateway

+ Param *models.CommonSystemParams

+ Project *models.Project

+ type InvocationRegistry struct

+ func NewInvocationRegistry() *InvocationRegistry

+ func (r *InvocationRegistry) Get(invocationID string) (*InvocationContext, error)

+ func (r *InvocationRegistry) Register(inv *InvocationContext) error

+ func (r *InvocationRegistry) Unregister(invocationID string)

+ type TenantScopeError struct

+ Code string

+ Message string

+ func AsTenantScopeError(err error) (*TenantScopeError, bool)

+ func NewTenantScopeError(code, message string) *TenantScopeError

+ func (e *TenantScopeError) Error() string

Jul 16, 2026

Changes in this version

+ const ABIVersion

+ const EventAccepted

+ const EventCommitted

+ const EventDeadLettered

+ const EventFailed

+ const EventRunning

+ func AllowCallableRuntime(fn *models.ApitoFunction) bool

+ func DataGatewaySubject(projectID string) string

+ func DeployDraft(ctx context.Context, store ArtifactStore, fn *models.ApitoFunction, ...) (*models.FunctionRevision, *models.FunctionDeployment, error)

+ func EventSubject(projectID, functionName string) string

+ func FindFunctionByName(project *models.Project, name string) *models.ApitoFunction

+ func InvokeSubject(projectID, functionName string) string

+ func RegisterCoreDataOps(g *EngineDataGateway, batch ProjectBatchExecutor)

+ func RequireCapability(caps []string) func(context.Context, *DataGatewayCall) error

+ func RollbackDeployment(fn *models.ApitoFunction, previousRevisionID, deployedBy string) *models.FunctionDeployment

+ func ValidateBatchOps(ops []BatchOp) error

+ func VerifyFunctionSecret(fn *models.ApitoFunction, provided string) error

+ type ArtifactStore interface

+ Delete func(ctx context.Context, key string) error

+ Get func(ctx context.Context, key string) ([]byte, string, error)

+ Put func(ctx context.Context, key string, data []byte, hash string) error

+ type BatchOp struct

+ By float64

+ Connect map[string]interface{}

+ Disconnect map[string]interface{}

+ Field string

+ ID string

+ Model string

+ Op string

+ Payload map[string]interface{}

+ type BatchRequest struct

+ IdempotencyKey string

+ Operations []BatchOp

+ type BatchResult struct

+ Error string

+ IDs []string

+ OK bool

+ Replay bool

+ Result map[string]interface{}

+ func (r *BatchResult) StatusCommitted() bool

+ type DataGatewayCall struct

+ InvocationID string

+ Op string

+ Payload map[string]interface{}

+ ProjectID string

+ TenantID string

+ type DataGatewayResponse struct

+ Data map[string]interface{}

+ Error string

+ OK bool

+ type DataOpHandler func(ctx context.Context, call *DataGatewayCall) (*DataGatewayResponse, error)

+ type DefaultLimitsProvider struct

+ func (DefaultLimitsProvider) LimitsFor(ctx context.Context, projectID string, fn *models.ApitoFunction) (FunctionLimits, error)

+ type DenoRuntimeProvider struct

+ DenoPath string

+ WorkDir string

+ func (p *DenoRuntimeProvider) Execute(ctx context.Context, env *InvocationEnvelope, limits FunctionLimits) (*InvocationResult, error)

+ func (p *DenoRuntimeProvider) Name() string

+ type EngineDataGateway struct

+ CheckCapability func(ctx context.Context, call *DataGatewayCall) error

+ HostCallCount map[string]int

+ MaxHostCalls int

+ func NewEngineDataGateway() *EngineDataGateway

+ func (g *EngineDataGateway) Handle(ctx context.Context, call *DataGatewayCall) (*DataGatewayResponse, error)

+ func (g *EngineDataGateway) Register(op string, h DataOpHandler)

+ type EventDispatcher interface

+ Publish func(ctx context.Context, msg *EventMessage) error

+ Subscribe func(ctx context.Context, ...) (func() error, error)

+ type EventMessage struct

+ Attempt int

+ Function string

+ ID string

+ IdempotencyKey string

+ MaxDeliver int

+ Payload map[string]interface{}

+ ProjectID string

+ Trigger string

+ type FilesystemArtifactStore struct

+ func NewFilesystemArtifactStore(dir string) (*FilesystemArtifactStore, error)

+ func (s *FilesystemArtifactStore) Delete(ctx context.Context, key string) error

+ func (s *FilesystemArtifactStore) Get(ctx context.Context, key string) ([]byte, string, error)

+ func (s *FilesystemArtifactStore) Put(ctx context.Context, key string, data []byte, hash string) error

+ type FunctionDataGateway interface

+ Handle func(ctx context.Context, call *DataGatewayCall) (*DataGatewayResponse, error)

+ type FunctionInvoker interface

+ Invoke func(ctx context.Context, env *InvocationEnvelope) (*InvocationResult, error)

+ type FunctionLimits struct

+ MaxConcurrency int

+ MaxHostCalls int

+ MaxLogBytes int64

+ MaxRequestBytes int64

+ MaxResponseBytes int64

+ MemoryBytes int64

+ Timeout time.Duration

+ func DefaultCallableLimits() FunctionLimits

+ type FunctionLimitsProvider interface

+ LimitsFor func(ctx context.Context, projectID string, fn *models.ApitoFunction) (FunctionLimits, error)

+ type FunctionTransport interface

+ Close func() error

+ Request func(ctx context.Context, subject string, payload []byte, timeout time.Duration) ([]byte, error)

+ RespondHandler func(ctx context.Context, subject string, queueGroup string, ...) (func() error, error)

+ type HookLimitsProvider struct

+ Hook func(ctx context.Context, projectID string, fn *models.ApitoFunction) (memoryBytes int64, timeoutMs int64, maxConcurrency int, err error)

+ func (p HookLimitsProvider) LimitsFor(ctx context.Context, projectID string, fn *models.ApitoFunction) (FunctionLimits, error)

+ type InvocationEnvelope struct

+ ArtifactHash string

+ ArtifactKey string

+ Capabilities []string

+ DeadlineMs int64

+ Function string

+ Handler string

+ Idempotency string

+ InvocationID string

+ Principal Principal

+ ProjectID string

+ Request map[string]interface{}

+ RevisionID string

+ Role string

+ Runtime string

+ Source string

+ TenantID string

+ UserID string

+ Version string

+ func BuildEnvelope(fn *models.ApitoFunction, projectID, tenantID, userID, role string, ...) *InvocationEnvelope

+ type InvocationResult struct

+ DurationMs int64

+ Error string

+ ErrorClass string

+ HostCalls int

+ Logs []LogEntry

+ OK bool

+ Response map[string]interface{}

+ ResultDigest string

+ Version string

+ type LocalTransport struct

+ func NewLocalTransport() *LocalTransport

+ func (t *LocalTransport) Close() error

+ func (t *LocalTransport) Request(ctx context.Context, subject string, payload []byte, timeout time.Duration) ([]byte, error)

+ func (t *LocalTransport) RespondHandler(ctx context.Context, subject string, _ string, ...) (func() error, error)

+ type LogEntry struct

+ At string

+ Level string

+ Message string

+ type ManagerOption func(*RuntimeManager)

+ func WithArtifactStore(s ArtifactStore) ManagerOption

+ func WithDataGateway(g FunctionDataGateway) ManagerOption

+ func WithGlobalConcurrency(n int) ManagerOption

+ func WithLimitsProvider(p FunctionLimitsProvider) ManagerOption

+ func WithTransport(t FunctionTransport) ManagerOption

+ type MemoryBatchExecutor struct

+ Apply func(ctx context.Context, projectID, tenantScope string, op BatchOp) (string, error)

+ func NewMemoryBatchExecutor() *MemoryBatchExecutor

+ func (e *MemoryBatchExecutor) ExecuteBatch(ctx context.Context, projectID, tenantScope string, req *BatchRequest) (*BatchResult, error)

+ type MemoryEventDispatcher struct

+ func NewMemoryEventDispatcher() *MemoryEventDispatcher

+ func (d *MemoryEventDispatcher) DeadLetters() []*EventMessage

+ func (d *MemoryEventDispatcher) Publish(ctx context.Context, msg *EventMessage) error

+ func (d *MemoryEventDispatcher) Subscribe(ctx context.Context, ...) (func() error, error)

+ type NATSConn interface

+ Close func()

+ QueueSubscribe func(subject, queue string, ...) (func() error, error)

+ RequestWithContext func(ctx context.Context, subject string, data []byte) ([]byte, error)

+ type NATSFunctionTransport struct

+ func NewNATSFunctionTransport(conn NATSConn) *NATSFunctionTransport

+ func (t *NATSFunctionTransport) Close() error

+ func (t *NATSFunctionTransport) Request(ctx context.Context, subject string, payload []byte, timeout time.Duration) ([]byte, error)

+ func (t *NATSFunctionTransport) RespondHandler(ctx context.Context, subject string, queueGroup string, ...) (func() error, error)

+ type Principal struct

+ Mode string

+ Role string

+ UserID string

+ type ProjectBatchExecutor interface

+ ExecuteBatch func(ctx context.Context, projectID, tenantScope string, req *BatchRequest) (*BatchResult, error)

+ type RuntimeManager struct

+ func NewRuntimeManager(providers []RuntimeProvider, opts ...ManagerOption) *RuntimeManager

+ func (m *RuntimeManager) Artifacts() ArtifactStore

+ func (m *RuntimeManager) DataGateway() FunctionDataGateway

+ func (m *RuntimeManager) Invoke(ctx context.Context, env *InvocationEnvelope) (*InvocationResult, error)

+ func (m *RuntimeManager) RegisterProvider(p RuntimeProvider)

+ type RuntimeProvider interface

+ Execute func(ctx context.Context, env *InvocationEnvelope, limits FunctionLimits) (*InvocationResult, error)

+ Name func() string

+ type StubRuntimeProvider struct

+ RuntimeName string

+ func (p *StubRuntimeProvider) Execute(ctx context.Context, env *InvocationEnvelope, limits FunctionLimits) (*InvocationResult, error)

+ func (p *StubRuntimeProvider) Name() string

+ type WazeroRuntimeProvider struct

+ func NewWazeroRuntimeProvider(ctx context.Context) *WazeroRuntimeProvider

+ func (p *WazeroRuntimeProvider) Close(ctx context.Context) error

+ func (p *WazeroRuntimeProvider) Execute(ctx context.Context, env *InvocationEnvelope, limits FunctionLimits) (*InvocationResult, error)

+ func (p *WazeroRuntimeProvider) Name() string