Make getPruner() private
This commit is contained in:
@@ -29,7 +29,7 @@ type SnapJob struct {
|
|||||||
|
|
||||||
func (j *SnapJob) Name() string { return j.name }
|
func (j *SnapJob) Name() string { return j.name }
|
||||||
|
|
||||||
func (j *SnapJob) GetPruner(ctx context.Context, sender *endpoint.Sender) (*pruner.Pruner) {
|
func (j *SnapJob) getPruner(ctx context.Context, sender *endpoint.Sender) (*pruner.Pruner) {
|
||||||
p := j.prunerFactory.BuildSinglePruner(ctx,sender,sender)
|
p := j.prunerFactory.BuildSinglePruner(ctx,sender,sender)
|
||||||
return p
|
return p
|
||||||
}
|
}
|
||||||
@@ -121,7 +121,7 @@ func (j *SnapJob) doPrune(ctx context.Context) {
|
|||||||
log := GetLogger(ctx)
|
log := GetLogger(ctx)
|
||||||
ctx = logging.WithSubsystemLoggers(ctx, log)
|
ctx = logging.WithSubsystemLoggers(ctx, log)
|
||||||
sender := endpoint.NewSender(j.FSFilter())
|
sender := endpoint.NewSender(j.FSFilter())
|
||||||
j.pruner = j.GetPruner(ctx, sender)
|
j.pruner = j.getPruner(ctx, sender)
|
||||||
log.Info("start pruning")
|
log.Info("start pruning")
|
||||||
j.pruner.Prune()
|
j.pruner.Prune()
|
||||||
log.Info("finished pruning")
|
log.Info("finished pruning")
|
||||||
|
|||||||
Reference in New Issue
Block a user