forked from 0x2E/fusion
Merge pull request #62 from mtlynch/creates-insert
Rename Item.Creates to Item.Insert
This commit is contained in:
commit
09a409a5de
3 changed files with 3 additions and 3 deletions
|
@ -59,7 +59,7 @@ func (i Item) Get(id uint) (*model.Item, error) {
|
|||
return &res, err
|
||||
}
|
||||
|
||||
func (i Item) Creates(items []*model.Item) error {
|
||||
func (i Item) Insert(items []*model.Item) error {
|
||||
// limit batchSize to fix 'too many SQL variable' error
|
||||
now := time.Now()
|
||||
for _, i := range items {
|
||||
|
|
|
@ -66,7 +66,7 @@ func (p *Puller) do(ctx context.Context, f *model.Feed, force bool) error {
|
|||
FeedID: f.ID,
|
||||
})
|
||||
}
|
||||
if err := p.itemRepo.Creates(data); err != nil {
|
||||
if err := p.itemRepo.Insert(data); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
|
|
@ -24,7 +24,7 @@ type FeedRepo interface {
|
|||
}
|
||||
|
||||
type ItemRepo interface {
|
||||
Creates(items []*model.Item) error
|
||||
Insert(items []*model.Item) error
|
||||
}
|
||||
|
||||
type Puller struct {
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue