MaxOpenConns: cluster.PostgreSQL.ConnectionPool,
QueueSize: cluster.API.WebsocketServerEventQueue,
Logger: ctxlog.FromContext(ctx),
+ Reg: reg,
}
done := make(chan struct{})
go func() {
eventSource: eventSource,
newPermChecker: func() permChecker { return newPermChecker(*client) },
done: done,
+ reg: reg,
}
return rtr
}