Versions in this module Expand all Collapse all v1 v1.0.0 Mar 7, 2026 Changes in this version + type ExecutionMetrics struct + AverageLatency time.Duration + FailedCalls int64 + LastExecutedAt time.Time + P95Latency time.Duration + P99Latency time.Duration + SuccessfulCalls int64 + TotalExecutions int64 + type FunctionMetadata struct + Description string + InputType string + Local bool + Name string + OutputType string + RegisteredAt time.Time + Retries int + Timeout int + type LocalFunctionExecutor struct + func NewLocalFunctionExecutor(maxConcurrent int) *LocalFunctionExecutor + func (e *LocalFunctionExecutor) DeregisterFunction(name string) error + func (e *LocalFunctionExecutor) Execute(ctx context.Context, functionName string, input any) (any, error) + func (e *LocalFunctionExecutor) ExecuteAsync(ctx context.Context, functionName string, input any) (string, error) + func (e *LocalFunctionExecutor) GetMetadata(functionName string) (*FunctionMetadata, error) + func (e *LocalFunctionExecutor) GetMetrics(functionName string) (*ExecutionMetrics, error) + func (e *LocalFunctionExecutor) GetResult(ctx context.Context, jobID string) (any, error) + func (e *LocalFunctionExecutor) IsHealthy(ctx context.Context) bool + func (e *LocalFunctionExecutor) ListFunctions() []string + func (e *LocalFunctionExecutor) RegisterFunction(name string, fn port.FunctionHandler) error + func (e *LocalFunctionExecutor) Start(ctx context.Context) error + func (e *LocalFunctionExecutor) Stop(ctx context.Context) error
Go to main page