providers

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 19, 2026 License: MIT Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ProvideDB

func ProvideDB(env *config.Config) (*database.DB, error)

ProvideDB is a static provider for the database.

Types

type AuthProvider

type AuthProvider struct {
	engine.BaseProvider
	// contains filtered or unexported fields
}

AuthProvider implements engine.Provider for the OAuth2 service.

func NewAuthProvider

func NewAuthProvider(m *auth.OAuth2Manager) *AuthProvider

func (*AuthProvider) Name

func (p *AuthProvider) Name() string

func (*AuthProvider) Register

func (p *AuthProvider) Register(a *engine.App) error

type CockpitProvider

type CockpitProvider struct {
	engine.BaseProvider
	// contains filtered or unexported fields
}

func NewCockpitProvider

func NewCockpitProvider(
	dash *telemetry.Dashboard,
	sandbox *platformtelemetry.MailSandbox,
	queueMon *telemetry.QueueMonitor,
	db *database.DB,
	router *http.Router,
) *CockpitProvider

func (*CockpitProvider) Boot

func (p *CockpitProvider) Boot(app *engine.App) error

func (*CockpitProvider) Name

func (p *CockpitProvider) Name() string

func (*CockpitProvider) Register

func (p *CockpitProvider) Register(app *engine.App) error

type DatabaseProvider

type DatabaseProvider struct {
	engine.BaseProvider
	// contains filtered or unexported fields
}

DatabaseProvider implements engine.Provider for the Database service.

func (*DatabaseProvider) Boot

func (p *DatabaseProvider) Boot(a *engine.App) error

Boot starts the database connection.

func (*DatabaseProvider) Register

func (p *DatabaseProvider) Register(a *engine.App) error

Register assembles the DB service into the app.

func (*DatabaseProvider) Shutdown

func (p *DatabaseProvider) Shutdown(ctx context.Context, a *engine.App) error

Shutdown gracefully closes the database connection.

type HTTPProvider

type HTTPProvider struct {
	Handler http.Handler
}

HTTPProvider manages the lifecycle of the HTTP server.

func NewHTTPProvider

func NewHTTPProvider(handler http.Handler) *HTTPProvider

NewHTTPProvider creates a new HTTPProvider with the given handler.

func (*HTTPProvider) Boot

func (p *HTTPProvider) Boot(app *engine.App) error

Boot is a no-op for HTTPProvider.

func (*HTTPProvider) Name

func (p *HTTPProvider) Name() string

Name returns the provider name.

func (*HTTPProvider) Register

func (p *HTTPProvider) Register(app *engine.App) error

Register registers the HTTP server as a service.

func (*HTTPProvider) Shutdown

func (p *HTTPProvider) Shutdown(ctx context.Context, app *engine.App) error

Shutdown gracefully stops the HTTP server.

type I18nProvider

type I18nProvider struct {
	engine.BaseProvider
	// contains filtered or unexported fields
}

func NewI18nProvider

func NewI18nProvider(fallback string) *I18nProvider

func (*I18nProvider) Boot

func (p *I18nProvider) Boot(a *engine.App) error

func (*I18nProvider) Name

func (p *I18nProvider) Name() string

func (*I18nProvider) Register

func (p *I18nProvider) Register(a *engine.App) error

func (*I18nProvider) Shutdown

func (p *I18nProvider) Shutdown(ctx context.Context, a *engine.App) error

type NotificationProvider

type NotificationProvider struct {
	engine.BaseProvider
	// contains filtered or unexported fields
}

func NewNotificationProvider

func NewNotificationProvider(m mail.Mailer) *NotificationProvider

func (*NotificationProvider) Name

func (p *NotificationProvider) Name() string

func (*NotificationProvider) Register

func (p *NotificationProvider) Register(a *engine.App) error

type ORMProvider

type ORMProvider struct {
	engine.BaseProvider
	// contains filtered or unexported fields
}

ORMProvider implements engine.Provider for the ORM service. Register this provider in your application to connect to the database.

In an idiomatic Go setup, use google/wire to inject the *database.DB directly into handlers or repositories rather than resolving it from a container.

func (*ORMProvider) Boot

func (p *ORMProvider) Boot(a *engine.App) error

Boot initializes ORM metrics if telemetry is enabled.

func (*ORMProvider) Register

func (p *ORMProvider) Register(a *engine.App) error

Register connects to the database and registers the *database.DB instance.

func (*ORMProvider) Shutdown

func (p *ORMProvider) Shutdown(ctx context.Context, _ *engine.App) error

Shutdown closes the database connection pool.

type ObservabilityProvider

type ObservabilityProvider struct {
	engine.BaseProvider
	// contains filtered or unexported fields
}

ObservabilityProvider implements engine.Provider for observability services.

func NewObservabilityProvider

func NewObservabilityProvider() *ObservabilityProvider

NewObservabilityProvider creates a new ObservabilityProvider.

func (*ObservabilityProvider) Boot

func (p *ObservabilityProvider) Boot(app *engine.App) error

Boot initializes health checks, tracing, and metrics.

func (*ObservabilityProvider) Register

func (p *ObservabilityProvider) Register(app *engine.App) error

Register is a no-op for ObservabilityProvider.

func (*ObservabilityProvider) Shutdown

func (p *ObservabilityProvider) Shutdown(ctx context.Context, app *engine.App) error

Shutdown gracefully stops any observability background tasks.

type QueueProvider

type QueueProvider struct {
	engine.BaseProvider
	// contains filtered or unexported fields
}

func (*QueueProvider) Boot

func (p *QueueProvider) Boot(a *engine.App) error

func (*QueueProvider) Name

func (p *QueueProvider) Name() string

func (*QueueProvider) Register

func (p *QueueProvider) Register(a *engine.App) error

func (*QueueProvider) Shutdown

func (p *QueueProvider) Shutdown(ctx context.Context, a *engine.App) error

type RBACProvider

type RBACProvider struct {
	engine.BaseProvider
	// contains filtered or unexported fields
}

func NewRBACProvider

func NewRBACProvider(r *rbac.RBAC) *RBACProvider

func (*RBACProvider) Name

func (p *RBACProvider) Name() string

func (*RBACProvider) Register

func (p *RBACProvider) Register(a *engine.App) error

type SessionProvider

type SessionProvider struct {
	engine.BaseProvider
	// contains filtered or unexported fields
}

func NewSessionProvider

func NewSessionProvider(store session.Store) *SessionProvider

func (*SessionProvider) Name

func (p *SessionProvider) Name() string

func (*SessionProvider) Register

func (p *SessionProvider) Register(a *engine.App) error

type StorageProvider

type StorageProvider struct {
	engine.BaseProvider
	// contains filtered or unexported fields
}

func NewStorageProvider

func NewStorageProvider() *StorageProvider

func (*StorageProvider) Name

func (p *StorageProvider) Name() string

func (*StorageProvider) Register

func (p *StorageProvider) Register(a *engine.App) error

type ValidateProvider

type ValidateProvider struct {
	engine.BaseProvider
}

func (*ValidateProvider) Name

func (p *ValidateProvider) Name() string

func (*ValidateProvider) Register

func (p *ValidateProvider) Register(app *engine.App) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL