db

Documentation

Index

• func NewSqlDB(cfg config.DatabaseConfig) (*sql.DB, error)
• type DB
  • func NewDB(sqlDB *sql.DB, log *zap.SugaredLogger, bus *eventbus.EventBus) (*DB, error)
  • func (db *DB) Ping() error
  • func (db *DB) TX(ctx context.Context, fn func(ctx context.Context) error) error
  • func (db *DB) Truncate(table string) error

Functions

func NewSqlDB

func NewSqlDB(cfg config.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) Ping

func (db *DB) Ping() error

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