Packages

object Resolver extends Serializable

Companion object. Lets us create a Resolver from a Json

Linear Supertypes
Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Resolver
  2. Serializable
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. final case class ResolverConfig(cacheSize: Int, cacheTtl: Option[TTL], repositoryRefs: List[Json]) extends Product with Serializable
  2. sealed trait ResolverResult[+K, +A] extends AnyRef

    The result of doing a lookup with the resolver, carrying information on whether the cache was used

  3. type SchemaContentListLookupResult = ResolverResult[SchemaKey, SchemaContentList]
  4. case class SchemaItem(schema: Json, supersededBy: SupersededBy) extends Product with Serializable

    The result of doing schema lookup

    The result of doing schema lookup

    schema

    Schema json

    supersededBy

    Superseding schema version if the schema is superseded by another schema. Otherwise, it is None.

  5. type SchemaListKey = (Vendor, Name, Model)
  6. type SchemaListLookupResult = ResolverResult[SchemaListKey, SchemaList]
  7. type SchemaLookupResult = ResolverResult[SchemaKey, SchemaItem]
  8. case class SchemaResolutionError(schemaKey: SchemaKey, error: ResolutionError) extends Product with Serializable
  9. type SupersededBy = Option[Full]

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. val SelfDescribingKey: SchemaKey
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def bootstrap[F[_]](implicit arg0: Monad[F], arg1: CreateResolverCache[F]): F[Resolver[F]]

    A Resolver which only looks at our embedded repo

  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  10. def fromConfig[F[_]](config: ResolverConfig)(implicit arg0: Monad[F], arg1: CreateResolverCache[F]): EitherT[F, DecodingFailure, Resolver[F]]
  11. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  13. def init[F[_]](cacheSize: Int, cacheTtl: Option[TTL], refs: Registry*)(implicit arg0: Monad[F], arg1: CreateResolverCache[F]): F[Resolver[F]]

    Constructs a Resolver instance from an arg array of RepositoryRefs.

    Constructs a Resolver instance from an arg array of RepositoryRefs.

    cacheSize

    The size of the cache

    cacheTtl

    Optional time to live for schemas

    refs

    Any RepositoryRef to add to this resolver

    returns

    a configured Resolver instance

  14. def initPure(refs: InMemory*): Resolver[Id]

    Construct a pure resolver, working only with in-memory registries, no cache, no clock

  15. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  16. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  18. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  19. def parse[F[_]](config: Json)(implicit arg0: Monad[F], arg1: CreateResolverCache[F]): F[Either[DecodingFailure, Resolver[F]]]

    Construct a Resolver instance from a Json *and* validates against embedded schema (hence side-effect)

    Construct a Resolver instance from a Json *and* validates against embedded schema (hence side-effect)

    config

    The JSON containing the configuration for this resolver

    returns

    a configured Resolver instance

  20. def parseConfig(config: Json): Either[DecodingFailure, ResolverConfig]
  21. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  22. def toString(): String
    Definition Classes
    AnyRef → Any
  23. def traverseRepos[F[_], A](get: (Registry) => F[Either[RegistryError, A]], remaining: List[Registry], tried: LookupFailureMap)(implicit arg0: Monad[F], arg1: RegistryLookup[F], arg2: Clock[F]): F[Either[LookupFailureMap, A]]

    Tail-recursive function to find our schema in one of our repositories

    Tail-recursive function to find our schema in one of our repositories

    get

    a function to get an entity from first registry

    remaining

    A List of repositories we have to look in (not-tried yet or with non-404 error)

    tried

    A Map of repositories with their accumulated errors we have looked in fruitlessly so far

    returns

    either a Success-boxed schema (as a Json), or a Failure-boxing of Map of repositories with all their accumulated errors

  24. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  25. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  26. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  27. object ResolverResult

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped