Simplifying creation and publishing of schemas while building applications
A system includes a memory and a processor, where the processor is in communication with the memory. The processor is configured to receive a request to build an application, where the application is associated with source code. The source code is analyzed to detect whether a first interface is implemented within the application. The source code is parsed to determine an invocation of the first interface. Inputs and outputs (I/Os) from the first interface are determined based on the invocation of the first interface. A model is generated based on the I/Os associated with the first interface, where the model includes a structure of each of the I/Os. The model is published to a registry.
1. A system, comprising:
a memory; and
a processor in communication with the memory, wherein the processor is configured to:
receive a request to build an application that is operable to stream data to other applications, wherein the application is associated with source code;
analyze the source code to detect whether a first interface is implemented within the application;
parse the source code to determine an invocation of the first interface;
determine inputs and outputs (I/Os) from the first interface based on the invocation of the first interface;
generate a model based on the I/Os associated with the first interface, wherein the model includes a structure of each of the I/Os; and
publish the model to a registry,
wherein analyzing the source code comprises:
parsing the source code to determine whether a library is included in the application; and
determining whether the library is associated with the first interface.
2. The system of claim 1 , wherein the first interface is a streaming interface.
3. The system of claim 2 , wherein the streaming interface is a Kafka interface.
4. The system of claim 1 , wherein the model is a schema.
5. The system of claim 1 , wherein the model is written in JavaScript Object Notation (JSON).
6. The system of claim 1 , wherein the model is written in Avro schema.
7. The system of claim 1 , wherein the model is written in Protobuf schema.
8. The system of claim 1 , wherein the processor is further configured to build the application.
9. A method, comprising:
receiving a request to build an application that is operable to stream data to other applications, wherein the application is associated with source code;
analyzing the source code to detect whether a first interface is implemented within the application;
parsing the source code to determine an invocation of the first interface;
determining inputs and outputs (I/Os) from the first interface based on the invocation of the first interface;
generating a model based on the I/Os associated with the first interface, wherein the model includes a structure of each of the I/Os; and
publishing the model to a registry,
wherein analyzing the source code comprises:
parsing the source code to determine whether a library is included in the application; and
determining whether the library is associated with the first interface.
10. The method of claim 9 , wherein the first interface is a streaming interface.
11. The method of claim 10 , wherein the streaming interface is a Kafka interface.
12. The method of claim 9 , wherein the model is a schema.
13. The method of claim 9 , wherein the model is written in JavaScript Object Notation (JSON).
14. The method of claim 9 , wherein the model is written in Avro schema.
15. The method of claim 9 , wherein the model is written in Protobuf schema.
16. The method of claim 9 , wherein the processor is further configured to build the application.
17. A non-transitory machine readable medium storing code, which when executed by a processor is configured to:
receive a request to build an application that is operable to stream data to other applications, wherein the application is associated with source code;
analyze the source code to detect whether a first interface is implemented within the application;
parse the source code to determine an invocation of the first interface;
determine inputs and outputs (I/Os) from the first interface based on the invocation of the first interface;
generate a model based on the I/Os associated with the first interface, wherein the model includes a structure of each of the I/Os; and
publish the model to a registry,
wherein analyzing the source code comprises:
parsing the source code to determine whether a library is included in the application; and
determining whether the library is associated with the first interface.