saas

Documentation

Index

• Variables
• func InitCache()
• func InitConnStrGenerator(sharedDsn string)
• func InitConnStrResolver(sharedDsn string)
• func InitDbProvider()
• func InitSaas(sharedDsn string)
• func NewClientProvider() saas.ClientProvider[*gorm.DB]
• type TenantStore
  • func (t *TenantStore) GetByNameOrId(ctx context.Context, nameOrId string) (*saas.TenantConfig, error)

Variables

var Cache *saas.Cache[string, *sgorm.DbWrap]

var ConnStrGen saas.ConnStrGenerator

var ConnStrResolver data.ConnStrResolver

var DbProvider sgorm.DbProvider

var EnsureDbExist = func(s string) error {
	dbname, err := utils.ParseDBNameFromPostgresDSN(s)
	if err != nil {
		return err
	}

	noDbDsn, err := utils.RemoveDBNameFromPostgresDSN(s)
	if err != nil {
		return err
	}

	db, err := sql.Open("pgx", noDbDsn)
	if err != nil {
		return err
	}

	var exists bool
	err = db.QueryRowContext(context.Background(), "SELECT EXISTS(SELECT 1 FROM pg_database WHERE datname = $1)", dbname).Scan(&exists)
	if err != nil {
		return err
	}

	if !exists {
		_, err := db.ExecContext(context.Background(), fmt.Sprintf("CREATE DATABASE \"%s\"", dbname))
		if err != nil {
			return err
		}
	}

	return db.Close()
}

Functions

func InitCache

func InitCache()

func InitConnStrGenerator

func InitConnStrGenerator(sharedDsn string)

func InitConnStrResolver

func InitConnStrResolver(sharedDsn string)

func InitDbProvider

func InitDbProvider()

func InitSaas

func InitSaas(sharedDsn string)

func NewClientProvider

func NewClientProvider() saas.ClientProvider[*gorm.DB]

Types

type TenantStore

type TenantStore struct {
	DbProvider sgorm.DbProvider
}

var TenantStorage *TenantStore

func (*TenantStore) GetByNameOrId

func (t *TenantStore) GetByNameOrId(ctx context.Context, nameOrId string) (*saas.TenantConfig, error)