Merge pull request #34 from FabianKramm/hooks

feat: add generic controller
loft-sh · Aug 30, 2022 · 0b2ce49 · 0b2ce49
2 parents 68a7bf2 + 1dcab88
commit 0b2ce49
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 0 deletions.
diff --git a/plugin/plugin.go b/plugin/plugin.go
@@ -547,6 +547,16 @@ func (m *manager) start() error {
 				return errors.Wrapf(err, "start %s syncer", v.Name())
 			}
 		}
+
+		// controller starter?
+		controllerStarter, ok := v.(syncer.ControllerStarter)
+		if ok {
+			log.Infof("Start controller %s", v.Name())
+			err = controllerStarter.Register(m.context)
+			if err != nil {
+				return errors.Wrapf(err, "start %s controller", v.Name())
+			}
+		}
 	}
 
 	log.Infof("Successfully started plugin.")

diff --git a/syncer/types.go b/syncer/types.go
@@ -130,3 +130,9 @@ type IndicesRegisterer interface {
 type ControllerModifier interface {
 	ModifyController(ctx *context.RegisterContext, builder *builder.Builder) (*builder.Builder, error)
 }
+
+// ControllerStarter is a generic controller that can be used if the syncer abstraction does not fit
+// the use case
+type ControllerStarter interface {
+	Register(ctx *context.RegisterContext) error
+}