Enable conformance test for memcached state store

Signed-off-by: Bernd Verst <[email protected]>

.github/infrastructure/docker-compose-memcached.yml

@@ -0,0 +1,7 @@
+version: '2'
+
+services:
+  memcached:
+    image: docker.io/memcached:1.6
+    ports:
+      - '11211:11211'

.github/workflows/conformance.yml

@@ -62,6 +62,7 @@ jobs:
         - secretstores.localenv
         - secretstores.localfile
         - state.cassandra
+        - state.memcached
         - state.mongodb
         - state.mysql
         - state.postgresql
@@ -237,6 +238,10 @@ jobs:
     - name: Start kafka
       run: docker-compose -f ./.github/infrastructure/docker-compose-kafka.yml -p kafka up -d
       if: contains(matrix.component, 'kafka')
+
+    - name: Start memcached
+      run: docker-compose -f ./.github/infrastructure/docker-compose-memcached.yml -p memcached up -d
+      if: contains(matrix.component, 'memcached')
 
     - name: Start natsstreaming
       run: docker-compose -f ./.github/infrastructure/docker-compose-natsstreaming.yml -p natsstreaming up -d

state/memcached/memcached.go

@@ -154,6 +154,9 @@ func (m *Memcached) setValue(req *state.SetRequest) error {
 func (m *Memcached) Delete(req *state.DeleteRequest) error {
 	err := m.client.Delete(req.Key)
 	if err != nil {
+		if err == memcache.ErrCacheMiss {
+			return nil
+		}
 		return err
 	}
 

tests/config/state/memcached/statestore.yaml

@@ -0,0 +1,10 @@
+apiVersion: dapr.io/v1alpha1
+kind: Component
+metadata:
+  name: statestore
+spec:
+  type: state.memcached
+  version: v1
+  metadata:
+  - name: hosts
+    value: "localhost:11211"

tests/config/state/tests.yml

@@ -5,6 +5,9 @@ components:
     allOperations: true
   - component: mongodb
     allOperations: true
+  - component: memcached
+    allOperations: false
+    operations: [ "set", "get", "delete", "bulkset", "bulkdelete" ]
   - component: azure.cosmosdb
     allOperations: true
   - component: azure.blobstorage

tests/conformance/common.go

@@ -68,6 +68,7 @@ import (
 	s_azuretablestorage "github.com/dapr/components-contrib/state/azure/tablestorage"
 	s_cassandra "github.com/dapr/components-contrib/state/cassandra"
 	s_cockroachdb "github.com/dapr/components-contrib/state/cockroachdb"
+	s_memcached "github.com/dapr/components-contrib/state/memcached"
 	s_mongodb "github.com/dapr/components-contrib/state/mongodb"
 	s_mysql "github.com/dapr/components-contrib/state/mysql"
 	s_postgresql "github.com/dapr/components-contrib/state/postgresql"
@@ -431,6 +432,8 @@ func loadStateStore(tc TestComponent) state.Store {
 		store = s_cassandra.NewCassandraStateStore(testLogger)
 	case "cockroachdb":
 		store = s_cockroachdb.New(testLogger)
+	case "memcached":
+		store = s_memcached.NewMemCacheStateStore(testLogger)
 	default:
 		return nil
 	}