+// Begin transaction identified by k
+func (c *Conn) Begin(k string) (err error) {
+ fn := filepath.Join(c.path, ".journal", k)
+ f, err := os.OpenFile(fn, os.O_CREATE|os.O_TRUNC|os.O_WRONLY|os.O_SYNC, 0666)
+ if err != nil {
+ return
+ }
+ err = f.Close()
+ return
+}
+
+// End transaction identified by k
+func (c *Conn) End(k string) (err error) {
+ fn := filepath.Join(c.path, ".journal", k)
+ err = os.Remove(fn)
+ return
+}
+