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 orgId, 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 orgId, 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 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 orgId,
 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 orgId,
 String providerId)

Specified by:

identityProvider in interface io.confluent.security.trustservice.store.TrustCache