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

• 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.XOrm
• func GRPCContext(ctx *Context) context.Context
• func Handler(controller iController) gin.HandlerFunc
• func LoadConfig(yamlFile string, conf interface{}) (err error)
• func NewGRPCServer(cfg goo_grpc.Config) *goo_grpc.Server
• 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 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

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.XOrm

func GRPCContext

func GRPCContext(ctx *Context) context.Context

func Handler

func Handler(controller iController) gin.HandlerFunc

定义控制器调用实现

func LoadConfig

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

func NewGRPCServer

func NewGRPCServer(cfg goo_grpc.Config) *goo_grpc.Server

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 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