infrastructure

Documentation

Index

• func NewHealthHandlers(mount *echo.Group, logger logger.Logger, postgresClient *sqlx.DB, ...)
• type App
  • func NewApp(ctx context.Context, cfg *config.Config, logger logger.Logger, ...) *App
  • func (a *App) Run(ctx context.Context) error
  • func (a *App) Shutdown()
• type CustomValidator
  • func (cv *CustomValidator) Validate(i interface{}) error
• type HealthHandlers
• type Web
  • func NewWeb(cfg *config.Config, logger logger.Logger, lock *latch.CountDownLatch) *Web
  • func (w *Web) Shutdown() error
  • func (w *Web) Start() error

Functions

func NewHealthHandlers

func NewHealthHandlers(
	mount *echo.Group,
	logger logger.Logger,
	postgresClient *sqlx.DB,
	redisClient *redis.Client,
	kafkaClient *kafka.Conn,
)

Types

type App

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

func NewApp

func NewApp(
	ctx context.Context,
	cfg *config.Config,
	logger logger.Logger,
	lock *latch.CountDownLatch,
) *App

func (*App) Run

func (a *App) Run(ctx context.Context) error

func (*App) Shutdown

func (a *App) Shutdown()

type CustomValidator

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

func (*CustomValidator) Validate

func (cv *CustomValidator) Validate(i interface{}) error

type HealthHandlers

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

type Web

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

func NewWeb

func NewWeb(cfg *config.Config, logger logger.Logger, lock *latch.CountDownLatch) *Web

func (*Web) Shutdown

func (w *Web) Shutdown() error

func (*Web) Start

func (w *Web) Start() error