heldiamgo

package module
v0.0.0-...-c3ec36b Latest Latest
Warning

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

 Go to latest Published: Aug 20, 2022 License: MIT Imports: 38 Imported by: 0

README

go

个人golang常用工具包

996.icu

Documentation

Index

Constants

View Source 
const (
	DateFormat     = "2006-01-02"
	DateTimeFormat = "2006-01-02 15:04:05"
	TimeFormat     = "15:04:05"
)

时间格式

View Source 
const TracingChild = 1
View Source 
const TracingFollowsFrom = 2

Variables

View Source 
var (
	LockFail   = err1.NewError(-100, "锁失败")
	UnlockFail = err1.NewError(-101, "解锁失败")
)
View Source 
var EnableMetrics = false //是否开启性能统计
View Source 
var MetricsCancel context.CancelFunc
View Source 
var MetricsRegistry metrics.Registry
View Source 
var Tracing = true

开启追踪

Functions

func DateEndTimeString 

func DateEndTimeString(t time.Time) string

日期结束时间

func DateStartTimeString 

func DateStartTimeString(t time.Time) string

日期起始时间

func Decimal 

func Decimal(value float64, preciseDigits int) float64

浮点数保留指定的位数 @value float64 要转换的浮点数值 @preciseDigits int 要保留的位数

func ID 

func ID() uint64

生成唯一数字ID

func IDGen 

func IDGen() string

生成数字ID带日期

func IsChineseChar 

func IsChineseChar(str string) bool

判断是否有中文

func IsEmail 

func IsEmail(emailaddress string) bool

验证是否是有效的邮箱

func IsHomePhone 

func IsHomePhone(phone string) bool

验证是否为家庭电话

func IsIdCard 

func IsIdCard(Identnumber string) bool

验证是否有效的身份证号码

func IsPhone 

func IsPhone(phonenumber string) bool

验证是否是有效的手机号

func IsTimeString 

func IsTimeString(timeString string, timeFormat string) bool

验证是否是时间字符串

func JsonString 

func JsonString(obj interface{}) string

json数据

func MetricExpHandler 

func MetricExpHandler() http.Handler

爆露性能统计http接口

func PprofHttpHandler 

func PprofHttpHandler() (string, http.Handler)

func RandCode 

func RandCode(len int, onlynumber bool) string

生成随机字符串,len字符串长度,onlynumber 是否只包含数字

func RemoveFloat32ArrayDuplicate 

func RemoveFloat32ArrayDuplicate(arr []float32) (newArr []float32)

float32数组去除重复

func RemoveFloat64ArrayDuplicate 

func RemoveFloat64ArrayDuplicate(arr []float64) (newArr []float64)

float64数组去除重复

func RemoveInt32ArrayDuplicate 

func RemoveInt32ArrayDuplicate(arr []int32) (newArr []int32)

int32数组去除重复

func RemoveInt64ArrayDuplicate 

func RemoveInt64ArrayDuplicate(arr []int64) (newArr []int64)

int64数组去除重复

func RemoveIntArrayDuplicate 

func RemoveIntArrayDuplicate(arr []int) (newArr []int)

int数组去除重复

func RemoveStringArrayDuplicate 

func RemoveStringArrayDuplicate(list []string) []string

字符串数组去重

func SetLogger 

func SetLogger(lg logs.ILogger)

设置日志

func StartMetrics 

func StartMetrics(influxdbURL string, influxdbName string,
	influxdbUser string, influxdbPwd string)

开启性能统计

func StopMetrics 

func StopMetrics()

结束性能统计

func StringSliceIsRepeat 

func StringSliceIsRepeat(slc []string) bool

判断字符串类型的切片元素是否重复

func TimeNow 

func TimeNow() string

当前日期时间

func UUID 

func UUID() string

Types

type Circle 

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

圆形 https://blog.golang.org/go-imagedraw-package

func NewCircle 

func NewCircle(p image.Point, r int) *Circle

新建一个圆形，p为圆形中心点. r为半径

func (*Circle) At 

func (c *Circle) At(x, y int) color.Color

func (*Circle) Bounds 

func (c *Circle) Bounds() image.Rectangle

func (*Circle) ColorModel 

func (c *Circle) ColorModel() color.Model

type Context 

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

上下文

func NewContext 

func NewContext(operationName string) *Context

初始化上下文

func NewContextWithTracing 

func NewContextWithTracing(tracingSpan TracingSpan) *Context

初始化上下文

func (*Context) Copy 

func (t *Context) Copy() IContext

Copy

func (*Context) Finish 

func (t *Context) Finish()

Finish

func (*Context) Logf 

func (t *Context) Logf(fields ...opentracinglog.Field) IContext

日志

func (*Context) SetTracingType 

func (t *Context) SetTracingType(tracingType int)

func (*Context) Start 

func (t *Context) Start(operationName string) TracingContext

Start

func (*Context) TracingSpan 

func (t *Context) TracingSpan() TracingSpan

追踪信息获取,可能返回nil

type Ellipse 

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

椭圆形

func (*Ellipse) At 

func (c *Ellipse) At(x, y int) color.Color

func (*Ellipse) Bounds 

func (c *Ellipse) Bounds() image.Rectangle

func (*Ellipse) ColorModel 

func (c *Ellipse) ColorModel() color.Model

func (*Ellipse) SetBounds 

func (c *Ellipse) SetBounds(rect image.Rectangle)

func (*Ellipse) SetRadius 

func (c *Ellipse) SetRadius(radius int)

type EtcdLockFactory 

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

func NewEtcdLockFactory 

func NewEtcdLockFactory(endpoints []string) (*EtcdLockFactory, error)

初始化ETCD连接

func (*EtcdLockFactory) Close 

func (e *EtcdLockFactory) Close()

关闭etcd对象

func (*EtcdLockFactory) GetEtcdClient 

func (e *EtcdLockFactory) GetEtcdClient() *clientv3.Client

获取etcd连接对象

func (*EtcdLockFactory) GetEtcdSession 

func (e *EtcdLockFactory) GetEtcdSession() (*concurrency.Session, error)

获取etcd会话

func (*EtcdLockFactory) GetLock 

func (e *EtcdLockFactory) GetLock(path string) (*Lock, error)

获取一个分布式锁对象。如果出错会painc需要处理panic情况

type HandleFunc 

type HandleFunc func()

type IContext 

type IContext interface {
	TracingContext

	Copy() IContext

	SetTracingType(int)

	Logf(fields ...opentracinglog.Field) IContext

	TracingSpan() TracingSpan
}

func ContextChild 

func ContextChild(parentCtx IContext) IContext

ChildOf

func ContextFollows 

func ContextFollows(parentCtx IContext) IContext

FollowsFrom

type JSTemplate 

type JSTemplate struct {
	ExtendType string //扩展文件名
	Cache      bool   //是否缓存
	// contains filtered or unexported fields
}

JSTemplate JS模版引擎

func NewJSTemplate 

func NewJSTemplate(TemplateDIR string, ExtendType ...string) *JSTemplate

NewJSTemplate 深层JS模版引擎对象

func (*JSTemplate) Error 

func (je *JSTemplate) Error() error

Error 错误记录

func (*JSTemplate) SetTemplateDir 

func (je *JSTemplate) SetTemplateDir(TemplateDir string)

SetTemplateDir 设置模版目录

func (*JSTemplate) Template 

func (je *JSTemplate) Template(body []byte, params ...interface{}) ([]byte, error)

Template 解析模版

@Param body 模版内容

@Param params 模版参数

type Lock 

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

锁对象

func (*Lock) CallFunc 

func (l *Lock) CallFunc(fun func() err1.Error) err1.Error

回调处理

func (*Lock) IsLock 

func (l *Lock) IsLock() bool

func (*Lock) Lock 

func (l *Lock) Lock()

func (*Lock) LockErr 

func (l *Lock) LockErr() error

func (*Lock) Unlock 

func (l *Lock) Unlock()

解锁

type Ms15LenIDGenerator 

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

毫秒级15位ID生成器

func NewMs15LenIDGenerator 

func NewMs15LenIDGenerator(workID int64) *Ms15LenIDGenerator

实例化毫秒15位一个ID生成器

func (*Ms15LenIDGenerator) NextID 

func (mig *Ms15LenIDGenerator) NextID() (int64, error)

生成下一个ID

type RedisKeyValue 

type RedisKeyValue struct {
	Key   string
	Value string
}

redis键值

type RedisUtil 

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

RedisUtil redis操作工具

func InitializeRedis 

func InitializeRedis(host, password, db string, maxidle, maxactive int) *RedisUtil

初始化redis,host=地址，password密码,db数据名称，maxidle最大有效连接数,active 最大可用连接数

func (*RedisUtil) DEL 

func (r *RedisUtil) DEL(key ...interface{}) int

DEL 删除 @return 返回删除的个数,-1代表错误

func (*RedisUtil) Debug 

func (r *RedisUtil) Debug(b bool)

设置是否调试，调试状态不进入真正缓存

func (*RedisUtil) DelKeys 

func (r *RedisUtil) DelKeys(pattern string) (int, error)

func (*RedisUtil) EXPIRE 

func (r *RedisUtil) EXPIRE(key string, expireTime int64) int

EXPIRE 设置过期时间 @return -1=错误，0=key不存在， 1=成功

func (*RedisUtil) GET 

func (r *RedisUtil) GET(key string) string

GET 获取 @return 如果key不存在返回空

func (*RedisUtil) GETEXP 

func (r *RedisUtil) GETEXP(key string, expireTime int64) string

GETEXP 获取值并更新过期时间 @return 如果key不存在返回空

func (*RedisUtil) GETSET 

func (r *RedisUtil) GETSET(key, value string) string

GETSET 获取旧值并设置新值 @return 如果key不存在返回空

func (*RedisUtil) GetConn 

func (r *RedisUtil) GetConn(fun func(redis.Conn))

GetConn 获取redis链接

func (*RedisUtil) INCRBY 

func (r *RedisUtil) INCRBY(key string, increment int64) (int64, error)

原子操作

func (*RedisUtil) KEYS 

func (r *RedisUtil) KEYS(pattern string) ([]string, error)

KEYS 获取key集合 @param {string} pattern 匹配模式 Supported glob-style patterns: h?llo matches hello, hallo and hxllo h*llo matches hllo and heeeello h[ae]llo matches hello and hallo, but not hillo h[^e]llo matches hallo, hbllo, ... but not hello h[a-b]llo matches hallo and hbllo Use \ to escape special characters if you want to match them verbatim. @return 返回符合patten的key

func (*RedisUtil) MGET 

func (r *RedisUtil) MGET(keys ...string) ([]string, error)

批量获取

func (*RedisUtil) MGETWithKeyPattern 

func (r *RedisUtil) MGETWithKeyPattern(pattern string) ([]*RedisKeyValue, error)

按key的正则方式批量获取

func (*RedisUtil) Mutex 

func (r *RedisUtil) Mutex(key string, options ...redsync.Option) *redsync.Mutex

redis分布式锁对象

func (*RedisUtil) Prefix 

func (r *RedisUtil) Prefix() string

缓存前缀

func (*RedisUtil) SADD 

func (r *RedisUtil) SADD(key, member string) (int64, error)

将元素添加到集合,返回0/1(失败/成功)

func (*RedisUtil) SCARD 

func (r *RedisUtil) SCARD(key string) (int64, error)

返回集合key成员数量

func (*RedisUtil) SET 

func (r *RedisUtil) SET(key, value string) bool

SET 设置值

func (*RedisUtil) SETEX 

func (r *RedisUtil) SETEX(key, value string, expireTime int64) bool

SETEX 设置值和过期时间

func (*RedisUtil) SISMEMBER 

func (r *RedisUtil) SISMEMBER(key string, member string) bool

判断序集合key是否包含成员member

func (*RedisUtil) SMEMBERS 

func (r *RedisUtil) SMEMBERS(key string) ([]string, error)

获取集合所有值

func (*RedisUtil) SREM 

func (r *RedisUtil) SREM(key string, member string) (int64, error)

移除集合key中指定成员的排名,返回移除数量

func (*RedisUtil) SetLogger 

func (r *RedisUtil) SetLogger(lg logs.ILogger)

设置日志

func (*RedisUtil) SetPrefix 

func (r *RedisUtil) SetPrefix(prefix string)

设置缓存前缀

func (*RedisUtil) ZADD 

func (r *RedisUtil) ZADD(key string, score float64, member string) (int64, error)

将元素添加有序集合,返回0/1(失败/成功)

func (*RedisUtil) ZCARD 

func (r *RedisUtil) ZCARD(key string) (int64, error)

返回有序集合key成员数量

func (*RedisUtil) ZINCRBY 

func (r *RedisUtil) ZINCRBY(key string, increment int64, member string) (int64, error)

为有序集合key成员score增加值

func (*RedisUtil) ZRANGE 

func (r *RedisUtil) ZRANGE(key string, start, stop int64, withscores bool) ([]string, error)

返回有序集合key中，指定区间的成员(按score从小到大排序)

func (*RedisUtil) ZRANK 

func (r *RedisUtil) ZRANK(key string, member string) (int64, error)

返回有序集合key中,指定成员的排名(按score从小到大排序),第一名为0

func (*RedisUtil) ZREM 

func (r *RedisUtil) ZREM(key string, member string) (int64, error)

移除有序集合key中指定成员的排名,返回移除数量

func (*RedisUtil) ZREVRANGE 

func (r *RedisUtil) ZREVRANGE(key string, start, stop int64, withscores bool) ([]string, error)

返回有序集合key中，指定区间的成员(按score从大到小排序)

func (*RedisUtil) ZREVRANK 

func (r *RedisUtil) ZREVRANK(key string, member string) (int64, error)

返回有序集合key中,指定成员的排名(按score从大到小排序),第一名为0

func (*RedisUtil) ZSCORE 

func (r *RedisUtil) ZSCORE(key string, member string) (float64, error)

返回有序集合成员score值

type TracingContext 

type TracingContext interface {
	//Start 注意:由于该方法可能会进行连级调用所以不允许返回nil
	Start(operationName string) TracingContext

	//Finish 标记追踪结束
	Finish()
}

追踪上下文

type TracingSpan 

type TracingSpan interface {
	//SpanContext
	SpanContext() opentracing.SpanContext

	//context.Context
	Context(ctx context.Context) context.Context

	//Span
	Span() opentracing.Span

	//ChildOf
	ChildOf(operationName string) TracingSpan

	//FollowsFrom
	FollowsFrom(operationName string) TracingSpan

	//日志
	Logf(fields ...opentracinglog.Field)

	//Finish
	Finish()

	//Start
	Start(operationName string) TracingSpan

	//InjectHttpHeader
	InjectHttpHeader(header http.Header)
}

func NewTracingSpanExtractHttpRequest 

func NewTracingSpanExtractHttpRequest(req *http.Request) TracingSpan

解析一个HTTP追踪请求

func NewTracingSpanStart 

func NewTracingSpanStart(operationName string) TracingSpan

新建一个追踪

type TracingSpanImpl 

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

数据

func (*TracingSpanImpl) ChildOf 

func (t *TracingSpanImpl) ChildOf(operationName string) TracingSpan

ChildOf

func (*TracingSpanImpl) Context 

func (t *TracingSpanImpl) Context(ctx context.Context) context.Context

context.Context

func (*TracingSpanImpl) Finish 

func (t *TracingSpanImpl) Finish()

Finish

func (*TracingSpanImpl) FollowsFrom 

func (t *TracingSpanImpl) FollowsFrom(operationName string) TracingSpan

FollowsFrom

func (*TracingSpanImpl) InjectHttpHeader 

func (t *TracingSpanImpl) InjectHttpHeader(header http.Header)

编码HTTP请求

func (*TracingSpanImpl) Logf 

func (t *TracingSpanImpl) Logf(fields ...opentracinglog.Field)

日志

func (*TracingSpanImpl) Span 

func (t *TracingSpanImpl) Span() opentracing.Span

Span

func (*TracingSpanImpl) SpanContext 

func (t *TracingSpanImpl) SpanContext() opentracing.SpanContext

SpanContext

func (*TracingSpanImpl) Start 

func (t *TracingSpanImpl) Start(operationName string) TracingSpan

Start

Source Files

View all Source files

Directories

Path Synopsis
rsa
db
mssql
package gosql mssql工具包..引用"github.com/denisenkom/go-mssqldb"
 package gosql mssql工具包..引用"github.com/denisenkom/go-mssqldb"
mysql
package gosql mysql工具包..引用"github.com/go-sql-driver/mysql"
 package gosql mysql工具包..引用"github.com/go-sql-driver/mysql"
tags
beego
cmd
rpcx
socketTool

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.