リスタートの時にメールボックスクリアしたくなったんですが、（厳密にはRestartではなくてStop => 新しいのをStartみたいなのでもOKなんですが・・）あんまりいい方法がなくてうーんって感じだったので検討をメモ書き程度に。 結論としてはstashするか、dea…

ここに書くことによって途中でやめられなくするメソッドです。 ハッカーニュースを眺めていたら以下のようなCS系講義動画のまとめリポジトリが流れていました。 GitHub - Developer-Y/cs-video-courses: List of Computer Science courses with video lectur…

以下の話題はansible 2.2以降では修正されています。 https://github.com/ansible/ansible/pull/18094 ansible_managed ansibleのtemplate内で {{ ansible_managed }} とすると Ansible managed: {file} modified on %Y-%m-%d %H:%M:%S by {uid} on {host}的…

結論 initialize() https://github.com/akka/akka/blob/v2.4.13/akka-actor/src/main/scala/akka/actor/FSM.scala#L511-L522 をFSMのコンストラクタの最後(または適切なライフサイクルメソッド内)で呼びましょう。 ActorのreceiveTimeout akka actorにはrece…

dockerコンテナ上で何故かcurlが上手くつながらない問題にハマったのでメモするシリーズ。 環境 Ubuntu 14.04.5 LTS ( on OpenStack) Docker version 1.11.2, build b9f10c9 症状 ホストで curl https://github.com は正常にレスポンスを受け取れるのにもか…

結論 wrappers.protoが便利 背景 protobufでは値を省略したときに、その型で定められたデフォルト値が代入されます。 例えばstringを省略すると自動的に""を指定したことになり、「値が指定されなかった」のか「空文字列を明示的に入れた」のかを区別しない…

ponyで何か作りたいなと思ったのでひとまずScalaで作ってそれを移植しようかなーと思い立ち作ってみた。 GitHub - matsu-chara/redica get/setしか叩け無いけどまあいいよね( ◜◡‾) レスポンスのパースが限定的なので勉強がてらもう少し作って見るかも。 せっ…

はろぽに〜₍₍ (ง´･_･`)ว ⁾⁾ Pony 0.3リリース 2016年8月26日にPony 0.3がリリースされました。 チュートリアルについてのブログを書いたときから大分経ったような気がするので、 最近のPony事情についてちょっとまとめようかなーと思います。 （ついでにチ…

ExecutionContextとblockingについて調べたメモ [scala] - だいたいよくわからないブログ の続きです。 今回の記事の結論 blockingをたくさん呼ぶとOOMになるまでスレッド数が増え続けるっぽい。 ==> 追記: scala2.12 だとlimitがあるので安心して使えるらし…

気になったのでコードを追ったりしてみました。備忘録けんメモ書きです。 そもそもtimeoutがどうやって送信されてどうやってbrokerで受信されているのかが追いにくいのですが、 https://github.com/apache/kafka/blob/0.9.0.0/clients/src/main/java/org/apa…

概ね Mailbox with Explicit Acknowledgement — Akka Documentation のお話です。 まずはbuild.sbtです。 name := "akka-scala-seed" version := "1.0" scalaVersion := "2.11.8" val akkaVersion = "2.4.8" libraryDependencies ++= Seq( "com.typesafe.akk…

consumerが復数同時に同じpartitionにつないだときに、どのクライアントが担当するかを意図的に決定させるためにconsumer.idを設定していたんですが、新consumerでconsumer.id設定できるところがみつからないなーと思ったので、Kafkaコードを微妙に追いつつ…

アイコンを変えました₍₍ (ง´･_･`)ว ⁾⁾ そして作りました。 GitHub - matsu-chara/slackloud slackloudとは slackのトークンさえあれば ./run.sh "#作成対象チャンネル" --post "#画像ポストチャンネル" でワードクラウドの生成、画像投稿までやってくれる便…

細かいものを書いてブログを延命するエブリデイ₍₍ (ง´･_･`)ว ⁾⁾ 前置き iterm2 3.0のshell integrationが結構よくて、 時間がかかるコマンドを実行しちゃった後に、あっ終わったら通知して欲しかった・・・ってときにもCmd-Opt-Aで後付アラートしかけられた…

markdownのjson codeblockにAPIレスポンスの仕様とか書いてるけど何か微妙にずれたりしていてﾜｰってなるときに備えて作りました。 codeblockを抜き出してきてjsonlintを叩きまくる仕様です。 実装が雑だけど、困ってないしあんまり継続的にはメンテしないだ…

github.com 分報チャンネルが社内で話題なので流量を可視化することで仕事の集中度となんかリンクしてるのかなーと思って雑に作りました。 22~0時とかに山がありますがその辺は仕事してるのではなくて帰宅後雑談タイムだなーとかが分かります。 ruby力がなさ…

Apache Kafka Meetup Japan #1 at Yahoo! JAPAN - connpass Kafkaを使った マイクロサービス基盤 part2 ＋運用して起きたトラブル集 from matsu_chara www.slideshare.net ザクザクとした発表になりましたが、これからKafkaを導入しようとか今導入してますと…

ansible.cfgにask_vault_pass = Trueを設定したいけどそうすると必要なとき以外もvaultパスを聞かれてつらいのをなんとか回避する ansible-vaultで暗号化したファイルをansible-playbookコマンドなどで使いたい場合は ansible-playbook --ask-vault-pass -i …

akka 2.3.13です。 preRestartの中のどの位置でsuper.preRestart(..) を呼ぶかによって微妙に処理の順番が変わって辛かったのでメモします。 gist.github.com コメントのとおりですが、 最初にsuper.preRestartを呼ぶとpreStart -> postStop -> preRestart …

akka 2.3.13です KillされたことをテストしたくなったのでググったらEventFilterなるものが出てきました。 Testing Actor Systems — Akka Documentation なんとログを見て特定の例外ログが出ているかどうかを見るもののようです。ゴリ押してますね。 使い方…

歌舞伎座.tech#9「異種プログラミング言語格闘勉強会」 - connpass で発表しました。 オープンな勉強会で発表したのは初めてだったので胃に穴が空きそうでしたが、なんとか乗り越えられました・・死にそう・・・(◞‸◟) ponyの知名度がちょっとでも上がれば幸…

pony runtime ponyのランタイムについての論文を読んでいる中でActorの仕組みについての部分を見て現状の実装はどうなっているのか気になったので少しだけ見てみました。 論文は2013年ですが現時点(2016/3/5)での最新コミットのソースを見てみます。 *1 acto…

この記事の結論 globalなExecutionContextではブロックする処理をblockingで包むとスレッド数が勝手に増えるから空きスレッドが無くて実行できないといったことを防げる。 ExecutionContext.fromExecutorService(new ForkJoinPool(100)) で生成されるThread…

akka2.3.13です。 actorの初期化について迷ったのですが公式ドキュメントに書いてあったのでまとめます。 モチベ Actorのフィールドでなんらかの値を初期化する際に以下のパターンが考えられます。 *1 var foo = _ // varで宣言 override preStart() { super…

www.amazon.co.jp を読みました。(2015/12/24発売) 全体を通してJava8とScala版のコードが併記されているので賞味としてはもう少し短くなりそうです。 この本では、akkaを使った並行処理だけでなくakka-remoteを使った分散システムの作成にも取り組みます。 …

注：どうなんだろうというところで終わっているので結論はありません。 akka 2.3.13です。 Actorの中で使ってるライブラリがデッドロックしてる？みたいなケースに遭遇したので雑に調査しました。 とりあえず少なくとも以下の様な状況でKillしようとしても止…

akka 2.3.13です。 preStartの中で例外が出た時にpostStopが呼ばれないような挙動があり、微妙に問題になったので本当に呼ばれてないのかどうか調べてみました。 import akka.actor._ object Main extends App { val system = ActorSystem() try { val actor…

某会社の某アカウントシステムで使われているという継続モナドコントローラーですが、 今までいまいちよくわかっていなかったのですが友達に教えてもらってなるほど！と思ったので書き記します。 ActionCont 継続モナドコントローラー（ActionCont）について…

ansible高速化のためにansible.cfgに色々設定していましたが、fact_cachingの機能を使うと {{ ansible_date_time.date }}_{{ ansible_date_time.hour}}{{ ansible_date_time.minute }}{{ ansible_date_time.second }} のような変数に使われているdate_timeま…

このエントリが投稿されているということはネタ切れが近いということです(´･_･`) 本題 Future.sequence の引数が (implicit canBuildFrom, executorContext) となっていて、 executorContextだけ渡せないつらいと思ったら (implicitly, execurtor) でいける…