Add ListById (iface only)

Author: Mark C

connectors/airbyte/conn.go

@@ -15,6 +15,7 @@ import (
 )
 
 type source struct {
+	adiomv1connect.UnimplementedConnectorServiceHandler
 	dockerImage string
 	config      string
 

connectors/dynamodb/conn.go

@@ -24,6 +24,7 @@ import (
 )
 
 type conn struct {
+	adiomv1connect.UnimplementedConnectorServiceHandler
 	client        *client
 	streamsClient *dynamodbstreams.Client
 	spec          string

connectors/mongo/conn.go

@@ -64,6 +64,7 @@ type buffer struct {
 }
 
 type conn struct {
+	adiomv1connect.UnimplementedConnectorServiceHandler
 	client *mongo.Client
 
 	settings ConnectorSettings

connectors/null/connector.go

@@ -21,6 +21,7 @@ import (
 )
 
 type conn struct {
+	adiomv1connect.UnimplementedConnectorServiceHandler
 	id          string
 	logJson     bool
 	sleep       time.Duration
@@ -146,5 +147,10 @@ func (c *conn) WriteUpdates(ctx context.Context, r *connect.Request[adiomv1.Writ
 }
 
 func NewConn(id string, logJson bool, sleep time.Duration, sleepJitter time.Duration) adiomv1connect.ConnectorServiceHandler {
-	return &conn{id, logJson, sleep, sleepJitter}
+	return &conn{
+		id:          id,
+		logJson:     logJson,
+		sleep:       sleep,
+		sleepJitter: sleepJitter,
+	}
 }

connectors/postgres/conn.go

@@ -52,6 +52,7 @@ type PostgresSettings struct {
 }
 
 type conn struct {
+	adiomv1connect.UnimplementedConnectorServiceHandler
 	replicationUrl string
 	id             uint64
 	c              *pgxpool.Pool

connectors/random/connector.go

@@ -19,6 +19,7 @@ import (
 )
 
 type conn struct {
+	adiomv1connect.UnimplementedConnectorServiceHandler
 	settings ConnectorSettings
 
 	docMap      map[string]*IndexMap //map of locations to map of document IDs

connectors/random/connv2.go

@@ -20,6 +20,7 @@ import (
 )
 
 type connV2 struct {
+	adiomv1connect.UnimplementedConnectorServiceHandler
 	payload                         map[string]any
 	namespacePrefix                 string
 	initialSource                   []byte

connectors/s3vector/conn.go

@@ -22,6 +22,7 @@ import (
 )
 
 type conn struct {
+	adiomv1connect.UnimplementedConnectorServiceHandler
 	client         *s3vectors.Client
 	bucketName     *string
 	vectorKey      string

connectors/testconn/connector.go

@@ -30,6 +30,7 @@ import (
 )
 
 type conn struct {
+	adiomv1connect.UnimplementedConnectorServiceHandler
 	bootstrapPath string
 	updatesPath   string
 	loop          bool