Merge pull request #49 from pior/manager

Simplify the Manager API and code

Author: pior

README.md

@@ -41,7 +41,7 @@ func run(ctx context.Context) error {
 - [Process start and shutdown](#process-start-and-shutdown)
 - [Restart](#restart)
 - [HTTP Server](#http-server)
-- [Dependency Manager](#dependency-manager)
+- [Manager](#manager)
 
 ### Process start and shutdown
 
@@ -96,38 +96,36 @@ func main() {
 }
 ```
 
-### Dependency Manager
+### Manager
 
-The `Manager` runnable starts and stops all runnables while respecting the dependency between them.
-Components with dependencies will be stopped before their dependencies.
+The `Manager` groups runnables into two tiers: **processes** (foreground work) and **services** (infrastructure).
+Shutdown is triggered when the context is cancelled or any runnable completes.
+During shutdown, processes are stopped first, then services — ensuring services remain available while processes drain.
 
-Example with three components:
 ```go
-g := runnable.NewManager()
-g.Add(jobQueue)
-g.Add(httpServer, jobQueue) // jobs is a dependency
-g.Add(monitor)
+g := runnable.Manager()
+g.RegisterService(jobQueue)
+g.Register(httpServer)
+g.Register(monitor)
 
-runnable.Run(g.Build())
+runnable.Run(g)
 ```
 
 <details>
   <summary markdown="span">Logs of a demo app</summary>
 
 ```shell
-$ go run ./examples/example
-level=INFO msg=started runnable=manager/JobQueue
+$ go run ./examples/example/
+level=INFO msg=started runnable=manager/StupidJobQueue
 level=INFO msg=started runnable=manager/httpserver
-level=INFO msg=started runnable=manager/Monitor
+level=INFO msg=started runnable=manager/every-3s/RunnableFunc
 ...
-^Clevel=INFO msg="received signal" runnable=signal/manager signal=interrupt
+^C
+level=INFO msg="signal received" runnable=signal signal=interrupt
 level=INFO msg="starting shutdown" runnable=manager reason="context cancelled"
-level=INFO msg=cancelled runnable=manager/httpserver
-level=INFO msg=cancelled runnable=manager/Monitor
-level=INFO msg=stopped runnable=manager/Monitor
 level=INFO msg=stopped runnable=manager/httpserver
-level=INFO msg=cancelled runnable=manager/JobQueue
-level=INFO msg=stopped runnable=manager/JobQueue
+level=INFO msg=stopped runnable=manager/every-3s/RunnableFunc
+level=INFO msg=stopped runnable=manager/StupidJobQueue
 level=INFO msg="shutdown complete" runnable=manager
 ```
 

example_test.go

@@ -51,10 +51,10 @@ func (*CleanupTask) Run(ctx context.Context) error {
 func Example() {
 	runnable.SetLogger(slog.New(slog.NewTextHandler(os.Stdout, nil)))
 
-	g := runnable.NewManager()
+	g := runnable.Manager()
 
 	jobs := NewJobs()
-	g.Add(jobs)
+	g.RegisterService(jobs)
 
 	server := &http.Server{
 		Addr: "127.0.0.1:8080",
@@ -63,7 +63,7 @@ func Example() {
 			jobs.Perform(id)
 		}),
 	}
-	g.Add(runnable.HTTPServer(server), jobs)
+	g.Register(runnable.HTTPServer(server))
 
 	task := runnable.FuncNamed("enqueue", func(ctx context.Context) error {
 		_, _ = http.Post("http://127.0.0.1:8080/?id=1", "test/plain", nil)
@@ -72,12 +72,12 @@ func Example() {
 
 		return nil // quit right away, will trigger a shutdown
 	})
-	g.Add(task)
+	g.Register(task)
 
 	cleanup := runnable.Every(&CleanupTask{}, time.Hour)
-	g.Add(cleanup, jobs)
+	g.Register(cleanup)
 
-	runnable.Run(g.Build())
+	runnable.Run(g)
 
 	// level=INFO msg=started runnable=manager/Jobs
 	// level=INFO msg=started runnable=manager/httpserver

examples/example/main.go

@@ -27,10 +27,10 @@ func main() {
 	})
 	monitor = runnable.Every(monitor, 3*time.Second)
 
-	g := runnable.NewManager()
-	g.Add(jobs)
-	g.Add(serverRunner, jobs) // jobs is a dependency
-	g.Add(monitor)
+	g := runnable.Manager()
+	g.RegisterService(jobs)
+	g.Register(serverRunner)
+	g.Register(monitor)
 
-	runnable.Run(g.Build())
+	runnable.Run(g)
 }

examples/test/main.go

@@ -147,10 +147,10 @@ func main() {
 	db := &DB{metrics: metrics}
 	server := &ServerWithDB{db}
 
-	g := runnable.NewManager()
-	g.Add(metrics)
-	g.Add(db, metrics)
-	g.Add(server, db)
+	g := runnable.Manager()
+	g.RegisterService(metrics)
+	g.RegisterService(db)
+	g.Register(server)
 
-	runnable.Run(g.Build())
+	runnable.Run(g)
 }