data

Documentation

Index

• Variables
• type Database
  • func NewDatabase(cfg *config.DatabaseConfig, log *zap.Logger) (*Database, error)
  • func ProvideDatabase(lc fx.Lifecycle, cfg *config.DatabaseConfig, log *zap.Logger) (*Database, error)
  • func (d *Database) Client() *ent.Client
  • func (d *Database) Close() error
• type UserRepo
  • func NewUserRepo(db *Database) *UserRepo
  • func (r *UserRepo) CreateUser(ctx context.Context, name, email string) (*ent.User, error)
  • func (r *UserRepo) GetUser(ctx context.Context, id int64) (*ent.User, error)
  • func (r *UserRepo) ListUsers(ctx context.Context) ([]*ent.User, error)

Variables

var Module = fx.Module("data",
	fx.Provide(
		fx.Annotate(
			func(cfg *config.AppConfig) *config.DatabaseConfig {
				return &cfg.Database
			},
			fx.As(new(*config.DatabaseConfig)),
		),
		ProvideDatabase,
	),
)

Types

type Database

type Database struct {
	// contains filtered or unexported fields
}

func NewDatabase

func NewDatabase(cfg *config.DatabaseConfig, log *zap.Logger) (*Database, error)

func ProvideDatabase

func ProvideDatabase(lc fx.Lifecycle, cfg *config.DatabaseConfig, log *zap.Logger) (*Database, error)

func (*Database) Client

func (d *Database) Client() *ent.Client

func (*Database) Close

func (d *Database) Close() error

type UserRepo

type UserRepo struct {
	// contains filtered or unexported fields
}

func NewUserRepo

func NewUserRepo(db *Database) *UserRepo

func (*UserRepo) CreateUser

func (r *UserRepo) CreateUser(ctx context.Context, name, email string) (*ent.User, error)

func (*UserRepo) GetUser

func (r *UserRepo) GetUser(ctx context.Context, id int64) (*ent.User, error)

func (*UserRepo) ListUsers

func (r *UserRepo) ListUsers(ctx context.Context) ([]*ent.User, error)