func (q *queue) Add(wb *leveldb.Batch, urlStr string, depth int, when time.Time) error {
	t := uint64(when.UnixNano())
	qkey := bytes.Join([][]byte{queuePrefix, encodeUint64(t), encodeUint64(uint64(rand.Int63()))}, queueKeySep)
	return q.db.PutObjBatch(wb, qkey, &queuePair{URL: urlStr, Depth: depth})
}
// Add an item to the pending work queue.
Add an item to the pending work queue.
// Add an item to the pending work queue .
func (q *queue) Add(wb *leveldb.Batch, urlStr string, depth int, when time.Time) error {
	t := uint64(when.UnixNano())
	qkey := bytes.Join([][]byte{queuePrefix, encodeUint64(t), encodeUint64(uint64(rand.Int63()))}, queueKeySep)
	return q.db.PutObjBatch(wb, qkey, &queuePair{URL: urlStr, Depth: depth})
}
func ( q * queue ) Add ( wb * leveldb . Batch , urlStr string , depth int , when time . Time ) error { t := uint64 ( when . UnixNano ( ) ) qkey := bytes . Join ( [ ] [ ] byte { queuePrefix , encodeUint64 ( t ) , encodeUint64 ( uint64 ( rand . Int63 ( ) ) ) } , queueKeySep ) return q . db . PutObjBatch ( wb , qkey , & queuePair { URL : urlStr , Depth : depth } ) }
Add an item to the pending work queue.
Add an item to the pending work queue .