Versions in this module Expand all Collapse all v0 v0.0.3 Jul 16, 2026 v0.0.2 Jul 15, 2026 Changes in this version + func ApplyDBPoolTuning(db *sql.DB, t DBPoolTuning) + func NewLogger(cfg Config) *slog.Logger + func RequireMounted(srv *Server, src DescriptorSource) error + func Run(ctx context.Context, cfg Config, srv Server) error + type Config struct + Addr string + AutoMigrate bool + CORSAllowCredentials bool + CORSOrigins []string + DBDriver string + DBPoolTuning DBPoolTuning + DatabaseURL string + Environment string + FailurePolicy FailurePolicy + LogFormat string + LogLevel slog.Level + OTLPEndpoint string + OperatorHealthProbeAddr string + PprofAddr string + PreStopDelay time.Duration + ReadMaxBytes int + SecurityHeaders bool + SendMaxBytes int + ServiceName string + ServiceVersion string + ShutdownTimeout time.Duration + TLSCertPath string + TLSKeyPath string + type ContextWorker interface + RunContext func(ctx context.Context) error + type DBPoolTuning struct + ConnMaxIdleTime time.Duration + ConnMaxLifetime time.Duration + MaxIdleConns int + MaxOpenConns int + type DescriptorSource interface + RangeFiles func(func(protoreflect.FileDescriptor) bool) + type FailurePolicy int + const FailProcess + const Ignore + type FlowCheck struct + Check func(ctx context.Context) FlowResult + Name string + type FlowResult struct + OK bool + Summary string + type Operator interface + Name func() string + type Server struct + CORSMiddleware func(origins []string, allowCredentials bool) func(http.Handler) http.Handler + FlowChecks []FlowCheck + HTTPMiddleware func(http.Handler) http.Handler + Handler http.Handler + HandlerOpts []connect.HandlerOption + Logger *slog.Logger + Mux *http.ServeMux + OnShutdown func(context.Context) error + Operators []Operator + RequestIDMiddleware func() func(http.Handler) http.Handler + RunOperators func(ctx context.Context, logger *slog.Logger, healthProbeAddr string) error + SecurityHeadersMiddleware func(production bool) func(http.Handler) http.Handler + Workers []Worker + func (s *Server) AddFlowCheck(c FlowCheck) + func (s *Server) AddOperator(o Operator) + func (s *Server) AddWorker(w Worker) + func (s *Server) Mount(connectPath string, svc any, mountOpts ...mountkit.Option) + func (s *Server) Mounted(name string) + func (s *Server) MountedNames() []string + func (s *Server) RequireMounted(src DescriptorSource) error + type Worker interface + Name func() string + Start func(ctx context.Context) error + Stop func(ctx context.Context) error
Go to main page