runtime

Aug 9, 2026

Changes in this version

type StreamConfig

+ CAFile string

+ CertFile string

+ KeyFile string

+ Password string

+ User string

Aug 2, 2026

Changes in this version

type RestCtx

+ func (c *RestCtx) Stream() io.Reader

+ type SpoolDef struct

+ Async bool

+ Concurrency int

+ Dir string

+ MemoryLimit string

+ Mode string

+ PartSize string

type StorageDef

+ Spool *SpoolDef

Aug 2, 2026

Changes in this version

type AuthConfig

+ JWKSURL string

type KVConfig

+ PoolSize int

Jul 31, 2026

Changes in this version

+ func GenerateProto(info *db.TableInfo, modelName, svcName, pkg string) string

+ func GrpcCall[T any](ctx context.Context, gc *GrpcClient, ...) (T, error)

+ func MustGetGrpcServer(svc *Service) *grpc.Server

+ type ClientConnInterface = grpc.ClientConnInterface

+ func MustGetGrpcClientConn(svc *Service, name string) ClientConnInterface

+ type PGPool = pgxpool.Pool

+ type PrometheusConfig struct

+ Enabled bool

+ Host string

+ Path string

+ Port int

type Service

+ func (s *Service) RegisterGrpcService(name string, fn func(srv *grpc.Server)) *Service

type ServiceConfig

+ Prometheus *PrometheusConfig

Jul 27, 2026

Changes in this version

+ func PoolPGRead(pools map[string]any, name string) *pgxpool.Pool

+ func SLOEvent(name string, isError bool)

type DBConfig

+ ReadURL string

type EntryHandlers

+ Reapers []*Reaper

+ type GCConfig struct

+ GOGC int

+ MemoryLimit string

type ListParams

+ Fields []string

type OpenAPIConf

+ SpecCacheTTL string

type PoolConf

+ StatementTimeout string

type RestCtx

+ func (c *RestCtx) PoolRead(name string) *pgxpool.Pool

+ type SLOConfig struct

+ Name string

+ Target float64

+ Window time.Duration

type ServerConf

+ Compression bool

+ GC *GCConfig

+ IdleTimeout string

+ LogSampleRate float64

+ LogSkipPaths []string

+ ReadTimeout string

+ ReduceMemoryUsage bool

+ StreamRequestBody bool

+ WriteTimeout string

type Service

+ func (s *Service) PoolRead(name string) *pgxpool.Pool

Jul 24, 2026

Changes in this version

+ func GenerateShortCode(n int) string

+ func InsertOutbox(ctx context.Context, pool *pgxpool.Pool, subject string, payload []byte) error

+ func InsertOutboxJSON(ctx context.Context, pool *pgxpool.Pool, subject string, data any) error

+ func PresignTTL(store any) time.Duration

type ExitWorker

+ TermOnFailure bool

+ type OutboxRecord struct

+ CreatedAt string

+ ID int64

+ Payload string

+ Status string

+ Subject string

+ type OutboxRelay struct

+ func NewOutboxRelay(pool *pgxpool.Pool, broker events.EventBroker) (*OutboxRelay, error)

+ func (r *OutboxRelay) Start()

+ func (r *OutboxRelay) Stop()

+ type SeedFunc func(context.Context, *Service) error

type Service

+ func (s *Service) WithSeed(fn SeedFunc) *Service

Jul 24, 2026

Changes in this version

+ func VerifyCallbackSignature(payload []byte, secret string, signature string) bool

+ type AsyncCallbackConf struct

+ Retry int

+ RetryDelay string

+ Secret string

+ URL string

type AsyncJobManager

+ func NewAsyncJobManagerWithRetry(store JobStore, processor AsyncHandler, maxRetries int) *AsyncJobManager

+ func (m *AsyncJobManager) HandleCancel() fiber.Handler

+ func (m *AsyncJobManager) HandleList() fiber.Handler

+ func (m *AsyncJobManager) HandleStatusSSE() fiber.Handler

+ type AsyncReassignConf struct

+ Enabled bool

+ MaxRetries int

+ ProcessingTimeout string

+ ReapInterval string

+ type AsyncStoreConf struct

+ Bucket string

+ Callback *AsyncCallbackConf

+ DB string

+ Driver string

+ KV string

+ MaxConcurrent int

+ Reassign *AsyncReassignConf

+ ResultTTL string

+ Stream string

+ Table string

type EntryDef

+ AsyncStore *AsyncStoreConf

type GrpcClientConf

+ Secure bool

type GrpcInterceptorsConfig

+ Prometheus bool

type GrpcServerConf

+ EtcdEndpoints []string

+ EtcdKey string

type JobState

+ CallbackURL string

+ MaxRetries int

+ ProcessingDeadline *time.Time

+ RetryCount int

type JobStore

+ Cleanup func(ctx context.Context, ttl time.Duration) (int, error)

+ List func() ([]*JobState, error)

+ ReapStale func(ctx context.Context, timeout time.Duration, maxRetries int) (int, error)

+ type Reaper struct

+ func NewReaper(store JobStore, timeout, interval time.Duration, maxRetries int) *Reaper

+ func (r *Reaper) Start()

+ func (r *Reaper) Stop()

type ServerConf

+ Mode string

type Service

+ func (s *Service) GetGRPCClient(name string) *GrpcClient

+ func (s *Service) GetGrpcServer() *GrpcServer

Jul 22, 2026

Changes in this version

+ func BuildDirectTarget(endpoints []string) string

+ func BuildEtcdTarget(endpoints []string, key string) string

+ func BulkheadGet(name string) *syncx.Limit

+ func BulkheadRegister(name string, limit int)

+ type CorrelationConf struct

+ Enabled bool

+ RequestHeader string

+ ResponseHeader string

+ SkipPaths []string

type DBConfig

+ SlowQuery *SlowQueryConf

type EntryDef

+ APIStatus string

+ APIVersion string

+ Bulkhead map[string]int

+ Fallback string

+ Retry *RetryConf

+ ServiceName string

+ SunsetDate string

+ type GrpcClient struct

+ func NewGrpcClient(cfg *GrpcClientConf) (*GrpcClient, error)

+ func (gc *GrpcClient) Close() error

+ func (gc *GrpcClient) Conn() *grpc.ClientConn

+ func (gc *GrpcClient) Name() string

+ type GrpcClientConf struct

+ Endpoints []string

+ Name string

+ NonBlock bool

+ Target string

+ Timeout int64

+ type GrpcInterceptorsConfig struct

+ Breaker bool

+ Shedding bool

+ Timeout bool

+ Trace bool

+ type GrpcRegisterFn func(server *grpc.Server)

+ type GrpcServer struct

+ func NewGrpcServer(cfg *GrpcServerConf, register GrpcRegisterFn, ...) (*GrpcServer, error)

+ func (gs *GrpcServer) Server() *grpc.Server

+ func (gs *GrpcServer) Start()

+ func (gs *GrpcServer) Stop()

+ type GrpcServerConf struct

+ CpuThreshold int64

+ Health bool

+ ListenOn string

+ Timeout int64

+ type PoolHealth struct

+ Driver string

+ IdleConns int

+ InUseConns int

+ MaxConns int

+ Name string

+ Status string

+ TotalConns int

+ UtilizationPct float64

+ WaitCount int64

+ WaitDuration string

+ func CheckPoolHealth(name, driver string, pool any) PoolHealth

+ type RetryConf struct

+ InitialInterval string

+ MaxBackoff string

+ MaxRetries int

+ Multiplier float64

type ServerConf

+ Correlation *CorrelationConf

+ GrpcClients []GrpcClientConf

+ GrpcServer *GrpcServerConf

+ Telemetry *TelemetryConf

type Service

+ func (s *Service) WithJWTBlacklist(fn func(rawToken string) bool) *Service

type ServiceConfig

+ Log *logx.LogConf

+ type SlowQueryConf struct

+ Enabled bool

+ Threshold string

type TelemetryConf

+ OtlpHeaders map[string]string

+ OtlpHttpPath string

+ OtlpHttpSecure bool

+ SkipPaths []string

+ TraceResponseHeader string

Jul 18, 2026

Changes in this version

type CSRFConf

+ JSONCheck bool

type EntryDef

+ RequiresMFA bool

+ TenantField string

+ TenantScope string

type RestCtx

+ func (c *RestCtx) PoolPG(name string) *pgxpool.Pool

+ func (c *RestCtx) PoolSQL(name string) *sql.DB

type ServerConf

+ SlowQueryThreshold string

Jul 16, 2026

Changes in this version

+ func SetRateLimitMaxFunc(fn func(c fiber.Ctx) int)

type AuthConfig

+ Cookie *AuthCookieConfig

+ Refresh *RefreshConfig

+ type AuthCookieConfig struct

+ AccessTokenName string

+ Domain string

+ HTTPOnly bool

+ Path string

+ RefreshTokenName string

+ SameSite string

+ Secure bool

+ type CSPConf struct

+ BaseURI []string

+ ConnectSrc []string

+ DefaultSrc []string

+ FontSrc []string

+ FormAction []string

+ FrameAncestors []string

+ FrameSrc []string

+ ImgSrc []string

+ Level string

+ ObjectSrc []string

+ ScriptSrc []string

+ StyleSrc []string

+ UpgradeInsecureReq bool

+ type Cookie struct

+ Domain string

+ HTTPOnly bool

+ MaxAge int

+ Name string

+ Path string

+ SameSite string

+ Secure bool

+ Value string

+ func NewCookie(name, value string, maxAge int) *Cookie

type EntryDef

+ Cache string

+ PerRoleLimits map[string]*RateLimitDef

+ RateLimitPerKey *RateLimitDef

+ RateLimitPerUser *RateLimitDef

+ type KVConfig struct

+ Driver string

+ Name string

+ URL string

+ type Map = map[string]any

type RateLimitConf

+ Algorithm string

+ KV string

+ PerKey *RateLimitDef

+ SkipFailedRequests bool

+ SkipSuccessfulRequests bool

+ TTL string

type RateLimitDef

+ TTL string

+ type RefreshConfig struct

+ Enabled bool

+ Endpoint string

+ KratosRefreshURL string

+ Secret string

+ TTL int

+ ZitadelClientID string

+ ZitadelTokenURL string

type SecurityHeadersConf

+ CSPConfig *CSPConf

type Service

+ func (s *Service) KV(name string) *redis.Redis

+ func (s *Service) Stream(name string) events.EventBroker

+ func (s *Service) WithRateLimitMaxFunc(fn func(c fiber.Ctx) int) *Service

type ServiceConfig

+ KV []KVConfig

+ Stream []StreamConfig

+ type StreamConfig struct

+ Brokers []string

+ ConsumerGroup string

+ Driver string

+ MaxReconnects int

+ Name string

+ ReconnectWait string

+ RetryOnFail bool

+ Streams []StreamDef

+ Timeout string

+ URL string

Jul 12, 2026

Changes in this version

+ type EncryptCookieDef struct

+ Enabled bool

+ Except []string

+ Key string

type EntryDef

+ APIPrefix string

+ AuthModes []string

+ JWTFrom string

type RestCtx

+ func (c *RestCtx) SetCookie(cookie *fiber.Cookie)

type SecurityDef

+ EncryptCookie *EncryptCookieDef

type Service

+ func (s *Service) WithAPIKeyValidator(fn func(ctx context.Context, key string) (*middleware.AuthContext, error)) *Service

Jul 12, 2026

Changes in this version

type EntryDef

+ Timeout string

type ServerConf

+ Breaker bool

+ LoadShedding bool

+ Logger bool

Jul 11, 2026

Changes in this version

+ const NodeType

+ var ErrNotFound = db.ErrNotFound

+ func GetTable[T any](s *Service, name string) *db.Table[T]

+ type CacheConfig struct

+ L1 string

+ L1Size int

+ L1TTL string

+ L2 string

+ L2Path string

type EntryDef

+ MaxPageSize int

+ PageSize int

+ Pagination string

+ Sortable []string

+ type KeysetResponse struct

+ Data any

+ NextCursor string

+ PageSize int

type ListParams

+ Cursor string

+ Pagination string

type PoolConfig

+ IdleTimeout string

+ MaxConnsPerHost int

+ MaxIdleConns int

+ MaxIdlePerHost int

type RestCtx

+ func (c *RestCtx) Redirect(url string, statusCode ...int) error

type Service

+ func (s *Service) PoolPGTyped(name string) *pgxpool.Pool

+ func (s *Service) Storage(path string) server.StorageBackend

type StorageDef

+ Cache *CacheConfig

+ Pool *PoolConfig

+ Presign bool

+ PresignTTL string

Jul 8, 2026

Changes in this version

type Service

+ func NewFromYAML(content []byte) (*Service, error)

type ServiceConfig

+ func ParseConfig(content []byte) (*ServiceConfig, error)

Jul 8, 2026

Changes in this version

type TursoConf

+ func (t *TursoConf) Validate() error

Jul 8, 2026

Changes in this version

+ const TargetAuto

+ const TargetBare

+ const TargetDocker

+ const TargetKube

+ const TargetVercel

+ func CheckVercelWarnings(cfg *ServiceConfig)

+ func ValidateProjectStructure(yamlPath string, target string) error

+ type DeployConfig struct

+ Target string

type ServiceConfig

+ Deploy *DeployConfig

Jul 7, 2026

Changes in this version

type DBConfig

+ Turso *TursoConf

+ type TursoConf struct

+ BusyTimeout int

+ Mode string

Jul 7, 2026

Changes in this version

+ type RestCtx struct

+ func (c *RestCtx) Bind(v any) error

+ func (c *RestCtx) Body() []byte

+ func (c *RestCtx) Context() context.Context

+ func (c *RestCtx) Get(key string) string

+ func (c *RestCtx) JSON(data any) error

+ func (c *RestCtx) Locals(key any, values ...any) any

+ func (c *RestCtx) Method() string

+ func (c *RestCtx) Params(key string) string

+ func (c *RestCtx) Path() string

+ func (c *RestCtx) Query(key string, defaultValue ...string) string

+ func (c *RestCtx) ResponseBody() string

+ func (c *RestCtx) SendStatus(code int) error

+ func (c *RestCtx) SendString(s string) error

+ func (c *RestCtx) Set(key, val string)

+ func (c *RestCtx) Status(code int) *RestCtx

+ func (c *RestCtx) StatusCode() int

Jul 7, 2026

Changes in this version

+ func CachedCRUD[T any](svc *Service, name, poolName, tableName string, redisConf redis.RedisConf, ...)

+ func MongoMustRegister(svc *Service, name, poolName, database, collection, lookupField string)

+ func MustRegister[T any](svc *Service, name, poolName, tableName string, hooks EntryHooks[T])

+ func MySQLCachedCRUD[T any](svc *Service, name, poolName, tableName string, redisConf redis.RedisConf, ...)

+ func MySQLMustRegister[T any](svc *Service, name, poolName, tableName string, hooks EntryHooks[T])

+ func TursoMustRegister[T any](svc *Service, name, poolName, tableName string, hooks EntryHooks[T])

type CRUDProvider

+ func NewMongoCRUDProvider(model *mon.Model, lookupField string) CRUDProvider

type DBConfig

+ Database string

Jul 5, 2026

Changes in this version

+ type CRUDFactory func() CRUDProvider

type Service

+ func (s *Service) WithCRUDFactory(model string, factory CRUDFactory) *Service

Jul 4, 2026

Changes in this version

type AuthConfig

+ Driver string

+ Enabled bool

+ KetoURL string

+ KratosURL string

+ OpenFGAStore string

+ OpenFGAURL string

+ ZitadelURL string

type EntryDef

+ Permissions []string

+ Roles []string

type Service

+ func (s *Service) WithAuthValidator(fn func(context.Context, *middleware.AuthContext, []string) error) *Service

Jul 2, 2026

Changes in this version

type AuthConfig

+ Algorithm string

+ Audience string

+ Expiry int

+ Issuer string

+ type ContentSecurityDef struct

+ Enabled bool

+ PublicKey string

+ Strict bool

+ type CryptionDef struct

+ Enabled bool

+ Key string

+ type SecurityDef struct

+ ContentSecurity *ContentSecurityDef

+ Cryption *CryptionDef

type ServerConf

+ Security *SecurityDef

Jun 28, 2026

Changes in this version

+ func AppGetMySQL[T any](a *App, name string, tableName string) (*db.MySQLTable[T], error)

+ func AppGetPool[T any](a *App, name string, tableName string) (*db.Table[T], error)

+ func AppGetTurso[T any](a *App, name string, tableName string) (*db.TursoTable[T], error)

+ type App struct

+ DB map[string]any

+ NATS map[string]*events.Conn

+ func NewApp(configPath string) (*App, error)

+ func (a *App) AddDB(ctx context.Context, name, driver, url string) error

+ func (a *App) Run() error

+ func (a *App) WithCustomRoutes(fn func(app *fiber.App)) *App

+ type AuthConfig struct

+ ContextKey string

+ PrevSecret string

+ Secret string

+ TokenLookup string

+ type ConsumerDef struct

+ AckWait string

+ BackOff []string

+ DeliverPolicy string

+ Durable string

+ Handler string

+ MaxDeliver int

+ NakDelay string

+ PullBatch int

+ PullMaxWait string

+ QueueGroup string

+ Stream string

+ Subject string

+ type ContentSecurityConf struct

+ Enabled bool

+ PublicKey string

+ Strict bool

+ type CryptionConf struct

+ Enabled bool

+ Key string

type DBConfig

+ Resource string

+ Table string

+ func (d DBConfig) DriverDefaults()

+ type EndpointConf struct

+ List ListConfig

+ type FilterDef struct

+ Column string

+ Type string

+ type GatewayConf struct

+ Enabled bool

+ Port int

+ Upstreams []UpstreamDef

+ type Hooks interface

+ AfterCreate func(ctx context.Context, entity *T) error

+ AfterDelete func(ctx context.Context, id any) error

+ AfterUpdate func(ctx context.Context, entity *T) error

+ BeforeCreate func(ctx context.Context, req T) (T, error)

+ BeforeDelete func(ctx context.Context, id any) error

+ BeforeUpdate func(ctx context.Context, id any, patch map[string]any) (map[string]any, error)

+ type ListConfig struct

+ Filterable []FilterDef

+ MaxPage int

+ PageSize int

+ Sortable []string

+ func (l ListConfig) EffectivePageSize(size int) int

+ func (l ListConfig) IsFilterable(col string) bool

+ func (l ListConfig) IsSortable(col string) bool

+ type NATSConfig struct

+ Consumers []ConsumerDef

+ MaxReconnects int

+ Name string

+ Producers []ProducerDef

+ ReconnectWait string

+ RetryOnFail bool

+ Streams []StreamDef

+ Timeout string

+ URL string

+ type PoolConfig struct

+ HealthCheckPeriod string

+ MaxConnIdleTime string

+ MaxConnLifetime string

+ MaxConns int32

+ MinConns int32

+ ReservedConns int32

+ type ProducerDef struct

+ After []string

+ Stream string

+ Subject string

+ type RealtimeConfig struct

+ SSE []SSEDef

+ WebSocket []WebSocketDef

+ type RedisConfig struct

+ Addr string

+ DB int

+ Name string

+ Pass string

+ PoolSize int

+ TLS bool

+ TLSSkipVerify bool

+ type RouteConf struct

+ Middleware []string

+ Path string

+ type RouteMap struct

+ Method string

+ Path string

+ type SSEDef struct

+ Auth bool

+ Handler string

+ Path string

+ type SecurityConf struct

+ ContentSecurity *ContentSecurityConf

+ Cryption *CryptionConf

type ServerConf

+ Routes []RouteConf

type Service

+ func (s *Service[T]) BuildOpenAPI() (*openapi3.T, error)

+ func (s *Service[T]) Consume(stream string, durable string, ...) error

+ func (s *Service[T]) Table() *db.Table[T]

+ func (s *Service[T]) WithCustomRoutes(fn func(app *fiber.App)) *Service[T]

+ func (s *Service[T]) WithSSEHandlers(h map[string]SSEHandler) *Service[T]

+ func (s *Service[T]) WithWSHandlers(h map[string]WSHandler) *Service[T]

type ServiceConfig

+ Auth AuthConfig

+ DB DBConfig

+ Endpoints EndpointConf

+ Gateway GatewayConf

+ Health bool

+ MultiDB []DBConfig

+ MultiNATS []NATSConfig

+ MultiRedis []RedisConfig

+ OpenAPI OpenAPIConf

+ Realtime RealtimeConfig

+ Security SecurityConf

+ Services []ServiceDef

+ Telemetry TelemetryConf

+ func (c *ServiceConfig) Validate() error

+ type ServiceDef struct

+ DBName string

+ Model string

+ NATSRef string

+ Name string

+ Table string

+ type TelemetryConf struct

+ Batcher string

+ Enabled bool

+ Endpoint string

+ Name string

+ Sampler float64

+ type UpstreamDef struct

+ Mappings []RouteMap

+ Name string

+ Target string

+ type WebSocketDef struct

+ Auth bool

+ Handler string

+ Path string

Jul 1, 2026

Changes in this version

+ func SanitizeFilename(name string) string

+ type AsyncHandler func(body []byte, job *JobState) error

+ type AsyncJobManager struct

+ func NewAsyncJobManager(store JobStore, processor AsyncHandler) *AsyncJobManager

+ func (m *AsyncJobManager) HandleStatus() fiber.Handler

+ func (m *AsyncJobManager) HandleSubmit() fiber.Handler

+ type AutocertTLS struct

+ CacheDir string

+ Domains []string

+ Email string

+ type CSRFConf struct

+ CookieName string

+ Enabled bool

+ ExcludePaths []string

+ HeaderName string

+ SameSite string

+ Secure bool

+ type CookieConf struct

+ SameSite string

+ Secure bool

type EntryDef

+ CSRF *bool

+ EventPublish []EventPublishTarget

+ EventStream string

+ MagicBytes bool

+ MaxFiles int

+ RateLimit *RateLimitDef

+ ValidationModel string

type EntryHandlers

+ Async map[string]AsyncHandler

+ type EventPublishTarget struct

+ EventStream string

+ Stream string

+ Subject string

+ type EventStreamConnConf struct

+ Brokers []string

+ ConsumerGroup string

+ Driver string

+ MaxReconnects int

+ Name string

+ ReconnectWait string

+ RetryOnFail bool

+ Streams []StreamDef

+ Timeout string

+ URL string

+ func (e *EventStreamConnConf) Validate() error

type ExitWorker

+ EventStream string

+ type JobState struct

+ CreatedAt time.Time

+ Error string

+ ID string

+ Result any

+ Status JobStatus

+ UpdatedAt time.Time

+ type JobStatus string

+ const JobCompleted

+ const JobFailed

+ const JobPending

+ const JobProcessing

+ type JobStore interface

+ Create func(id string) *JobState

+ Delete func(id string)

+ Get func(id string) (*JobState, bool)

+ Update func(id string, status JobStatus, result any, errMsg string)

+ type ManualTLS struct

+ CertFile string

+ KeyFile string

+ type RateLimitConf struct

+ Driver string

+ Enabled bool

+ Global *RateLimitDef

+ PerIP *RateLimitDef

+ PerUser *RateLimitDef

+ RedisURL string

+ type RateLimitDef struct

+ Burst int

+ RequestsPerSecond int

+ type SSRFConf struct

+ AllowedHosts []string

+ BlockLoopback bool

+ BlockMetadata bool

+ BlockPrivate bool

+ Enabled bool

+ type SecurityHeadersConf struct

+ COEP string

+ COOP string

+ CORP string

+ CSP string

+ CSPReportPath string

+ CacheControl string

+ FrameOptions string

+ HSTS bool

+ HSTSIncludeSubs bool

+ HSTSMaxAge int

+ PermissionsPolicy string

+ ReferrerPolicy string

type ServerConf

+ CSRF *CSRFConf

+ Cookies *CookieConf

+ RateLimit *RateLimitConf

+ SSRF *SSRFConf

+ SecurityHeaders *SecurityHeadersConf

+ TLS *TLSConf

type Service

+ func (s *Service) RegisterValidation(name string, model any) *Service

+ func (s *Service) SafeHTTPClient() *middleware.SafeHTTPClient

+ func (s *Service) WithAsync(name string, handler AsyncHandler) *Service

type ServiceConfig

+ EventStreams []EventStreamConnConf

+ type TLSConf struct

+ Autocert *AutocertTLS

+ CipherSuites []string

+ CurvePrefs []string

+ Enabled bool

+ Manual *ManualTLS

+ MaxVersion string

+ MinVersion string

+ RedirectHTTP bool

+ RedirectPort int

Jun 29, 2026

Changes in this version

+ func BuildOpenAPI(cfg *ServiceConfig, models map[string]*db.TableInfo) (*openapi3.T, error)

+ func Pool(pools map[string]any, name string) any

+ func PoolPG(pools map[string]any, name string) *pgxpool.Pool

+ func PoolSQL(pools map[string]any, name string) *sql.DB

+ func RegisterEntries(app *fiber.App, cfg *ServiceConfig, handlers *EntryHandlers, prefix string, ...) error

+ func TableFor[T any](pools map[string]any, poolName, tableName string) (*db.Table[T], error)

+ func WrapTransformHandler[T any](handler func(*fiber.Ctx) error, hooks EntryHooks[T]) func(*fiber.Ctx) error

+ type CORSConf struct

+ Credentials bool

+ Headers []string

+ MaxAge int

+ Methods []string

+ Origins []string

+ type CRUDOverrides struct

+ Create string

+ Delete string

+ Get string

+ List string

+ Update string

+ type CRUDProvider interface

+ Create func(ctx *fiber.Ctx, body []byte) error

+ Delete func(ctx *fiber.Ctx, id string) error

+ Get func(ctx *fiber.Ctx, id string) error

+ List func(ctx *fiber.Ctx, params ListParams) error

+ Update func(ctx *fiber.Ctx, id string, body []byte) error

+ func NewCRUDProvider[T any](table *db.Table[T], hooks EntryHooks[T]) CRUDProvider

+ func NewMySQLCRUDProvider[T any](table *db.MySQLTable[T], hooks EntryHooks[T]) CRUDProvider

+ func NewTursoCRUDProvider[T any](table *db.TursoTable[T], hooks EntryHooks[T]) CRUDProvider

+ type CronJob struct

+ Handler string

+ Mode string

+ Name string

+ Publish *CronPublish

+ Schedule string

+ func (c *CronJob) Validate() error

+ type CronJobFunc func(ctx context.Context) error

+ type CronPublish struct

+ Stream string

+ Subject string

+ type CronScheduler struct

+ func NewCronScheduler() *CronScheduler

+ func (s *CronScheduler) AddAll(cronDefs []CronJob, natsConns map[string]*events.Conn, ...) error

+ func (s *CronScheduler) AddJob(cfg CronJob, natsConn *events.Conn, handler CronJobFunc) error

+ func (s *CronScheduler) Start()

+ func (s *CronScheduler) Stop()

+ type DBConfig struct

+ Driver string

+ Name string

+ Pool *PoolConf

+ URL string

+ func (d *DBConfig) Validate() error

+ type DefaultExitHooks struct

+ func (DefaultExitHooks) OnError(_ context.Context, _ error)

+ func (DefaultExitHooks) OnMessage(_ context.Context, msg []byte) ([]byte, error)

+ func (DefaultExitHooks) OnSuccess(_ context.Context)

+ type DefaultHooks struct

+ func (DefaultHooks[T]) AfterCreate(_ context.Context, _ *T) error

+ func (DefaultHooks[T]) AfterDelete(_ context.Context, _ any) error

+ func (DefaultHooks[T]) AfterTransform(_ context.Context, _ any) error

+ func (DefaultHooks[T]) AfterUpdate(_ context.Context, _ *T) error

+ func (DefaultHooks[T]) BeforeCreate(_ context.Context, req T) (T, error)

+ func (DefaultHooks[T]) BeforeDelete(_ context.Context, _ any) error

+ func (DefaultHooks[T]) BeforeTransform(_ context.Context, req T) (T, error)

+ func (DefaultHooks[T]) BeforeUpdate(_ context.Context, _ any, patch map[string]any) (map[string]any, error)

+ type EntryDef struct

+ AllowedTypes []string

+ Auth bool

+ DB string

+ Handler string

+ MaxSize string

+ Method string

+ Model string

+ NATSPublish []NATSPublishTarget

+ Overrides *CRUDOverrides

+ Path string

+ Resource string

+ Storage *StorageDef

+ Table string

+ Type string

+ func (e *EntryDef) Validate() error

+ type EntryHandlers struct

+ CRUD map[string]CRUDProvider

+ Rest map[string]func(*fiber.Ctx) error

+ SSE map[string]SSEHandler

+ Storage map[string]server.StorageBackend

+ Transform map[string]any

+ WS map[string]WSHandler

+ type EntryHooks interface

+ AfterCreate func(ctx context.Context, entity *T) error

+ AfterDelete func(ctx context.Context, id any) error

+ AfterTransform func(ctx context.Context, result any) error

+ AfterUpdate func(ctx context.Context, entity *T) error

+ BeforeCreate func(ctx context.Context, req T) (T, error)

+ BeforeDelete func(ctx context.Context, id any) error

+ BeforeTransform func(ctx context.Context, req T) (T, error)

+ BeforeUpdate func(ctx context.Context, id any, patch map[string]any) (map[string]any, error)

+ type ExitHandler func(ctx context.Context, msg []byte) ([]byte, error)

+ type ExitHooks interface

+ OnError func(ctx context.Context, err error)

+ OnMessage func(ctx context.Context, msg []byte) ([]byte, error)

+ OnSuccess func(ctx context.Context)

+ type ExitWorker struct

+ ConsumerMode string

+ DB string

+ Handler string

+ MaxConcurrent int

+ Name string

+ PullBatch int

+ PullMaxWait string

+ Reply bool

+ ReplyTimeout string

+ Subscribe SubscribeDef

+ func (e *ExitWorker) Validate() error

+ type ExitWorkerManager struct

+ func NewExitWorkerManager() *ExitWorkerManager

+ func (m *ExitWorkerManager) Shutdown(timeout time.Duration)

+ func (m *ExitWorkerManager) Start(ctx context.Context, exitDefs []ExitWorker, natsConns map[string]*events.Conn, ...) error

+ type ListParams struct

+ Filters map[string]string

+ Page int

+ Size int

+ Sort string

+ type NATSConnConf struct

+ MaxReconnects int

+ Name string

+ ReconnectWait string

+ RetryOnFail bool

+ Streams []StreamDef

+ Timeout string

+ URL string

+ func (n *NATSConnConf) Validate() error

+ type NATSPublishTarget struct

+ Stream string

+ Subject string

+ type OpenAPIConf struct

+ DarkMode bool

+ DocsPath string

+ Enabled bool

+ SpecPath string

+ Theme string

+ Version string

+ type PaginatedResponse struct

+ Data any

+ Page int

+ Size int

+ Total int64

+ type PoolConf struct

+ HealthCheckPeriod string

+ MaxConnIdleTime string

+ MaxConnLifetime string

+ MaxConns int32

+ MinConns int32

+ ReservedConns int32

+ type RouteMW struct

+ Apply []string

+ Path string

+ type SSEHandler func(ctx context.Context, send func(data string)) error

+ type ServerConf struct

+ APIPrefix string

+ BodyLimit int

+ CORS *CORSConf

+ HealthPath string

+ Host string

+ MaxBytes int

+ MaxConnLimit int

+ MaxConns int

+ MetricsPath string

+ Middleware []RouteMW

+ OpenAPI *OpenAPIConf

+ Prefork bool

+ RecoverStack bool

+ ShutdownTimeout string

+ Static []StaticDef

+ Timeout string

+ type Service struct

+ func New(configPath string) (*Service, error)

+ func (s *Service) App() *fiber.App

+ func (s *Service) NATS(name string) *events.Conn

+ func (s *Service) Pool(name string) any

+ func (s *Service) PoolPG(name string) any

+ func (s *Service) RegisterModel(name string, model any) *Service

+ func (s *Service) Run() error

+ func (s *Service) RunWithContext(ctx context.Context) error

+ func (s *Service) WithCRUD(model string, provider CRUDProvider) *Service

+ func (s *Service) WithCron(name string, handler CronJobFunc) *Service

+ func (s *Service) WithExit(name string, h ExitHandler) *Service

+ func (s *Service) WithExitHooks(h map[string]ExitHooks) *Service

+ func (s *Service) WithHandlers(h *EntryHandlers) *Service

+ func (s *Service) WithHooks(model string, hooks any) *Service

+ func (s *Service) WithRest(name string, h func(*fiber.Ctx) error) *Service

+ func (s *Service) WithSSE(name string, h SSEHandler) *Service

+ func (s *Service) WithWS(name string, h WSHandler) *Service

+ type ServiceConfig struct

+ Cron []CronJob

+ Databases []DBConfig

+ Entry []EntryDef

+ Exit []ExitWorker

+ NATS []NATSConnConf

+ Name string

+ Port int

+ Server ServerConf

+ func LoadConfig(path string) (*ServiceConfig, error)

+ type StaticDef struct

+ Dir string

+ Prefix string

+ type StorageDef struct

+ AccessKey string

+ Bucket string

+ Endpoint string

+ Mode string

+ Path string

+ Region string

+ SecretKey string

+ type StreamDef struct

+ Compression string

+ MaxAge string

+ MaxBytes int64

+ Name string

+ Storage string

+ type SubscribeDef struct

+ Durable string

+ Stream string

+ Subject string

+ type WSHandler func(ctx context.Context, conn *websocket.Conn) error