something something metrics
This commit is contained in:
@@ -36,8 +36,9 @@ public class Program
|
|||||||
|
|
||||||
var metrics = services.GetRequiredService<MareMetrics>();
|
var metrics = services.GetRequiredService<MareMetrics>();
|
||||||
|
|
||||||
metrics.SetGaugeTo(MetricsAPI.GaugePairs, context.ClientPairs.Count());
|
metrics.SetGaugeTo(MetricsAPI.GaugeUsersRegistered, context.Users.AsNoTracking().Count());
|
||||||
metrics.SetGaugeTo(MetricsAPI.GaugePairsPaused, context.ClientPairs.Count(p => p.IsPaused));
|
metrics.SetGaugeTo(MetricsAPI.GaugePairs, context.ClientPairs.AsNoTracking().Count());
|
||||||
|
metrics.SetGaugeTo(MetricsAPI.GaugePairsPaused, context.ClientPairs.AsNoTracking().Count(p => p.IsPaused));
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -67,6 +67,7 @@ public class SystemInfoService : IHostedService, IDisposable
|
|||||||
_mareMetrics.SetGaugeTo(MetricsAPI.GaugeGroups, db.Groups.AsNoTracking().Count());
|
_mareMetrics.SetGaugeTo(MetricsAPI.GaugeGroups, db.Groups.AsNoTracking().Count());
|
||||||
_mareMetrics.SetGaugeTo(MetricsAPI.GaugeGroupPairs, db.GroupPairs.AsNoTracking().Count());
|
_mareMetrics.SetGaugeTo(MetricsAPI.GaugeGroupPairs, db.GroupPairs.AsNoTracking().Count());
|
||||||
_mareMetrics.SetGaugeTo(MetricsAPI.GaugeGroupPairsPaused, db.GroupPairs.AsNoTracking().Count(p => p.IsPaused));
|
_mareMetrics.SetGaugeTo(MetricsAPI.GaugeGroupPairsPaused, db.GroupPairs.AsNoTracking().Count(p => p.IsPaused));
|
||||||
|
_mareMetrics.SetGaugeTo(MetricsAPI.GaugeUsersRegistered, db.Users.AsNoTracking().Count());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -185,8 +185,6 @@ public class UserCleanupService : IHostedService
|
|||||||
dbContext.Users.Remove(user);
|
dbContext.Users.Remove(user);
|
||||||
|
|
||||||
await dbContext.SaveChangesAsync().ConfigureAwait(false);
|
await dbContext.SaveChangesAsync().ConfigureAwait(false);
|
||||||
|
|
||||||
metrics.DecGauge(MetricsAPI.GaugeUsersRegistered, 1);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public Task StopAsync(CancellationToken cancellationToken)
|
public Task StopAsync(CancellationToken cancellationToken)
|
||||||
|
|||||||
@@ -864,8 +864,6 @@ public class MareModule : InteractionModuleBase
|
|||||||
|
|
||||||
_botServices.Logger.LogInformation("User registered: {userUID}", user.UID);
|
_botServices.Logger.LogInformation("User registered: {userUID}", user.UID);
|
||||||
|
|
||||||
_botServices.Metrics.IncGauge(MetricsAPI.GaugeUsersRegistered, 1);
|
|
||||||
|
|
||||||
lodestoneAuth.StartedAt = null;
|
lodestoneAuth.StartedAt = null;
|
||||||
lodestoneAuth.User = user;
|
lodestoneAuth.User = user;
|
||||||
lodestoneAuth.LodestoneAuthString = null;
|
lodestoneAuth.LodestoneAuthString = null;
|
||||||
|
|||||||
@@ -15,9 +15,6 @@ public class Program
|
|||||||
{
|
{
|
||||||
var services = scope.ServiceProvider;
|
var services = scope.ServiceProvider;
|
||||||
using var dbContext = services.GetRequiredService<MareDbContext>();
|
using var dbContext = services.GetRequiredService<MareDbContext>();
|
||||||
var metrics = services.GetRequiredService<MareMetrics>();
|
|
||||||
|
|
||||||
metrics.SetGaugeTo(MetricsAPI.GaugeUsersRegistered, dbContext.Users.Count());
|
|
||||||
|
|
||||||
var options = host.Services.GetService<IConfigurationService<ServicesConfiguration>>();
|
var options = host.Services.GetService<IConfigurationService<ServicesConfiguration>>();
|
||||||
var optionsServer = host.Services.GetService<IConfigurationService<ServerConfiguration>>();
|
var optionsServer = host.Services.GetService<IConfigurationService<ServerConfiguration>>();
|
||||||
|
|||||||
@@ -33,10 +33,7 @@ public class Startup
|
|||||||
}, Configuration.GetValue(nameof(MareConfigurationBase.DbContextPoolSize), 1024));
|
}, Configuration.GetValue(nameof(MareConfigurationBase.DbContextPoolSize), 1024));
|
||||||
|
|
||||||
services.AddSingleton(m => new MareMetrics(m.GetService<ILogger<MareMetrics>>(), new List<string> { },
|
services.AddSingleton(m => new MareMetrics(m.GetService<ILogger<MareMetrics>>(), new List<string> { },
|
||||||
new List<string>
|
new List<string> {}));
|
||||||
{
|
|
||||||
MetricsAPI.GaugeUsersRegistered
|
|
||||||
}));
|
|
||||||
|
|
||||||
var noRetryConfig = new MethodConfig
|
var noRetryConfig = new MethodConfig
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -9,7 +9,7 @@ public class MareConfigurationBase : IMareConfiguration
|
|||||||
{
|
{
|
||||||
public int DbContextPoolSize { get; set; } = 100;
|
public int DbContextPoolSize { get; set; } = 100;
|
||||||
public string ShardName { get; set; } = string.Empty;
|
public string ShardName { get; set; } = string.Empty;
|
||||||
public int MetricsPort { get; set; } = 4981;
|
public int MetricsPort { get; set; }
|
||||||
|
|
||||||
public T GetValue<T>(string key)
|
public T GetValue<T>(string key)
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user