public

package

Go to main page

Versions in this module

v1

v1.0.0

Oct 29, 2021

Changes in this version

+ const AdminSessionInfoKey

+ const DistributedLimiterPrefix

+ const FlowAppPrefix

+ const FlowServicePrefix

+ const FlowTotal

+ const HTTPRuleTypeDomain

+ const HTTPRuleTypePrefixURL

+ const JwtExpires

+ const JwtSignKey

+ const LoadTypeGRPC

+ const LoadTypeHTTP

+ const LoadTypeTCP

+ const RedisFlowDayKey

+ const RedisFlowHourKey

+ const ServiceDetailContextKey

+ const TranslatorKey

+ const ValidatorKey

+ var LoadTypeMap = map[int]string

+ func DefaultGetValidParams(c *gin.Context, params interface{}) error

+ func GenSaltPassword(salt, password string) string

+ func GetTranslation(c *gin.Context) (ut.Translator, error)

+ func GetValidator(c *gin.Context) (*validator.Validate, error)

+ func GinLogNotice(c *gin.Context, dltag string, m map[string]interface{})

+ func GinLogWarning(c *gin.Context, dltag string, m map[string]interface{})

+ func HTTPPathsValidate(httpPaths string) error

+ func InArrayString(s string, arr []string) bool

+ func InIPSliceStr(targetIP, ipSliceStr string) bool

+ func JwtDecode(tokenString string) (*jwt.StandardClaims, error)

+ func JwtEncode(claims jwt.StandardClaims) (string, error)

+ func Obj2Json(s interface{}) string

+ func ServiceNameValidate(serviceName string) error

+ func UpstreamListValidate(upstreamList string) error

type Response

+ Stack interface{}

+ TraceId interface{}

type ResponseCode

+ const GROUPALL_SAVE_FLOWERROR

v0

v0.1.1

Dec 31, 2019

Changes in this version

type APPCountService

+ ReqDate string

type RequestCountService

+ ReqDate string

v0.1.0

Oct 12, 2019

Changes in this version

+ const AccessControlAppIDHourTotalCallPrefix

+ const AccessControlAppIDTotalCallPrefix

+ const AdminCookiePrefix

+ const AdminCookieSecrit

+ const AdminExpired

+ const ContentEncoding

+ const IPDefaultWeight

+ const RRLvs

+ const RRNginx

+ const RequestModuleCounterPrefix

+ const RequestModuleHourCounterPrefix

+ const UserGroupPerfix

+ var AuthConf *AuthConfig

+ var CheckLogger *log.Logger

+ var ConfHandler *viper.Viper

+ var ConfPath string

+ var DayFormat = "2006-01-02"

+ var FullTimeFormat = "2006-01-02 15:04:05"

+ var GormPool *gorm.DB

+ var StatLogger *log.Logger

+ var SysLogger *log.Logger

+ var TimeFormat = "15:04:05"

+ var TimeLocation *time.Location

+ var TraceLoggerOn bool

+ var Uptime time.Time

+ var ValidatorHandler = validator.New(&validator.Config{ ... })

+ func AesDecrypt(c context.Context, crypted, key []byte) ([]byte, error)

+ func AesEncrypt(c context.Context, origData, key []byte) ([]byte, error)

+ func AuthIPList(clientIP string, whiteList []string) bool

+ func CheckConnPort(port string) error

+ func ComLogNotice(c *gin.Context, dltag string, m map[string]interface{})

+ func ComLogWarning(c *gin.Context, dltag string, m map[string]interface{})

+ func ContextError(c context.Context, dltag string, m map[string]interface{})

+ func ContextNotice(c context.Context, dltag string, m map[string]interface{})

+ func ContextWarning(c context.Context, dltag string, m map[string]interface{})

+ func GetGinTraceContext(c *gin.Context) *lib.TraceContext

+ func GetSign(paramMap map[string]string, secret string) string

+ func GetTraceContext(c context.Context) *lib.TraceContext

+ func HTTPError(errcode ResponseCode, message string, w http.ResponseWriter, r *http.Request)

+ func HTTPGET(log *log.Logger, urlString string, urlParams url.Values, msTimeout int, ...) (*http.Response, []byte, error)

+ func HTTPPOST(log *log.Logger, urlString string, urlParams url.Values, msTimeout int, ...) (*http.Response, []byte, error)

+ func HTTPSuccess(message string, w http.ResponseWriter, r *http.Request)

+ func InOrPrefixStringList(t string, arr []string) bool

+ func InStringList(t string, list []string) bool

+ func InitConf()

+ func InitMysql() error

+ func IsProductEnv() bool

+ func LogErrorf(c context.Context, msg string, m Map)

+ func LogInfof(c context.Context, msg string, m Map)

+ func LogWarnf(c context.Context, msg string, m Map)

+ func MD5(s string) string

+ func PKCS5Padding(ciphertext []byte, blockSize int) []byte

+ func PKCS5UnPadding(origData []byte) []byte

+ func ParseGzip(data []byte) ([]byte, error)

+ func RedisConfDo(log *log.Logger, name string, commandName string, args ...interface{}) (interface{}, error)

+ func RedisConfPipline(log *log.Logger, name string, pip ...func(c redis.Conn)) error

+ func RedisLogDo(log *log.Logger, c redis.Conn, commandName string, args ...interface{}) (interface{}, error)

+ func RemoteIP(req *http.Request) string

+ func ResponseError(c *gin.Context, code ResponseCode, err error)

+ func ResponseSuccess(c *gin.Context, data interface{})

+ func Substr(str string, start int64, end int64) string

+ func TraceTagError(trace *lib.TraceContext, dltag string, m map[string]interface{})

+ func TraceTagInfo(trace *lib.TraceContext, dltag string, m map[string]interface{})

+ func TraceTagWarn(trace *lib.TraceContext, dltag string, m map[string]interface{})

+ type APPCountService struct

+ AppID string

+ Interval time.Duration

+ Lock sync.RWMutex

+ QPS int64

+ ReqCount int64

+ TickerCount int64

+ TotalCount int64

+ Unix int64

+ func NewAPPCountService(appID string, interval time.Duration, maxCnt int) (*APPCountService, error)

+ func (o *APPCountService) GetDayCount(day string) (int64, error)

+ func (o *APPCountService) GetHourCount(dayhour string) (int64, error)

+ func (o *APPCountService) Increase(context context.Context)

+ type AuthConfig struct

+ Base struct{ ... }

+ type Context struct

+ Req *http.Request

+ Res http.ResponseWriter

+ StatusCode int

+ func NewContext(w http.ResponseWriter, r *http.Request) *Context

+ func (c *Context) AcceptJSON() bool

+ func (c *Context) Cookie(name string) (*http.Cookie, error)

+ func (c *Context) Cookies() []*http.Cookie

+ func (c *Context) Error(code int, msg string)

+ func (c *Context) Exists(k string) bool

+ func (c *Context) File(name string) (multipart.File, *multipart.FileHeader, error)

+ func (c *Context) Host() string

+ func (c *Context) IsAjaxReq() bool

+ func (c *Context) IsBrowser() bool

+ func (c *Context) JSON(data interface{})

+ func (c *Context) Location(message, url string)

+ func (c *Context) Method() string

+ func (c *Context) Path() string

+ func (c *Context) Query(k string) string

+ func (c *Context) QueryBool(k string) (bool, error)

+ func (c *Context) QueryInt(k string) (int, error)

+ func (c *Context) QueryInt64(k string) (int64, error)

+ func (c *Context) Redirect(location string, code ...int)

+ func (c *Context) RemoteAddr() string

+ func (c *Context) Schema() string

+ func (c *Context) SetCookie(cookie *http.Cookie)

+ func (c *Context) SetStatusCode(code int)

+ func (c *Context) String(s string)

+ func (c *Context) Success(data interface{})

+ func (c *Context) URI() string

+ func (c *Context) Write(data []byte)

+ type ContextKey string

+ type FlowCounter struct

+ var FlowCounterHandler *FlowCounter

+ func NewFlowCounter() *FlowCounter

+ func (c *FlowCounter) GetAPPCounter(appID string) *APPCountService

+ func (c *FlowCounter) GetRequestCounter(moduleName string) *RequestCountService

+ type FlowLimiter struct

+ var FlowLimiterHandler *FlowLimiter

+ func NewFlowLimiter() *FlowLimiter

+ func (t *FlowLimiter) AddAppVisitor(appID string, qps int64) *rate.Limiter

+ func (t *FlowLimiter) AddLimitVisitor(name string, qps int64) *rate.Limiter

+ func (t *FlowLimiter) CleanupLimitVisitors()

+ func (t *FlowLimiter) GetAPPLimitVisitor(appID string, qps int64) *rate.Limiter

+ func (t *FlowLimiter) GetModuleIPVisitor(moduleIPAddr string, qps int64) *rate.Limiter

+ type LimitVisitor struct

+ type Map map[string]interface

+ type MapItem struct

+ Key string

+ Val string

+ type MapSorter []MapItem

+ func NewMapSorter(m map[string]string) MapSorter

+ func (ms MapSorter) Len() int

+ func (ms MapSorter) Less(i, j int) bool

+ func (ms MapSorter) Swap(i, j int)

+ type RR interface

+ Add func(node interface{}, weight int)

+ Next func() interface{}

+ RemoveAll func()

+ Reset func()

+ func NewWeightedRR(rtype int) RR

+ type RequestCountService struct

+ Interval time.Duration

+ Lock sync.RWMutex

+ ModuleName string

+ QPS int64

+ ReqCount int64

+ TickerCount int64

+ TotalCount int64

+ Unix int64

+ func NewRequestCountService(moduleName string, interval time.Duration, maxCnt int) (*RequestCountService, error)

+ func (o *RequestCountService) GetDayCount(day string) (int64, error)

+ func (o *RequestCountService) GetHourCount(dayhour string) (int64, error)

+ func (o *RequestCountService) Increase(ctx context.Context, remoteAddr string)

+ type Response struct

+ Data interface{}

+ ErrorCode ResponseCode

+ ErrorMsg string

+ TraceID interface{}

+ type ResponseCode int

+ const CustomizeCode

+ const InternalErrorCode

+ const InvalidRequestErrorCode

+ const SuccessCode

+ const UndefErrorCode

+ const ValidErrorCode

+ type WLVS struct

+ func (w *WLVS) Add(node interface{}, weight int)

+ func (w *WLVS) Next() interface{}

+ func (w *WLVS) RemoveAll()

+ func (w *WLVS) Reset()

+ type WNGINX struct

+ func (w *WNGINX) Add(node interface{}, weight int)

+ func (w *WNGINX) Next() interface{}

+ func (w *WNGINX) RemoveAll()

+ func (w *WNGINX) Reset()

+ type WeightLvs struct

+ Node interface{}

+ Weight int

+ type WeightNginx struct

+ CurrentWeight int

+ EffectiveWeight int

+ Node interface{}

+ Weight int

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