infra

Documentation

Index

• func NewDB(cfg DbConfig) *sqlx.DB
• func Start(ctx context.Context, lock *latch.CountDownLatch, cfg Config)
• func StartMQ(ctx context.Context, lock *latch.CountDownLatch, ...) *fake.FakeMQ
• func StartWebServer(ctx context.Context, lock *latch.CountDownLatch, cfg WebConfig, ...)
• type Config
  • func LoadEnvVars() Config
• type DbConfig
• type WebConfig

Functions

func NewDB

func NewDB(cfg DbConfig) *sqlx.DB

NewDB creates a new postgres database connection. It should receive database connection configuration but for the demo purposes we will ignore it

func Start

func Start(ctx context.Context, lock *latch.CountDownLatch, cfg Config)

func StartMQ

func StartMQ(
	ctx context.Context,
	lock *latch.CountDownLatch,
	regSub fakesub.RegistrationController,
) *fake.FakeMQ

func StartWebServer

func StartWebServer(
	ctx context.Context,
	lock *latch.CountDownLatch,
	cfg WebConfig,
	c web.CustomerController,
	r web.RegistrationController,
)

Types

type Config

type Config struct {
	WebConfig
	DbConfig
	OutboxHeartbeat time.Duration `env:"OUTBOX_HEARTBEAT" envDefault:"5s"`
}

func LoadEnvVars

func LoadEnvVars() Config

type DbConfig

type DbConfig struct {
	DbName     string `env:"DB_NAME" envDefault:"postgres"`
	DbHost     string `env:"DB_HOST" envDefault:"localhost"`
	DbPort     int    `env:"DB_PORT" envDefault:"5432"`
	DbUser     string `env:"DB_USER" envDefault:"postgres"`
	DbPassword string `env:"DB_PASSWORD" envDefault:"secret"`
}

type WebConfig

type WebConfig struct {
	Port string `env:"PORT" envDefault:":8080"`
}