components

package
v1.0.10 Latest Latest
Warning

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

 Go to latest Published: Sep 26, 2019 License: MIT Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CACHE_FILE = 1 + iota
	CACHE_MEM
)
View Source 
const (
	TCPStatusNone = iota
	TCPStatusConnected
	TCPStatusDisconnected
)

TCP状态常量

View Source 
const (
	TCPEventConnected = iota
	TCPEventDisconnected
	TCPEventRecv
	TCPEventWritten
)

TCP事件常量

Variables

View Source 
var CKRedisPool *redis.Pool
View Source 
var ImageMime = map[string]string{
	"image/jpeg": "jpg",
	"image/jpg":  "jpg",
	"image/png":  "png"}

Functions

func CallAction 

func CallAction(i interface{}, c *gin.Context)

调用Controller 的 Action 方法

func CallActionGet 

func CallActionGet(i interface{}, c *gin.Context)

调用Controller 的 Action 方法 GET

func Cross 

func Cross(c *gin.Context, is_cross bool, org string)

是否可以跨域调用

func Display 

func Display(c *gin.Context, html []byte)

显示HTML数据

func GetActiveCount added in v1.0.6 

func GetActiveCount() int

func GetIdleCount added in v1.0.6 

func GetIdleCount() int

func GetProperty 

func GetProperty(c *gin.Context) []byte

得到POST原始数据

func InitPprof 

func InitPprof(server *gin.Engine)

func InitRedisPool 

func InitRedisPool(cfg *RedisConfig)

Types

type CKRedis 

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

func NewCKRedis 

func NewCKRedis() (*CKRedis, error)

初始一个消息队列

func (*CKRedis) Close 

func (m *CKRedis) Close()

关闭连接

func (*CKRedis) Count 

func (m *CKRedis) Count() (int, error)

得到队列消息数

func (*CKRedis) Do 

func (m *CKRedis) Do(command string, args ...interface{}) (interface{}, error)

执行命令

func (*CKRedis) Exists 

func (m *CKRedis) Exists(key string) bool

是否存在一个缓存值

func (*CKRedis) GAdd 

func (m *CKRedis) GAdd(key string, lon string, lat string, member string) (bool, error)

添加一个坐标到 GEOHASH

func (*CKRedis) GDist 

func (m *CKRedis) GDist(key string, member string, member2 string) (int, error)

计算两个位置的距离,返回米

func (*CKRedis) GPos 

func (m *CKRedis) GPos(key string, member string) ([]interface{}, error)

得到一个member 的坐标

func (*CKRedis) GRadius 

func (m *CKRedis) GRadius(key string, lon string, lat string, radius int) ([]*RedisGeo, error)

得到传入坐标半径的所有所坐标

func (*CKRedis) Get 

func (m *CKRedis) Get(key string) (interface{}, error)

得到一个缓存值

func (*CKRedis) HDel 

func (m *CKRedis) HDel(key, field string) (bool, error)

删除一个 hash 值

func (*CKRedis) HExists 

func (m *CKRedis) HExists(key, field string) (bool, error)

检查是否存在一个HASH值

func (*CKRedis) HGet 

func (m *CKRedis) HGet(key, field string) (interface{}, error)

得到一个HASH值

func (*CKRedis) HKeys 

func (m *CKRedis) HKeys(key string) ([]interface{}, error)

得到所有 hash 键

func (*CKRedis) HLen 

func (m *CKRedis) HLen(key string) (int, error)

得到 hash 长度

func (*CKRedis) HMGet 

func (m *CKRedis) HMGet(key string, field ...interface{}) ([]interface{}, error)

得到多个HASH 值

func (*CKRedis) HSet 

func (m *CKRedis) HSet(key, field string, val interface{}) (bool, error)

--- HASH --- 设置一个HASH值

func (*CKRedis) Keys 

func (m *CKRedis) Keys(perm string) ([]string, error)

得到KEYS

func (*CKRedis) LLen 

func (m *CKRedis) LLen(key string) (int, error)

得到LIST长度

func (*CKRedis) LPush 

func (m *CKRedis) LPush(key string, value string) (int, error)

--- LIST 列表 --- 插入一条记录,或多条记录

func (*CKRedis) LRange 

func (m *CKRedis) LRange(key string, start int, stop int) ([]interface{}, error)

得到一个区间的LIST值列表

func (*CKRedis) LSet 

func (m *CKRedis) LSet(key string, index int, value string) (int, error)

更新一个下标值

func (*CKRedis) Lock 

func (m *CKRedis) Lock()

func (*CKRedis) Push 

func (m *CKRedis) Push(msg string) error

PUSH 消息到队列

func (*CKRedis) RPop 

func (m *CKRedis) RPop(key string) (string, error)

删除列表尾记录并返回

func (*CKRedis) Receive 

func (m *CKRedis) Receive() (string, error)

接收队列消息

func (*CKRedis) Remove 

func (m *CKRedis) Remove(key ...string) error

删除一个缓存值

func (*CKRedis) Set 

func (m *CKRedis) Set(key string, val interface{}, exp int) error

设置一个缓存值

func (*CKRedis) SetDB 

func (m *CKRedis) SetDB(db_idx int)

设置当前操作的数据ID

func (*CKRedis) SetMessageQueueName 

func (m *CKRedis) SetMessageQueueName(name string)

设置当前操作的消息队列名称

func (*CKRedis) ZAdd 

func (m *CKRedis) ZAdd(key string, score int, member string) (bool, error)

添加一个member有序集合

func (*CKRedis) ZCard 

func (m *CKRedis) ZCard(key string) (int, error)

返回有序集合的基数

func (*CKRedis) ZCount 

func (m *CKRedis) ZCount(key string, min string, max string) (int, error)

返回指定score 大小之间的成员数量

func (*CKRedis) ZRangeByScore 

func (m *CKRedis) ZRangeByScore(key string, min string, max string, with_score bool) ([]string, error)

返回指定 score 大小之间的成员列表

func (*CKRedis) ZRem 

func (m *CKRedis) ZRem(key, member string) (bool, error)

删除有序集合里面的成员

type Cache 

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

func NewCache 

func NewCache(cache_type int) *Cache

func (*Cache) Delete 

func (this *Cache) Delete(key string) bool

func (*Cache) Get 

func (this *Cache) Get(key string) (interface{}, error)

*

  • Cache Functions

func (*Cache) Set 

func (this *Cache) Set(key string, v interface{}, expire int64) bool

type CacheData 

type CacheData struct {
	Expire  int64  `json:"expire"`
	Content string `json:"content"`
}

type CacheIn 

type CacheIn interface {
	Get(key string) (interface{}, error)
	Set(key string, value interface{}, expire int64) bool
	Delete(key string) bool
}

type ConnEvent 

type ConnEvent struct {
	EventType int
	Conn      *Connection
	Data      []byte
}

type Connection 

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

func NewConnection 

func NewConnection(c net.Conn, sendBufferSize int, eq IEventQueue) *Connection

func (*Connection) Close 

func (this *Connection) Close()

func (*Connection) GetConnId 

func (this *Connection) GetConnId() int

func (*Connection) GetReadTimeoutSec 

func (this *Connection) GetReadTimeoutSec() int

func (*Connection) GetStatus 

func (this *Connection) GetStatus() int

func (*Connection) GetUserdata 

func (this *Connection) GetUserdata() interface{}

func (*Connection) Send 

func (this *Connection) Send(msg []byte, cpy bool)

func (*Connection) SetConnId 

func (this *Connection) SetConnId(id int)

func (*Connection) SetReadTimeoutSec 

func (this *Connection) SetReadTimeoutSec(sec int)

func (*Connection) SetUserdata 

func (this *Connection) SetUserdata(ud interface{})

type FileCache 

type FileCache struct {
	CacheIn
	// contains filtered or unexported fields
}

func (*FileCache) Delete 

func (this *FileCache) Delete(key string) bool

func (*FileCache) Get 

func (this *FileCache) Get(key string) (interface{}, error)

*

  • FileCache Functions

func (*FileCache) GetName 

func (this *FileCache) GetName(key string) string

func (*FileCache) Set 

func (this *FileCache) Set(key string, v interface{}, expire int64) bool

type GoroutinePool 

type GoroutinePool struct {
	Queue  chan interface{} //队列池
	Number int              //并发协程数
	Total  int              //处理数据量
	Worker func(obj ...interface{}) bool
	// contains filtered or unexported fields
}

协程池

func NewPoll 

func NewPoll(number int, worker func(obj ...interface{}) bool) *GoroutinePool

新建一个协程池

func (*GoroutinePool) AddTask 

func (this *GoroutinePool) AddTask(task interface{})

func (*GoroutinePool) AddTaskInterface 

func (this *GoroutinePool) AddTaskInterface(tasks []interface{})

func (*GoroutinePool) AddTaskStrings 

func (this *GoroutinePool) AddTaskStrings(tasks []string)

func (*GoroutinePool) SetFinishCallback 

func (this *GoroutinePool) SetFinishCallback(callback func())

func (*GoroutinePool) Start 

func (this *GoroutinePool) Start()

func (*GoroutinePool) Stop 

func (this *GoroutinePool) Stop()

type IEventHandler 

type IEventHandler interface {
	OnConnected(evt *ConnEvent)
	OnDisconnected(evt *ConnEvent)
	OnRecv(evt *ConnEvent)
}

type IEventQueue 

type IEventQueue interface {
	Push(*ConnEvent)
	Pop() *ConnEvent
}

type IEventTCP 

type IEventTCP interface {
	OnConnected(evt *TCPConnEvent)
	OnDisconnected(evt *TCPConnEvent)
	OnRecv(evt *TCPConnEvent)
	OnWritten(evt *TCPConnEvent)
}

type IStreamProtocol 

type IStreamProtocol interface {
	//  Init
	Init()
	//  get the header length of the stream
	GetHeaderLength() int
	//  read the header length of the stream
	UnserializeHeader([]byte) int
	//  format header
	SerializeHeader([]byte) []byte
}

type MediaData 

type MediaData struct {
	FileType string
	FileName string
	Content  []byte
}

type MemCache 

type MemCache struct {
	CacheIn
	// contains filtered or unexported fields
}

GO本地内存数据缓存

func NewMemCache 

func NewMemCache() *MemCache

新创建一个内存缓存

func (*MemCache) Delete 

func (m *MemCache) Delete(key string) bool

删除缓存

func (*MemCache) Dump 

func (m *MemCache) Dump()

func (*MemCache) Get 

func (m *MemCache) Get(key string) (interface{}, error)

*

  • MemCache Functions

func (*MemCache) Set 

func (m *MemCache) Set(key string, v interface{}, expire int64) bool

设置数据

func (*MemCache) Stat 

func (m *MemCache) Stat()

type MemCacheData 

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

func (*MemCacheData) IsExpire 

func (mc *MemCacheData) IsExpire() bool

数据是否过期

type RedisConfig 

type RedisConfig struct {
	RDServer   string `json:"rd_server" yaml:"rd_server"`
	RDPort     string `json:"rd_port" yaml:"rd_port"`
	RDDb       int    `json:"rd_db" yaml:"rd_db"`
	RDPassword string `json:"rd_password" yaml:"rd_password"`
	RDListName string `json:"rd_list_name" yaml:"rd_list_name"`
	RDPoolSize int    `json:"rd_pool_size" yaml:"rd_pool_size"`
	RDIdleSize int    `json:"rd_idle_size" yaml:"rd_idle_size"`
}

redis 配置

type RedisGeo 

type RedisGeo struct {
	Member string  `json:"member"`
	Lon    float64 `json:"lon"`
	Lat    float64 `json:"lat"`
	Dist   float64 `json:"dist"`
}

GEO地理位置

type SysLog 

type SysLog struct {
	Prefix string
}

func NewSysLog 

func NewSysLog(prefix string) *SysLog

func (*SysLog) Error 

func (l *SysLog) Error(err interface{})

记录错误

func (*SysLog) Info 

func (l *SysLog) Info(msg string)

func (*SysLog) Write 

func (l *SysLog) Write(p []byte) (n int, err error)

func (*SysLog) WriteFile 

func (l *SysLog) WriteFile(filename string, data []byte, perm os.FileMode) error

type TCPConnEvent 

type TCPConnEvent struct {
	EventType int
	Conn      *TCPConnect
	Data      interface{}
}

事件类型结构数据

type TCPConnect 

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

TCP连接

func NewTCPConnect 

func NewTCPConnect(c net.Conn, evt IEventTCP) *TCPConnect

新建TCP服务连接

func (*TCPConnect) Close 

func (tp *TCPConnect) Close()

关闭连接

func (*TCPConnect) Run 

func (tp *TCPConnect) Run()

运行

func (*TCPConnect) SetDebug 

func (tp *TCPConnect) SetDebug(yes bool)

设置DEBUG状态

func (*TCPConnect) SetReadTimeout 

func (tp *TCPConnect) SetReadTimeout(ss int64)

设置读取超时

func (*TCPConnect) Status 

func (tp *TCPConnect) Status() int

得到当前TCP状态

func (*TCPConnect) WriteData 

func (tp *TCPConnect) WriteData(data []byte)

写入数据到TCP

type Template 

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

func NewTemplate 

func NewTemplate(tempDir string) *Template

func (*Template) Assign 

func (t *Template) Assign(key string, val interface{})

设置模板变量

func (*Template) Display 

func (t *Template) Display(resp http.ResponseWriter, html []byte)

向浏览器输出内容

func (*Template) Parse 

func (t *Template) Parse(tempName string) (string, error)

编辑输出模块内容

type TemplateCon 

type TemplateCon struct {
	Content []byte
	ModTime int64
}

type Upload 

type Upload struct {
}

func NewUpload 

func NewUpload() *Upload

func (*Upload) ImageBase64 

func (*Upload) ImageBase64(base64_str string) string

func (*Upload) MoveTmpToSave 

func (*Upload) MoveTmpToSave(tmp_file string) string

type Weixin 

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

func NewWeixin 

func NewWeixin(app_id, app_secret string) *Weixin

func (*Weixin) CreateQrCode 

func (w *Weixin) CreateQrCode(token, content string) (*WxQrCode, error)

创建永久二维码

func (*Weixin) CreateTempQrCode 

func (w *Weixin) CreateTempQrCode(token, content string, time_s int) (*WxQrCode, error)

创建临时二维码

func (*Weixin) CreateWxAppQrCode 

func (w *Weixin) CreateWxAppQrCode(token, scene, page string, width int) (string, error)

创建微信小程序二维码

func (*Weixin) GetAccessToken 

func (w *Weixin) GetAccessToken() (*WxAccessToken, error)

得到公众号全局 ACCESS_TOKEN

func (*Weixin) GetJsapiTicket 

func (w *Weixin) GetJsapiTicket(access_token string) (*WxJsapiTicket, error)

获取JsTicket

func (*Weixin) GetMedia 

func (w *Weixin) GetMedia(access_token string, media_id string) (*MediaData, error)

得到临时素材

func (*Weixin) GetUserAccessToken 

func (w *Weixin) GetUserAccessToken(code string) (*WxUserAccessToken, error)

使用code获取用户access token

func (*Weixin) GetUserInfo 

func (w *Weixin) GetUserInfo(access_token string, openid string) (*WxUserInfo, error)

拉取用户信息

func (*Weixin) GetUserInfoAccessToken 

func (w *Weixin) GetUserInfoAccessToken(access_token string, openid string) (*WxUser, error)

使用用户access token 获取用户信息

func (*Weixin) Http 

func (w *Weixin) Http(uri string) (string, error)

发起HTTP连接

func (*Weixin) SendCustomMessage 

func (w *Weixin) SendCustomMessage(token, openid, msg_type string, data utils.M) (string, error)

向用户发送客户消息

func (*Weixin) SendTemplateMessage 

func (w *Weixin) SendTemplateMessage(access_token string, data utils.M) error

发送模板消息

func (*Weixin) SignJsTicket 

func (w *Weixin) SignJsTicket(data map[string]interface{}) string

进行JSTICKET签名

func (*Weixin) WebAuth 

func (w *Weixin) WebAuth(redirect_uri string, mpid string, base bool) string

发起 WEB 验证受权

type WxAccessToken 

type WxAccessToken struct {
	AccessToken string `json:"access_token"`
	ExpiresIn   int    `json:"expires_in"`
}

type WxError 

type WxError struct {
	ErrorCode int    `json:"errcode"`
	ErrorMsg  string `json:"errmsg"`
}

type WxJsapiTicket 

type WxJsapiTicket struct {
	Ticket    string `json:"ticket"`
	ExpiresIn int    `json:"expires_in"`
}

type WxQrCode 

type WxQrCode struct {
	Ticket        string `json:"ticket"`
	ExpireSeconds int    `json:"expire_seconds"`
	Url           string `json:"url"`
}

微信二维码结构

type WxUser 

type WxUser struct {
	NickName string `json:"nickname"`
	OpenId   string `json:"openid"`
	Sex      int    `json:"sex"`
	Province string `json:"province"`
	City     string `json:"city"`
	Country  string `json:"country"`
	HeadImg  string `json:"headimgurl"`
	UnionId  string `json:"unionid"`
}

网页受权接口获取用户数据

type WxUserAccessToken 

type WxUserAccessToken struct {
	AccessToken  string `json:"access_token"`
	ExpiresIn    int    `json:"expires_in"`
	RefreshToken string `json:"refresh_token"`
	OpenId       string `json:"openid"`
	Scope        string `json:"scope"`
	UnionId      string `json:"unionid"`
}

type WxUserInfo 

type WxUserInfo struct {
	Subscribe      int    `json:"subscribe"`
	Subscribe_time int    `json:"subscribe_time"`
	Nickname       string `json:"nickname"`
	OpenId         string `json:"openid"`
	Sex            int    `json:"sex"`
	Province       string `json:"province"`
	City           string `json:"city"`
	Country        string `json:"country"`
	HeadImg        string `json:"headimgurl"`
	Language       string `json:"language"`
	UnionId        string `json:"unionid"`
	Remark         string `json:"remark"`
	Groupid        int    `json:"groupid"`
	Tagid_list     []int  `json:"tagid_list"`
}

用公众号接口获取的用户数据

Source Files

View all Source files

Directories

Path Synopsis

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.