tiglog/golib
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: tiglog:74c9bf36fd87a0a271bbb93204c0fc485d293cf7
Branches Tags
tiglog:main
..
compare: tiglog:47f14f94ab700b90996154703bfdd3c61d6d7523
Branches Tags
tiglog:main

No commits in common. "74c9bf36fd87a0a271bbb93204c0fc485d293cf7" and "47f14f94ab700b90996154703bfdd3c61d6d7523" have entirely different histories.
74c9bf36fd ... 47f14f94ab

4 changed files with 22 additions and 60 deletions
Show Stats Expand all files Collapse all files

8
gqueue/queue.go
View File

@ -29,7 +29,7 @@ func Init(addr, username, password string, database int) {
var cli *asynq.Client var cli *asynq.Client
func GetClient() *asynq.Client { func Client() *asynq.Client {
onceCli.Do(func() { onceCli.Do(func() {
cli = asynq.NewClient(redisOpt) cli = asynq.NewClient(redisOpt)
}) })
@ -38,7 +38,7 @@ func GetClient() *asynq.Client {
var svc *asynq.Server var svc *asynq.Server
func GetServerWithArgs(concurrency int, fn asynq.ErrorHandlerFunc) *asynq.Server { func ServerWithArgs(concurrency int, fn asynq.ErrorHandlerFunc) *asynq.Server {
onceSvc.Do(func() { onceSvc.Do(func() {
svc = asynq.NewServer( svc = asynq.NewServer(
redisOpt, redisOpt,
@ -51,7 +51,7 @@ func GetServerWithArgs(concurrency int, fn asynq.ErrorHandlerFunc) *asynq.Server
return svc return svc
} }
func GetServerWithConfig(cfg asynq.Config) *asynq.Server { func ServerWithConfig(cfg asynq.Config) *asynq.Server {
onceSvc.Do(func() { onceSvc.Do(func() {
svc = asynq.NewServer( svc = asynq.NewServer(
redisOpt, redisOpt,
@ -61,7 +61,7 @@ func GetServerWithConfig(cfg asynq.Config) *asynq.Server {
return svc return svc
} }
func GetServer() *asynq.Server { func Server() *asynq.Server {
onceSvc.Do(func() { onceSvc.Do(func() {
svc = asynq.NewServer( svc = asynq.NewServer(
redisOpt, redisOpt,

30
gqueue/wrapper.go
View File

@ -1,30 +0,0 @@
//
// wrapper.go
// Copyright (C) 2023 tiglog <me@tiglog.com>
//
// Distributed under terms of the MIT license.
//
package gqueue
import "github.com/hibiken/asynq"
type Task = asynq.Task
type Client = asynq.Client
type Server = asynq.Server
var GetRetryCount = asynq.GetRetryCount
var GetTaskID = asynq.GetTaskID
var GetQueueName = asynq.GetQueueName
var GetMaxRetry = asynq.GetMaxRetry
var ProcessIn = asynq.ProcessIn
var ProcessAt = asynq.ProcessAt
var MaxRetry = asynq.MaxRetry
var Timeout = asynq.Timeout
var SkipRetry = asynq.SkipRetry
var NewTask = asynq.NewTask
var NewServeMux = asynq.NewServeMux
var NewClient = asynq.NewClient

18
gweb/gin.go
View File

@ -16,8 +16,26 @@ import (
"os/signal" "os/signal"
"syscall" "syscall"
"time" "time"
"github.com/gin-gonic/gin"
) )
type Engine = gin.Engine
type Context = gin.Context
type H = gin.H
const (
ReleaseMode = gin.ReleaseMode
DebugMode = gin.DebugMode
TestMode = gin.TestMode
)
var New = gin.New
var SetMode = gin.SetMode
var Mode = gin.Mode
func RunWeb(app *Engine, addr string) { func RunWeb(app *Engine, addr string) {
if addr[0] == ':' { if addr[0] == ':' {
addr = "127.0.0.1" + addr addr = "127.0.0.1" + addr

26
gweb/wrapper.go
View File

@ -1,26 +0,0 @@
//
// wrapper.go
// Copyright (C) 2023 tiglog <me@tiglog.com>
//
// Distributed under terms of the MIT license.
//
package gweb
import "github.com/gin-gonic/gin"
type Engine = gin.Engine
type Context = gin.Context
type H = gin.H
const (
ReleaseMode = gin.ReleaseMode
DebugMode = gin.DebugMode
TestMode = gin.TestMode
)
var New = gin.New
var SetMode = gin.SetMode
var Mode = gin.Mode