Packages

final case class Resolver[F[_]](repos: List[Registry], cache: Option[ResolverCache[F]]) extends Product with Serializable

Resolves schemas from one or more Iglu schema registries

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

Instance Constructors

  1. new Resolver(repos: List[Registry], cache: Option[ResolverCache[F]])

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. val cache: Option[ResolverCache[F]]
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def fetchSchemas(vendor: Vendor, name: Name, model: Model)(implicit F: Monad[F], L: RegistryLookup[F], C: Clock[F]): EitherT[F, ResolutionError, List[SelfDescribingSchema[Json]]]

    Get list of full self-describing schemas available on Iglu Server for particular vendor/name pair

  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. def listSchemas(vendor: Vendor, name: Name, model: Model)(implicit F: Monad[F], L: RegistryLookup[F], C: Clock[F]): F[Either[ResolutionError, SchemaList]]

    Get list of available schemas for particular vendor and name part Server supposed to return them in proper order

  12. def listSchemasLike(schemaKey: SchemaKey)(implicit F: Monad[F], L: RegistryLookup[F], C: Clock[F]): F[Either[ResolutionError, SchemaList]]

    Vendor, name, model are extracted from supplied schema key to call on the listSchemas.

    Vendor, name, model are extracted from supplied schema key to call on the listSchemas. The important difference from listSchemas is that it would invalidate cache, if returned list did not contain SchemaKey supplied in argument. Making it a safer option is latest schema bound is known.

  13. def listSchemasLikeResult(schemaKey: SchemaKey)(implicit F: Monad[F], L: RegistryLookup[F], C: Clock[F]): F[Either[ResolutionError, SchemaListLookupResult]]

    Vendor, name, model are extracted from supplied schema key to call on the listSchemas.

    Vendor, name, model are extracted from supplied schema key to call on the listSchemas. The important difference from listSchemas is that it would invalidate cache, if returned list did not contain SchemaKey supplied in argument. Making it a safer option is latest schema bound is known.

  14. def listSchemasResult(vendor: Vendor, name: Name, model: Model, mustIncludeKey: Option[SchemaKey] = None)(implicit F: Monad[F], L: RegistryLookup[F], C: Clock[F]): F[Either[ResolutionError, SchemaListLookupResult]]

    Get list of available schemas for particular vendor and name part Has an extra argument mustIncludeKey which is used to invalidate cache if SchemaKey supplied in it is not in the list.

    Get list of available schemas for particular vendor and name part Has an extra argument mustIncludeKey which is used to invalidate cache if SchemaKey supplied in it is not in the list. Server supposed to return them in proper order

  15. def listSchemasResult(vendor: Vendor, name: Name, model: Model)(implicit F: Monad[F], L: RegistryLookup[F], C: Clock[F]): F[Either[ResolutionError, SchemaListLookupResult]]

    Get list of available schemas for particular vendor and name part Server supposed to return them in proper order

  16. def lookupSchema(schemaKey: SchemaKey)(implicit F: Monad[F], L: RegistryLookup[F], C: Clock[F]): F[Either[ResolutionError, Json]]

    Tries to find the given schema in any of the provided repository refs If any of repositories gives non-non-found error, lookup will retried

    Tries to find the given schema in any of the provided repository refs If any of repositories gives non-non-found error, lookup will retried

    schemaKey

    The SchemaKey uniquely identifying the schema in Iglu

    returns

    a Validation boxing either the Schema's Json on Success, or an error String on Failure

  17. def lookupSchemaResult(schemaKey: SchemaKey, resolveSupersedingSchema: Boolean = false)(implicit F: Monad[F], L: RegistryLookup[F], C: Clock[F]): F[Either[ResolutionError, SchemaLookupResult]]

    Tries to find the given schema in any of the provided repository refs If any of repositories gives non-non-found error, lookup will retried

    Tries to find the given schema in any of the provided repository refs If any of repositories gives non-non-found error, lookup will retried

    schemaKey

    The SchemaKey uniquely identifying the schema in Iglu

    resolveSupersedingSchema

    Specify whether superseding schema version should be taken into account

    returns

    a Resolver.ResolverResult boxing the schema Json on success, or a ResolutionError on failure

  18. def lookupSchemasUntil(maxSchemaKey: SchemaKey)(implicit F: Monad[F], L: RegistryLookup[F], C: Clock[F]): F[Either[SchemaResolutionError, NonEmptyList[SelfDescribingSchema[Json]]]]

    The variant of lookupSchemasUntilResult that returns the result that isn't wrapped with ResolverResult

  19. def lookupSchemasUntilResult(maxSchemaKey: SchemaKey)(implicit F: Monad[F], L: RegistryLookup[F], C: Clock[F]): F[Either[SchemaResolutionError, SchemaContentListLookupResult]]

    Looks up all the schemas with the same model until maxSchemaKey.

    Looks up all the schemas with the same model until maxSchemaKey. For the schemas of previous revisions, it starts with addition = 0 and increments it until a NotFound.

    maxSchemaKey

    The SchemaKey until which schemas of the same model should get returned

    returns

    All the schemas if all went well, Resolver.SchemaResolutionError with the first error that happened while looking up the schemas if something went wrong.

  20. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  21. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  22. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  23. def productElementNames: Iterator[String]
    Definition Classes
    Product
  24. def productIterator: Iterator[Any]
    Definition Classes
    Product
  25. val repos: List[Registry]
  26. def resolutionErrorToFailureMap(resolutionError: SchemaResolutionError): LookupFailureMap
  27. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  28. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  29. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  30. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

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 Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped