···

       
59
       
 
       
	cs.firehoseLk.Lock()

     

       
60
       
 
       
	defer cs.firehoseLk.Unlock()

     

       
61
       
 
       


     

       
62
       
-
       
	if err := cs.store.Where(firehoseCursor{Key: "firehose"}).Update("val", cs.firehoseSeq).Error; err != nil {

     

       
63
       
 
       
		return fmt.Errorf("error persisting firehose seq: %w", err)

     

       
64
       
 
       
	}

     

       
65
       
 
       
	return nil

     

···

       
59
       
 
       
	cs.firehoseLk.Lock()

     

       
60
       
 
       
	defer cs.firehoseLk.Unlock()

     

       
61
       
 
       


     

       
62
       
+
       
	if err := cs.store.Model(&firehoseCursor{}).Where(firehoseCursor{Key: "firehose"}).Update("val", cs.firehoseSeq).Error; err != nil {

     

       
63
       
 
       
		return fmt.Errorf("error persisting firehose seq: %w", err)

     

       
64
       
 
       
	}

     

       
65
       
 
       
	return nil

     

···

       
22
       
 
       
}

     

       
23
       
 
       


     

       
24
       
 
       
func (cs *CursorService) SetHostCursor(host string, cursor string) error {

     

       
25
       
-
       
	if err := cs.store.Where(hostCursor{

     

       
26
       
 
       
		Host: host,

     

       
27
       
 
       
	}).Update("cursor", cursor).Error; err != nil {

     

       
28
       
 
       
		return err

     

···

       
22
       
 
       
}

     

       
23
       
 
       


     

       
24
       
 
       
func (cs *CursorService) SetHostCursor(host string, cursor string) error {

     

       
25
       
+
       
	if err := cs.store.Model(&hostCursor{}).Where(hostCursor{

     

       
26
       
 
       
		Host: host,

     

       
27
       
 
       
	}).Update("cursor", cursor).Error; err != nil {

     

       
28
       
 
       
		return err