benjamyn/any-sync
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

descrease net.pool ttl

Browse Source
This commit is contained in:
Sergey Cherepanov 2023-06-23 18:27:59 +02:00
parent 291b8daf5f
commit f0ffc9b7bf
No known key found for this signature in database
GPG Key ID: 87F8EDE8FBDF637C
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
net/pool/poolservice.go
View File

@ -49,8 +49,8 @@ func (p *poolService) Init(a *app.App) (err error) {
return p.dialer.Dial(ctx, id) return p.dialer.Dial(ctx, id)
}, },
ocache.WithLogger(log.Sugar()), ocache.WithLogger(log.Sugar()),
ocache.WithGCPeriod(time.Minute), ocache.WithGCPeriod(time.Minute/2),
ocache.WithTTL(time.Minute*5), ocache.WithTTL(time.Minute),
ocache.WithPrometheus(p.metricReg, "netpool", "outgoing"), ocache.WithPrometheus(p.metricReg, "netpool", "outgoing"),
) )
p.pool.incoming = ocache.New( p.pool.incoming = ocache.New(
@ -58,8 +58,8 @@ func (p *poolService) Init(a *app.App) (err error) {
return nil, ocache.ErrNotExists return nil, ocache.ErrNotExists
}, },
ocache.WithLogger(log.Sugar()), ocache.WithLogger(log.Sugar()),
ocache.WithGCPeriod(time.Minute), ocache.WithGCPeriod(time.Minute/2),
ocache.WithTTL(time.Minute*5), ocache.WithTTL(time.Minute),
ocache.WithPrometheus(p.metricReg, "netpool", "incoming"), ocache.WithPrometheus(p.metricReg, "netpool", "incoming"),
) )
return nil return nil