Cloud/Services/Broker/IBrokerConsumer.cs

@@ -0,0 +1,7 @@
+namespace Cloud.Services.Broker
+{
+    public interface IBrokerConsumer 
+    {
+        // TODO: добавить методы для получения данных
+    }
+}

Cloud/Services/Broker/IBrokerProdurcer.cs

@@ -0,0 +1,9 @@
+using Cloud.Services.Broker.Support;
+
+namespace Cloud.Services.Broker
+{
+    public interface IBrokerProdurcer 
+    {
+        Task ProduceAsync(string topic, Command command);
+    }
+}

Cloud/Services/Broker/IBrokerService.cs

@@ -0,0 +1,10 @@
+using Cloud.Services.Broker.Support;
+
+namespace Cloud.Services.Broker
+{
+    public interface IBrokerService 
+    {
+        Task<CommandResult> Produce(Command command);
+        Task<T> Consume<T>(string topic);
+    }
+}

Cloud/Services/Broker/Implement/Kafka/KafkaService.cs

@@ -0,0 +1,17 @@
+using Cloud.Services.Broker.Support;
+
+namespace Cloud.Services.Broker.Implement.Kafka
+{
+    public class KafkaService : IBrokerService
+    {
+        public Task<T> Consume<T>(string topic)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<CommandResult> Produce(Command command)
+        {
+            throw new NotImplementedException();
+        }
+    }
+}

Cloud/Services/Broker/Support/Command.cs

@@ -0,0 +1,9 @@
+namespace Cloud.Services.Broker.Support
+{
+    public class Command 
+    {
+        public int Id { get; set; }
+        public int GreenhouseId { get; set; }
+        public string CommandName { get; set; } = null!;
+    }
+}

Cloud/Services/Broker/Support/CommandResult.cs

@@ -0,0 +1,9 @@
+namespace Cloud.Services.Broker.Support
+{
+    public class CommandResult 
+    {
+        public int CommandId { get; set; }
+        public int GreenhouseId { get; set; }
+        public string ResultMessage { get; set; } = string.Empty;
+    }
+}

Cloud/Services/Broker/Support/GreenhouseInfo.cs

@@ -0,0 +1,12 @@
+namespace Cloud.Services.Broker.Support
+{
+    public class GreenhouseInfo 
+    {
+        public int Id { get; set; }
+        public int PercentWater { get; set; }
+        public int SoilTemperature { get; set; }
+        public bool PumpStatus { get; set; }
+        public bool HeatingStatus { get; set; }
+        public bool AutoWateringStatus { get; set; }
+    }
+}