feat: Add Sentry option to spec

Author: disq

managedplugin/plugin.go

@@ -77,6 +77,7 @@ type Config struct {
 	Version     string
 	Environment []string // environment variables to pass to the plugin in key=value format
 	DockerAuth  string
+	SentryDSN   string
 }
 
 type Client struct {
@@ -549,6 +550,8 @@ func (c *Client) getPluginArgs() []string {
 	}
 	if c.noSentry {
 		args = append(args, "--no-sentry")
+	} else if len(c.config.SentryDSN) > 0 {
+		args = append(args, "--sentry-dsn", c.config.SentryDSN)
 	}
 	if c.licenseFile != "" {
 		args = append(args, "--license", c.licenseFile)

specs/destination.go

@@ -21,6 +21,9 @@ type Destination struct {
 	BatchSizeBytes int         `json:"batch_size_bytes,omitempty"`
 	Spec           any         `json:"spec,omitempty"`
 	PKMode         PKMode      `json:"pk_mode,omitempty"`
+
+	// SentryDSN is the DSN used to report errors to Sentry
+	SentryDSN string `json:"sentry_dsn,omitempty"`
 }
 
 func (d *Destination) SetDefaults(defaultBatchSize, defaultBatchSizeBytes int) {

specs/source.go

@@ -53,6 +53,9 @@ type Source struct {
 	// DeterministicCQID is a flag that indicates whether the source plugin should generate a random UUID as the value of _cq_id
 	// or whether it should calculate a UUID that is a hash of the primary keys (if they exist) or the entire resource.
 	DeterministicCQID bool `json:"deterministic_cq_id,omitempty"`
+
+	// SentryDSN is the DSN used to report errors to Sentry
+	SentryDSN string `json:"sentry_dsn,omitempty"`
 }
 
 func (s *Source) SetDefaults() {