goo

README

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 ClientIP(c *gin.Context) string
• func CreateToken(appId string, openid int64) (tokenStr string, err error)
• func DB(names ...string) *goo_db.Client
• func ES() *goo_es.ESClient
• func FlagInit()
• func GrpcContext(c *gin.Context) context.Context
• func Handler(controller iController) gin.HandlerFunc
• func LoadConfig(yamlFile string, conf interface{}) (err error)
• func Mongo(names ...string) *mongo.Database
• func MongoClient(names ...string) *goo_mongo.Client
• func Redis(names ...string) *goo_redis.Client
• func RequestBody(c *gin.Context) interface{}
• func RequestId(c *gin.Context) string
• func ValidationMessage(err error, messages map[string]string) string
• type Encryption
  • func (enc *Encryption) Decode(str string) (b []byte, err error)
  • func (enc *Encryption) Encode(b []byte) (str string, err error)
• type Env
  • func (env Env) String() string
  • func (env Env) Tag() string
• type LocalUpload
  • func (lu LocalUpload) Upload(c *gin.Context, uploadDir string) *Response
• type Option
  • func CorsHeaderOption(corsHeaders ...string) Option
  • func EnableEncryptionOption(encryptKey, encryptSecret string, excludeUris ...string) Option
  • func EnvOption(env Env) Option
  • func NoAccessPathsOption(noAccessPaths ...string) Option
  • func NoLogPathsOption(noLogPaths ...string) Option
  • func PProfEnableOption(pprofEnable bool) Option
  • func ServerNameOption(serverName 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) Copy() *Response
  • func (rsp *Response) String() string
• type Server
  • func NewServer(opt ...Option) *Server
  • func (s *Server) Run(addr string)
• 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 ClientIP

func ClientIP(c *gin.Context) string

客户端IP

func CreateToken

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

func DB

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

func ES

func ES() *goo_es.ESClient

func FlagInit

func FlagInit()

func GrpcContext

func GrpcContext(c *gin.Context) context.Context

func Handler

func Handler(controller iController) gin.HandlerFunc

定义控制器调用实现

func LoadConfig

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

func Mongo

func Mongo(names ...string) *mongo.Database

func MongoClient

func MongoClient(names ...string) *goo_mongo.Client

func Redis

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

func RequestBody

func RequestBody(c *gin.Context) interface{}

请求数据

func RequestId

func RequestId(c *gin.Context) string

唯一ID

func ValidationMessage

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

Types

type Encryption

type Encryption struct {
	Key    string
	Secret string
}

func (*Encryption) Decode

func (enc *Encryption) Decode(str string) (b []byte, err error)

func (*Encryption) Encode

func (enc *Encryption) Encode(b []byte) (str string, err error)

type Env

type Env string

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

func (Env) String

func (env Env) String() string

func (Env) Tag

func (env Env) Tag() string

type LocalUpload

type LocalUpload struct {
}

func (LocalUpload) Upload

func (lu LocalUpload) Upload(c *gin.Context, uploadDir string) *Response

type Option

type Option interface {
	// contains filtered or unexported methods
}

func CorsHeaderOption

func CorsHeaderOption(corsHeaders ...string) Option

跨域

func EnableEncryptionOption

func EnableEncryptionOption(encryptKey, encryptSecret string, excludeUris ...string) Option

启用加密传输

func EnvOption

func EnvOption(env Env) Option

运行环境

func NoAccessPathsOption

func NoAccessPathsOption(noAccessPaths ...string) Option

禁止访问的path

func NoLogPathsOption

func NoLogPathsOption(noLogPaths ...string) Option

不记录日志的path

func PProfEnableOption

func PProfEnableOption(pprofEnable bool) Option

开启分析

func ServerNameOption

func ServerNameOption(serverName string) Option

服务名称

type Response

type Response struct {
	Code    int32         `json:"code"`
	Message string        `json:"message"`
	Data    interface{}   `json:"data,omitempty"`
	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) Copy

func (rsp *Response) Copy() *Response

func (*Response) String

func (rsp *Response) String() string

type Server

type Server struct {
	*gin.Engine
}

定义web服务

func NewServer

func NewServer(opt ...Option) *Server

func (*Server) Run

func (s *Server) Run(addr string)

启动服务

type Token

type Token struct {
	AppId     string `json:"app_id"`
	OpenId    int64  `json:"data"`
	NonceStr  string `json:"nonce"`
	Timestamp int64  `json:"ts"`
}

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