first commit

Author: KirillKurdyukov

slo/playground/configs/compose.yaml

@@ -7,7 +7,7 @@ x-runtime: &runtime
   network_mode: host
 
 x-ydb-node: &ydb-node
-  image: cr.yandex/crptqonuodf51kdj7a7d/ydb:24.2.7
+  image: cr.yandex/crptqonuodf51kdj7a7d/ydb:24.3.11.13
   restart: always
   <<: *runtime
   volumes:
@@ -270,31 +270,31 @@ services:
       tenant-init:
         condition: service_completed_successfully
 
-  prometheus:
-    image: prom/prometheus
-    restart: unless-stopped
-    <<: *runtime
-    ports:
-      - "9090:9090"
-    volumes:
-      - ./prometheus.yml:/etc/prometheus/prometheus.yml
-    deploy: &monitoring-deploy
-      resources:
-        limits:
-          cpus: "0.1"
-          memory: 1000M
-        reservations:
-          cpus: "0.001"
-          memory: 50M
-
-  prometheus-pushgateway:
-    image: prom/pushgateway
-    restart: unless-stopped
-    <<: *runtime
-    ports:
-      - "9091:9091"
-    deploy:
-      <<: *monitoring-deploy
+#  prometheus:
+#    image: prom/prometheus
+#    restart: unless-stopped
+#    <<: *runtime
+#    ports:
+#      - "9090:9090"
+#    volumes:
+#      - ./prometheus.yml:/etc/prometheus/prometheus.yml
+#    deploy: &monitoring-deploy
+#      resources:
+#        limits:
+#          cpus: "0.1"
+#          memory: 1000M
+#        reservations:
+#          cpus: "0.001"
+#          memory: 50M
+#
+#  prometheus-pushgateway:
+#    image: prom/pushgateway
+#    restart: unless-stopped
+#    <<: *runtime
+#    ports:
+#      - "9091:9091"
+#    deploy:
+#      <<: *monitoring-deploy
 
 #  chaos:
 #    image: docker:latest

slo/playground/configs/ydb.yaml

@@ -1,3 +1,6 @@
+p_q_config:
+  require_credentials_in_new_protocol: false
+
 actor_system_config:
   cpu_count: 1
   node_type: STORAGE
@@ -40,7 +43,7 @@ domains_config:
             vdisk_kind: Default
   state_storage:
     - ring:
-        node: [1]
+        node: [ 1 ]
         nto_select: 1
       ssid: 1
 host_configs:

slo/src/AdoNet/Program.cs

@@ -3,4 +3,4 @@
 using AdoNet;
 using Internal;
 
-await Cli.Run(new SloContext(), args);
+await Cli.Run(new SloTableContext(), args);

slo/src/AdoNet/SloContext.cs renamed to slo/src/AdoNet/SloTableContext.cs

@@ -8,7 +8,7 @@
 
 namespace AdoNet;
 
-public class SloContext : SloContext<YdbDataSource>
+public class SloTableContext : SloTableContext<YdbDataSource>
 {
     private readonly AsyncPolicy _policy = Policy.Handle<YdbException>(exception => exception.IsTransient)
         .WaitAndRetryAsync(10, attempt => TimeSpan.FromMilliseconds(attempt * 10),
@@ -103,6 +103,9 @@ protected override Task<YdbDataSource> CreateClient(Config config)
         var port = splitEndpoint[1].Split(":")[1];
 
         return Task.FromResult(new YdbDataSource(new YdbConnectionStringBuilder
-            { UseTls = useTls, Host = host, Port = int.Parse(port), Database = config.Db, LoggerFactory = Factory }));
+        {
+            UseTls = useTls, Host = host, Port = int.Parse(port), Database = config.Db,
+            LoggerFactory = ISloContext.Factory
+        }));
     }
 }

slo/src/Internal/Cli.cs

@@ -101,7 +101,7 @@ public static class Cli
         CreateCommand, RunCommand
     };
 
-    public static async Task<int> Run<T>(SloContext<T> sloContext, string[] args) where T : IDisposable
+    public static async Task<int> Run(ISloContext sloContext, string[] args)
     {
         CreateCommand.SetHandler(async createConfig => { await sloContext.Create(createConfig); },
             new CreateConfigBinder(EndpointArgument, DbArgument, ResourceYdbPath, MinPartitionsCountOption,

slo/src/Internal/SloContext.cs renamed to slo/src/Internal/SloTableContext.cs

@@ -7,10 +7,10 @@
 
 namespace Internal;
 
-public abstract class SloContext<T> where T : IDisposable
+public interface ISloContext
 {
     // ReSharper disable once StaticMemberInGenericType
-    protected static readonly ILoggerFactory Factory =
+    public static readonly ILoggerFactory Factory =
         LoggerFactory.Create(builder =>
         {
             builder.AddConsole().SetMinimumLevel(LogLevel.Information);
@@ -19,7 +19,15 @@ public abstract class SloContext<T> where T : IDisposable
             builder.AddFilter("Ydb.Sdk.Services.Topic", LogLevel.Debug);
         });
 
-    protected static readonly ILogger Logger = Factory.CreateLogger<SloContext<T>>();
+
+    public Task Create(CreateConfig config);
+
+    public Task Run(RunConfig runConfig);
+}
+
+public abstract class SloTableContext<T> : ISloContext where T : IDisposable
+{
+    protected static readonly ILogger Logger = ISloContext.Factory.CreateLogger<SloTableContext<T>>();
 
     private volatile int _maxId;
 

slo/src/TableService/Program.cs

@@ -3,4 +3,4 @@
 using Internal;
 using TableService;
 
-return await Cli.Run(new SloContext(), args);
+return await Cli.Run(new SloTableContext(), args);

slo/src/TableService/SloContext.cs renamed to slo/src/TableService/SloTableContext.cs

@@ -7,7 +7,7 @@
 
 namespace TableService;
 
-public class SloContext : SloContext<TableClient>
+public class SloTableContext : SloTableContext<TableClient>
 {
     private readonly TxControl _txControl = TxControl.BeginSerializableRW().Commit();
     protected override string Job => "TableService";
@@ -79,6 +79,7 @@ protected override async Task Create(TableClient client, string createTableSql,
 
     protected override async Task<TableClient> CreateClient(Config config)
     {
-        return new TableClient(await Driver.CreateInitialized(new DriverConfig(config.Endpoint, config.Db), Factory));
+        return new TableClient(await Driver.CreateInitialized(new DriverConfig(config.Endpoint, config.Db),
+            ISloContext.Factory));
     }
 }

slo/src/TopicService/Program.cs

@@ -0,0 +1,4 @@
+using Internal;
+using TopicService;
+
+return await Cli.Run(new SloTopicContext(), args);