feat(database/online): implement CreateTable for dynamoDB

internal/database/online/dynamodb/create_table.go

@@ -0,0 +1,37 @@
+package dynamodb
+
+import (
+	"context"
+
+	"github.com/aws/aws-sdk-go-v2/aws"
+	"github.com/aws/aws-sdk-go-v2/service/dynamodb"
+	"github.com/aws/aws-sdk-go-v2/service/dynamodb/types"
+	"github.com/oom-ai/oomstore/internal/database/online"
+	"github.com/oom-ai/oomstore/pkg/errdefs"
+)
+
+func (db *DB) CreateTable(ctx context.Context, opt online.CreateTableOpt) error {
+	_, err := db.Client.CreateTable(ctx, &dynamodb.CreateTableInput{
+		TableName: aws.String(opt.TableName),
+		KeySchema: []types.KeySchemaElement{
+			{
+				AttributeName: aws.String(opt.EntityName),
+				KeyType:       types.KeyTypeHash,
+			},
+		},
+		AttributeDefinitions: []types.AttributeDefinition{
+			{
+				AttributeName: aws.String(opt.EntityName),
+				AttributeType: types.ScalarAttributeTypeS,
+			},
+		},
+		ProvisionedThroughput: &types.ProvisionedThroughput{
+			ReadCapacityUnits:  aws.Int64(10),
+			WriteCapacityUnits: aws.Int64(10),
+		},
+	})
+	if err != nil {
+		return errdefs.WithStack(err)
+	}
+	return nil
+}

internal/database/online/dynamodb/store.go

@@ -7,9 +7,9 @@ import (
 	"github.com/aws/aws-sdk-go-v2/config"
 	"github.com/aws/aws-sdk-go-v2/credentials"
 	"github.com/aws/aws-sdk-go-v2/service/dynamodb"
-	"github.com/oom-ai/oomstore/pkg/errdefs"
 
 	"github.com/oom-ai/oomstore/internal/database/online"
+	"github.com/oom-ai/oomstore/pkg/errdefs"
 	"github.com/oom-ai/oomstore/pkg/oomstore/types"
 )
 
@@ -55,8 +55,3 @@ func (db *DB) Ping(ctx context.Context) error {
 func (db *DB) Close() error {
 	return nil
 }
-
-func (db *DB) CreateTable(ctx context.Context, opt online.CreateTableOpt) error {
-	//TODO implement me
-	panic("implement me")
-}

internal/database/online/dynamodb/store_test.go

@@ -72,3 +72,7 @@ func TestPrepareStreamTable(t *testing.T) {
 func TestPush(t *testing.T) {
 	test_impl.TestPush(t, prepareStore, destroyStore(t))
 }
+
+func TestCreateTable(t *testing.T) {
+	test_impl.TestCreateTable(t, prepareStore, destroyStore(t))
+}