warp10-scala-client
API
Generated with
warp10-scala-client/com.clevercloud.warp10client/Warp10Client

Warp10Client

com.clevercloud.warp10client.Warp10Client
class Warp10Client(warpContext: WarpClientContext)

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

def exec: Flow[WarpScript, Seq[GTS], NotUsed]
def exec(script: WarpScript): Future[Seq[GTS]]
def fetch(readToken: String): Flow[Query[FetchRange], Future[Either[WarpException, Seq[GTS]]], NotUsed]
def fetch(readToken: String, query: Query[FetchRange]): Future[Either[WarpException, Seq[GTS]]]
def push(writeToken: String): Flow[GTS, Future[Either[WarpException, Unit]], NotUsed]
def push(gts: GTS, writeToken: String): Future[Either[WarpException, Unit]]
def push(gtsSeq: Seq[GTS], writeToken: String, batchSize: Int): Future[Either[WarpException, Unit]]
def pushSeq(writeToken: String): Flow[Seq[GTS], Future[Either[WarpException, Unit]], NotUsed]
Generated with