[#1869] shard: Embed gcCfg
as raw struct
Signed-off-by: Evgenii Stratonikov <evgeniy@morphbits.ru>
This commit is contained in:
parent
60e9de8d63
commit
f769fc83fc
3 changed files with 4 additions and 4 deletions
|
@ -135,7 +135,7 @@ func (s *Shard) Init() error {
|
||||||
s.updateObjectCounter()
|
s.updateObjectCounter()
|
||||||
|
|
||||||
s.gc = &gc{
|
s.gc = &gc{
|
||||||
gcCfg: s.gcCfg,
|
gcCfg: &s.gcCfg,
|
||||||
remover: s.removeGarbage,
|
remover: s.removeGarbage,
|
||||||
stopChannel: make(chan struct{}),
|
stopChannel: make(chan struct{}),
|
||||||
eventChan: make(chan Event),
|
eventChan: make(chan Event),
|
||||||
|
|
|
@ -82,8 +82,8 @@ type gcCfg struct {
|
||||||
workerPoolInit func(int) util.WorkerPool
|
workerPoolInit func(int) util.WorkerPool
|
||||||
}
|
}
|
||||||
|
|
||||||
func defaultGCCfg() *gcCfg {
|
func defaultGCCfg() gcCfg {
|
||||||
return &gcCfg{
|
return gcCfg{
|
||||||
removerInterval: 10 * time.Second,
|
removerInterval: 10 * time.Second,
|
||||||
log: &logger.Logger{Logger: zap.L()},
|
log: &logger.Logger{Logger: zap.L()},
|
||||||
workerPoolInit: func(int) util.WorkerPool {
|
workerPoolInit: func(int) util.WorkerPool {
|
||||||
|
|
|
@ -85,7 +85,7 @@ type cfg struct {
|
||||||
|
|
||||||
log *logger.Logger
|
log *logger.Logger
|
||||||
|
|
||||||
gcCfg *gcCfg
|
gcCfg gcCfg
|
||||||
|
|
||||||
expiredTombstonesCallback ExpiredTombstonesCallback
|
expiredTombstonesCallback ExpiredTombstonesCallback
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue