goserver

Documentation

Index

• func ClientIP(c *gin.Context) string
• func CreateToken(appId string, openid int64) (tokenStr string, err error)
• func GrpcContext(c *gin.Context) context.Context
• func Handler(controller iController) gin.HandlerFunc
• func LoadJsonConfig(jsonFile string, conf interface{}) (err error)
• func LoadYamlConfig(yamlFile string, conf interface{}) (err error)
• func RequestBody(c *gin.Context) interface{}
• func RequestId(c *gin.Context) string
• func ValidationMessage(err error, messages map[string]string) string
• type Config
• type Encryption
  • func (enc *Encryption) Decode(str string) (b []byte, err error)
  • func (enc *Encryption) Encode(b []byte) (str string, err error)
• 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 goio.Environment) 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

Functions

func ClientIP

func ClientIP(c *gin.Context) string

客户端IP

func CreateToken

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

func GrpcContext

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

func Handler

func Handler(controller iController) gin.HandlerFunc

定义控制器调用实现

func LoadJsonConfig

func LoadJsonConfig(jsonFile string, conf interface{}) (err error)

func LoadYamlConfig

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

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 Config

type Config struct {
	Env goio.Environment `yaml:"env"`

	Server struct {
		Addr string `yaml:"addr"`
		Name string `yaml:"name"`
	} `yaml:"server"`

	Prometheus  prometheusx.Config  `yaml:"prometheus"`
	MongoDB     gomongo.Config      `yaml:"mongodb"`
	Mysql       gogorm.Config       `yaml:"mysql"`
	Postgres    gogorm.Config       `yaml:"postgres"`
	Sqlite      gogorm.Config       `yaml:"sqlite"`
	Clickhouse1 gogorm.Config       `yaml:"clickhouse1"`
	Redis       goredis.Config      `yaml:"redis"`
	Kafka       gokafka.Config      `yaml:"kafka"`
	Clickhouse  goclickhouse.Config `yaml:"clickhouse"`
	Es          goes.Config         `yaml:"es"`

	Etcd goetcd.Config `yaml:"etcd"`

	FeiShu string `yaml:"feishu"`
}

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 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 goio.Environment) 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"`
	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