MCPcopy Create free account
hub / github.com/Tradeshift/ts-reaktive

github.com/Tradeshift/ts-reaktive @v0.16.3

Chat with this repo
repository ↗ · DeepWiki ↗ · release v0.16.3 ↗ · + Follow
1,620 symbols 5,050 edges 204 files 468 documented · 29% updated 13d agov0.16.3 · 2020-01-13★ 444 open issues

Browse by type

Functions 1,336 Types & classes 284
What it actually does AI analysis from the code graph — generated when you open this
loading…
README

ts-reaktive

This repository shows how to build reactive applications in Java 8 using the Akka framework, on Akka Persistence, with cassandra as backend, and exposing an event sourced stream using HTTP.

In addition, it contains several extensions for kamon that provide insight to a running, clustered akka application.

The repository consists of the following modules: - ts-reaktive-actors contains the base Java classes with which a reactive application can be built - ts-reaktive-akka contains Akka additions that haven't been merged in to akka main yet - ts-reaktive-cassandra contains classes that help using Cassandra in an async way - ts-reaktive-java contains various utility classes for Java 8 - ts-reaktive-kamon-akka provides dead letter monitoring for an actor system. Just have it on your classpath to enable. - ts-reaktive-kamon-akka-cluster provides cluster membership monitoring for akka clustering. Just have it on your classpath to enable. - ts-reaktive-kamon-log4j provides log4j error and warning monitoring. Just have it on your classpath to enable. - ts-reaktive-marshal provides a non-blocking marshalling DSL for XML and JSON - ts-reaktive-marshal-akka uses the above marshalling inside akka reactive streams - ts-reaktive-ssl provides utility classes to read SSL keys and certs in PEM format - ts-reaktive-testkit provides a test framework for testing akka routes with real HTTP - ts-reaktive-testkit-assertj provides AssertJ-style assertions for Java 8 CompletionStage (with wait support) and Jackson's JsonNode.

How to use from SBT

If you use SBT, you can use this library by adding the following:

resolvers += Resolver.bintrayRepo("jypma", "maven")

libraryDependencies ++= {
  val version = "0.0.34"
  Seq(
    "com.tradeshift" %% "ts-reaktive-actors" % version,
    "com.tradeshift" %% "ts-reaktive-aws" % version,
    "com.tradeshift" %% "ts-reaktive-akka" % version,
    "com.tradeshift" %% "ts-reaktive-cassandra" % version,
    "com.tradeshift" %% "ts-reaktive-marshal" % version,
    "com.tradeshift" %% "ts-reaktive-marshal-akka" % version,
    "com.tradeshift" %% "ts-reaktive-replication" % version,
    "com.tradeshift" %% "ts-reaktive-ssl" % version,
    "com.tradeshift" %% "ts-reaktive-testkit" % version % "test",
    "com.tradeshift" %% "ts-reaktive-testkit-assertj" % version % "test",
    "com.tradeshift" %% "ts-reaktive-kamon-akka" % version,
    "com.tradeshift" %% "ts-reaktive-kamon-akka-cluster" % version,
    "com.tradeshift" %% "ts-reaktive-kamon-log4j" % version
  )
}

How to use from Maven

If you use Maven, you can add the following to your settings.xml file or your pom.xml, and then add the individual dependencies shown above:

<repositories>
  <repository>
    <snapshots>
      <enabled>false</enabled>
    </snapshots>
    <id>bintray-jypma-maven</id>
    <name>bintray</name>
    <url>http://dl.bintray.com/jypma/maven</url>
  </repository>
</repositories>
<pluginRepositories>
  <pluginRepository>
    <snapshots>
      <enabled>false</enabled>
    </snapshots>
    <id>bintray-jypma-maven</id>
    <name>bintray-plugins</name>
    <url>http://dl.bintray.com/jypma/maven</url>
  </pluginRepository>
</pluginRepositories>

Other build systems

Visit bintray and click "Set me up".

Extension points exported contracts — how you extend this code

Core symbols most depended-on inside this repo

Shape

Method 1,336
Class 261
Interface 19
Enum 4

Languages

Java100%

Modules by API surface

ts-reaktive-replication/src/test/java/com/tradeshift/reaktive/replication/TestData.java214 symbols
ts-reaktive-actors/src/main/java/com/tradeshift/reaktive/materialize/MaterializerActor.java52 symbols
ts-reaktive-marshal/src/main/java/com/tradeshift/reaktive/json/JSONEvent.java43 symbols
ts-reaktive-marshal/src/main/java/com/tradeshift/reaktive/xml/impl/AbstractStaxHandler.java35 symbols
ts-reaktive-actors/src/test/java/com/tradeshift/reaktive/actors/AbstractStatefulPersistentActorSpec.java28 symbols
ts-reaktive-marshal/src/main/java/com/tradeshift/reaktive/xml/impl/StaxEventHandler.java23 symbols
ts-reaktive-marshal/src/main/java/com/tradeshift/reaktive/xml/AttributeDelegate.java23 symbols
ts-reaktive-actors/src/main/java/com/tradeshift/reaktive/actors/AbstractStatefulPersistentActor.java23 symbols
ts-reaktive-marshal/src/main/java/com/tradeshift/reaktive/marshal/IterableProtocol.java22 symbols
ts-reaktive-csv/src/main/java/com/tradeshift/reaktive/csv/CsvEvent.java20 symbols
ts-reaktive-actors/src/main/java/com/tradeshift/reaktive/materialize/MaterializerWorkers.java18 symbols
ts-reaktive-replication/src/main/java/com/tradeshift/reaktive/replication/DataCenterForwarder.java17 symbols

For agents

$ claude mcp add ts-reaktive \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

Ask about this repo answers extend the page