dependency

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 27, 2025 License: MIT Imports: 50 Imported by: 0

Documentation

Index

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 InvokeMigrations(c config.Cfg, s config.Server, db *sql.DB, lc fx.Lifecycle) error

func InvokePostgres

func InvokePostgres(conn *pgxpool.Pool) error

func InvokeRedis

func InvokeRedis(rdb *redis.Client) error

func InvokeSeeders added in v1.0.0

func InvokeSeeders(c config.Cfg, s config.Server, db *sql.DB, lc fx.Lifecycle) error

func ProvideAsynqMonitoringServer added in v0.1.0

func ProvideAsynqMonitoringServer(c config.Cfg, l *xlog.DebugLogger, lc fx.Lifecycle) *echo.Echo

func ProvideAsynqRedisConnOption added in v0.1.0

func ProvideAsynqRedisConnOption(c config.Cfg) *asynq.RedisClientOpt

func ProvideAsynqServerName added in v0.3.1

func ProvideAsynqServerName(c config.Cfg) config.Server

func ProvideAsynqmonOption added in v0.1.0

func ProvideAsynqmonOption(c config.Cfg, o *asynq.RedisClientOpt) *asynqmon.Options

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 ProvideHTTPServer(c config.Cfg, logger *xlog.DebugLogger, lc fx.Lifecycle) *echo.Echo

func ProvideHTTPServerName added in v0.3.1

func ProvideHTTPServerName(c config.Cfg) config.Server

func ProvideHttpClient added in v1.0.0

func ProvideHttpClient() *resty.Client

func ProvideIoLogger

func ProvideIoLogger(c config.Cfg, s config.Server, lp otelog.LoggerProvider) *xlog.IOLogger

func ProvideOtelConfig added in v0.4.0

func ProvideOtelConfig(c config.Cfg, s config.Server) xtracer.Config

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 ProvideOtelResource(c xtracer.Config) (*resource.Resource, error)

func ProvideOtelTracer added in v0.4.0

func ProvideOtelTracer(p OtelParamFx) (trace.Tracer, error)

func ProvidePostgres

func ProvidePostgres(c config.Cfg, s config.Server, d *xlog.DebugLogger, lc fx.Lifecycle) (*pgxpool.Pool, error)

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 ProvideRedis

func ProvideRedis(c config.Cfg, s config.Server, lc fx.Lifecycle) *redis.Client

func ProvideRedisLock added in v1.0.0

func ProvideRedisLock(c *redis.Client) *redislock.Client

func ProvideTimeZoneLocation

func ProvideTimeZoneLocation(cfg config.Cfg) (*time.Location, error)

func ProvideTrxLogger

func ProvideTrxLogger(c config.Cfg, s config.Server, lp otelog.LoggerProvider) *xlog.TrxLogger

func ProvideXAsynq

func ProvideXAsynq(c config.Cfg, opt *asynq.RedisClientOpt, log *xlog.DebugLogger, loc *time.Location) *xasynq.Asynq

func ProvideXGmail

func ProvideXGmail(c config.Cfg) *xmail.XGmail

func RotateLog

func RotateLog()

Types

type InvokeAsynqMonitoringServerParam added in v0.1.0

type InvokeAsynqMonitoringServerParam struct {
	fx.In

	Echo *echo.Echo
	Opt  *asynqmon.Options
}

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"`
}

type OtelParamFx added in v0.4.0

type OtelParamFx struct {
	fx.In

	Lc         fx.Lifecycle
	Cfg        xtracer.Config
	GrpcClient *xtracer.GrpcClient
	Resource   *resource.Resource
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL