/gen.dapr-component <component-type> "<config>"

# Examples:
/gen.dapr-component "pubsub.kafka" "Kafka brokers at localhost:9092, todo-events topic"
/gen.dapr-component "state.postgresql" "PostgreSQL connection, todo-keys table"
/gen.dapr-component "secret.kubernetes" "Kubernetes secret store for JWT and DB password"
/gen.dapr-component "bindings.cron" "Cron binding for daily reminder check"

phase-XX/k8s/dapr/
  ├── components/
  │   ├── pubsub-kafka.yaml         # Kafka pub/sub
  │   ├── state-postgres.yaml        # PostgreSQL state
  │   ├── secret-k8s.yaml          # Kubernetes secrets
  │   └── bindings-cron.yaml        # Cron bindings
  ├── config/
  │   └── dapr-config.yaml          # Dapr application config
  └── overlays/
      ├── dev/                       # Dev overrides
      ├── staging/                   # Staging overrides
      └── prod/                      # Production overrides

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: kafka-pubsub
  namespace: production
spec:
  type: pubsub.kafka
  version: v1
  metadata:
  - name: brokers
    value: "kafka-broker-0.kafka.svc.cluster.local:9092,kafka-broker-1.kafka.svc.cluster.local:9092,kafka-broker-2.kafka.svc.cluster.local:9092"
  - name: authRequired
    value: "true"
  - name: sasl
    value: "plaintext"
  - name: consumerGroup
    value: "todo-consumer-group"
  - name: autoCommit
    value: "true"
  - name: initialOffset
    value: "newest"
  - name: maxMessageBytes
    value: "1024"
scopes:
  - todo-backend
  - ai-service

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: postgres-state
  namespace: production
spec:
  type: state.postgresql
  version: v1
  metadata:
  - name: connectionString
    secretKeyRef:
      name: postgres-secret
      key: connectionString
  - name: tableName
    value: "dapr_state"
  - name: cleanupInterval
    value: "1h"
  - name: maxConcurrentWrites
    value: "10"
  - name: keyPrefix
    value: "todo"
  - name: queryIndexes
    value: "id,created_at"
scopes:
  - todo-backend
  - ai-service

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: kubernetes-secret-store
  namespace: production
spec:
  type: secretstores.kubernetes
  version: v1
  metadata:
  - name: allowedSecrets
    value: "jwt-secret,postgres-password,api-key"
scopes:
  - todo-backend
  - ai-service

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: daily-reminder-cron
  namespace: production
spec:
  type: bindings.cron
  version: v1
  metadata:
  - name: schedule
    value: "@daily"
  - name: direction
    value: "input"
  - name: data
    value: '{"action": "check_reminders"}'
scopes:
  - todo-backend

apiVersion: dapr.io/v1
kind: Configuration
metadata:
  name: dapr-config
  namespace: production
spec:
  # API tracing
  tracing:
    samplingRate: "1"
    zipkin:
      endpointAddress: "http://zipkin.default.svc.cluster.local:9411/api/v2/spans"
  # Metrics
  metrics:
    enabled: true
    rules:
      - name: dapr-api
        labels:
          app: "todo-backend"
        regex: "dapr-api.*"
      - name: dapr-runtime
        labels:
          app: "todo-backend"
        regex: "dapr-runtime.*"
  # Application protocol
  http:
    maxRequestBodySize: 4
  # Feature flags
  features:
    - name: AppHealthCheck
      enabled: true
    - name: GracefulShutdown
      enabled: true
    - name: NameResolution
      enabled: true
  # mTLS configuration
  mtls:
    enabled: true
    workloadCertTTL: 3600s
  # API server
  api:
    allowedOrigins:
      - "https://todo.example.com"
    maxRequestSizeMB: 10

apiVersion: apps/v1
kind: Deployment
metadata:
  name: todo-backend
spec:
  replicas: 3
  template:
    metadata:
      annotations:
        dapr.io/enabled: "true"
        dapr.io/app-id: "todo-backend"
        dapr.io/app-port: "8000"
        dapr.io/config: "dapr-config"
        dapr.io/sidecar-cpu-request: "100m"
        dapr.io/sidecar-memory-request: "128Mi"
        dapr.io/sidecar-cpu-limit: "500m"
        dapr.io/sidecar-memory-limit: "512Mi"
    spec:
      containers:
        - name: todo-backend
          image: todo-backend:latest
          ports:
            - containerPort: 8000
          env:
            - name: DAPR_HTTP_PORT
              value: "3500"
            - name: DAPR_GRPC_PORT
              value: "50001"

from dapr.clients import DaprClient
import json

dapr = DaprClient()

# Save state
dapr.save_state(
    store_name="postgres-state",
    key=f"todo-{todo_id}",
    value=json.dumps(todo_data),
    state_metadata={"ttlInSeconds": 3600}
)

# Get state
state = dapr.get_state(store_name="postgres-state", key=f"todo-{todo_id}")

# Delete state
dapr.delete_state(store_name="postgres-state", key=f"todo-{todo_id}")

# Publish event
dapr.publish_event(
    pubsub_name="kafka-pubsub",
    topic="todo-events",
    data=json.dumps(event_data),
    metadata={"partitionKey": todo_id}
)

# Subscribe to topic
# (configured via subscriptions.yaml)

apiVersion: dapr.io/v2alpha1
kind: Subscription
metadata:
  name: todo-events-subscription
spec:
  topic: todo-events
  routes:
    - rule:
        match: 'event.type == "TodoCreated"'
      path: /api/v1/todos/handle-created
    - rule:
        match: 'event.type == "TodoCompleted"'
      path: /api/v1/todos/handle-completed
  pubsubname: kafka-pubsub
  deadLetterTopic: todo-events-dlt

k8s/dapr/
  ├── components/           # Component definitions
  ├── config/
  │   └── dapr-config.yaml
  ├── subscriptions/       # Event subscriptions
  ├── overlays/
  │   ├── dev/
  │   ├── staging/
  │   └── prod/
  └── secrets/             # Dapr secrets

# Initialize Dapr in Kubernetes
dapr init --kubernetes --runtime-version=1.13.0

# Verify Dapr installation
dapr status --kubernetes

# List components
dapr components -k

# List configurations
dapr configurations -k

# Get logs
dapr logs --kubernetes --app-id todo-backend --namespace production

# Uninstall Dapr
dapr uninstall --kubernetes