buildersoftio · eneshoxha · Feb 8, 2025 · Jan 21, 2025 · Jan 21, 2025 · Feb 8, 2025
diff --git a/Assets/cortex-all.svg b/Assets/cortex-all.svg
diff --git a/Cortex.sln b/Cortex.sln
@@ -53,6 +53,10 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Cortex.Streams.PostgreSQL",
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Cortex.Streams.MongoDb", "src\Cortex.Streams.MongoDb\Cortex.Streams.MongoDb.csproj", "{FC86D3AB-778D-45D7-AF36-1F89FC16DE55}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Cortex.Streams.Elasticsearch", "src\Cortex.Streams.Elasticsearch\Cortex.Streams.Elasticsearch.csproj", "{4D1F117D-48D7-47AD-9DAC-3B2DB45E628A}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Cortex.Types", "src\Cortex.Types\Cortex.Types.csproj", "{64E12D4C-FBB2-4004-8316-C886CBFC614B}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -158,6 +162,14 @@ Global
 		{FC86D3AB-778D-45D7-AF36-1F89FC16DE55}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{FC86D3AB-778D-45D7-AF36-1F89FC16DE55}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{FC86D3AB-778D-45D7-AF36-1F89FC16DE55}.Release|Any CPU.Build.0 = Release|Any CPU
+		{4D1F117D-48D7-47AD-9DAC-3B2DB45E628A}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{4D1F117D-48D7-47AD-9DAC-3B2DB45E628A}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{4D1F117D-48D7-47AD-9DAC-3B2DB45E628A}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{4D1F117D-48D7-47AD-9DAC-3B2DB45E628A}.Release|Any CPU.Build.0 = Release|Any CPU
+		{64E12D4C-FBB2-4004-8316-C886CBFC614B}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{64E12D4C-FBB2-4004-8316-C886CBFC614B}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{64E12D4C-FBB2-4004-8316-C886CBFC614B}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{64E12D4C-FBB2-4004-8316-C886CBFC614B}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

diff --git a/README.md b/README.md
@@ -1,3 +1,5 @@
+![Cortex](./Assets/cortex-all.svg)
+
 # Cortex Data Framework
 
 **Cortex Data Framework** is a robust, extensible platform designed to facilitate real-time data streaming, processing, and state management. It provides developers with a comprehensive suite of tools and libraries to build scalable, high-performance data pipelines tailored to diverse use cases. By abstracting underlying streaming technologies and state management solutions, Cortex Data Framework enables seamless integration, simplified development workflows, and enhanced maintainability for complex data-driven applications.
@@ -6,7 +8,7 @@
 [![GitHub License](https://img.shields.io/github/license/buildersoftio/cortex)](https://github.com/buildersoftio/cortex/blob/master/LICENSE)
 [![NuGet Version](https://img.shields.io/nuget/v/Cortex.Streams?label=Cortex.Streams)](https://www.nuget.org/packages/Cortex.Streams)
 [![GitHub contributors](https://img.shields.io/github/contributors/buildersoftio/cortex)](https://github.com/buildersoftio/cortex)
-[![Discord Shield](https://discord.com/api/guilds/1310034212371566612/widget.png?style=shield)](https://discord.com/invite/4Gfe6mhJ)
+[![Discord Shield](https://discord.com/api/guilds/1310034212371566612/widget.png?style=shield)](https://discord.gg/JnMJV33QHu)
 
 ## Key Features
 - **Modular Architecture**: Comprises distinct, interchangeable modules for streaming, state management, and connectors, allowing developers to choose components that best fit their requirements.
@@ -72,6 +74,9 @@
 - **Cortex.Streams.Http:** Implementation of Http Source and Sink operators.
 [![NuGet Version](https://img.shields.io/nuget/v/Cortex.Streams.Http?label=Cortex.Streams.Http)](https://www.nuget.org/packages/Cortex.Streams.Http)
 
+- **Cortex.Streams.Elasticsearch:** Implementation of Elasticsearch Sink operators.
+[![NuGet Version](https://img.shields.io/nuget/v/Cortex.Streams.Elasticsearch?label=Cortex.Streams.Elasticsearch)](https://www.nuget.org/packages/Cortex.Streams.Elasticsearch)
+
 - **Cortex.Streams.CDC.MSSqlServer:** CDC adapter for Microsoft Sql Server.
 [![NuGet Version](https://img.shields.io/nuget/v/Cortex.Streams.CDC.MSSqlServer?label=Cortex.Streams.CDC.MSSqlServer)](https://www.nuget.org/packages/Cortex.Streams.CDC.MSSqlServer)
 
@@ -111,6 +116,9 @@
 - **Cortex.Telemetry.OpenTelemetry:** Adds support for Open Telemetry.
 [![NuGet Version](https://img.shields.io/nuget/v/Cortex.Telemetry.OpenTelemetry?label=Cortex.Telemetry.OpenTelemetry)](https://www.nuget.org/packages/Cortex.Telemetry.OpenTelemetry)
 
+- **Cortex.Types:** Use complex types like OneOf, AllOf and AnyOf
+[![NuGet Version](https://img.shields.io/nuget/v/Cortex.Types?label=Cortex.Types)](https://www.nuget.org/packages/Cortex.Types)
+
 
 ## Getting Started
 
@@ -324,7 +332,7 @@ We'd love to hear from you! Whether you have questions, feedback, or need suppor
 - Email: cortex@buildersoft.io
 - Website: https://buildersoft.io
 - GitHub Issues: [Cortex Data Framework Issues](https://github.com/buildersoftio/cortex/issues)
-- Join our Discord Community: [![Discord Shield](https://discord.com/api/guilds/1310034212371566612/widget.png?style=shield)](https://discord.com/invite/4Gfe6mhJ)
+- Join our Discord Community: [![Discord Shield](https://discord.com/api/guilds/1310034212371566612/widget.png?style=shield)](https://discord.gg/JnMJV33QHu)
 
 
 Thank you for using Cortex Data Framework! We hope it empowers you to build scalable and efficient data processing pipelines effortlessly.

diff --git a/src/Cortex.Mediator/Assets/andyX.png b/src/Cortex.Mediator/Assets/andyX.png
diff --git a/src/Cortex.States.Cassandra/Assets/cortex.png b/src/Cortex.States.Cassandra/Assets/cortex.png
diff --git a/src/Cortex.States.ClickHouse/Assets/cortex.png b/src/Cortex.States.ClickHouse/Assets/cortex.png
diff --git a/src/Cortex.States.MSSqlServer/Assets/cortex.png b/src/Cortex.States.MSSqlServer/Assets/cortex.png
diff --git a/src/Cortex.States.MongoDb/Assets/cortex.png b/src/Cortex.States.MongoDb/Assets/cortex.png
diff --git a/src/Cortex.States.PostgreSQL/Assets/cortex.png b/src/Cortex.States.PostgreSQL/Assets/cortex.png
diff --git a/src/Cortex.States.RocksDb/Assets/cortex.png b/src/Cortex.States.RocksDb/Assets/cortex.png
diff --git a/src/Cortex.States.SQLite/Assets/cortex.png b/src/Cortex.States.SQLite/Assets/cortex.png
diff --git a/src/Cortex.States/Assets/cortex.png b/src/Cortex.States/Assets/cortex.png
diff --git a/src/Cortex.Streams.AWSSQS/Assets/cortex.png b/src/Cortex.Streams.AWSSQS/Assets/cortex.png
diff --git a/src/Cortex.Streams.AzureBlobStorage/Assets/cortex.png b/src/Cortex.Streams.AzureBlobStorage/Assets/cortex.png
diff --git a/src/Cortex.Streams.AzureServiceBus/Assets/cortex.png b/src/Cortex.Streams.AzureServiceBus/Assets/cortex.png
diff --git a/src/Cortex.Streams.Elasticsearch/Assets/cortex.png b/src/Cortex.Streams.Elasticsearch/Assets/cortex.png
diff --git a/src/Cortex.Streams.Elasticsearch/Assets/license.md b/src/Cortex.Streams.Elasticsearch/Assets/license.md
@@ -0,0 +1,20 @@
+The MIT License (MIT)
+
+Copyright (c) 2025 Buildersoft
+
+Permission is hereby granted, free of charge, to any person obtaining a copy of
+this software and associated documentation files (the "Software"), to deal in
+the Software without restriction, including without limitation the rights to
+use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
+the Software, and to permit persons to whom the Software is furnished to do so,
+subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
+IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
+CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
diff --git a/src/Cortex.Streams.Elasticsearch/Cortex.Streams.Elasticsearch.csproj b/src/Cortex.Streams.Elasticsearch/Cortex.Streams.Elasticsearch.csproj
@@ -0,0 +1,56 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+	<PropertyGroup>
+		<TargetFrameworks>net9.0;net8.0</TargetFrameworks>
+
+		<AssemblyVersion>1.0.1</AssemblyVersion>
+		<FileVersion>1.0.1</FileVersion>
+		<Product>Buildersoft Cortex Framework</Product>
+		<Company>Buildersoft</Company>
+		<Authors>Buildersoft,EnesHoxha</Authors>
+		<Copyright>Copyright © Buildersoft 2025</Copyright>
+
+		<Description>Cortex Data Framework is a robust, extensible platform designed to facilitate real-time data streaming, processing, and state management. It provides developers with a comprehensive suite of tools and libraries to build scalable, high-performance data pipelines tailored to diverse use cases. By abstracting underlying streaming technologies and state management solutions, Cortex Data Framework enables seamless integration, simplified development workflows, and enhanced maintainability for complex data-driven applications.	</Description>
+
+
+		<RepositoryUrl>https://github.com/buildersoftio/cortex</RepositoryUrl>
+		<PackageTags>cortex cdc eda streaming distributed streams states elasticsearch</PackageTags>
+
+		<Version>1.0.1</Version>
+		<PackageLicenseFile>license.md</PackageLicenseFile>
+		<PackageIcon>cortex.png</PackageIcon>
+		<PackageId>Cortex.Streams.Elasticsearch</PackageId>
+		<GeneratePackageOnBuild>True</GeneratePackageOnBuild>
+		<IsPublishable>True</IsPublishable>
+		<PackageRequireLicenseAcceptance>True</PackageRequireLicenseAcceptance>
+		<RepositoryType></RepositoryType>
+		<PackageReleaseNotes>Just as the Cortex in our brains handles complex processing efficiently, Cortex Data Framework brings brainpower to your data management!	</PackageReleaseNotes>
+		<PackageProjectUrl>https://buildersoft.io/</PackageProjectUrl>
+		<PackageReadmeFile>README.md</PackageReadmeFile>
+	</PropertyGroup>
+
+	<ItemGroup>
+		<None Include="..\..\README.md">
+			<Pack>True</Pack>
+			<PackagePath>\</PackagePath>
+		</None>
+		<None Include="Assets\cortex.png">
+			<Pack>True</Pack>
+			<PackagePath></PackagePath>
+		</None>
+		<None Include="Assets\license.md">
+			<Pack>True</Pack>
+			<PackagePath></PackagePath>
+		</None>
+	</ItemGroup>
+
+	<ItemGroup>
+		<PackageReference Include="Elastic.Clients.Elasticsearch" Version="8.17.1" />
+		<PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="9.0.0" />
+	</ItemGroup>
+
+	<ItemGroup>
+		<ProjectReference Include="..\Cortex.Streams\Cortex.Streams.csproj" />
+	</ItemGroup>
+
+</Project>