Ticketing Rubyライブラリ ​

リポジトリ ​

例 ​

基本的な例 ​

brokerはapplication起動時に1つ作って共有します。wait=0はqueueなしの即時試行1回で最大255秒、leaseは1〜250秒です。最後のminimum-work budgetは必須で0も可能です。秒未満は切り上げ、範囲外または正規化lease超過budgetは送信前に拒否し、clampしません。

require "ticketing"

broker = Ticketing::TicketBroker.connect("127.0.0.1:5225")
broker.wait_ready(5)

ticket = broker.acquire("key", 5, 30, 2)
begin
  token = ticket.token
  # In the same DB transaction: verify/update token high-water and perform the business write.
ensure
  ticket.release
end

自動close/dropはbounded best-effort releaseです。結果が必要ならexplicit release APIを使います。tokenは同じDB transactionで保護対象writeをfenceしなければなりません。

知っておきたい挙動 ​

• request byteを1つでも送った可能性があり確定応答を失うとIndeterminateです。同じownerでAを自動再送せず、callerはcritical sectionへ入りません。
• 送信前cancelはunsent、possible-send後cancelはsessionを閉じます。同時にgrant tokenをparseした場合はboundedなexact-token補償releaseを試みます。
• M、全てのE、malformed/oversized/unknown responseはsession-fatalです。未確定possible-send acquireはIndeterminateです。
• Bはcapacityによる確定拒否で即時返却します。内部retryはなく、callerがapplication backoff後に新ownerで新acquireを開始できます。
• explicit/compensating releaseはcall/enqueueから絶対5秒だけexact tokenを再試行します。Rは成功、Nは既にないかcurrent tokenでない状態、最終応答なしは成功と推定せずerrorです。
• 正の保守的残り時間がありrequired work budgetを満たす場合だけTicketを返します。250秒超workは送信前にunsupportedです。
• tokenによるDB fencingは必須です。同じDB transactionでtoken <= stored_high_waterを拒否し、high-water更新とbusiness writeを行ってcommit/rollback後にreleaseします。

セキュリティオプション(トークン · TLS) ​

すべてのオプションは任意です。tokenはサーバーのclient_tokensに合わせ、TLSはオフ / システム 信頼ストア / CA指定 / 検証省略(テスト専用)の4モードがあります。

broker = Ticketing::TicketBroker.new(
  ["10.0.0.1:5225", "10.0.0.2:5225", "10.0.0.3:5225"],
  token: "123",
  tls: "system-roots" # "off" | "insecure-skip-verify" | CAファイルへのパス
)

サーバー側のトークン・TLS・クラスタ設定はTicketingサーバーデプロイ ページで生成できます。