yu

package module

Go to main page

Versions in this module

v0

v0.2.1

Jan 16, 2023

Changes in this version

+ func Cost(msg string) func()

+ func LoadOrSaveYaml(name string, data any, def func() any) (err error)

+ func LoadYaml(name string, data any) error

+ func SaveYaml(name string, data any) error

+ type IQueue interface

+ Start func()

+ Stop func()

+ Submit func(args any, sync bool)

type QueueManager

+ func (qm *QueueManager) StartQueues()

v0.2.0

Aug 1, 2022

Changes in this version

type GormDB

+ func (gdb *GormDB) CreateTable(dst any) (err error)

v0.1.9

Jul 30, 2022

Changes in this version

+ func JsonToProto(d string, m proto.Message)

+ func ProtoToJson(m proto.Message) string

+ type EchoServer struct

+ Echo *echo.Echo

+ func NewEchoServer(name, addr string) *EchoServer

+ func (s *EchoServer) BasicAuth(name, pass string) echo.MiddlewareFunc

+ func (s *EchoServer) Group(path string, m ...echo.MiddlewareFunc) *echo.Group

+ func (s *EchoServer) Health()

+ func (s *EchoServer) Info() string

+ func (s *EchoServer) JSON(c echo.Context, data any) error

+ func (s *EchoServer) JsonErr(c echo.Context, err error) error

+ func (s *EchoServer) JsonMsg(c echo.Context, msg string) error

+ func (s *EchoServer) JsonOK(c echo.Context, data any) error

+ func (s *EchoServer) NoCache() echo.MiddlewareFunc

+ func (s *EchoServer) OnStart() bool

+ func (s *EchoServer) OnStop()

+ func (s *EchoServer) PromeMetrics() echo.MiddlewareFunc

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

+ func (s *EchoServer) PromethousHandler(c echo.Context) error

type GinServer

+ func (s *GinServer) BasicAuth(username, password string) gin.HandlerFunc

+ func (s *GinServer) CORS(acceptedOrigin, AcceptedMethods, AcceptedHeaders, MaxAge string) gin.HandlerFunc

+ func (s *GinServer) GzipJSON(c *gin.Context, data any)

+ func (s *GinServer) JSON(c *gin.Context, data any)

+ func (s *GinServer) JsonErr(c *gin.Context, err error)

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

+ func (s *GinServer) JsonOK(c *gin.Context, data any)

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

+ func (s *GinServer) NoCache() gin.HandlerFunc

+ func (s *GinServer) PromeMetrics() gin.HandlerFunc

+ func (s *GinServer) PromethousHandler() gin.HandlerFunc

+ type IApp interface

+ Name func() string

+ OnStart func() bool

+ OnStop func()

+ Servers func() []IServer

+ type IServer interface

+ Info func() string

+ OnStart func() bool

+ OnStop func()

v0.1.8

Apr 8, 2022

v0.1.7

Jan 10, 2022

v0.1.6

Jan 4, 2022

v0.1.5

Nov 29, 2021

Changes in this version

type Resp

+ Msg string

v0.1.4

Oct 31, 2021

Changes in this version

type GormDB

+ func (db *GormDB) BatchInsertTb(tb string, value interface{}, batchSize int, conds ...clause.Expression) error

+ func (db *GormDB) InsertTb(tb string, value interface{}, conds ...clause.Expression) error

v0.1.3

Oct 20, 2021

Changes in this version

type MqttSubPub

+ func (m *MqttSubPub) Unsub(topic string) (err error)

v0.1.2

Sep 10, 2021

v0.1.1

Sep 10, 2021

v0.1.0

Sep 3, 2021

v0.0.9

Aug 5, 2021

Changes in this version

type MqttSubPub

+ func (m *MqttSubPub) Sub(topic string)

v0.0.8

Jul 26, 2021

Changes in this version

+ type GrpcConn struct

+ type GrpcConnManager struct

+ func NewGrpcConnManager() *GrpcConnManager

+ func (gm *GrpcConnManager) AddConn(name, addr string, connecter GrpcConnecter, opts ...grpc.DialOption)

+ func (gm *GrpcConnManager) CloseConns()

+ func (gm *GrpcConnManager) Reconnect(name string)

+ type GrpcConnecter interface

+ OnConnected func(*grpc.ClientConn)

v0.0.7

May 24, 2021

Changes in this version

+ func IsGrpcConnReady(c *grpc.ClientConn) bool

+ func WithTrace() grpc.DialOption

v0.0.6

May 14, 2021

v0.0.5

Apr 29, 2021

Changes in this version

type App

+ func NewApp(name string, start func() bool, stop func(), svrs ...ServerInterface) *App

+ type MqttSubPub struct

+ func NewMqttSubPub(id, addr, user, pass string, topics ...string) *MqttSubPub

+ func (m *MqttSubPub) Info() string

+ func (m *MqttSubPub) OnStart() bool

+ func (m *MqttSubPub) OnStop()

+ func (m *MqttSubPub) Pub(topic string, payload []byte)

+ func (m *MqttSubPub) SetSubDeal(deal func(mqtt.Message))

v0.0.4

Apr 28, 2021

v0.0.3

Apr 27, 2021

v0.0.2

Apr 27, 2021

Changes in this version

+ func PromeMetrics() gin.HandlerFunc

+ func PromeTrace(label string) func()

+ func PromeUnaryInterceptor() grpc.ServerOption

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

type Queue

+ func NewQueueWithTimeout(size, num int, deal, dealOut dealFunc, out time.Duration) *Queue

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

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

+ type QueueManager struct

+ func NewQueueManager() *QueueManager

+ func (qm *QueueManager) AddQueue(q *Queue)

+ func (qm *QueueManager) GetQueue(i int) *Queue

+ func (qm *QueueManager) PushQueue(i int, args interface{})

+ func (qm *QueueManager) StartQueue()

+ func (qm *QueueManager) StopQueue()

v0.0.1

Mar 24, 2021

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 DurationsSummary *prometheus.SummaryVec

+ var LatencyHistogram *prometheus.HistogramVec

+ var RequestCounter *prometheus.CounterVec

+ func BasicAuth(username, password string) gin.HandlerFunc

+ func CORS(acceptedOrigin, AcceptedMethods, AcceptedHeaders, MaxAge string) gin.HandlerFunc

+ func CreateFolder(path string) error

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

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

+ func GetRealIP(req *http.Request) string

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

+ func GzipJSON(c *gin.Context, data interface{})

+ func HeadSeparator(path string) string

+ func InitPrometheus(name string)

+ func JSON(c *gin.Context, data interface{})

+ func JsonErr(c *gin.Context, err error)

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

+ func JsonOK(c *gin.Context, data interface{})

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

+ 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 LogErr(err error, msg string)

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

+ func MD5(src string) []byte

+ 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 NoCache() gin.HandlerFunc

+ func PromMetrics() gin.HandlerFunc

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

+ func PromethousHandler() gin.HandlerFunc

+ func RandomString(n int) string

+ func Run(app AppInterface)

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

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

+ func StrTime(timestamp int64, timeLayout string) string

+ func TailSeparator(path string) string

+ func ToJsonStr(data interface{}) string

+ func Trace(msg string) func()

+ func TraceUnaryInt(ctx context.Context, method string, req, reply interface{}, ...) error

+ func UUID() string

+ func UnixTime(timeStr, layout string) int64

+ 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

+ PreStmt bool

+ SkipTran bool

+ 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()

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

+ type GormDB struct

+ func MustOpen(dial gorm.Dialector, d DSN) *GormDB

+ func MustOpenMySQL(d DSN) *GormDB

+ func MustOpenPostgres(d DSN) *GormDB

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

+ 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 (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 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{}

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

+ func RespErr(err error) *Resp

+ func RespMsg(code int, msg 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 ServerInterface interface

+ Info func() string

+ OnStart func() bool

+ OnStop func()

+ 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