Enable dynamodbstream (#84)

Author: mosuka

.github/workflows/integration.yml

@@ -37,7 +37,7 @@ jobs:
       localstack:
         image: localstack/localstack:latest
         env:
-          SERVICES: s3,dynamodb
+          SERVICES: s3,dynamodb,dynamodbstreams
           DEFAULT_REGION: ap-northeast-1
           AWS_ACCESS_KEY_ID: dummy
           AWS_SECRET_ACCESS_KEY: dummy

docker-compose.yml

@@ -68,30 +68,30 @@ services:
   #   depends_on:
   #     - localstack
 
-  phalanx:
-    container_name: phalanx
-    image: mosuka/phalanx:latest
-    environment:
-      MINIO_ENDPOINT: minio:9000
-      MINIO_ACCESS_KEY: ${MINIO_ACCESS_KEY}
-      MINIO_SECRET_KEY: ${MINIO_SECRET_KEY}
-      MINIO_REGION_NAME: ${MINIO_REGION_NAME}
-      MINIO_SESSION_TOKEN: ${MINIO_SESSION_TOKEN}
-      MINIO_SECURE: ${MINIO_SECURE}
-      ETCD_ENDPOINTS: etcd:2379
-    command:
-      - '--host=phalanx'
-      - '--bind-port=2000'
-      - '--grpc-port=5000'
-      - '--http-port=8000'
-      - '--roles=indexer,searcher'
-      - '--index-metastore-uri=etcd://phalanx/metastore'
-      - '--log-level=info'
-    ports:
-      - "2000:2000"
-      - "5000:5000"
-      - "8000:8000"
-    depends_on:
-      - etcd
-      - minio
-    restart: always
+  # phalanx:
+  #   container_name: phalanx
+  #   image: mosuka/phalanx:latest
+  #   environment:
+  #     MINIO_ENDPOINT: minio:9000
+  #     MINIO_ACCESS_KEY: ${MINIO_ACCESS_KEY}
+  #     MINIO_SECRET_KEY: ${MINIO_SECRET_KEY}
+  #     MINIO_REGION_NAME: ${MINIO_REGION_NAME}
+  #     MINIO_SESSION_TOKEN: ${MINIO_SESSION_TOKEN}
+  #     MINIO_SECURE: ${MINIO_SECURE}
+  #     ETCD_ENDPOINTS: etcd:2379
+  #   command:
+  #     - '--host=phalanx'
+  #     - '--bind-port=2000'
+  #     - '--grpc-port=5000'
+  #     - '--http-port=8000'
+  #     - '--roles=indexer,searcher'
+  #     - '--index-metastore-uri=etcd://phalanx/metastore'
+  #     - '--log-level=info'
+  #   ports:
+  #     - "2000:2000"
+  #     - "5000:5000"
+  #     - "8000:8000"
+  #   depends_on:
+  #     - etcd
+  #     - minio
+  #   restart: always

example.env

@@ -18,5 +18,5 @@ AWS_USE_PATH_STYLE=true
 
 ETCD_ENDPOINTS=127.0.0.1:2379
 
-LOCALSTACK_SERVICES=s3,dynamodb
+LOCALSTACK_SERVICES=s3,dynamodb,dynamodbstreams
 LOCALSTACK_DEFAULT_REGION=ap-northeast-1

metastore/storage_dynamodb.go

@@ -319,6 +319,10 @@ func (m *DynamodbStorage) createTable() error {
 			},
 		},
 		BillingMode: types.BillingModePayPerRequest,
+		StreamSpecification: &types.StreamSpecification{
+			StreamEnabled:  aws.Bool(true),
+			StreamViewType: types.StreamViewTypeNewAndOldImages,
+		},
 	})
 	if err != nil {
 		var rne *types.ResourceInUseException