connections: make use of keepalive options

This commit is contained in:
Roman Khimov 2021-04-29 22:58:54 +03:00 committed by Roman Khimov
parent afbb9d51f1
commit f99f9e88a7
2 changed files with 16 additions and 1 deletions

3
app.go
View file

@ -114,6 +114,9 @@ func newApp(ctx context.Context, opt ...Option) App {
NodeRequestTimeout: a.cfg.GetDuration(cfgReqTimeout),
ClientRebalanceInterval: a.cfg.GetDuration(cfgRebalance),
SessionExpirationEpoch: math.MaxUint64,
KeepaliveTime: a.cfg.GetDuration(cfgKeepaliveTime),
KeepaliveTimeout: a.cfg.GetDuration(cfgKeepaliveTimeout),
KeepalivePermitWoStream: a.cfg.GetBool(cfgKeepalivePermitWithoutStream),
}
pool, err := pb.Build(ctx, opts)
if err != nil {