quick azure port.

nitrictech · Jan 10, 2024 · 18aa107 · 18aa107
1 parent d68494f
commit 18aa107
Show file tree

Hide file tree

Showing 3 changed files with 27 additions and 332 deletions.
diff --git a/cloud/azure/deploy/program.go b/cloud/azure/deploy/program.go
@@ -72,8 +72,8 @@ func NewUpProgram(ctx context.Context, details *StackDetails, config *config.Azu
 		})
 
 		// Get Collections
-		collections := lo.Filter[*deploy.Resource](spec.Resources, func(item *deploy.Resource, index int) bool {
-			return item.GetCollection() != nil
+		keyvalueStores := lo.Filter[*deploy.Resource](spec.Resources, func(item *deploy.Resource, index int) bool {
+			return item.GetKeyValueStore() != nil
 		})
 
 		// Get Buckets
@@ -181,10 +181,10 @@ func NewUpProgram(ctx context.Context, details *StackDetails, config *config.Azu
 		}
 
 		var mongoCollections *collection.MongoCollections
-		if len(collections) > 0 {
+		if len(keyvalueStores) > 0 {
 			mongoCollections, err = collection.NewMongoCollections(ctx, "mongodb", &collection.MongoCollectionsArgs{
 				ResourceGroup: rg,
-				Collections:   collections,
+				Collections:   keyvalueStores,
 			})
 			if err != nil {
 				return err

diff --git a/cloud/azure/runtime/cmd/main.go b/cloud/azure/runtime/cmd/main.go
@@ -44,7 +44,7 @@ func main() {
 
 	membraneOpts := membrane.DefaultMembraneOptions()
 
-	membraneOpts.DocumentPlugin, err = mongodb_service.New()
+	membraneOpts.KeyValuePlugin, err = mongodb_service.New()
 	if err != nil {
 		log.Default().Println("Failed to load document plugin:", err.Error())
 	}