code: func (ss *SQLSubStore) AddSeqPending(subid, seqno uint64) error {
  	var err error
  	ss.Lock()
  	if !ss.closed {
  		if ss.cache != nil {
  			if isFull := ss.addSeq(subid, seqno); isFull {
  				err = ss.flush()
  			}
  		} else {
  			ls := ss.subLastSent[subid]
  			if seqno > ls {
  				ss.subLastSent[subid] = seqno
  			}
  			ss.curRow++
  			_, err = ss.sqlStore.preparedStmts[sqlSubAddPending].Exec(subid, ss.curRow, seqno)
  			if err != nil {
  				err = sqlStmtError(sqlSubAddPending, err)
  			}
  		}
  	}
  	ss.Unlock()
  	return err
  }
docs: // AddSeqPending implements the SubStore interface