diff --git a/pkg/breaksync/sync.go b/pkg/breaksync/sync.go index 89bff226..61c2236a 100644 --- a/pkg/breaksync/sync.go +++ b/pkg/breaksync/sync.go @@ -32,7 +32,7 @@ func (s *Synchronization) AddSources(sources ...SyncSource) *Synchronization { return s } -func (s *Synchronization) Run(business func(uint64, []any) error) (err error) { +func (s *Synchronization) Run(business func(uint, []any) error) (err error) { if err = s.read(); err != nil { return } @@ -98,8 +98,8 @@ func (s *Synchronization) computeRuptures() { } } -func (s *Synchronization) computeItems(items []any) uint64 { - var itemsFlags uint64 +func (s *Synchronization) computeItems(items []any) uint { + var itemsFlags uint for i, source := range s.sources { if !source.IsSynchronized() { diff --git a/pkg/breaksync/sync_test.go b/pkg/breaksync/sync_test.go index 34a2878f..00268f9b 100644 --- a/pkg/breaksync/sync_test.go +++ b/pkg/breaksync/sync_test.go @@ -139,7 +139,7 @@ func TestRun(t *testing.T) { t.Parallel() var result int - err := testCase.instance.Run(func(synchronization uint64, items []any) error { + err := testCase.instance.Run(func(synchronization uint, items []any) error { if synchronization != 0 { return nil } diff --git a/pkg/db/db.go b/pkg/db/db.go index 143503f9..832663d6 100644 --- a/pkg/db/db.go +++ b/pkg/db/db.go @@ -237,7 +237,7 @@ func (s Service) Get(ctx context.Context, scanner func(pgx.Row) error, query str return scanner(s.QueryRow(ctx, query, args...)) } -func (s Service) Create(ctx context.Context, query string, args ...any) (id uint64, err error) { +func (s Service) Create(ctx context.Context, query string, args ...any) (id uint, err error) { tx := readTx(ctx) if tx == nil { return 0, ErrNoTransaction @@ -246,7 +246,7 @@ func (s Service) Create(ctx context.Context, query string, args ...any) (id uint ctx, cancel := context.WithTimeout(ctx, SQLTimeout) defer cancel() - var newID uint64 + var newID uint return newID, tx.QueryRow(ctx, query, args...).Scan(&newID) }