Allow the cache to be purged. (#3)

Author: scudette

api.go

@@ -20,7 +20,7 @@ type DiskLRU struct {
 	encoder Encoder
 
 	set_stm, get_stm, get_update_expiry_stm,
-	peek_stm, delete_stm,
+	peek_stm, delete_stm, purge_stm,
 	clear_stm, cleanup_expires_stm,
 	cleanup_lru_stm *sql.Stmt
 
@@ -43,6 +43,10 @@ func (self *DiskLRU) houseKeeping(ctx context.Context) {
 		return
 	}
 
+	if self.opts.HouseKeepPeriodSec == 0 {
+		self.opts.HouseKeepPeriodSec = 60
+	}
+
 	for {
 		select {
 		case <-ctx.Done():
@@ -130,6 +134,11 @@ func (self *DiskLRU) Get(key string) (interface{}, error) {
 	return self.encoder.Decode(buf)
 }
 
+func (self *DiskLRU) Purge() error {
+	_, err := self.purge_stm.Exec()
+	return err
+}
+
 type CacheItem struct {
 	Key   string
 	Value interface{}
@@ -251,6 +260,12 @@ func NewDiskLRU(
 		return nil, err
 	}
 
+	self.purge_stm, err = handle.Prepare(
+		`DELETE FROM cache`)
+	if err != nil {
+		return nil, err
+	}
+
 	self.clear_stm, err = handle.Prepare(`DELETE FROM cache`)
 	if err != nil {
 		return nil, err