great update, disruptive

.gitignore

@@ -0,0 +1 @@
+.idea

ctl.go

@@ -25,31 +25,27 @@ type DestroyUnit struct {
 }
 
 func registerDestroy(seq int, name string, unit Handler) {
-	destroys = append(destroys, DestroyUnit{
+	destroyUnits = append(destroyUnits, DestroyUnit{
 		Seq:  seq,
 		Name: name,
 		Unit: unit,
 	})
 }
 
-func SetupActive(fn func()) {
-	activeFunc = fn
-}
-
 func RegisterHandler(seq int, name string, handler func(ctx *context.Context) Handler) {
-	creates = append(creates, Unit{
+	units = append(units, Unit{
 		Seq:    seq,
 		Name:   name,
 		Handle: handler,
 	})
 }
 
-func sortCreates() {
-	sort.Slice(creates, func(i, j int) bool {
-		return creates[i].Seq < creates[j].Seq
-	})
-}
-
-func init() {
+func Bootstrap(activeFunc func()) {
+	if activeFunc == nil {
+		panic("===== unset active func =====")
+	}
 	activeFunc()
+	sort.Slice(units, func(i, j int) bool {
+		return units[i].Seq < units[j].Seq
+	})
 }

example/main.go

@@ -11,7 +11,7 @@ import (
 func main() {
 
 	// register services
-	pkgCtl.SetupActive(example_units.Active)
+	pkgCtl.Bootstrap(example_units.Active)
 
 	var (
 		ctx, cancel = context.WithCancel(context.Background())

store.go

@@ -6,11 +6,10 @@ import (
 )
 
 var (
-	activeFunc    = func() {}
 	closeListener = make(chan struct{}, 1)
 	cancelFunc    context.CancelFunc
-	creates       = make([]Unit, 0)
-	destroys      = make([]DestroyUnit, 0)
+	units         = make([]Unit, 0)
+	destroyUnits  = make([]DestroyUnit, 0)
 )
 
 var Log *log.Logger

tool.go

@@ -24,7 +24,7 @@ func ForceExit() error {
 // this func can only be called when ListenAndDestroy is used, otherwise an error will be return
 func Exit() error {
 	if cancelFunc == nil {
-		return errors.New("not set cancelFunc")
+		return errors.New("unset cancelFunc")
 	}
 	return Destroy(cancelFunc)
 }
@@ -50,11 +50,11 @@ func ExitWithTimeout(d time.Duration) error {
 // Destroy unregister all services immediately after calling
 func Destroy(cancel context.CancelFunc) (err error) {
 	cancel()
-	for i := 0; i < len(destroys); i++ {
-		if err = destroys[i].Unit.Destroy(); err != nil {
+	for i := 0; i < len(destroyUnits); i++ {
+		if err = destroyUnits[i].Unit.Destroy(); err != nil {
 			Log.Printf(
 				"unit %s destroy fail, error: %s",
-				destroys[i].Name,
+				destroyUnits[i].Name,
 				err.Error(),
 			)
 		}
@@ -66,8 +66,7 @@ func Destroy(cancel context.CancelFunc) (err error) {
 
 // Startup all registered services in order
 func Startup(ctx *context.Context) error {
-	sortCreates()
-	size := len(creates)
+	size := len(units)
 	if size == 0 {
 		return errors.New("no unit require register")
 	}
@@ -79,7 +78,7 @@ func Startup(ctx *context.Context) error {
 		if len(ec) == 1 {
 			return <-ec
 		}
-		unit := creates[i]
+		unit := units[i]
 		uHandler := unit.Handle(ctx)
 		if err = uHandler.Create(); err != nil {
 			Log.Printf("unit %s create fail, error: %s", unit.Name, err.Error())