app

Documentation

Index

• type Container
  • func NewContainer(cfg *config.Config, log *zap.Logger, logLevel zap.AtomicLevel) (*Container, error)
  • func (ct *Container) Close()
  • func (ct *Container) NewAsynqScheduler() (*asynq.Scheduler, error)
  • func (ct *Container) NewAsynqServeMux() (*asynq.ServeMux, error)
  • func (ct *Container) NewAsynqServer() *asynq.Server
  • func (ct *Container) RunServer(ctx context.Context) error

Types

type Container

type Container struct {
	Cfg      *config.Config
	Log      *zap.Logger
	LogLevel zap.AtomicLevel

	MeterProvider  *sdkmetric.MeterProvider
	TracerProvider *sdktrace.TracerProvider

	DebugServer   *debug.Server
	MetricsServer *telemetry.MetricsServer

	RedisOpt  asynq.RedisClientOpt
	WorkQueue work.Queue
}

Container provides common dependencies for the app, and handles their lifecycle.

func NewContainer

func NewContainer(cfg *config.Config, log *zap.Logger, logLevel zap.AtomicLevel) (*Container, error)

func (*Container) Close

func (ct *Container) Close()

func (*Container) NewAsynqScheduler

func (ct *Container) NewAsynqScheduler() (*asynq.Scheduler, error)

func (*Container) NewAsynqServeMux

func (ct *Container) NewAsynqServeMux() (*asynq.ServeMux, error)

func (*Container) NewAsynqServer

func (ct *Container) NewAsynqServer() *asynq.Server

func (*Container) RunServer

func (ct *Container) RunServer(ctx context.Context) error