We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2fe097f commit b458d01Copy full SHA for b458d01
internal/pipeline/step.go
@@ -1,6 +1,8 @@
1
package pipeline
2
3
import (
4
+ "fmt"
5
+
6
broker "github.com/layer5io/meshkit/broker"
7
"github.com/layer5io/meshkit/logger"
8
internalconfig "github.com/layer5io/meshsync/internal/config"
@@ -32,6 +34,13 @@ func newRegisterInformerStep(log logger.Handler, informer dynamicinformer.Dynami
32
34
// Exec - step interface
33
35
func (ri *RegisterInformer) Exec(request *pipeline.Request) *pipeline.Result {
36
gvr, _ := schema.ParseResourceArg(ri.config.Name)
37
+ if gvr == nil {
38
+ return &pipeline.Result{
39
+ Error: internalconfig.ErrInitConfig(fmt.Errorf("error parsing resource arg, gvr not found")),
40
+ Data: nil,
41
+ }
42
43
44
iclient := ri.informer.ForResource(*gvr)
45
46
ri.registerHandlers(iclient.Informer())
0 commit comments