Append-Only Olay Deposu & Gerçek Zamanlı CQRS Projeksiyonları

resource "aws_opensearch_domain" "read_projections" {
  domain_name    = "tinycto-read-projections"
  engine_version = "OpenSearch_2.11"

  cluster_config {
    instance_type  = "r6g.xlarge.search"
    instance_count = 3
  }
}

apiVersion: apps/v1
kind: Deployment
metadata:
  name: order-projection-engine
spec:
  replicas: 4
  template:
    spec:
      containers:
        - name: projector
          image: tinycto/order-projector:v2.1
          env:
            - name: KAFKA_BOOTSTRAP_SERVERS
              value: "kafka:9092"
            - name: TARGET_ELASTICSEARCH_URL
              value: "http://opensearch:9200"

CREATE TABLE domain_events (
  aggregate_id UUID NOT NULL,
  version BIGINT NOT NULL,
  event_type VARCHAR(128) NOT NULL,
  payload JSONB NOT NULL,
  occurred_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
  PRIMARY KEY (aggregate_id, version)
);