go-pkg/asynqmon
2
0
Fork 0
mirror of https://github.com/hibiken/asynqmon.git synced 2025-10-03 18:52:01 +08:00
Code Issues Projects Releases Wiki Activity

rename PayloadStringer => BytesStringer

Browse Source
This commit is contained in:
ajatprabha
2021-09-30 23:39:41 +05:30
parent c8189f3bf6
commit 9d9cc731de
2 changed files with 21 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
router.go
View File

@@ -8,18 +8,18 @@ import (
)
type RouterOptions struct {
RedisClient redis.UniversalClient
Inspector *asynq.Inspector
Middlewares []mux.MiddlewareFunc
PayloadStringer PayloadStringer
RedisClient redis.UniversalClient
Inspector *asynq.Inspector
Middlewares []mux.MiddlewareFunc
BytesStringer BytesStringer
}
func NewRouter(opts RouterOptions) *mux.Router {
router := mux.NewRouter()
inspector := opts.Inspector
t := &transformer{ps: defaultPayloadStringer}
if opts.PayloadStringer != nil {
t = &transformer{ps: opts.PayloadStringer}
t := &transformer{bs: defaultBytesStringer}
if opts.BytesStringer != nil {
t = &transformer{bs: opts.BytesStringer}
}
for _, mf := range opts.Middlewares {