db

Documentation

Index

• type DB
  • func NewDB(cfg *config.DatabaseConfig) (*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

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(cfg *config.DatabaseConfig) (*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