Selly-Modules
/
appier
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

remove-logs

This commit is contained in:
Minh Nguyen 2022-03-25 16:07:05 +07:00
parent f3b9bb24f2
commit 03a4279d14
3 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
go.mod
View File

@ -4,7 +4,7 @@ go 1.17
require (
github.com/Selly-Modules/natsio v0.0.0-20220321031929-3fe4271f1bbc
github.com/Selly-Modules/redisdb v1.0.1-0.20220325075428-59ae8ffc4812
github.com/Selly-Modules/redisdb v1.0.1-0.20220325090539-b1135a975fd6
github.com/robfig/cron/v3 v3.0.1
)

2
go.sum
View File

@ -8,6 +8,8 @@ github.com/Selly-Modules/redisdb v1.0.1-0.20220325073544-1ab40b99b8b9 h1:TTI8SL4
github.com/Selly-Modules/redisdb v1.0.1-0.20220325073544-1ab40b99b8b9/go.mod h1:J2GWyoHN5b8RfZXUJmGnEFw7Z4UIogUM4Ry76DstktQ=
github.com/Selly-Modules/redisdb v1.0.1-0.20220325075428-59ae8ffc4812 h1:Y2/O7z/nkcapWGtqVrJtK3q+aDCwp/vsPchpWTQRdY0=
github.com/Selly-Modules/redisdb v1.0.1-0.20220325075428-59ae8ffc4812/go.mod h1:J2GWyoHN5b8RfZXUJmGnEFw7Z4UIogUM4Ry76DstktQ=
github.com/Selly-Modules/redisdb v1.0.1-0.20220325090539-b1135a975fd6 h1:WotogiPSQRqZShd9uapfLDZcGL2VRCNuvbi3sun1C70=
github.com/Selly-Modules/redisdb v1.0.1-0.20220325090539-b1135a975fd6/go.mod h1:J2GWyoHN5b8RfZXUJmGnEFw7Z4UIogUM4Ry76DstktQ=
github.com/cespare/xxhash/v2 v2.1.1 h1:6MnRN8NT7+YBpUIWxHtefFZOKTAPgGjpQSxqLNn0+qY=
github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
github.com/cespare/xxhash/v2 v2.1.2 h1:YRXhKfTDauu4ajMg1TPgFO5jnlC2HCbmLXMcTG5cbYE=

3
sync_to_service.go
View File

@ -37,12 +37,10 @@ func handleSyncDataToServiceAppier(pattern string, typeData string) {
for {
keys, values := redisdb.GetWithPrefixPattern(pattern)
if len(keys) == 0 {
fmt.Println("No keys data")
return
}
if len(values) == 0 {
fmt.Println("No values DATA")
return
}
@ -57,7 +55,6 @@ func handleSyncDataToServiceAppier(pattern string, typeData string) {
// processSyncToServiceAppier ...
func processSyncToServiceAppier(typeData string, values []string) {
fmt.Println("Sends")
for {
if len(values) <= 20 {
syncDataByList(typeData, values)