single_flight: plugin can now be registered from config file

IrineSistiana · Oct 4, 2021 · 47acee1 · 47acee1
1 parent 6ede745
commit 47acee1
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/dispatcher/plugin/executable/single_flight/single_flight.go b/dispatcher/plugin/executable/single_flight/single_flight.go
@@ -30,9 +30,18 @@ const (
 )
 
 func init() {
+	handler.RegInitFunc(PluginType, Init, func() interface{} { return new(Args) })
 	handler.MustRegPlugin(&singleFlight{BP: handler.NewBP("_single_flight", PluginType)}, true)
 }
 
+type Args struct{}
+
+func Init(bp *handler.BP, args interface{}) (p handler.Plugin, err error) {
+	return &singleFlight{
+		BP: bp,
+	}, err
+}
+
 type singleFlight struct {
 	*handler.BP