pkg

May 16, 2024

Changes in this version

type TracerPkg

+ func (p *TracerPkg) DisableTracer()

+ func (p *TracerPkg) EnableTracer()

May 9, 2024

Changes in this version

type Redis

+ func NewRedisClient(host string, port int, auth string, poolSize int, defaultDb int, prefix string) *Redis

May 6, 2024

Changes in this version

type ApolloPkg

+ func (c *ApolloPkg) GetStringMapStruct(key string, outputStruct interface{}) error

type ConfigPkg

+ func (c *ConfigPkg) GetStringMapStruct(key string, outputStruct interface{}) error

Apr 29, 2024

Changes in this version

type ApiPkg

+ func (p *ApiPkg) GetErrorResponse(data interface{}, sqls []string, err error) (int, interface{})

Apr 24, 2024

Changes in this version

type ApolloConfPkg

+ CacheDir string

Apr 23, 2024

Changes in this version

+ var ApolloStruct = func(alias string, outputStruct interface{}) error

Apr 23, 2024

Changes in this version

+ var ApolloAlias = func(alias string) *ApolloPkg

type ApolloPkg

+ func (c *ApolloPkg) GetBool(key string) bool

+ func (c *ApolloPkg) GetDuration(key string) time.Duration

+ func (c *ApolloPkg) GetFloat64(key string) float64

+ func (c *ApolloPkg) GetInt(key string) int

+ func (c *ApolloPkg) GetInt32(key string) int32

+ func (c *ApolloPkg) GetInt64(key string) int64

+ func (c *ApolloPkg) GetIntSlice(key string) []int

+ func (c *ApolloPkg) GetSizeInBytes(key string) uint

+ func (c *ApolloPkg) GetString(key string) string

+ func (c *ApolloPkg) GetStringMap(key string) map[string]any

+ func (c *ApolloPkg) GetStringMapString(key string) map[string]string

+ func (c *ApolloPkg) GetStringMapStringSlice(key string) map[string][]string

+ func (c *ApolloPkg) GetStringSlice(key string) []string

+ func (c *ApolloPkg) GetTime(key string) time.Time

+ func (c *ApolloPkg) GetUint(key string) uint

+ func (c *ApolloPkg) GetUint16(key string) uint16

+ func (c *ApolloPkg) GetUint32(key string) uint32

+ func (c *ApolloPkg) GetUint64(key string) uint64

+ func (c *ApolloPkg) Start(vp *ConfigPkg, callback ApUpdateCallback) error

+ type AppConfigPkg struct

+ AppID string

+ Cluster string

+ Namespaces []string

+ Secret string

Apr 18, 2024

Changes in this version

type ApConfig

+ Namespaces []string

+ type ApolloConfPkg struct

+ App map[string]ApConfig

+ Service string

type ApolloPkg

+ ApStructMap map[string]interface{}

type ConfigPkg

+ LocalStructMap map[string]interface{}

Apr 12, 2024

Changes in this version

type ApolloPkg

+ ApKeyAlias map[string]string

+ func (c *ApolloPkg) Prefix(key string) *ApolloPkg

Apr 12, 2024

Changes in this version

type ApConfig

+ Secret string

Apr 11, 2024

Changes in this version

+ type ApUpdateCallback func(appId string, namespace string)

type TracerPkg

+ func (p *TracerPkg) CheckEnable() bool

Apr 8, 2024

Changes in this version

type ApolloPkg

+ func (c *ApolloPkg) UpdateByMerge(updates map[string]interface{}) error

Apr 3, 2024

Changes in this version

+ const ComponentIDGINHttpServer

+ const ComponentRedisServer

+ var Api = &ApiPkg

+ var Apollo = &ApolloPkg

+ var Config = &ConfigPkg

+ var Database = &DatabasePkg

+ var GCM = &GoroutineContextManager

+ var Http = &HttpPkg

+ var RedisCli = &Redis

+ var Tracer = &TracerPkg

+ type ApConfig struct

+ AppID string

+ Cluster string

+ NameSpaceNames []string

+ type ApiPkg struct

+ func (p *ApiPkg) RegisterRoutes(r *gin.Engine, routes ...*Routes)

+ func (p *ApiPkg) RegisterValidates(validates *[]Validators)

+ type ApolloPkg struct

+ ApClients map[string]agollo.Client

+ ApConfigs []ApConfig

+ ApUrl string

+ func (c *ApolloPkg) StartApollo(apolloServerURL string, apolloConfigs []ApConfig) error

+ func (c *ApolloPkg) Update(updates map[string]interface{}, prefix string)

+ type Callback func(map[string]*gorm.DB)

+ type ConfigPkg struct

+ ConfigPath string

+ ConfigType string

+ func (c *ConfigPkg) Init(configPath string, configType string)

+ func (c *ConfigPkg) Read(file string) *ConfigPkg

+ func (c *ConfigPkg) Update(updates map[string]interface{}, prefix string) error

+ type CustomLogFormatter struct

+ func (c *CustomLogFormatter) Format(entry *logrus.Entry) ([]byte, error)

+ type CustomLogHook struct

+ LogDir string

+ func (hook *CustomLogHook) Fire(entry *logrus.Entry) error

+ func (hook *CustomLogHook) Levels() []logrus.Level

+ type DatabasePkg struct

+ func (c *DatabasePkg) GetDb(configData map[string]interface{}) *gorm.DB

+ func (c *DatabasePkg) Init(conf map[string]interface{}, callback Callback)

+ type DbPoolConfig struct

+ Charset string

+ ConnMaxIdleTime int

+ ConnMaxLifetime int

+ Database string

+ Host string

+ MaxIdleConns int

+ MaxOpenConns int

+ Name string

+ Password string

+ Port int

+ TablePrefix string

+ Type string

+ User string

+ type EntrySpanOptions struct

+ Component int32

+ Extractor propagation.Extractor

+ Layer agentV3.SpanLayer

+ Log []string

+ OperationName string

+ type ExitSpanOptions struct

+ Component int32

+ Injector propagation.Injector

+ Layer agentV3.SpanLayer

+ Log []string

+ OperationName string

+ Peer string

+ type GormLogger struct

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

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

+ func (p *GormLogger) LogMode(level logger.LogLevel) logger.Interface

+ func (p *GormLogger) Trace(ctx context.Context, begin time.Time, fc func() (string, int64), err error)

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

+ type GoroutineContextManager struct

+ GlobalGinContextKey string

+ func (gcm *GoroutineContextManager) GetContext(ctx context.Context) (*gin.Context, bool)

+ func (gcm *GoroutineContextManager) SetContext(ctx *gin.Context)

+ type HttpPkg struct

+ func (p *HttpPkg) Get(c context.Context, link string, timeout int, header map[string]string) (string, error)

+ func (p *HttpPkg) Post(c context.Context, link string, requestBody io.Reader, timeout int, ...) (string, error)

+ type LocalSpanOptions struct

+ Component int32

+ Layer agentV3.SpanLayer

+ Log []string

+ OperationName string

+ type LoggerPkg struct

+ EnableDesensitization bool

+ var Logger *LoggerPkg

+ func NewLogger(logDir string, enableDesensitization bool) *LoggerPkg

+ func (p *LoggerPkg) WithContent(content string) *logrus.Entry

+ type Redis struct

+ func (p *Redis) Del(c context.Context, key string) error

+ func (p *Redis) Get(c context.Context, key string) *redis.StringCmd

+ func (p *Redis) Init(host string, port int, auth string, poolSize int, defaultDb int, prefix string)

+ func (p *Redis) Set(c context.Context, key string, value interface{}, expiration time.Duration) error

+ func (p *Redis) SetNX(c context.Context, key string, value interface{}, expiration time.Duration) error

+ type ResponseContent struct

+ Code int

+ Data interface{}

+ Error error

+ type Routes struct

+ Group string

+ Rules []Rule

+ type Rule struct

+ DataBind binding.Binding

+ Handler interface{}

+ Method string

+ Route string

+ type TracerPkg struct

+ func (p *TracerPkg) CreateEntrySpan(c context.Context, opts EntrySpanOptions) (go2sky.Span, context.Context, error)

+ func (p *TracerPkg) CreateExitSpan(c context.Context, opts ExitSpanOptions) (go2sky.Span, error)

+ func (p *TracerPkg) CreateExitSpanWithContext(c context.Context, opts ExitSpanOptions) (go2sky.Span, context.Context, error)

+ func (p *TracerPkg) CreateLocalSpan(c context.Context, opts LocalSpanOptions) (go2sky.Span, context.Context, error)

+ func (p *TracerPkg) Init(serviceAddr string, serviceName string, enable bool)

+ func (p *TracerPkg) SpanErr(span go2sky.Span, content ...string)

+ func (p *TracerPkg) SpanTag(span go2sky.Span, tag go2sky.Tag, content string)

+ type Validators struct

+ Handler func(fl validator.FieldLevel) bool

+ Msg string

+ RegExp string

+ Tag string