myfx

package module

v0.0.0-...-a0d3b52 Latest Latest Go to latest Published: Jan 14, 2025 License: MIT Imports: 39 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/yankeguo/myfx

README ¶

myfx

All my favorite Golang libraries, wrapped with Fx

Credits

GUO YANKE, MIT License

Documentation ¶

Index ¶

Variables
func ClearSampleSwitch(ctx context.Context) context.Context
func NewAsynqClient(r *redis.Client, lc fx.Lifecycle) *asynq.Client
func NewAsynqLogger(log *zap.Logger) asynq.Logger
func NewAsynqServer(r *redis.Client, logger asynq.Logger) *asynq.Server
func NewFiberServer() *fiber.App
func NewGormDB(vb Verbose, log *zap.Logger, tp trace.TracerProvider) (db *gorm.DB, err error)
func NewOTELLoggerProvider(lc fx.Lifecycle, res *resource.Resource) (log.Exporter, otellog.LoggerProvider, error)
func NewOTELMetricProvider(lc fx.Lifecycle, res *resource.Resource) (metric.Exporter, otelmetric.MeterProvider, error)
func NewOTELPropagator() propagation.TextMapPropagator
func NewOTELResource() (res *resource.Resource, err error)
func NewOTELTraceProvider(lc fx.Lifecycle, res *resource.Resource, s trace.Sampler) (trace.SpanExporter, oteltrace.TracerProvider, error)
func NewRedisClient(tp trace.TracerProvider, mp metric.MeterProvider) (r *redis.Client, err error)
func NewRedsync(r *redis.Client) *redsync.Redsync
func NewRestyClient(log *zap.Logger, tp trace.TracerProvider, vb Verbose) *resty.Client
func NewZhipuClient(client *resty.Client) (*zhipu.Client, error)
func ProvidePrivateLogger(name string) fx.Option
func ProvideSwitchSampler(defaultValue bool) fx.Option
func SampleSwitch(defaultValue bool) trace.Sampler
func SetSampleSwitch(ctx context.Context, enabled bool) context.Context
func SetupOTEL(pr propagation.TextMapPropagator, tp oteltrace.TracerProvider, ...) (err error)
func SetupRoyalGuard(vb Verbose, log *zap.Logger)
type LoggerFactory
- func NewLoggerFactory(lp log.LoggerProvider) LoggerFactory
type Verbose
- func NewVerbose() Verbose

Constants ¶

This section is empty.

Variables ¶

View Source

var Module = fx.Module(
	"myfx",
	ProvidePrivateLogger("github.com/yankeguo/myfx"),
	fx.Provide(
		NewAsynqClient,
		NewAsynqLogger,
		NewAsynqServer,
		NewFiberServer,
		NewGormDB,
		NewLoggerFactory,
		NewOTELLoggerProvider,
		NewOTELMetricProvider,
		NewOTELPropagator,
		NewOTELResource,
		NewOTELTraceProvider,
		NewRedisClient,
		NewRedsync,
		NewRestyClient,
		NewVerbose,
		NewZhipuClient,
	),
	fx.Invoke(
		SetupRoyalGuard,
		SetupOTEL,
	),
)

Functions ¶

func ClearSampleSwitch ¶

func ClearSampleSwitch(ctx context.Context) context.Context

func NewAsynqClient ¶

func NewAsynqClient(r *redis.Client, lc fx.Lifecycle) *asynq.Client

func NewAsynqLogger ¶

func NewAsynqLogger(log *zap.Logger) asynq.Logger

func NewAsynqServer ¶

func NewAsynqServer(r *redis.Client, logger asynq.Logger) *asynq.Server

func NewFiberServer ¶

func NewFiberServer() *fiber.App

func NewGormDB ¶

func NewGormDB(vb Verbose, log *zap.Logger, tp trace.TracerProvider) (db *gorm.DB, err error)

func NewOTELLoggerProvider ¶

func NewOTELLoggerProvider(lc fx.Lifecycle, res *resource.Resource) (log.Exporter, otellog.LoggerProvider, error)

func NewOTELMetricProvider ¶

func NewOTELMetricProvider(lc fx.Lifecycle, res *resource.Resource) (metric.Exporter, otelmetric.MeterProvider, error)

func NewOTELPropagator ¶

func NewOTELPropagator() propagation.TextMapPropagator

func NewOTELResource ¶

func NewOTELResource() (res *resource.Resource, err error)

func NewOTELTraceProvider ¶

func NewOTELTraceProvider(lc fx.Lifecycle, res *resource.Resource, s trace.Sampler) (trace.SpanExporter, oteltrace.TracerProvider, error)

func NewRedisClient ¶

func NewRedisClient(tp trace.TracerProvider, mp metric.MeterProvider) (r *redis.Client, err error)

func NewRedsync ¶

func NewRedsync(r *redis.Client) *redsync.Redsync

func NewRestyClient ¶

func NewRestyClient(log *zap.Logger, tp trace.TracerProvider, vb Verbose) *resty.Client

func NewZhipuClient ¶

func NewZhipuClient(client *resty.Client) (*zhipu.Client, error)

func ProvidePrivateLogger ¶

func ProvidePrivateLogger(name string) fx.Option

func ProvideSwitchSampler ¶

func ProvideSwitchSampler(defaultValue bool) fx.Option

func SampleSwitch ¶

func SampleSwitch(defaultValue bool) trace.Sampler

func SetSampleSwitch ¶

func SetSampleSwitch(ctx context.Context, enabled bool) context.Context

func SetupOTEL ¶

func SetupOTEL(pr propagation.TextMapPropagator, tp oteltrace.TracerProvider, mp otelmetric.MeterProvider, lp otellog.LoggerProvider) (err error)

func SetupRoyalGuard ¶

func SetupRoyalGuard(vb Verbose, log *zap.Logger)

Types ¶

type LoggerFactory ¶

type LoggerFactory interface {
	Logger(pkg string) *zap.Logger
}

func NewLoggerFactory ¶

func NewLoggerFactory(lp log.LoggerProvider) LoggerFactory

type Verbose ¶

type Verbose interface {
	Set(verbose bool)
	Get() bool
}

func NewVerbose ¶

func NewVerbose() Verbose

Source Files ¶

View all Source files

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