commit
cc8779cfb2
2
go.mod
2
go.mod
|
@ -4,7 +4,7 @@ go 1.17
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/Selly-Modules/natsio v0.0.0-20220321031929-3fe4271f1bbc
|
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
|
github.com/robfig/cron/v3 v3.0.1
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
2
go.sum
2
go.sum
|
@ -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.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 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.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 h1:6MnRN8NT7+YBpUIWxHtefFZOKTAPgGjpQSxqLNn0+qY=
|
||||||
github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
|
github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
|
||||||
github.com/cespare/xxhash/v2 v2.1.2 h1:YRXhKfTDauu4ajMg1TPgFO5jnlC2HCbmLXMcTG5cbYE=
|
github.com/cespare/xxhash/v2 v2.1.2 h1:YRXhKfTDauu4ajMg1TPgFO5jnlC2HCbmLXMcTG5cbYE=
|
||||||
|
|
|
@ -37,12 +37,10 @@ func handleSyncDataToServiceAppier(pattern string, typeData string) {
|
||||||
for {
|
for {
|
||||||
keys, values := redisdb.GetWithPrefixPattern(pattern)
|
keys, values := redisdb.GetWithPrefixPattern(pattern)
|
||||||
if len(keys) == 0 {
|
if len(keys) == 0 {
|
||||||
fmt.Println("No keys data")
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
if len(values) == 0 {
|
if len(values) == 0 {
|
||||||
fmt.Println("No values DATA")
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -57,7 +55,6 @@ func handleSyncDataToServiceAppier(pattern string, typeData string) {
|
||||||
|
|
||||||
// processSyncToServiceAppier ...
|
// processSyncToServiceAppier ...
|
||||||
func processSyncToServiceAppier(typeData string, values []string) {
|
func processSyncToServiceAppier(typeData string, values []string) {
|
||||||
fmt.Println("Sends")
|
|
||||||
for {
|
for {
|
||||||
if len(values) <= 20 {
|
if len(values) <= 20 {
|
||||||
syncDataByList(typeData, values)
|
syncDataByList(typeData, values)
|
||||||
|
|
Loading…
Reference in New Issue