fix(auth): spooler locks correct database (#1134)

This commit is contained in:
Silvan 2020-12-24 13:01:23 +01:00 committed by GitHub
parent a6c4702b8e
commit 28c8274eab
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 8 deletions

View File

@ -77,12 +77,6 @@ func Register(configs Configs, bulkLimit, errorCount uint64, view *view.View, es
}
}
func subscribe(es eventstore.Eventstore, handlers []query.Handler) {
for _, handler := range handlers {
es.Subscribe(handler.AggregateTypes()...)
}
}
func (configs Configs) cycleDuration(viewModel string) time.Duration {
c, ok := configs[viewModel]
if !ok {

View File

@ -2,12 +2,13 @@ package spooler
import (
"database/sql"
es_locker "github.com/caos/zitadel/internal/eventstore/locker"
"time"
es_locker "github.com/caos/zitadel/internal/eventstore/locker"
)
const (
lockTable = "management.locks"
lockTable = "auth.locks"
)
type locker struct {