New APIs and implementations for local and ccloud:
getSchemaRegistryForCluster(): Get the schema registry appropriate for the Kafka cluster. Born out of previously private implementations.
getSchemasForCluster(): Get the schema bindings appropriate for the Kafka cluster. These were previously coded as lambdas within the getTopicsForCluster() implementation.
getSchemasForTopicRegistry(): Get the schema bindings appropriate for the kafka cluster holding the topic.
Improve performance of getTopicsForCluster() implementations by refactoring and (possibly) fetching the topics and schemas concurrently, then matching them in separate code block.
CCloudResourceLoader.getInstance() typed to return CCloudResourceLoader instead of the base class ResourceLoader.
Improve docstrings.
topicQuickPick(): load schemas and topics concurrently using loader APIs.
Fix skipped test "loadTopicSchemas() should return schemas for CCloud Kafka topics when available", needed some additional setup at the ResourceLoader level.
Summary of Changes
getSchemaRegistryForCluster()
: Get the schema registry appropriate for the Kafka cluster. Born out of previously private implementations.getSchemasForCluster()
: Get the schema bindings appropriate for the Kafka cluster. These were previously coded as lambdas within thegetTopicsForCluster()
implementation.getSchemasForTopicRegistry()
: Get the schema bindings appropriate for the kafka cluster holding the topic.getTopicsForCluster()
implementations by refactoring and (possibly) fetching the topics and schemas concurrently, then matching them in separate code block.CCloudResourceLoader.getInstance()
typed to returnCCloudResourceLoader
instead of the base classResourceLoader
.topicQuickPick()
: load schemas and topics concurrently using loader APIs.loadTopicSchemas()
atoploader.getSchemasForTopicRegistry()
.getSchemasForTopicEnv()
, replaced byloader.getSchemasForTopicRegistry()
Any additional details or context that should be provided?
Pull request checklist
Please check if your PR fulfills the following (if applicable):
Tests
Other
.vsix
file?