From 22b187990798200e575f7729cfc9d0192f843eec Mon Sep 17 00:00:00 2001 From: Mark C Date: Fri, 12 Dec 2025 21:55:46 -0800 Subject: [PATCH] Add payload-json to fakesource --- internal/app/options/connectorflags.go | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/internal/app/options/connectorflags.go b/internal/app/options/connectorflags.go index e229875d..130e1909 100644 --- a/internal/app/options/connectorflags.go +++ b/internal/app/options/connectorflags.go @@ -2,6 +2,7 @@ package options import ( "crypto/tls" + "encoding/json" "errors" "fmt" "net" @@ -246,6 +247,10 @@ func GetRegisteredConnectors() []RegisteredConnector { Name: "payload", Usage: "Payload for all items (`key:value`)", }, + &cli.StringFlag{ + Name: "payload-json", + Usage: "Payload for all items as a json (overrides payload)", + }, }, func(c *cli.Context, _ []string, _ AdditionalSettings) (adiomv1connect.ConnectorServiceHandler, error) { var m map[string]any payload := c.StringSlice("payload") @@ -256,6 +261,12 @@ func GetRegisteredConnectors() []RegisteredConnector { k, v, _ := strings.Cut(p, ":") m[k] = v } + payloadJSON := c.String("payload-json") + if payloadJSON != "" { + if err := json.Unmarshal([]byte(payloadJSON), &m); err != nil { + return nil, fmt.Errorf("err unmarshalling payload-json: %w", err) + } + } return random.NewConnV2(random.ConnV2Input{ NamespacePrefix: c.String("namespace-prefix"), NumNamespaces: c.Int("num-namespaces"),