public interface LocalStore
MetadataEvent
.Modifier and Type | Method and Description |
---|---|
void |
addMetadataEvent(String logicalCluster,
String topic,
io.confluent.protobuf.events.catalog.v1.MetadataEvent metadataEvent)
Add a topic
MetadataEvent to the store. |
void |
clear()
Clear all data in the store.
|
Set<String> |
logicalClusters()
Get all tenants in the store.
|
io.confluent.protobuf.events.catalog.v1.MetadataEvent |
metadataEvent(String topic)
Given a topic name with tenant prefix, get the
MetadataEvent of this topic. |
io.confluent.protobuf.events.catalog.v1.MetadataEvent |
removeMetadataEvent(String logicalCluster,
String topic)
Given tenant and the topic name, remove the
MetadataEvent of this topic
from the store. |
int |
size()
Get the total number of metadataEvents in this store.
|
Set<String> |
topics(String logicalCluster)
Given the tenant id, get the set of topics belong to this tenant.
|
void addMetadataEvent(String logicalCluster, String topic, io.confluent.protobuf.events.catalog.v1.MetadataEvent metadataEvent)
MetadataEvent
to the store.logicalCluster
- the tenant of this topictopic
- the topic name includes tenant prefixmetadataEvent
- the MetadataEvent of this topicSet<String> topics(String logicalCluster)
Set<String> logicalClusters()
io.confluent.protobuf.events.catalog.v1.MetadataEvent metadataEvent(String topic)
MetadataEvent
of this topic.null
otherwiseio.confluent.protobuf.events.catalog.v1.MetadataEvent removeMetadataEvent(String logicalCluster, String topic)
MetadataEvent
of this topic
from the store.null
otherwisevoid clear()
int size()