構築する必要のなかった Webhook ファンアウト

# Sender side — your Stripe webhook handler.
# Pipe holds the body until 12 readers are attached.
curl -X POST "https://api.hoody.com/api/v1/pipe/billing?n=12" \
  -H "Authorization: Bearer $HOODY_TOKEN" \
  -H "Content-Type: application/json" \
  --data-binary "@stripe-event.json"

# Receiver side — one of twelve subscriber containers.
# Same path, same n. Streams the event body when fan-out is ready.
curl -N "https://api.hoody.com/api/v1/pipe/billing?n=12" \
  -H "Authorization: Bearer $HOODY_TOKEN" | ./billing-handler.sh

# n must match on both ends — mismatch returns 400.
# Default n=1 is point-to-point. n=12 is fan-out for twelve.

同じ URL、同じクエリ文字列、両端共通。送信者の接続がブローカー、リーダーの接続がコンシューマーグループです。トピックがないため、バックプレッシャーはトピック単位ではなくソケット単位です — 1 つのインフライト本文と、それを引っ張る 12 のソケットがあるだけです。

• プロビジョニングするキューはない

  SQS も、Kafka クラスターも、RabbitMQ エクスチェンジもありません。パイプがキューであり、一度に 1 メッセージのために生きています。

• コンシューマーグループの管理は不要

  オフセットも、コミットも、リバランスもありません。パイプは n のソケットが接続するまで本文を保持します — それが調整モデルのすべてです。

• ドレインする DLQ は不要

  送信者が n のリーダーが揃わずに切断した場合、パイプはタイムアウト (5 分 TTL) し、Stripe がリトライします。世話するポイズンメッセージのバケットはありません。

• 言語ごとの SDK は不要

  サブスクライバーは curl ループ。送信者は curl。プロトコルは HTTP。URL を叩けるものなら何でもクラスターに参加できます。

• ソケットごとのバックプレッシャー

  遅いリーダーは自分の接続を絞ります。他の 11 はフルスピードでストリームし続けます。フリート全体にわたるヘッドオブラインブロッキングはありません。

• デフォルトで忘れっぽい

  本文は最後のリーダーが切断した瞬間に消えます。設定する保持ポリシーも、スケジュールするログ圧縮も、書く GDPR の delete-on-request ジョブもありません。