service

Documentation

Index

• type BackgroundTasks
  • func NewBackgroundTasks(cfg config.BackgroundTasksConfig, logger *zerolog.Logger, useCase UseCase) *BackgroundTasks
  • func (b *BackgroundTasks) Start(ctx context.Context)
• type HTTPServer
  • func NewHTTPServer(httpCfg config.HTTPServerConfig, logger *zerolog.Logger, ...) *HTTPServer
  • func (s *HTTPServer) Start() error
• type PostgresCheck
  • func NewPostgresCheck(name string, pool *pgxpool.Pool) *PostgresCheck
  • func (check *PostgresCheck) Execute(ctx context.Context) (interface{}, error)
  • func (check *PostgresCheck) Name() string
• type PostgresDB
  • func NewPostgresDB(ctx context.Context, cfg config.PostgresConfig, logger *zerolog.Logger, ...) *PostgresDB
  • func (d PostgresDB) GetPool() *pgxpool.Pool
• type StartupCheckService
  • func NewStartupCheck(startupCheckCfg config.CheckConfig) *StartupCheckService
  • func (s *StartupCheckService) GetCheckPeriod() time.Duration
  • func (s *StartupCheckService) GetChecker() gosundheit.Health
• type UseCase

Types

type BackgroundTasks

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

func NewBackgroundTasks

func NewBackgroundTasks(cfg config.BackgroundTasksConfig, logger *zerolog.Logger, useCase UseCase) *BackgroundTasks

func (*BackgroundTasks) Start

func (b *BackgroundTasks) Start(ctx context.Context)

type HTTPServer

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

func NewHTTPServer

func NewHTTPServer(
	httpCfg config.HTTPServerConfig,
	logger *zerolog.Logger,
	startupCheckSvc *StartupCheckService,
	currencyController *currency.Controller,
) *HTTPServer

func (*HTTPServer) Start

func (s *HTTPServer) Start() error

type PostgresCheck

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

func NewPostgresCheck

func NewPostgresCheck(name string, pool *pgxpool.Pool) *PostgresCheck

func (*PostgresCheck) Execute

func (check *PostgresCheck) Execute(ctx context.Context) (interface{}, error)

func (*PostgresCheck) Name

func (check *PostgresCheck) Name() string

type PostgresDB

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

func NewPostgresDB

func NewPostgresDB(
	ctx context.Context,
	cfg config.PostgresConfig,
	logger *zerolog.Logger,
	startupCheckSvc *StartupCheckService,
) *PostgresDB

func (PostgresDB) GetPool

func (d PostgresDB) GetPool() *pgxpool.Pool

type StartupCheckService

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

func NewStartupCheck

func NewStartupCheck(startupCheckCfg config.CheckConfig) *StartupCheckService

func (*StartupCheckService) GetCheckPeriod

func (s *StartupCheckService) GetCheckPeriod() time.Duration

func (*StartupCheckService) GetChecker

func (s *StartupCheckService) GetChecker() gosundheit.Health

type UseCase

type UseCase interface {
	Update(ctx context.Context, er *entity.CurrencyPair) error
	Init(ctx context.Context, pair *entity.CurrencyPair) error
}