config

package
v0.0.0-...-e006840 Latest Latest
Warning

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

 Go to latest Published: Jul 30, 2025 License: MIT Imports: 44 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SUCCESS = "成功"
	FAILURE = "失败"
)

logger

View Source 
const (
	KV     = "kv"
	PWD    = "pwd"
	RSA    = "rsa"
	JWT    = "jwt"
	SECRET = "secret"
	SALT   = "salt"
	PUK    = "puk"
	PRK    = "prk"
	ID     = "id"
	APP    = "app"
)

vault

View Source 
const (
	Bearer = "Bearer "
	UserID = "userID"
	// headers params
	Method        = "method"
	URI           = "uri"
	ClientIp      = "client_ip"
	UserAgent     = "user-agent"
	TraceId       = "trace_id"
	SpanId        = "span_id"
	ParentId      = "parent_id"
	Authorization = "authorization"
	AppId         = "app_id"
	RequestId     = "request_id"
	UserId        = "user_id"
	RequestURI    = "request_uri"
	Signature     = "signature"
	// jaeger
	UberTraceId = "uber-trace-id"
	// redis
	Nonce = "nonce"
	// pool
	MyWsConn = "MyWsConn"
)
View Source 
const (
	TokenExpired     = "Token已过期"
	TokenNotValidYet = "Token不再有效"
	TokenMalformed   = "Token非法"
	TokenInvalid     = "Token无效"
)
View Source 
const (
	Username = "liuzhao"
	Password = "123456"
)

vault access

Variables

View Source 
var RocketMQSet = wire.NewSet(
	wire.Struct(new(RocketMQ), "*"),
	wire.Bind(new(IRocketMQ), new(*RocketMQ)),
)

Functions

func GenGinLoggerFields 

func GenGinLoggerFields(c *gin.Context) logrus.Fields

func GetClientIP 

func GetClientIP(c *gin.Context) string

func GetPrivateKey 

func GetPrivateKey() *rsa.PrivateKey

func GetPublicKey 

func GetPublicKey() *rsa.PublicKey

func GetPublicKeyStr 

func GetPublicKeyStr() string

func GetUserAgent 

func GetUserAgent(c *gin.Context) string

func InitDB 

func InitDB() (*gorm.DB, func(), error)

func InitGinEngine 

func InitGinEngine() *gin.Engine

InitGinEngine Gin引擎的provider

func InitLogger 

func InitLogger() *logrus.Logger

初始化系统日志

func InitLogrus 

func InitLogrus() *logrus.Logger

日志扩展loggerx的Provider

func InitLogrusEntry 

func InitLogrusEntry() *logrus.Entry

func InitPrometheusRegistry 

func InitPrometheusRegistry() *prometheus.Registry

func InitRedis 

func InitRedis() (*redis.Client, func(), error)

func InitTracer 

func InitTracer() *jConfig.Configuration

func InitVault 

func InitVault()

func InitWebSocket 

func InitWebSocket() *websocket.Upgrader

func LoadEnv 

func LoadEnv() string

加载环境变量ENV，设置配置文件路径

func LogFailure 

func LogFailure(code ext.Code, desc string, err error)

func LogSuccess 

func LogSuccess(desc string)

func LoggerForHTTP 

func LoggerForHTTP() gin.HandlerFunc

HTTP 日志中间件

func LoggerForRPC 

func LoggerForRPC(
	ctx context.Context,
	req interface{},
	_ *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler,
) (interface{}, error)

RPC 日志中间件

func SelectFromMetadata 

func SelectFromMetadata(md metadata.MD, key string) string

func SetHeadersForDownstream 

func SetHeadersForDownstream(c *gin.Context, downstreamName string) error

func SetMetadataForDownstreamFromHttpHeaders 

func SetMetadataForDownstreamFromHttpHeaders(
	ctx context.Context,
	c *gin.Context,
	downstreamName string,
) (context.Context, error)

func ValidateHeaders 

func ValidateHeaders(c *gin.Context) error

func ValidateMetadata 

func ValidateMetadata(md metadata.MD) error

Types

type Config 

type Config struct {
	App         app
	Lib         lib
	Server      server
	Secret      secret
	Downstreams []downstream
}

func GetConfig 

func GetConfig() *Config

func (*Config) ConvertRSAKeys 

func (cfg *Config) ConvertRSAKeys()

func (*Config) GetSecret 

func (cfg *Config) GetSecret()

GetSecret 使用client token访问vault，获取secret，存入配置对象

func (*Config) HandleLoadedConfig 

func (cfg *Config) HandleLoadedConfig()

func (*Config) LoadConfig 

func (cfg *Config) LoadConfig(configFile string)

加载配置

func (*Config) LoadSecret 

func (cfg *Config) LoadSecret()

加载.env中的secret

func (*Config) PutAppSecret 

func (cfg *Config) PutAppSecret()

PutAppSecret 新增修改AppId和AppSecret

func (*Config) PutRSA 

func (cfg *Config) PutRSA()

PutRSA 新增和修改rsa

func (*Config) PutSalt 

func (cfg *Config) PutSalt()

PutSalt 新增和修改salt

func (*Config) SetRSAKeys 

func (cfg *Config) SetRSAKeys()

type CustomClaims 

type CustomClaims struct {
	jwt.RegisteredClaims

	UserID   string
	ClientIP string
}

type GormLogger 

type GormLogger struct {
	Config logger.Config
}

func InitGormLogger 

func InitGormLogger() *GormLogger

func (*GormLogger) Error 

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

func (*GormLogger) Info 

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

func (*GormLogger) LogMode 

func (l *GormLogger) LogMode(lev logger.LogLevel) logger.Interface

func (*GormLogger) Trace 

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

func (*GormLogger) Warn 

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

type IRocketMQ 

type IRocketMQ interface {
	GenProducer(string) (*rocketmq.Producer, error)
	GenPushConsumer(string) (*rocketmq.PushConsumer, error)
}

type Jwt 

type Jwt struct {
	SigningKey []byte
}

func NewJWT 

func NewJWT() *Jwt

func (*Jwt) GenerateToken 

func (j *Jwt) GenerateToken(
	userID string,
	clientIP string,
	duration time.Duration,
) (string, error)

func (*Jwt) ParseToken 

func (j *Jwt) ParseToken(tokenStr string) (string, string, error)

func (*Jwt) RefreshToken 

func (j *Jwt) RefreshToken(tokenStr string) (string, error)

type RocketMQ 

type RocketMQ struct{}

func (*RocketMQ) GenProducer 

func (r *RocketMQ) GenProducer(groupName string) (*rocketmq.Producer, error)

func (*RocketMQ) GenPushConsumer 

func (r *RocketMQ) GenPushConsumer(groupName string) (*rocketmq.PushConsumer, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.