Documentation
¶
Index ¶
- func InvokeAsynqMonitoringServer(p InvokeAsynqMonitoringServerParam) error
- func InvokeAsynqSchedulerServer(p InvokeAsynqSchedulerServerParam) error
- func InvokeAsynqWorkerServer(p InvokeAsynqWorkerServerParam) error
- func InvokeHttpServer(p InvokeHttpServerParam)
- func InvokeMigrations(c config.Cfg, s config.Server, db *sql.DB, lc fx.Lifecycle) error
- func InvokePostgres(conn *pgxpool.Pool) error
- func InvokeRedis(rdb *redis.Client) error
- func InvokeSeeders(c config.Cfg, s config.Server, db *sql.DB, lc fx.Lifecycle) error
- func ProvideAsynqMonitoringServer(c config.Cfg, l *xlog.DebugLogger, lc fx.Lifecycle) *echo.Echo
- func ProvideAsynqRedisConnOption(c config.Cfg) *asynq.RedisClientOpt
- func ProvideAsynqServerName(c config.Cfg) config.Server
- func ProvideAsynqmonOption(c config.Cfg, o *asynq.RedisClientOpt) *asynqmon.Options
- func ProvideDebugLogger(c config.Cfg, s config.Server, lp otelog.LoggerProvider) *xlog.DebugLogger
- func ProvideEncryptionAES(c config.Cfg) (*xsecurity.EncryptionAES, error)
- func ProvideHTTPServer(c config.Cfg, logger *xlog.DebugLogger, lc fx.Lifecycle) *echo.Echo
- func ProvideHTTPServerName(c config.Cfg) config.Server
- func ProvideHttpClient() *resty.Client
- func ProvideIoLogger(c config.Cfg, s config.Server, lp otelog.LoggerProvider) *xlog.IOLogger
- func ProvideOtelConfig(c config.Cfg, s config.Server) xtracer.Config
- func ProvideOtelGrpcClient(c xtracer.Config) (*xtracer.GrpcClient, error)
- func ProvideOtelLog(p OtelParamFx) (log.LoggerProvider, error)
- func ProvideOtelMetric(p OtelParamFx) (metric.Meter, error)
- func ProvideOtelResource(c xtracer.Config) (*resource.Resource, error)
- func ProvideOtelTracer(p OtelParamFx) (trace.Tracer, error)
- func ProvidePostgres(c config.Cfg, s config.Server, d *xlog.DebugLogger, lc fx.Lifecycle) (*pgxpool.Pool, error)
- func ProvidePostgresSQLDB(c config.Cfg, s config.Server, pool *pgxpool.Pool, lc fx.Lifecycle) (*sql.DB, error)
- func ProvideRedis(c config.Cfg, s config.Server, lc fx.Lifecycle) *redis.Client
- func ProvideRedisLock(c *redis.Client) *redislock.Client
- func ProvideTimeZoneLocation(cfg config.Cfg) (*time.Location, error)
- func ProvideTrxLogger(c config.Cfg, s config.Server, lp otelog.LoggerProvider) *xlog.TrxLogger
- func ProvideXAsynq(c config.Cfg, opt *asynq.RedisClientOpt, log *xlog.DebugLogger, ...) *xasynq.Asynq
- func ProvideXGmail(c config.Cfg) *xmail.XGmail
- func RotateLog()
- type InvokeAsynqMonitoringServerParam
- type InvokeAsynqSchedulerServerParam
- type InvokeAsynqWorkerServerParam
- type InvokeHttpServerParam
- type OtelParamFx
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InvokeAsynqMonitoringServer ¶ added in v0.1.0
func InvokeAsynqMonitoringServer(p InvokeAsynqMonitoringServerParam) error
func InvokeAsynqSchedulerServer ¶ added in v0.1.0
func InvokeAsynqSchedulerServer(p InvokeAsynqSchedulerServerParam) error
func InvokeAsynqWorkerServer ¶ added in v0.1.0
func InvokeAsynqWorkerServer(p InvokeAsynqWorkerServerParam) error
func InvokeHttpServer ¶
func InvokeHttpServer(p InvokeHttpServerParam)
func InvokeMigrations ¶ added in v1.0.0
func InvokePostgres ¶
func InvokeRedis ¶
func InvokeSeeders ¶ added in v1.0.0
func ProvideAsynqMonitoringServer ¶ added in v0.1.0
func ProvideAsynqRedisConnOption ¶ added in v0.1.0
func ProvideAsynqRedisConnOption(c config.Cfg) *asynq.RedisClientOpt
func ProvideAsynqServerName ¶ added in v0.3.1
func ProvideAsynqmonOption ¶ added in v0.1.0
func ProvideDebugLogger ¶
func ProvideDebugLogger(c config.Cfg, s config.Server, lp otelog.LoggerProvider) *xlog.DebugLogger
func ProvideEncryptionAES ¶ added in v1.0.0
func ProvideEncryptionAES(c config.Cfg) (*xsecurity.EncryptionAES, error)
NOTE ¶
Please Generate With Command: `openssl rand -base64 32`
func ProvideHTTPServer ¶
func ProvideHttpClient ¶ added in v1.0.0
func ProvideIoLogger ¶
func ProvideOtelConfig ¶ added in v0.4.0
func ProvideOtelGrpcClient ¶ added in v0.4.0
func ProvideOtelGrpcClient(c xtracer.Config) (*xtracer.GrpcClient, error)
func ProvideOtelLog ¶ added in v0.5.0
func ProvideOtelLog(p OtelParamFx) (log.LoggerProvider, error)
func ProvideOtelMetric ¶ added in v0.4.0
func ProvideOtelMetric(p OtelParamFx) (metric.Meter, error)
func ProvideOtelResource ¶ added in v0.4.0
func ProvideOtelTracer ¶ added in v0.4.0
func ProvideOtelTracer(p OtelParamFx) (trace.Tracer, error)
func ProvidePostgres ¶
func ProvidePostgresSQLDB ¶ added in v1.0.0
func ProvidePostgresSQLDB(c config.Cfg, s config.Server, pool *pgxpool.Pool, lc fx.Lifecycle) (*sql.DB, error)
This Paramater:
- pool *pgxpool.Pool just for load the provider.
func ProvideTrxLogger ¶
func ProvideXAsynq ¶
func ProvideXAsynq(c config.Cfg, opt *asynq.RedisClientOpt, log *xlog.DebugLogger, loc *time.Location) *xasynq.Asynq
Types ¶
type InvokeAsynqMonitoringServerParam ¶ added in v0.1.0
type InvokeAsynqSchedulerServerParam ¶ added in v0.1.0
type InvokeAsynqSchedulerServerParam struct {
fx.In
Cfg config.Cfg
Lfc fx.Lifecycle
Log *xlog.DebugLogger
Asynq *xasynq.Asynq
RedisConnOpt *asynq.RedisClientOpt
Router []asynq_router.AsynqSchedulerRouter `group:"global:asynq:scheduler:router"`
}
type InvokeAsynqWorkerServerParam ¶ added in v0.1.0
type InvokeAsynqWorkerServerParam struct {
fx.In
Cfg config.Cfg
Lfc fx.Lifecycle
Log *xlog.DebugLogger
RedisConnOpt *asynq.RedisClientOpt
Router []asynq_router.AsynqWorkerRouter `group:"global:asynq:worker:router"`
}
type InvokeHttpServerParam ¶
type InvokeHttpServerParam struct {
fx.In
Cfg config.Cfg
Server config.Server
Tracer trace.Tracer
Echo *echo.Echo
Middleware []http_middleware.Middleware `group:"global:http:middleware"`
Router []http_router.HttpRouter `group:"global:http:router"`
}
Source Files
¶
- dependency.asynq.go
- dependency.asynq.startup.monitoring.go
- dependency.asynq.startup.scheduler.go
- dependency.asynq.startup.worker.go
- dependency.cache.go
- dependency.db.go
- dependency.db.migration.go
- dependency.email.go
- dependency.http.client.go
- dependency.http.go
- dependency.http.startup.go
- dependency.log.go
- dependency.otel.go
- dependency.security.aes.go
- dependency.time.location.go
Click to show internal directories.
Click to hide internal directories.