Immutable class that manages a list of UUID entries that can have certain rights on a resource. The UUIDs typically represent either users or user gro

Helper class containing lambdas or method definitions which {@link ACL} uses when applying changes. You typically don't have to use this class directl

Wraps the Aalto XML parser as an akka flow of ByteString to XMLEvent. @see https://github.com/FasterXML/aalto-xml

Provides assertions for Results emitted from a command. Typically a subclass is written for the actual types in your project, so more type-safe varia

Contains AssertJ-style assertions on CompletionStage that implicitly wait for a result before running the assertion.

Base class for immutable classes that hold the state for an AbstractStatefulPersistentActor. Subclasses should pass their own type in as the S type pa

Base class for persistent actor that manages some state, receives commands of a defined type, and emits events of a defined type. The actor automatica

Abstract base class for SAX {@code ContentHandler} and {@code LexicalHandler} implementations that use StAX as a basis. All methods delegate to intern

Wraps the Actson JSON parser as an akka flow of ByteString to JSONEvent @see https://www.michel-kraemer.com/actson-reactive-json-parser/

Various functions relating to akka streams

Handles reading and writing a single attribute of a tag, matching any name

Protocol for reading and writing individual JSON fields and their value (through an inner protocol), mapping each field's name as a String, and delega

Forwards read events to multiple alternative protocols, emitting whenever any of the alternatives emit. If multiple alternatives emit for the same eve

Groups an Attribute with a Location since the StaX XMLEventFactory (and the default JDK implementation) seem to think that attributes never have a loc

Handles reading and writing a single attribute of a tag.

Contains utility methods that repeatedly try to evaluate a function, retrying when an assertion does not (yet) hold.

@deprecated replaced by {@link Base64Flows}

Provides flows for encoding and decoding base64 String and ByteString. <pre> Encoders: +----------------+ |

Protocol that emits the body of a tag as actual {@link Characters} events. This has the advantage that the body can be streamed, but the disadvantage

Represents the character data body at root level as a String. If during reading, an empty tag or no body is encountered, no value is emitted. In other

Protobuf type {@code com.tradeshift.reaktive.replication.TestEvent}

Protobuf type {@code com.tradeshift.reaktive.replication.TestCommand.Read}

Protobuf type {@code com.tradeshift.reaktive.replication.TestCommand.Write}

Protobuf type {@code com.tradeshift.reaktive.replication.TestCommand}

Captures bytes written to an output stream as ByteString instances, which can be picked off repeatedly by invoking {@link #getBytesAndReset()}. Insta

Base class to provide graph stages that transform ByteString streams. Overriding {@link #getInputChunkSizeMultiple()} guaranties chunking of the input

Various functions relating to byte strings

Message that can be sent to this actor to cancel any on-going reimport.

Cassandra's Java client has its own monitoring using codahale metrics. This class can route those metrics into statsd, so that they go together with t

Provides asynchronous, non-blocking access to a cassandra session.

Decodes a stream of bytes into a stream of characters, using a supplied {@link Charset}.

Encodes a stream of strings into a stream of bytes, using a supplied {@link Charset}.

Wrapper class around a cluster singleton with backoff supervisor of a known type, that can both be started and lookup up under a known global name.

Forwards read events to multiple alternative protocols, emitting whenever any of the alternatives emit. If multiple alternatives emit for the same eve

A command handler knows how to transform command into a result, asynchronously. Command handlers that don't need to to asynchronous work can implement

Various functions relating to CompletableFuture

Protocol that always writes the same value, and on reading emits "Present" when the expected value was indeed read.

Like java Consumer, but can throw checked exceptions

Message that can be sent to this actor to have it launch an extra worker, which starts work at the given timestamp, and works at most to the given end

Represents a single eveny in a CSV stream.

Parses an incoming stream of strings making up a CSV document into individual CSV events.

Contains static methods for the Java CSV marshalling DSL.

Encapsulates the settings that make up a particular CSV variant.

Aggregates subsequent CsvEvent.text() events for the same column value into single text event, up to a given limit

Renders an incoming stream of CSV events into string content, according to the given settings.

A remote data center to which events can be sent

Runs a continuous query for all events matching a certain tag, and forwards those events to a remote data center.

Parses an incoming byte string of "delimited" protobuf messages such, that each ByteString makes up a complete message. The stream is expected to con

Stage that drops incoming elements, until it finds one that matches the predicate, but starts output with the element BEFORE the one matching the pred

@author jan

Determines to which additional data centers a persistenceId should be replicated after a certain event is emitted.

Serializes instances of {@link akka.persistence.query.EventEnvelope}, into the protobuf {@link EventEnvelope}. In order to do this, it reuses akka's s

Exposes the full event stream of an akka persistence journal as an HTTP stream in chunked encoding, by querying the journal with a fixed tag. Subclas

Actor which just emits a single event into its journal and then exits. We do this to simulate a remote journal having been replicated to here.

Protocol for reading and writing a single JSON field and its value (through an inner protocol)