initialize

package

v0.0.0-...-0a821e7 Latest Latest Go to latest Published: Oct 15, 2025 License: MIT Imports: 56 Imported by: 0

Details

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

Repository

github.com/supuwoerc/weaver

Links

Open Source Insights

Documentation ¶

Rendered for

Index ¶

func LoadConfig(viperClient *viper.Viper, consulClient *api.Client) *conf.Config
func LoadConsulConfig(viperClient *viper.Viper) *conf.ConsulConfig
func NewConsulClient(conf *conf.ConsulConfig) *api.Client
func NewCronClient(l *CronLogger) *cron.Cron
func NewDialer(conf *conf.Config) *gomail.Dialer
func NewElasticsearchClient(conf *conf.Config, logger elastictransport.Logger) *elasticsearch.TypedClient
func NewEngine(emailClient *EmailClient, rc *local.CommonRedisClient, logger *logger.Logger, ...) *gin.Engine
func NewGORM(conf *conf.Config, l logger.Interface) *gorm.DB
func NewOTLPExporter(conf *conf.Config) *otlptrace.Exporter
func NewRedisClient(hook goredislib.Hook, conf *conf.Config) *local.CommonRedisClient
func NewS3Client(cfg *conf.Config) *s3.Client
func NewTracerProvider(conf *conf.Config, exporter tracesdk.SpanExporter) *tracesdk.TracerProvider
func NewViper() *viper.Viper
func NewWriterSyncer(conf *conf.Config) zapcore.WriteSyncer
func NewZapLogger(conf *conf.Config, sync zapcore.WriteSyncer) *zap.SugaredLogger
type ClientLogger
type CronLogger
- func NewCronLogger(logger *logger.Logger, emailClient *EmailClient) *CronLogger
- func (c *CronLogger) CronRecover() cron.JobWrapper
- func (c *CronLogger) Error(err error, msg string, keysAndValues ...interface{})
- func (c *CronLogger) Info(msg string, keysAndValues ...interface{})
type ElasticsearchLogLevel
type ElasticsearchLogger
- func NewElasticsearchLogger(l *weaverLogger.Logger, conf *conf.Config) *ElasticsearchLogger
- func (l *ElasticsearchLogger) LogRoundTrip(req *http.Request, res *http.Response, err error, _ time.Time, ...) error
- func (l *ElasticsearchLogger) RequestBodyEnabled() bool
- func (l *ElasticsearchLogger) ResponseBodyEnabled() bool
type EmailClient
- func NewEmailClient(logger ClientLogger, dialer *gomail.Dialer, conf *conf.Config) *EmailClient
- func (e *EmailClient) Alarm2Admin(ctx context.Context, subject constant.Subject, body string) error
- func (e *EmailClient) SendHTML(ctx context.Context, to string, subject constant.Subject, ...) error
- func (e *EmailClient) SendText(ctx context.Context, to string, subject constant.Subject, body string) error
type GormLogger
- func NewGormLogger(l *weaverLogger.Logger, conf *conf.Config) *GormLogger
- func (g *GormLogger) Error(ctx context.Context, msg string, data ...interface{})
- func (g *GormLogger) Info(ctx context.Context, msg string, data ...interface{})
- func (g *GormLogger) LogMode(level logger.LogLevel) logger.Interface
- func (g *GormLogger) Trace(ctx context.Context, begin time.Time, ...)
- func (g *GormLogger) Warn(ctx context.Context, msg string, data ...interface{})
type HttpServer
- func NewHttpServer(conf *conf.Config, handle http.Handler, logger *logger.Logger) *HttpServer
- func (s *HttpServer) Addr() string
- func (s *HttpServer) Port() int
- func (s *HttpServer) Run()
type OSSClient
type RedisLogLevel
type RedisLogger
- func NewRedisLogger(l *weaverLogger.Logger, conf *conf.Config) *RedisLogger
- func (r *RedisLogger) DialHook(next goredislib.DialHook) goredislib.DialHook
- func (r *RedisLogger) ProcessHook(next goredislib.ProcessHook) goredislib.ProcessHook
- func (r *RedisLogger) ProcessPipelineHook(next goredislib.ProcessPipelineHook) goredislib.ProcessPipelineHook
type S3CompatibleStorage
- func NewS3CompatibleStorage(cfg *conf.Config, client OSSClient) *S3CompatibleStorage
- func (s *S3CompatibleStorage) GetClient() OSSClient
- func (s *S3CompatibleStorage) GetConfig() *conf.OSSConfig

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func LoadConfig ¶

func LoadConfig(viperClient *viper.Viper, consulClient *api.Client) *conf.Config

func LoadConsulConfig ¶

func LoadConsulConfig(viperClient *viper.Viper) *conf.ConsulConfig

func NewConsulClient ¶

func NewConsulClient(conf *conf.ConsulConfig) *api.Client

func NewCronClient ¶

func NewCronClient(l *CronLogger) *cron.Cron

func NewDialer ¶

func NewDialer(conf *conf.Config) *gomail.Dialer

func NewElasticsearchClient ¶

func NewElasticsearchClient(conf *conf.Config, logger elastictransport.Logger) *elasticsearch.TypedClient

func NewEngine ¶

func NewEngine(emailClient *EmailClient, rc *local.CommonRedisClient, logger *logger.Logger, conf *conf.Config) *gin.Engine

func NewGORM ¶

func NewGORM(conf *conf.Config, l logger.Interface) *gorm.DB

func NewOTLPExporter ¶

func NewOTLPExporter(conf *conf.Config) *otlptrace.Exporter

func NewRedisClient ¶

func NewRedisClient(hook goredislib.Hook, conf *conf.Config) *local.CommonRedisClient

func NewS3Client ¶

func NewS3Client(cfg *conf.Config) *s3.Client

NewS3Client 创建兼容s3的客户端

func NewTracerProvider ¶

func NewTracerProvider(conf *conf.Config, exporter tracesdk.SpanExporter) *tracesdk.TracerProvider

func NewViper ¶

func NewViper() *viper.Viper

func NewWriterSyncer ¶

func NewWriterSyncer(conf *conf.Config) zapcore.WriteSyncer

func NewZapLogger ¶

func NewZapLogger(conf *conf.Config, sync zapcore.WriteSyncer) *zap.SugaredLogger

Types ¶

type ClientLogger ¶

type ClientLogger interface {
	logger.LogCtxInterface
	Debugw(msg string, keysAndValues ...interface{})
}

type CronLogger ¶

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

func NewCronLogger ¶

func NewCronLogger(logger *logger.Logger, emailClient *EmailClient) *CronLogger

func (*CronLogger) CronRecover ¶

func (c *CronLogger) CronRecover() cron.JobWrapper

func (*CronLogger) Error ¶

func (c *CronLogger) Error(err error, msg string, keysAndValues ...interface{})

func (*CronLogger) Info ¶

func (c *CronLogger) Info(msg string, keysAndValues ...interface{})

type ElasticsearchLogLevel ¶

type ElasticsearchLogLevel int

const (
	None ElasticsearchLogLevel = iota
	Request
	Response
	All
)

type ElasticsearchLogger ¶

type ElasticsearchLogger struct {
	goredislib.Hook
	*weaverLogger.Logger
	Level ElasticsearchLogLevel
}

func NewElasticsearchLogger ¶

func NewElasticsearchLogger(l *weaverLogger.Logger, conf *conf.Config) *ElasticsearchLogger

func (*ElasticsearchLogger) LogRoundTrip ¶

func (l *ElasticsearchLogger) LogRoundTrip(req *http.Request, res *http.Response, err error, _ time.Time, dur time.Duration) error

func (*ElasticsearchLogger) RequestBodyEnabled ¶

func (l *ElasticsearchLogger) RequestBodyEnabled() bool

func (*ElasticsearchLogger) ResponseBodyEnabled ¶

func (l *ElasticsearchLogger) ResponseBodyEnabled() bool

type EmailClient ¶

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

func NewEmailClient ¶

func NewEmailClient(logger ClientLogger, dialer *gomail.Dialer, conf *conf.Config) *EmailClient

func (*EmailClient) Alarm2Admin ¶

func (e *EmailClient) Alarm2Admin(ctx context.Context, subject constant.Subject, body string) error

func (*EmailClient) SendHTML ¶

func (e *EmailClient) SendHTML(ctx context.Context, to string, subject constant.Subject, templatePath constant.Template, data any) error

func (*EmailClient) SendText ¶

func (e *EmailClient) SendText(ctx context.Context, to string, subject constant.Subject, body string) error

type GormLogger ¶

type GormLogger struct {
	*weaverLogger.Logger
	Level                     logger.LogLevel
	SlowThreshold             time.Duration
	IgnoreRecordNotFoundError bool
}

func NewGormLogger ¶

func NewGormLogger(l *weaverLogger.Logger, conf *conf.Config) *GormLogger

func (*GormLogger) Error ¶

func (g *GormLogger) Error(ctx context.Context, msg string, data ...interface{})

func (*GormLogger) Info ¶

func (g *GormLogger) Info(ctx context.Context, msg string, data ...interface{})

func (*GormLogger) LogMode ¶

func (g *GormLogger) LogMode(level logger.LogLevel) logger.Interface

func (*GormLogger) Trace ¶

func (g *GormLogger) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error)

func (*GormLogger) Warn ¶

func (g *GormLogger) Warn(ctx context.Context, msg string, data ...interface{})

type HttpServer ¶

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

func NewHttpServer ¶

func NewHttpServer(conf *conf.Config, handle http.Handler, logger *logger.Logger) *HttpServer

NewHttpServer 创建http服务器

func (*HttpServer) Addr ¶

func (s *HttpServer) Addr() string

func (*HttpServer) Port ¶

func (s *HttpServer) Port() int

func (*HttpServer) Run ¶

func (s *HttpServer) Run()

type OSSClient ¶

type OSSClient interface {
	s3.HeadBucketAPIClient
	s3.HeadObjectAPIClient
	s3.ListBucketsAPIClient
	s3.ListDirectoryBucketsAPIClient
	s3.ListMultipartUploadsAPIClient
	s3.ListObjectVersionsAPIClient
	s3.ListObjectsV2APIClient
	s3.ListPartsAPIClient
}

OSSClient 定义兼容S3协议的客户端接口，便于mock和单元测试

type RedisLogLevel ¶

type RedisLogLevel int

const (
	Silent RedisLogLevel = iota + 1
	Error
	Warn
	Info
)

type RedisLogger ¶

type RedisLogger struct {
	goredislib.Hook
	*weaverLogger.Logger
	Level RedisLogLevel
}

func NewRedisLogger ¶

func NewRedisLogger(l *weaverLogger.Logger, conf *conf.Config) *RedisLogger

func (*RedisLogger) DialHook ¶

func (r *RedisLogger) DialHook(next goredislib.DialHook) goredislib.DialHook

func (*RedisLogger) ProcessHook ¶

func (r *RedisLogger) ProcessHook(next goredislib.ProcessHook) goredislib.ProcessHook

func (*RedisLogger) ProcessPipelineHook ¶

func (r *RedisLogger) ProcessPipelineHook(next goredislib.ProcessPipelineHook) goredislib.ProcessPipelineHook

type S3CompatibleStorage ¶

type S3CompatibleStorage struct {
	OSSClient
	// contains filtered or unexported fields
}

func NewS3CompatibleStorage ¶

func NewS3CompatibleStorage(cfg *conf.Config, client OSSClient) *S3CompatibleStorage

NewS3CompatibleStorage 创建兼容S3协议的存储客户端

func (*S3CompatibleStorage) GetClient ¶

func (s *S3CompatibleStorage) GetClient() OSSClient

GetClient 获取S3客户端

func (*S3CompatibleStorage) GetConfig ¶

func (s *S3CompatibleStorage) GetConfig() *conf.OSSConfig

GetConfig 获取配置

Source Files ¶

View all Source files

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