new db package with actor

db/actor.go

@@ -0,0 +1,24 @@
+package db
+
+import (
+	"context"
+	"database/sql"
+)
+
+type Func func(db *sql.DB)
+
+type Actor struct {
+	DB         *sql.DB
+	ActionChan chan Func
+}
+
+func (a *Actor) Run(ctx context.Context) error {
+	for {
+		select {
+		case f := <-a.ActionChan:
+			f(a.DB)
+		case <-ctx.Done():
+			return ctx.Err()
+		}
+	}
+}

db/doc.go

@@ -0,0 +1,14 @@
+package db
+/*
+
+Example usage: 
+	
+	ctx, _ := context.WithCancel(context.Background())
+	dba = &db.Actor{
+		DB:         s.db,
+		ActionChan: make(chan db.Func),
+	}
+	
+	go dba.Run(ctx)
+
+*/