Package org.eclipse.ditto.services.utils.akka.streaming

Interface TimestampPersistence

  • public interface TimestampPersistence
    Defines operations for managing metadata of streams.

    • Method Detail

      • setTimestamp

        akka.stream.javadsl.Source<akka.NotUsed,​akka.NotUsed> setTimestamp​(Instant timestamp)
        Updates the timestamp in the persistence..
        Parameters:
        timestamp - The timestamp.
        Returns:
        a Source holding the publisher to execute the operation.

      • setTaggedTimestamp

        akka.stream.javadsl.Source<akka.Done,​akka.NotUsed> setTaggedTimestamp​(Instant timestamp,
                                                                            @Nullable
                                                                            String tag)
        Update the timestamp with a tag.
        Parameters:
        timestamp - the timestamp to persist.
        tag - the tag.
        Returns:
        source that completes after the update completes.

      • getTimestampAsync

        akka.stream.javadsl.Source<Optional<Instant>,​akka.NotUsed> getTimestampAsync()
        Retrieve the timestamp in the persistence.
        Returns:
        a Source of the Instant stored in the persistence.

      • getTaggedTimestamp

        akka.stream.javadsl.Source<Optional<akka.japi.Pair<Instant,​String>>,​akka.NotUsed> getTaggedTimestamp()
        Retrieve the tagged timestamp if any exists in the collection.
        Returns:
        the tagged timestamp.