st

package module

Go to main page

Versions in this module

v0

v0.1.1

Feb 19, 2021

v0.1.0

Feb 19, 2021

v0.0.9

Feb 9, 2021

v0.0.8

Feb 9, 2021

v0.0.7

Feb 8, 2021

Changes in this version

+ func GrpcRecovery(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)

v0.0.6

Feb 8, 2021

Changes in this version

+ var DurationsSummary *prometheus.SummaryVec

+ var LatencyHistogram *prometheus.HistogramVec

+ var RequestCounter *prometheus.CounterVec

+ func InitPrometheus(name string)

+ func PromMetrics() gin.HandlerFunc

+ func PrometheusInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)

+ func PromethousHandler() gin.HandlerFunc

type DSN

+ PreStmt bool

+ SkipTran bool

type GinServer

+ func (s *GinServer) Promethous(name, pass string)

v0.0.5

Feb 6, 2021

v0.0.4

Feb 6, 2021

Changes in this version

type GormDB

+ func (db *GormDB) BatchInsert(tb string, value interface{}, batchSize int) error

v0.0.3

Feb 2, 2021

Changes in this version

+ func ConnectMongo(addr string) (client *mongo.Client, err error)

+ func Errf(fomart string, v ...interface{})

+ func GetCaller(d int) (string, int)

+ func HeadSeparator(path string) string

+ func JsonMsg(c *gin.Context, msg string)

+ func LoadOrSaveJSON(name string, res interface{}, def func() interface{}) (err error)

+ func LoadOrSaveToml(name string, data interface{}, def func() interface{}) (err error)

+ func LoadToml(name string, data interface{}) error

+ func LogControl(trace bool, skip []string) gin.HandlerFunc

+ func Logf(fomart string, v ...interface{})

+ func NewGrpcConn(addr string) (*grpc.ClientConn, error)

+ func NewRedisClient(addr, pass string, db int) *redis.Client

+ func NewRedisClients(addr, pass string) (clients map[int]*redis.Client, err error)

+ func Run(app AppInterface)

+ func SaveToml(name string, data interface{}) error

+ func TailSeparator(path string) string

+ type App struct

+ Na string

+ Start func() bool

+ Stop func()

+ Svrs []ServerInterface

+ func (a *App) Name() string

+ func (a *App) OnStart() bool

+ func (a *App) OnStop()

+ func (a *App) Servers() []ServerInterface

+ type AppInterface interface

+ Name func() string

+ OnStart func() bool

+ OnStop func()

+ Servers func() []ServerInterface

+ type DSN struct

+ DBName string

+ LogLevel logger.LogLevel

+ Password string

+ Port string

+ URL string

+ Username string

+ func (d DSN) MySQL() string

+ func (d DSN) Postgres() string

+ type GinServer struct

+ Engine *gin.Engine

+ Name string

+ Server *http.Server

+ func NewGinServer(name, addr, mod string) *GinServer

+ func (s *GinServer) Group(path string, handlers ...gin.HandlerFunc) *gin.RouterGroup

+ func (s *GinServer) Health()

+ func (s *GinServer) Info() string

+ func (s *GinServer) OnStart() bool

+ func (s *GinServer) OnStop()

+ type GormDB struct

+ func MustOpen(dial gorm.Dialector, logLevel logger.LogLevel) *GormDB

+ func MustOpenMySQL(d DSN) *GormDB

+ func MustOpenPostgres(d DSN) *GormDB

+ func (db *GormDB) ExecSQL(sql string, values ...interface{}) (int64, error)

+ func (db *GormDB) Insert(tb string, value interface{}) error

+ func (db *GormDB) Query(dest interface{}, stmt string, values ...interface{}) error

+ func (db *GormDB) QueryRow(stmt string, values ...interface{}) *sql.Row

+ func (db *GormDB) QueryRows(hand func(*sql.Rows) error, sql string, values ...interface{}) (err error)

+ func (db *GormDB) TxInsert(tb string, count int, get func(int) interface{}, hand func(error) bool) (err error)

+ func (gdb *GormDB) CloseDB()

+ type GrpcServer struct

+ Addr string

+ Name string

+ Register func(*GrpcServer)

+ func NewGrpcServer(name, addr string, reg func(*GrpcServer), opt ...grpc.ServerOption) *GrpcServer

+ func (gs *GrpcServer) Info() string

+ func (gs *GrpcServer) OnStart() bool

+ func (gs *GrpcServer) OnStop()

+ type HttpClient struct

+ func NewHttpClient() *HttpClient

+ func (c *HttpClient) GetJSON(url string, data interface{}) (err error)

+ func (c *HttpClient) GetJSONAuth(url, un, pa string, data interface{}) (err error)

+ func (c *HttpClient) PostFormJSON(url string, vals url.Values, data interface{}) (err error)

+ func (c *HttpClient) PostFormJSONAuth(url, un, pa string, vals url.Values, data interface{}) (err error)

+ func (c *HttpClient) PostJSON(url string, src, data interface{}) (err error)

+ func (c *HttpClient) PostJSONAuth(url, un, pa string, src, data interface{}) (err error)

+ type ServerInterface interface

+ Info func() string

+ OnStart func() bool

+ OnStop func()

v0.0.2

Dec 10, 2020

v0.0.1

Dec 2, 2020

Changes in this version

+ const CodeErr

+ const CodeOK

+ const TimeLayout1

+ const TimeLayout2

+ const TimeLayout3

+ const TimeLayout4

+ const TimeLayout5

+ const TimeLayout6

+ const TimeLayout7

+ const TimeLayout8

+ var DefaultConfig = &Config

+ func BindJSON(r *http.Request, data interface{}) error

+ func CheckPath(path string) string

+ func CheckPattern(pattern string) string

+ func CreateConfigFile(path string, c *Config)

+ func CreateFolder(path string) error

+ func GetRealIP(req *http.Request) string

+ func GzipJSON(w http.ResponseWriter, data interface{})

+ func JSON(w http.ResponseWriter, data interface{})

+ func JsonErr(w http.ResponseWriter, err error)

+ func JsonOK(w http.ResponseWriter, data interface{})

+ func JsonResp(w http.ResponseWriter, code int, res string)

+ func JsonWrong(w http.ResponseWriter, res string)

+ func LoadJSON(name string, data interface{}) error

+ func LoadOrCreateJSON(name string, data interface{}) error

+ func LogErr(err error, msg string)

+ func MD5(src string) []byte

+ func RandomString(n int) string

+ func SaveJSON(name string, data interface{}) error

+ func StrTime(timestamp int64, timeLayout string) string

+ func ToJsonStr(data interface{}) string

+ func Trace(msg string) func()

+ func UUID() string

+ func UnixTime(timeStr, layout string) int64

+ type Client struct

+ func NewClient() *Client

+ func NewConfigClient(c *ClientConfig) *Client

+ func (c *Client) GetJSON(url string, data interface{}) (err error)

+ func (c *Client) GetJSONAuth(url, un, pa string, data interface{}) (err error)

+ func (c *Client) PostFormJSON(url string, vals url.Values, data interface{}) (err error)

+ func (c *Client) PostFormJSONAuth(url, un, pa string, vals url.Values, data interface{}) (err error)

+ func (c *Client) PostJSON(url string, src, data interface{}) (err error)

+ func (c *Client) PostJSONAuth(url, un, pa string, src, data interface{}) (err error)

+ type ClientConfig struct

+ ExpectContinueTimeout time.Duration

+ IdleConnTimeout time.Duration

+ KeepAlive time.Duration

+ MaxIdleConns int

+ ResponseHeaderTimeout time.Duration

+ Timeout time.Duration

+ type Config struct

+ Client *ClientConfig

+ Name string

+ Server *ServerConfig

+ type Dealer func(http.ResponseWriter, *http.Request, Dealers, int)

+ func BasicAuth(username, password string) Dealer

+ func CORS(acceptedOrigin, AcceptedMethods, AcceptedHeaders, MaxAge string) Dealer

+ func Method(m string) Dealer

+ func NoCache() Dealer

+ func TraceH() Dealer

+ type Dealers []Dealer

+ func (ds Dealers) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type HttpHandler struct

+ Handler func(w http.ResponseWriter, r *http.Request)

+ Middleware Dealers

+ Pattern string

+ func GETHandler(p string, h func(w http.ResponseWriter, r *http.Request), m ...Dealer) *HttpHandler

+ func NewHandler(p string, h func(w http.ResponseWriter, r *http.Request), m ...Dealer) *HttpHandler

+ func POSTHandler(p string, h func(w http.ResponseWriter, r *http.Request), m ...Dealer) *HttpHandler

+ type Queue struct

+ func NewQueue(size int) *Queue

+ func (q *Queue) Start(num int, deal func(interface{}))

+ func (q *Queue) Stop()

+ func (q *Queue) Submit(item interface{})

+ func (q *Queue) Submit2(item interface{})

+ type Resp struct

+ Code int

+ Data interface{}

+ Result string

+ func NewResp(code int, result string, data interface{}) *Resp

+ func RespErr(err error) *Resp

+ func RespMsg(code int, result string) *Resp

+ func RespOK(data interface{}) *Resp

+ type Serial struct

+ func NewSerial(reset int) *Serial

+ func (s *Serial) Get() int

+ func (s *Serial) Reset(c int)

+ func (s *Serial) Start()

+ type Server struct

+ func NewConfigServer(c *ServerConfig) *Server

+ func NewServer() *Server

+ func (s *Server) Addr(addr string) *Server

+ func (s *Server) Exit()

+ func (s *Server) FileServer(pattern, dir string) *Server

+ func (s *Server) Handlers(list []*HttpHandler) *Server

+ func (s *Server) OnInit(init func()) *Server

+ func (s *Server) OnStop(stop func()) *Server

+ func (s *Server) Run()

+ type ServerConfig struct

+ Addr string

+ IdleTimeout time.Duration

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ type StmtDB struct

+ func NewStmtDB(db *sqlx.DB) *StmtDB

+ func (s *StmtDB) CloseDB()

+ func (s *StmtDB) DeferLock() func()

+ func (s *StmtDB) Lock()

+ func (s *StmtDB) NStmt(sqlStr string) (stmt *sqlx.NamedStmt, err error)

+ func (s *StmtDB) Stmt(sqlStr string) (stmt *sqlx.Stmt, err error)

+ func (s *StmtDB) Unlock()

+ type TStamp int64

+ func NewStampTime(te time.Time) TStamp

+ func NewStrStamp(ts string) TStamp

+ func NewTimeStamp(ts int64) TStamp

+ func (t *TStamp) UnmarshalJSON(b []byte) error

+ func (t TStamp) Format(layout string) string

+ func (t TStamp) GoString() string

+ func (t TStamp) Int64() int64

+ func (t TStamp) MarshalJSON() (buf []byte, err error)

+ func (t TStamp) String() string

+ func (t TStamp) Time() time.Time

+ type XmlMap map[string]string

+ func (m *XmlMap) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error

+ func (m XmlMap) MarshalXML(e *xml.Encoder, start xml.StartElement) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL