CloudFormation alarm resources for a node-based replication group. Alarms are controlled via threshold parameters. Pass None to disable an al

CloudWatch dashboard body for a node-based replication group. Args: node_ids: List of CacheClusterId values (e.g., ["my-cluster-001", "my

Parse a commandstats CSV. Expected columns: cluster_name, command, calls, usec Optional columns: uptime_days - days since server re

Print validation results to stdout.

Print summary to console.

Replace with your business logic.

Replace with your business logic.

Recommend min/max ACU settings.

Recommend min/max ACU settings.

Pick the cheapest result per class whose broker count fits within *broker_quota*. Returns a dict keyed by class with the recommended SizingResult

Refresh all pricing and instance data from AWS APIs. Tries live APIs first. On any failure, falls back to static defaults and reports what su

Refresh all pricing and instance data from AWS APIs. Tries live APIs first. On any failure, falls back to static defaults and reports what su

Write a local, ready-to-deploy copy of the template with sizing baked in. Reads the static source template internally, bakes the customer's sizin

Run full estimation from CLI arguments.

Run full estimation from CLI arguments.

Run all preflight checks against a source Redis/Valkey instance.

CloudFormation alarm resources for a serverless cache. Alarms are controlled via threshold parameters. Pass None to disable an alarm. CacheHi

CloudWatch dashboard body for a serverless cache. Note: CacheHitRate and some command-family metrics are only available for Valkey/Redis OSS

Start SSM port forwarding and keep it running until interrupted.

Connect to ElastiCache and run PING using the client library.

caps = output of compute(). Returns {decision, errors, warnings}.

Validate all recognized keys in a parameter dict. Takes a dict like {"cache_name": "my-cache", "region": "us-east-1"} and validates every key

Walk references/ and validate every .md file.

Walk scripts/ and validate every .py file (excluding this script).

Raise ValueError when the discovery contract lacks required fields or carries unknown values for closed enums (security.encryption_in_transit,

Validate a single .md reference file. Returns a list of Result objects.

Validate a single .py script file. Returns a list of Result objects.

Validate all skills in the top-level skills/ directory (recursive).

Write results to CSV.

Pillar 3: broker- and topic-level config compatibility. Reads broker_configs (full dump) and topics[].configs (full dump), filters against pe

Get the full instance_type -> memory_gb mapping.

Get node on-demand monthly rate (hourly x 730 hours).

Parse raw INFO commandstats output from valkey-cli (or redis-cli). Example line: cmdstat_get:calls=1000,usec=1500,usec_per_call=1.50,rejected_cal

Strip shell metacharacters from a value as a defense-in-depth safety net. This is NOT a substitute for proper validation -- always validate input

Return all rows from `entities` where tenant_id matches req.tenant. Uses cursor-based execution so the same shape works across psycopg2, psyc