Class MockBasicAuthStore

java.lang.Object

io.confluent.kafka.server.plugins.auth.oauth.MockBasicAuthStore

All Implemented Interfaces:

io.confluent.security.auth.metadata.AuthStore, Closeable, AutoCloseable, org.apache.kafka.common.Configurable

public class MockBasicAuthStore
extends Object
implements io.confluent.security.auth.metadata.AuthStore

Field Summary

Fields inherited from interface io.confluent.security.auth.metadata.AuthStore

INSTANCES

Constructor Summary

Constructors

Constructor	Description
MockBasicAuthStore(String brokerSessionId)

Method Summary

Modifier and Type	Method	Description
Collection<URL>	activeNodeUrls(String protocol)
io.confluent.security.auth.metadata.AuthCache	authCache()
void	close()
void	configure(Map<String,?> configs)
static MockBasicAuthStore	create()
static MockBasicAuthStore	create(String brokerSessionId)
boolean	isMasterWriter()
Integer	masterWriterId()
URL	masterWriterUrl(String protocol)
CompletionStage<Void>	startReader()
CompletionStage<Void>	startService(Collection<URL> serverUrls)
io.confluent.security.trustservice.store.TrustCache	trustCache()
io.confluent.security.auth.metadata.AuthWriter	writer()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.confluent.security.auth.metadata.AuthStore

updateStoreAuthCacheExternally

Constructor Details

MockBasicAuthStore

public MockBasicAuthStore(String brokerSessionId)

Method Details

create

public static MockBasicAuthStore create()

create

public static MockBasicAuthStore create(String brokerSessionId)

startReader

public CompletionStage<Void> startReader()

Specified by:

startReader in interface io.confluent.security.auth.metadata.AuthStore

startService

public CompletionStage<Void> startService(Collection<URL> serverUrls)

Specified by:

startService in interface io.confluent.security.auth.metadata.AuthStore

authCache

public io.confluent.security.auth.metadata.AuthCache authCache()

Specified by:

authCache in interface io.confluent.security.auth.metadata.AuthStore

trustCache

public io.confluent.security.trustservice.store.TrustCache trustCache()

Specified by:

trustCache in interface io.confluent.security.auth.metadata.AuthStore

writer

public io.confluent.security.auth.metadata.AuthWriter writer()

Specified by:

writer in interface io.confluent.security.auth.metadata.AuthStore

isMasterWriter

public boolean isMasterWriter()

Specified by:

isMasterWriter in interface io.confluent.security.auth.metadata.AuthStore

masterWriterUrl

public URL masterWriterUrl(String protocol)

Specified by:

masterWriterUrl in interface io.confluent.security.auth.metadata.AuthStore

masterWriterId

public Integer masterWriterId()

Specified by:

masterWriterId in interface io.confluent.security.auth.metadata.AuthStore

activeNodeUrls

public Collection<URL> activeNodeUrls(String protocol)

Specified by:

activeNodeUrls in interface io.confluent.security.auth.metadata.AuthStore

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable