Packages

c

com.lightbend.kafka.scala.iq.http

KeyValueFetcher

class KeyValueFetcher[K, V] extends LazyLogging with FailFastCirceSupport with Serializers

Abstraction for fetching information from a key/value state store based on the key and the store name passed in the API.

Supports basic fetch as well as fetch over a time window.

The fetch APIs support retry semantics in case the key is not available in the local state store. It then fetches the store information from the MetadataService and then requeries that store to get the information.

Linear Supertypes
Serializers, FailFastCirceSupport, FailFastUnmarshaller, BaseCirceSupport, LazyLogging, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. KeyValueFetcher
  2. Serializers
  3. FailFastCirceSupport
  4. FailFastUnmarshaller
  5. BaseCirceSupport
  6. LazyLogging
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new KeyValueFetcher(metadataService: MetadataService, localStateStoreQuery: LocalStateStoreQuery[K, V], httpRequester: HttpRequester, streams: KafkaStreams, executionContext: ExecutionContext, hostInfo: HostInfo)(implicit arg0: Decoder[K], arg1: Decoder[V], actorSystem: ActorSystem, keySerializer: Serializer[K], u: Unmarshaller[ResponseEntity, V])

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. final val byteArrayDeserializer: ByteArrayDeserializer
    Definition Classes
    Serializers
  6. final val byteArraySerde: Serde[Array[Byte]]
    Definition Classes
    Serializers
  7. final val byteArraySerializer: ByteArraySerializer
    Definition Classes
    Serializers
  8. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  11. def fetch(key: K, store: String, path: String): Future[V]

    Query for a key

  12. def fetchAll(store: String, path: String): Future[List[(K, V)]]

    Query all: Warning - this may be large depending on the data set

  13. def fetchApproxNumEntries(store: String, path: String): Future[Long]

    Query all hosts to find the sum of approximate number of entries

  14. def fetchRange(fromKey: K, toKey: K, store: String, path: String): Future[List[(K, V)]]

    Query for a range of keys

  15. def fetchWindowed(key: K, store: String, path: String, fromTime: Long, toTime: Long): Future[List[(Long, V)]]

    Query for a window

  16. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  17. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  18. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  19. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  20. implicit final def jsonMarshaller(implicit printer: Printer): ToEntityMarshaller[Json]
    Definition Classes
    BaseCirceSupport
  21. implicit final val jsonUnmarshaller: FromEntityUnmarshaller[Json]
    Definition Classes
    BaseCirceSupport
  22. lazy val logger: Logger
    Attributes
    protected
    Definition Classes
    LazyLogging
    Annotations
    @volatile()
  23. final val longSerde: Serde[Long]
    Definition Classes
    Serializers
  24. implicit final def marshaller[A](implicit arg0: Encoder[A], printer: Printer): ToEntityMarshaller[A]
    Definition Classes
    BaseCirceSupport
  25. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  26. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  27. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  28. final val stringDeserializer: StringDeserializer
    Definition Classes
    Serializers
  29. final val stringSerde: Serde[String]
    Definition Classes
    Serializers
  30. final val stringSerializer: StringSerializer
    Definition Classes
    Serializers
  31. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  32. def toString(): String
    Definition Classes
    AnyRef → Any
  33. implicit final def unmarshaller[A](implicit arg0: Decoder[A]): FromEntityUnmarshaller[A]
    Definition Classes
    FailFastUnmarshaller
  34. def unmarshallerContentTypes: Seq[ContentTypeRange]
    Definition Classes
    BaseCirceSupport
  35. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  36. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  37. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  38. final val windowedByteArrayDeserializer: WindowedDeserializer[Array[Byte]]
    Definition Classes
    Serializers
  39. final val windowedByteArraySerde: Serde[Windowed[Array[Byte]]]
    Definition Classes
    Serializers
  40. final val windowedByteArraySerializer: WindowedSerializer[Array[Byte]]
    Definition Classes
    Serializers
  41. final val windowedStringDeserializer: WindowedDeserializer[String]
    Definition Classes
    Serializers
  42. final val windowedStringSerde: Serde[Windowed[String]]
    Definition Classes
    Serializers
  43. final val windowedStringSerializer: WindowedSerializer[String]
    Definition Classes
    Serializers

Inherited from Serializers

Inherited from FailFastCirceSupport

Inherited from FailFastUnmarshaller

Inherited from BaseCirceSupport

Inherited from LazyLogging

Inherited from AnyRef

Inherited from Any

Ungrouped