Replace ateredis with atepg

.github/workflows/pr-workflow.yaml

@@ -89,7 +89,7 @@ jobs:
     - name: Create cluster
       run: hack/create-kind-cluster.sh
     - name: Install Agent Substrate
-      run: hack/install-ate-kind.sh --deploy-ate-system --ateapi-client-auth=${{ matrix.ateapi-client-auth }} --store-backend=postgres
+      run: hack/install-ate-kind.sh --deploy-ate-system --ateapi-client-auth=${{ matrix.ateapi-client-auth }}
     - name: Deploy micro-VM counter demo
       # Stages the (cached) assets into the cluster's rustfs and applies the
       # counter-microvm demo onto the control plane installed above.

README.md

@@ -91,7 +91,7 @@ To quickly set up the complete environment:
 # create cluster and local registry
 hack/create-kind-cluster.sh
 
-# install ate, valkey, rustfs
+# install ate, PostgreSQL, rustfs
 hack/install-ate-kind.sh --deploy-ate-system
 
 # install counter demo
@@ -128,7 +128,7 @@ curl -X POST -H "Host: my-counter-1.demo.actors.resources.substrate.ate.dev" -i
    gcloud auth application-default login --project=${PROJECT_ID}
    ```
 
-3. Provision the required GCP resources (GKE cluster, Redis, GCS, and IAM bindings):
+3. Provision the required GCP resources (GKE cluster, GCS, and IAM bindings):
    ```bash
    go run ./tools/setup-gcp bootstrap
    ```

benchmarking/locust/common/ateapi_pb2_grpc.py

@@ -292,7 +292,7 @@ def ListActors(self, request, context):
         raise NotImplementedError('Method not implemented!')
 
     def CreateAtespace(self, request, context):
-        """Create a new Atespace. Substrate-native, stored in Redis.
+        """Create a new Atespace. Substrate-native, stored in PostgreSQL.
         """
         context.set_code(grpc.StatusCode.UNIMPLEMENTED)
         context.set_details('Method not implemented!')

cmd/ateapi/internal/actoridentity/actoridentity_test.go

@@ -261,10 +261,7 @@ func seedActor(t *testing.T, ctx context.Context, st store.Interface, f actorFix
 			WorkerPodUid:    "worker-uid",
 		}
 	}
-	created, err := st.CreateActor(ctx, actor)
-	if err != nil {
-		t.Fatalf("seed actor: %v", err)
-	}
+	created := storetest.MustCreateActor(t, ctx, st, actor)
 
 	if f.noWorker {
 		return

cmd/ateapi/internal/controlapi/actor_snapshot_test.go

@@ -353,20 +353,17 @@ func TestCreateActorSnapshotTag_RejectsUnsetScope(t *testing.T) {
 }
 
 // serviceWithActorSnapshotTag seeds an ActorSnapshot and a tag pointing at it
-// in a miniredis-backed store, and returns a Service over it.
+// in a PostgreSQL-backed store, and returns a Service over it.
 func serviceWithActorSnapshotTag(t *testing.T, tag *ateapipb.ActorSnapshotTag) (*Service, *ateapipb.ActorSnapshotTag) {
 	t.Helper()
 	persistence, cleanup := storetest.SetupTestStore(t)
 	t.Cleanup(cleanup)
 
 	atespace, name := tag.GetMetadata().GetAtespace(), tag.GetMetadata().GetName()
-	snapshot, err := persistence.CreateActorSnapshot(context.Background(), &ateapipb.ActorSnapshot{
+	snapshot := storetest.MustCreateActorSnapshot(t, context.Background(), persistence, &ateapipb.ActorSnapshot{
 		Metadata:    &ateapipb.ResourceMetadata{Atespace: atespace, Name: "snapshot-" + name},
 		SnapshotUri: "gs://my-bucket/snapshots/" + atespace + "/snapshot-" + name,
 	})
-	if err != nil {
-		t.Fatalf("Failed to CreateActorSnapshot: %v", err)
-	}
 	tag.Snapshot = &ateapipb.ObjectRef{Atespace: snapshot.GetMetadata().GetAtespace(), Name: snapshot.GetMetadata().GetName()}
 	created, err := persistence.CreateActorSnapshotTag(context.Background(), atespace, snapshot.GetMetadata().GetName(), tag)
 	if err != nil {
@@ -383,12 +380,10 @@ func TestUpdateActorSnapshotTag_DeleteRecreateRace(t *testing.T) {
 	t.Cleanup(cleanup)
 
 	for _, name := range []string{"snapshot-1", "snapshot-2"} {
-		if _, err := persistence.CreateActorSnapshot(ctx, &ateapipb.ActorSnapshot{
+		storetest.MustCreateActorSnapshot(t, ctx, persistence, &ateapipb.ActorSnapshot{
 			Metadata:    &ateapipb.ResourceMetadata{Atespace: testAtespace, Name: name},
 			SnapshotUri: "gs://bucket/root/snapshots/" + testAtespace + "/" + name,
-		}); err != nil {
-			t.Fatalf("Failed to CreateActorSnapshot(%s): %v", name, err)
-		}
+		})
 	}
 
 	const tagName = "before-upgrade"
@@ -461,12 +456,10 @@ func TestUpdateActorSnapshotTag_ConcurrentUnguardedUpdate(t *testing.T) {
 	persistence, cleanup := storetest.SetupTestStore(t)
 	t.Cleanup(cleanup)
 
-	if _, err := persistence.CreateActorSnapshot(ctx, &ateapipb.ActorSnapshot{
+	storetest.MustCreateActorSnapshot(t, ctx, persistence, &ateapipb.ActorSnapshot{
 		Metadata:    &ateapipb.ResourceMetadata{Atespace: testAtespace, Name: "snapshot-1"},
 		SnapshotUri: "gs://bucket/root/snapshots/" + testAtespace + "/snapshot-1",
-	}); err != nil {
-		t.Fatalf("Failed to CreateActorSnapshot: %v", err)
-	}
+	})
 
 	const tagName = "before-upgrade"
 	originalTag, err := persistence.CreateActorSnapshotTag(ctx, testAtespace, "snapshot-1", &ateapipb.ActorSnapshotTag{