Class MockTrustCache

java.lang.Object
io.confluent.kafka.server.plugins.auth.oauth.MockTrustCache
All Implemented Interfaces:
io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey, io.confluent.security.auth.store.data.AuthValue>, io.confluent.security.trustservice.store.TrustCache
public class MockTrustCache extends Object implements io.confluent.security.trustservice.store.TrustCache, io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey, io.confluent.security.auth.store.data.AuthValue>

  • Constructor Summary

    Constructors
    Constructor
    Description
    MockTrustCache()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    fail(int partition, String errorMessage)
     
    Collection<io.confluent.security.trustservice.store.data.IdentityPool>
    findIdentityPools(String providerId)
     
    Collection<String>
    findIdentityProviderIds(String organizationId)
     
    io.confluent.security.auth.store.data.AuthValue
    get(io.confluent.security.auth.store.data.AuthKey key)
     
    io.confluent.security.trustservice.store.data.IdentityPool
    identityPool(String poolId)
     
    Map<String, io.confluent.security.trustservice.store.data.IdentityPool>
    identityPools()
     
    io.confluent.security.trustservice.store.data.IdentityProvider
    identityProvider(String providerid)
     
    org.jose4j.jwk.JsonWebKeySet
    jsonWebKeySet(String jwtIssuer)
     
    Map<String, org.jose4j.jwk.JsonWebKeySet>
    jsonWebKeySets()
     
    Map<? extends io.confluent.security.auth.store.data.AuthKey, ? extends io.confluent.security.auth.store.data.AuthValue>
    map(String entryType)
     
    io.confluent.security.auth.store.data.AuthValue
    put(io.confluent.security.auth.store.data.AuthKey key, io.confluent.security.auth.store.data.AuthValue value)
     
    io.confluent.security.authentication.oidc.RefreshTokenInfo
    refreshTokenInfo(String refreshTokenKey)
     
    io.confluent.security.auth.store.data.AuthValue
    remove(io.confluent.security.auth.store.data.AuthKey key)
     
    io.confluent.security.store.MetadataStoreStatus
    status(int partition)
     

    Methods inherited from class java.lang.Object

    equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • MockTrustCache

      public MockTrustCache()

  • Method Details

    • get

      public io.confluent.security.auth.store.data.AuthValue get(io.confluent.security.auth.store.data.AuthKey key)
      Specified by:
      get in interface io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey, io.confluent.security.auth.store.data.AuthValue>

    • put

      public io.confluent.security.auth.store.data.AuthValue put(io.confluent.security.auth.store.data.AuthKey key, io.confluent.security.auth.store.data.AuthValue value)
      Specified by:
      put in interface io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey, io.confluent.security.auth.store.data.AuthValue>

    • remove

      public io.confluent.security.auth.store.data.AuthValue remove(io.confluent.security.auth.store.data.AuthKey key)
      Specified by:
      remove in interface io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey, io.confluent.security.auth.store.data.AuthValue>

    • map

      public Map<? extends io.confluent.security.auth.store.data.AuthKey, ? extends io.confluent.security.auth.store.data.AuthValue> map(String entryType)
      Specified by:
      map in interface io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey, io.confluent.security.auth.store.data.AuthValue>

    • fail

      public void fail(int partition, String errorMessage)
      Specified by:
      fail in interface io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey, io.confluent.security.auth.store.data.AuthValue>

    • status

      public io.confluent.security.store.MetadataStoreStatus status(int partition)
      Specified by:
      status in interface io.confluent.security.store.KeyValueStore<io.confluent.security.auth.store.data.AuthKey, io.confluent.security.auth.store.data.AuthValue>

    • jsonWebKeySets

      public Map<String, org.jose4j.jwk.JsonWebKeySet> jsonWebKeySets()
      Specified by:
      jsonWebKeySets in interface io.confluent.security.trustservice.store.TrustCache

    • jsonWebKeySet

      public org.jose4j.jwk.JsonWebKeySet jsonWebKeySet(String jwtIssuer)
      Specified by:
      jsonWebKeySet in interface io.confluent.security.trustservice.store.TrustCache

    • identityPool

      public io.confluent.security.trustservice.store.data.IdentityPool identityPool(String poolId)
      Specified by:
      identityPool in interface io.confluent.security.trustservice.store.TrustCache

    • identityPools

      public Map<String, io.confluent.security.trustservice.store.data.IdentityPool> identityPools()
      Specified by:
      identityPools in interface io.confluent.security.trustservice.store.TrustCache

    • refreshTokenInfo

      public io.confluent.security.authentication.oidc.RefreshTokenInfo refreshTokenInfo(String refreshTokenKey)
      Specified by:
      refreshTokenInfo in interface io.confluent.security.trustservice.store.TrustCache

    • findIdentityPools

      public Collection<io.confluent.security.trustservice.store.data.IdentityPool> findIdentityPools(String providerId)
      Specified by:
      findIdentityPools in interface io.confluent.security.trustservice.store.TrustCache

    • findIdentityProviderIds

      public Collection<String> findIdentityProviderIds(String organizationId)
      Specified by:
      findIdentityProviderIds in interface io.confluent.security.trustservice.store.TrustCache

    • identityProvider

      public io.confluent.security.trustservice.store.data.IdentityProvider identityProvider(String providerid)
      Specified by:
      identityProvider in interface io.confluent.security.trustservice.store.TrustCache