public class MockBasicAuthStore extends Object implements io.confluent.security.auth.metadata.AuthStore
Constructor and Description |
---|
MockBasicAuthStore(String brokerSessionId) |
Modifier and Type | Method and 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() |
public MockBasicAuthStore(String brokerSessionId)
public static MockBasicAuthStore create()
public static MockBasicAuthStore create(String brokerSessionId)
public CompletionStage<Void> startReader()
startReader
in interface io.confluent.security.auth.metadata.AuthStore
public CompletionStage<Void> startService(Collection<URL> serverUrls)
startService
in interface io.confluent.security.auth.metadata.AuthStore
public io.confluent.security.auth.metadata.AuthCache authCache()
authCache
in interface io.confluent.security.auth.metadata.AuthStore
public io.confluent.security.trustservice.store.TrustCache trustCache()
trustCache
in interface io.confluent.security.auth.metadata.AuthStore
public io.confluent.security.auth.metadata.AuthWriter writer()
writer
in interface io.confluent.security.auth.metadata.AuthStore
public boolean isMasterWriter()
isMasterWriter
in interface io.confluent.security.auth.metadata.AuthStore
public URL masterWriterUrl(String protocol)
masterWriterUrl
in interface io.confluent.security.auth.metadata.AuthStore
public Integer masterWriterId()
masterWriterId
in interface io.confluent.security.auth.metadata.AuthStore
public Collection<URL> activeNodeUrls(String protocol)
activeNodeUrls
in interface io.confluent.security.auth.metadata.AuthStore
public void close()
close
in interface Closeable
close
in interface AutoCloseable