db

package

v1.2.0 Latest Latest Go to latest Published: Aug 18, 2026 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/webhookx-io/webhookx

Links

Open Source Insights

Documentation ¶

Index ¶

func NewSqlDB(cfg modules.DatabaseConfig) (*sql.DB, error)
type DB
- func NewDB(sqlDB *sql.DB, log *zap.SugaredLogger, bus eventbus.EventBus) (*DB, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewSqlDB ¶ added in v0.6.0

func NewSqlDB(cfg modules.DatabaseConfig) (*sql.DB, error)

Types ¶

type DB ¶

type DB struct {
	DB *sqlx.DB

	Workspaces       dao.WorkspaceDAO
	Endpoints        dao.EndpointDAO
	EndpointsWS      dao.EndpointDAO
	Events           dao.EventDAO
	EventsWS         dao.EventDAO
	Attempts         dao.AttemptDAO
	AttemptsWS       dao.AttemptDAO
	Sources          dao.SourceDAO
	SourcesWS        dao.SourceDAO
	AttemptDetails   dao.AttemptDetailDAO
	AttemptDetailsWS dao.AttemptDetailDAO
	Plugins          dao.PluginDAO
	PluginsWS        dao.PluginDAO
	// contains filtered or unexported fields
}

func NewDB ¶

func NewDB(sqlDB *sql.DB, log *zap.SugaredLogger, bus eventbus.EventBus) (*DB, error)

func (*DB) Close ¶ added in v1.0.1

func (db *DB) Close() error

func (*DB) Ping ¶

func (db *DB) Ping() error

func (*DB) SqlDB ¶ added in v1.0.0

func (db *DB) SqlDB() *sql.DB

func (*DB) Stats ¶ added in v0.8.0

func (db *DB) Stats() map[string]interface{}

func (*DB) TX ¶

func (db *DB) TX(ctx context.Context, fn func(ctx context.Context) error) error

func (*DB) Truncate ¶

func (db *DB) Truncate(table string) error

Source Files ¶

View all Source files

db.go

Directories ¶

Path	Synopsis
dao
entities
errs
migrations
migrator
transaction

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