Function initPlugin

cli/cmd/specs.go:100–108

initPlugin is a simple wrapper that will try to validate the spec before actually passing it to Init.

(ctx context.Context, client plugin.PluginClient, spec map[string]any, noConnection bool, syncID string)

// initPlugin is a simple wrapper that will try to validate the spec before actually passing it to Init.
func initPlugin(ctx context.Context, client plugin.PluginClient, spec map[string]any, noConnection bool, syncID string) error {
	specBytes, err := marshalSpec(spec)
	if err != nil {
		return err
	}

	_, err = client.Init(ctx, &plugin.Init_Request{Spec: specBytes, NoConnection: noConnection, InvocationId: syncID})
	return err
}

// validatePluginSpec encompasses spec validation against a plugin obtained
// over gRPC. Schema acquisition and validation are kept lenient so that a