Skip to content

Instantly share code, notes, and snippets.

@staltz
staltz / introrx.md
Last active July 26, 2024 04:24
The introduction to Reactive Programming you've been missing
@petitviolet
petitviolet / AkkaStreamPracWithActor.scala
Last active April 11, 2021 21:07
Akka-Stream with Actor using ActorPublisher and ActorSubscriber
package net.petitviolet.ex.persistence.task
import akka.NotUsed
import akka.actor._
import akka.pattern.ask
import akka.stream.actor.ActorSubscriberMessage.{ OnComplete, OnNext }
import akka.stream.actor.{ ActorPublisher, ActorSubscriber, OneByOneRequestStrategy, RequestStrategy }
import akka.stream.{ ActorMaterializer, ClosedShape }
import akka.util.Timeout
import org.reactivestreams.Publisher
@petitviolet
petitviolet / FutureTrap.md
Last active July 30, 2018 11:27
[Scala]Pay attention to the timing to call `Future.apply`.

what is this?

scala.concurrent.Future let asynchronous programming easily. We can process a code block asynchronously by providing it to Future.apply. The timing to start processing is just Future.apply invoked. (also, needs a idling thread.) Therefore, pay attention to the timing to call it.

not in parallel

Creating StorageClass with NFS Client Provisioner

We already have an NFS server so the next step is to install NFS client as a StorageClass. We'll use kubernetes nfs-client-provisioner.

Since the provisioner will need to interact with Kube API and we have RBAC enabled, the first step is to create a ServiceAccount.

curl https://raw.githubusercontent.com/kubernetes-incubator/external-storage/master/nfs-client/deploy/auth/serviceaccount.yaml