goo

README

定时任务

func main() {
	var wg sync.WaitGroup

	goo.Crond(1*time.Second, func() {
		fmt.Println(time.Now().Format("15:04:05"))
	})

	goo.Crond(3*time.Second, func() {
		fmt.Println(time.Now().Format("15:04:05"))
	})

	goo.CronMinute(func() {
		fmt.Println(time.Now().Format("15:04:05"))
	})

	goo.CronHour(func() {
		fmt.Println(time.Now().Format("15:04:05"))
	})

	goo.CronDay(func() {
		fmt.Println(time.Now().Format("15:04:05"))
	})

	wg.Add(1)
	goo_utils.AsyncFunc(func() {
		defer wg.Done()
		<-goo_context.Cancel().Done()
	})

	wg.Wait()
}

mysql

func main() {
	goo_db.Init(goo_context.Cancel(), goo_db.Config{
		Name:   "",
		Driver: "mysql",
		Master:      "root:123456@tcp(192.168.1.100:3306)/ttxian",
		Slaves:      []string{"root:123456@tcp(192.168.1.100:3307)/ttxian"},
		LogModel:    true,
		MaxIdle:     10,
		MaxOpen:     100,
		AutoPing:    true,
		LogFilePath: "",
		LogFileName: "",
	})

	m := map[string]string{}
	exist, err := goo.DB().Table("s_user").Get(&m)
	if err != nil {
		goo_log.Fatal(err.Error())
	}
	if !exist {
		goo_log.Fatal("no data")
	}
	goo_log.Debug(m["account"])

	var wg sync.WaitGroup
	wg.Add(1)
	goo_utils.AsyncFunc(func() {
		defer wg.Done()
		<-goo_context.Cancel().Done()
	})
	wg.Wait()
}

redis

func main() {
	goo_redis.Init(goo_context.Cancel(), goo_redis.Config{
		Name:     "",
		Addr:     "192.168.1.100:6379",
		Password: "123456",
		DB:       0,
		Prefix:   "tt",
		AutoPing: true,
	})

	err := goo.Redis().Set("name", "hnatao", 3*time.Second).Err()
	if err != nil {
		goo_log.Fatal(err.Error())
	}

	name := goo.Redis().Get("name").String()
	goo_log.Debug(name)

	var wg sync.WaitGroup
	wg.Add(1)
	goo_utils.AsyncFunc(func() {
		defer wg.Done()
		<-goo_context.Cancel().Done()
	})
	wg.Wait()
}

Token

func main() {
	tokenStr, err := goo.CreateToken("1111", 100)
	if err != nil {
		goo_log.Fatal(err.Error())
	}
	goo_log.Debug(tokenStr)

	token, err := goo.ParseToken(tokenStr, "1111")
	if err != nil {
		goo_log.Fatal(err.Error())
	}
	goo_log.Debug(token)
}

grpc

var cfg = goo_etcd.Config{
    User: "test",
    Password: "123456",
    Endpoints: []string{"localhost:23791", "localhost:23792", "localhost:23793"},
}

func init() {
	goo_etcd.Init(cfg)
}

func main() {
	s := goo.NewGRPCServer(goo_grpc.Config{
		ENV:         "test",
		ServiceName: "lpro/grpc-user",
		Version:     "v100",
		Addr:        "127.0.0.1:10011",
	}).Register2Etcd(goo_etcd.CLI())

	pb_user_v1.RegisterGetterServer(s.Server, &Server{})

	s.Serve()
}

server

type User struct {
	Age int `form:"age"`
}

func (u User) DoHandle(ctx *goo.Context) *goo.Response {
	if err := ctx.ShouldBind(&u); err != nil {
		return goo.Error(5001, "参数错误", err.Error())
	}
	return goo.Success(u.Age)
}

func main() {
	s := goo.NewServer()

	s.GET("/", goo.Handler(User{}))

	s.Run(":8080")
}

Documentation

Index

• Variables
• func CreateToken(appId string, openId int64) (tokenStr string, err error)
• func CronDay(fns ...func())
• func CronHour(fns ...func())
• func CronMinute(fns ...func())
• func Crond(d time.Duration, fns ...func())
• func DB(names ...string) *goo_db.Orm
• func FlagInit()
• func Handler(controller iController) gin.HandlerFunc
• func LoadConfig(yamlFile string, conf interface{}) (err error)
• func Redis(names ...string) *goo_redis.Redis
• func ValidationMessage(err error, messages map[string]string) string
• type Context
  • func NewContext(c *gin.Context) (ctx *Context)
  • func (ctx *Context) AbortWithStatusJSON(code int, rsp *Response, v ...interface{})
  • func (ctx *Context) JSON(code int, rsp *Response, v ...interface{})
• type Env
• type HandlerFunc
• type Option
  • func BaseDirOption(v string) Option
  • func CorsHeadersOption(v ...string) Option
  • func NewOption(name string, value interface{}) Option
  • func NoAccessPathsOption(v ...string) Option
  • func NoLogPathsOption(v ...string) Option
  • func PProfEnable(flag bool) Option
  • func ServerNameOption(v string) Option
• type Response
  • func Error(code int32, message string, v ...interface{}) *Response
  • func ErrorWithValidate(err error, messages map[string]string) *Response
  • func Success(data interface{}) *Response
  • func (rsp *Response) String() string
• type Server
  • func NewServer(opts ...Option) *Server
  • func (s *Server) Router(fn func(s *Server)) *Server
  • func (s *Server) Run(addr string)
  • func (s *Server) Use(handlers ...HandlerFunc) *Server
• type Token
  • func ParseToken(tokenStr, appId string) (token *Token, err error)
  • func (t *Token) Bytes() []byte
  • func (t *Token) String() string

Variables

var (
	Version     string
	VersionFlag = flag.Bool("v", false, "version")

	HelpFlag = flag.Bool("h", false, "help")
)

Functions

func CreateToken

func CreateToken(appId string, openId int64) (tokenStr string, err error)

func CronDay

func CronDay(fns ...func())

*

• 每天执行一次

func CronHour

func CronHour(fns ...func())

*

• 每小时执行一次

func CronMinute

func CronMinute(fns ...func())

*

• 每分钟执行一次

func Crond

func Crond(d time.Duration, fns ...func())

*

• 定期执行任务

func DB

func DB(names ...string) *goo_db.Orm

func FlagInit

func FlagInit()

func Handler

func Handler(controller iController) gin.HandlerFunc

定义控制器调用实现

func LoadConfig

func LoadConfig(yamlFile string, conf interface{}) (err error)

func Redis

func Redis(names ...string) *goo_redis.Redis

func ValidationMessage

func ValidationMessage(err error, messages map[string]string) string

Types

type Context

type Context struct {
	*gin.Context
	// contains filtered or unexported fields
}

func NewContext

func NewContext(c *gin.Context) (ctx *Context)

func (*Context) AbortWithStatusJSON

func (ctx *Context) AbortWithStatusJSON(code int, rsp *Response, v ...interface{})

中止并返回json数据

func (*Context) JSON

func (ctx *Context) JSON(code int, rsp *Response, v ...interface{})

返回json数据

type Env

type Env string

const (
	PRODUCTION  Env = "production"
	SIM         Env = "sim"
	TEST        Env = "test"
	DEVELOPMENT Env = "development"
)

type HandlerFunc

type HandlerFunc func(ctx *Context)

type Option

type Option struct {
	Name  string
	Value interface{}
}

func BaseDirOption

func BaseDirOption(v string) Option

根路径

func CorsHeadersOption

func CorsHeadersOption(v ...string) Option

跨域字段

func NewOption

func NewOption(name string, value interface{}) Option

func NoAccessPathsOption

func NoAccessPathsOption(v ...string) Option

不允许访问的路径

func NoLogPathsOption

func NoLogPathsOption(v ...string) Option

不记录日志的路径

func PProfEnable

func PProfEnable(flag bool) Option

性能分析

func ServerNameOption

func ServerNameOption(v string) Option

服务名称

type Response

type Response struct {
	Code    int32         `json:"code"`
	Message string        `json:"message"`
	Data    interface{}   `json:"data"`
	Errors  []interface{} `json:"-"`
}

func Error

func Error(code int32, message string, v ...interface{}) *Response

func ErrorWithValidate

func ErrorWithValidate(err error, messages map[string]string) *Response

func Success

func Success(data interface{}) *Response

func (*Response) String

func (rsp *Response) String() string

type Server

type Server struct {
	*gin.Engine
	// contains filtered or unexported fields
}

定义web服务

func NewServer

func NewServer(opts ...Option) *Server

func (*Server) Router

func (s *Server) Router(fn func(s *Server)) *Server

路由

func (*Server) Run

func (s *Server) Run(addr string)

启动服务

func (*Server) Use

func (s *Server) Use(handlers ...HandlerFunc) *Server

中间件

type Token

type Token struct {
	AppId     string
	OpenId    int64
	NonceStr  string
	Timestamp int64
}

func ParseToken

func ParseToken(tokenStr, appId string) (token *Token, err error)

func (*Token) Bytes

func (t *Token) Bytes() []byte

func (*Token) String

func (t *Token) String() string