Packages

sealed abstract class SchemaRegistryClientSettings[F[_]] extends AnyRef

Describes how to create a SchemaRegistryClient and which settings should be used. Settings are tailored for default implementation CachedSchemaRegistryClient.

Use SchemaRegistryClient#apply to create an instance.

Source
SchemaRegistryClientSettings.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SchemaRegistryClientSettings
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def baseUrl: String

    The base URL of the schema registry service.

  2. abstract def createSchemaRegistryClient: F[SchemaRegistryClient]

    Creates a new SchemaRegistryClient using the settings contained within this SchemaRegistryClientSettings.

  3. abstract def maxCacheSize: Int

    The maximum number of schemas to cache in the client.

    The maximum number of schemas to cache in the client.

    The default value is 1000.

  4. abstract def properties: Map[String, String]

    Properties provided when creating a SchemaRegistryClient.

    Properties provided when creating a SchemaRegistryClient. Numerous functions in SchemaRegistryClientSettings add properties here as necessary.

  5. abstract def withAuth(auth: Auth): SchemaRegistryClientSettings[F]

    Creates a new SchemaRegistryClientSettings instance with the specified authentication details.

  6. abstract def withCreateSchemaRegistryClient(createSchemaRegistryClientWith: (String, Int, Map[String, String]) => F[SchemaRegistryClient]): SchemaRegistryClientSettings[F]

    Creates a new SchemaRegistryClientSettings instance with the specified function for creating new instances of SchemaRegistryClient from settings.

    Creates a new SchemaRegistryClientSettings instance with the specified function for creating new instances of SchemaRegistryClient from settings. The arguments are baseUrl, maxCacheSize, and properties.

  7. abstract def withMaxCacheSize(maxCacheSize: Int): SchemaRegistryClientSettings[F]

    Creates a new SchemaRegistryClientSettings instance with the specified maxCacheSize.

  8. abstract def withProperties(properties: Map[String, String]): SchemaRegistryClientSettings[F]

    Creates a new SchemaRegistryClientSettings instance including properties with the specified keys and values.

  9. abstract def withProperties(properties: (String, String)*): SchemaRegistryClientSettings[F]

    Creates a new SchemaRegistryClientSettings instance including properties with the specified keys and values.

  10. abstract def withProperty(key: String, value: String): SchemaRegistryClientSettings[F]

    Creates a new SchemaRegistryClientSettings instance including a property with the specified key and value.

Concrete 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. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  14. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  15. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  16. def toString(): String
    Definition Classes
    AnyRef → Any
  17. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  18. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  19. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped