Akka gRPC（Scala）+CloudTraceで分散トレーシング
はじめに CloudTraceとは 概要はこちら。 GCP曰く「誰でも使用できる分散トレース システム」とのことで、GKE上で動かしているAkka gRPCで書かれたサービスのトレース結果を下のイメージ（クイックスタートより拝借）のように見たいなぁというのが今回の動機。 Scala環境ではOpenTelemetry（Java）を利用できそうです。 OpenTelemetryとは 概要はこちら。 Google翻訳によると「OpenTelemetryは、トレース、メトリック、ログなどのテレメトリデータの作成と管理用に設計された、API、SDK、ツール、および統合のセットです。」らしい。 OpenTracingとOpenCensusの合併した後継プロジェクトであり、CNCFのインキュベーターになっています。 Java以外にもGoとか.Netとか用意されているみたいですね。 Akka gRPCで利
akka http clientのmax-open-requestsについて | DevelopersIO
はじめに akka http client APIを使っていて以下のようなエラーに遭遇したので関連する設定について調べました。 akka.stream.BufferOverflowException: Exceeded configured max-open-requests value of [4]. これは何か？ エラーメッセージに記載されている説明ページには以下のように説明されています(要約) ホストごとにコネクションをプーリングしている コネクション数は akka.http.host-connection-pool.max-connectionで設定する プールを使うAPI(Http().singleRequest()など）でリクエストを送信すると、プールが処理できるリクエスト数を超えた場合はキューに入れられる キューのサイズ(max-open-requests) を超えた場合はB
AkkaのPersistence (Event Sourcing)の用途について
この記事はScala Advent Calendar 2021の16日目の記事です。 はじめに Akka Clusterを使った分散システムを実現するために、いくつかのAkkaのモジュールを理解する必要がある。 そのうちの一つにPersistence (Event Sourcing) がある。よく Actor を永続化するために使うということを聞くが、あまり使い所がピンと来なかったので、Akkaのドキュメントと参考文献を読みながらメモを書いていく。 Persistence (Event Sourcing) とは 状態を持ったアクターを永続化できるモジュール。 以下の二種の方法で永続化ができる Journal - 更新イベントを1つずつ発生した順番に保存 Snapshot - その時点でのActorの状態を直接保存 状態を持ったアクターのスナップショットも使うことはできるが(リカバリーする際
Akka HTTPの仕組みを理解する
LINE株式会社は、2023年10月1日にLINEヤフー株式会社になりました。LINEヤフー株式会社の新しいブログはこちらです。 LINEヤフー Tech Blog 初めまして、Ads Platform開発チームの岡田（@ocadaruma）です。 この記事はLINE Advent Calendar 2017の17日目の記事です。 今回、個人的に以前から気になっていたAkka HTTPの内部構造について、この機会に調べましたので紹介いたします。 Akka HTTPとは Akka HTTPは、Lightbend社によって開発されている、Scala/Java用のHTTP toolkitです。 現在はメンテナンスが終了したsprayの後継と位置付けられており、特徴的なRouting DSLをsprayから受け継いでいます。 また、Play Frameworkは2.6系より、Akka HTTPをデ
Scala. js+React+akka-httpでオンライン対戦可能なオセロを作ってみる - Qiita
使用ライブラリなど Scala.js scalajs-react akka-http circe モデリング ゲームのコアにあたる部分の実装指針です。 オセロのルールを閉じ込めたOthelloクラスを作成し、以下の2つの状態を保持 ボード ... 盤面。どこに何色の石が置かれているかを保持。 手番 ... 次は黒/白どちらの手番か（これは、通常プレイであれば、ボード上の石数から判断することも出来るものの、通常プレイ以外の拡張モードの構想もあり、切り出すことにしました） ゲームの情報を保持するGameクラスを作成し、勝敗や参加者のIDを保持 このクラスがOthelloインスタンスを内包しています。 参加者はParticipantクラスで定義 名前と状態（フリー、参加待ち、観戦中、対戦中）を持っています。 認証認可周りは今回の本題ではないので、ふわっと作ってます。 実装戦略 以下、どういった方
ScalaでMMOのサーバを書くための技術
この記事は、Play or Scala Advent Calendar 2012の25日めです。 Looking back 2012 2012年は、 Playのドキュメント翻訳 Scala、Playのビギナー向けの発表 会社の業務でもScalaが使えるようになった など、個人的にはPlayとScalaが身近な世界で躍進した年でした。そんな年にアドベントカレンダーの最終日を担当するというのは、何か感慨深いものがあります！ 最近はPlayやScalaが実践で使われ始めた影響か、バイナリ互換性やビルドツール、習得面などの実践的な課題が色々と話題になっています。課題に対しては来年移行も粛々と対応をしていき、Scalaの今後の発展に寄与していきたいと思います さて、本題に入ります。先日、AkkaでMMOのサーバ（ほんの小さなものですが）を書きました。その時に使ったScala関連の技術をいくつかご紹介
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
[Akka-HTTP]ルーティングDSLの基本となるPathMatcherのまとめ - Qiita![[Akka-HTTP]ルーティングDSLの基本となるPathMatcherのまとめ - Qiita](https://cdn-ak-scissors.b.st-hatena.com/image/square/b01313f481b654ea4afbb49fda05468bc0bcb295/height=288;version=1;width=512/https%3A%2F%2Fqiita-user-contents.imgix.net%2Fhttps%253A%252F%252Fcdn.qiita.com%252Fassets%252Fpublic%252Farticle-ogp-background-9f5428127621718a910c8b63951390ad.png%3Fixlib%3Drb-4.0.0%26w%3D1200%26mark64%3DaHR0cHM6Ly9xaWl0YS11c2VyLWNvbnRlbnRzLmltZ2l4Lm5ldC9-dGV4dD9peGxpYj1yYi00LjAuMCZ3PTkxNiZ0eHQ9JTVCQWtrYS1IVFRQJTVEJUUzJTgzJUFCJUUzJTgzJUJDJUUzJTgzJTg2JUUzJTgyJUEzJUUzJTgzJUIzJUUzJTgyJUIwRFNMJUUzJTgxJUFFJUU1JTlGJUJBJUU2JTlDJUFDJUUzJTgxJUE4JUUzJTgxJUFBJUUzJTgyJThCUGF0aE1hdGNoZXIlRTMlODElQUUlRTMlODElQkUlRTMlODElQTglRTMlODIlODEmdHh0LWNvbG9yPSUyMzIxMjEyMSZ0eHQtZm9udD1IaXJhZ2lubyUyMFNhbnMlMjBXNiZ0eHQtc2l6ZT01NiZ0eHQtY2xpcD1lbGxpcHNpcyZ0eHQtYWxpZ249bGVmdCUyQ3RvcCZzPTdlMmJlNTc0YWNmZTU0MjVjNDgxZTg0Y2Y3NTA1MDkw%26mark-x%3D142%26mark-y%3D112%26blend64%3DaHR0cHM6Ly9xaWl0YS11c2VyLWNvbnRlbnRzLmltZ2l4Lm5ldC9-dGV4dD9peGxpYj1yYi00LjAuMCZ3PTYxNiZ0eHQ9JTQwcGV0aXR2aW9sZXQmdHh0LWNvbG9yPSUyMzIxMjEyMSZ0eHQtZm9udD1IaXJhZ2lubyUyMFNhbnMlMjBXNiZ0eHQtc2l6ZT0zNiZ0eHQtYWxpZ249bGVmdCUyQ3RvcCZzPThlNjI5ZDA4M2JlYmMxZDYwNzRlYzcxMDFlM2FiZTdk%26blend-x%3D142%26blend-y%3D491%26blend-mode%3Dnormal%26s%3D3e13ab9e168ef129a352db3a2d63b265)
Reading an Akka-HTTP Response Body as a String | Baeldung on Scala
AWSでCQRS Event Sourcing するにはどうすればいいのか
Dynamically changing the throttling level on Akka Streams