Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
36 commits
Select commit Hold shift + click to select a range
e0ec222
PMM-7 Fix Makefile.devcontainer usage
maxkondr May 15, 2026
bb77f81
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 15, 2026
9161af8
PMM-7 Fix testifylint linter warnings
maxkondr May 15, 2026
eb4b6f4
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 15, 2026
14987af
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 15, 2026
45cbd2f
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 18, 2026
3d21901
PMM-7 Fix testifylint linter warnings (p2)
maxkondr May 18, 2026
80b5b0e
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 18, 2026
60484a2
fix
maxkondr May 19, 2026
ef9fb5d
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 19, 2026
cdec538
fix
maxkondr May 19, 2026
c2b14ed
fix
maxkondr May 19, 2026
288cf32
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 19, 2026
5c8289c
fix
maxkondr May 19, 2026
03af8ba
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 20, 2026
e6aca31
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 20, 2026
d67473f
PMM-7 Fix intrange linter warnings
maxkondr May 20, 2026
eb25aa0
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 20, 2026
abfa5cd
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 20, 2026
a9536e7
fix
maxkondr May 20, 2026
663fbf9
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 20, 2026
51cd34d
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 21, 2026
c7563b4
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 21, 2026
4efd669
PMM-7 Fix modernize linter warnings
maxkondr May 21, 2026
16d9a32
Update managed/cmd/pmm-managed/main.go
maxkondr May 22, 2026
5b2e263
replace panic with Fatal for func in waitGroup
maxkondr May 22, 2026
fcb4aca
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 22, 2026
0528a5e
PMM-7 Fix staticcheck linter warnings
maxkondr May 22, 2026
20441b4
fix noerrcheck linter warnings
maxkondr May 22, 2026
e081731
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 22, 2026
4bb5383
fix: use res.Err() instead of nil err in BenchmarkCollector
Copilot May 22, 2026
fbcea6b
fix
maxkondr May 22, 2026
9f8637d
fix
maxkondr May 22, 2026
7e43ebf
fix
maxkondr May 22, 2026
d9153ad
fix
maxkondr May 22, 2026
9eaca2f
Merge branch 'v3' into PMM-7-linter-fixes
maxkondr May 26, 2026
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions admin/commands/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -119,8 +119,8 @@ func (cmd *ConfigCommand) args(globals *flags.GlobalFlags) ([]string, bool) {
res = append(res, "--force")
}

if cmd.MetricsModeFlags.MetricsMode != "" {
res = append(res, fmt.Sprintf("--metrics-mode=%s", cmd.MetricsModeFlags.MetricsMode))
if cmd.MetricsMode != "" {
res = append(res, fmt.Sprintf("--metrics-mode=%s", cmd.MetricsMode))
}

if len(cmd.DisableCollectors) != 0 {
Expand Down
2 changes: 1 addition & 1 deletion admin/commands/inventory/add_agent_node_exporter.go
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ func (cmd *AddAgentNodeExporterCommand) RunCmd() (commands.Result, error) {
PushMetrics: cmd.PushMetrics,
ExposeExporter: cmd.ExposeExporter,
DisableCollectors: commands.ParseDisableCollectors(cmd.DisableCollectors),
LogLevel: cmd.LogLevelNoFatalFlags.LogLevel.EnumValue(),
LogLevel: cmd.LogLevel.EnumValue(),
},
},
Context: commands.Ctx,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ func (cmd *AddAgentQANMongoDBMongologAgentCommand) RunCmd() (commands.Result, er
TLSCa: tlsCa,
AuthenticationMechanism: cmd.AuthenticationMechanism,
AuthenticationDatabase: cmd.AuthenticationDatabase,
LogLevel: cmd.LogLevelFatalFlags.LogLevel.EnumValue(),
LogLevel: cmd.LogLevel.EnumValue(),
},
},
Context: commands.Ctx,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,7 @@ func (cmd *AddAgentQANMongoDBProfilerAgentCommand) RunCmd() (commands.Result, er
TLSCertificateKeyFilePassword: cmd.TLSCertificateKeyFilePassword,
TLSCa: tlsCa,
AuthenticationMechanism: cmd.AuthenticationMechanism,
LogLevel: cmd.LogLevelFatalFlags.LogLevel.EnumValue(),
LogLevel: cmd.LogLevel.EnumValue(),
},
},
Context: commands.Ctx,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -107,15 +107,15 @@ func (cmd *AddAgentQANMySQLPerfSchemaAgentCommand) RunCmd() (commands.Result, er
Password: cmd.Password,
CustomLabels: *customLabels,
SkipConnectionCheck: cmd.SkipConnectionCheck,
DisableCommentsParsing: !cmd.CommentsParsingFlags.CommentsParsingEnabled(),
DisableCommentsParsing: !cmd.CommentsParsingEnabled(),
MaxQueryLength: cmd.MaxQueryLength,
DisableQueryExamples: cmd.DisableQueryExamples,
TLS: cmd.TLS,
TLSSkipVerify: cmd.TLSSkipVerify,
TLSCa: tlsCa,
TLSCert: tlsCert,
TLSKey: tlsKey,
LogLevel: cmd.LogLevelFatalFlags.LogLevel.EnumValue(),
LogLevel: cmd.LogLevel.EnumValue(),
},
},
Context: commands.Ctx,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,7 @@ func (cmd *AddAgentQANMySQLSlowlogAgentCommand) RunCmd() (commands.Result, error
Password: cmd.Password,
CustomLabels: *customLabels,
SkipConnectionCheck: cmd.SkipConnectionCheck,
DisableCommentsParsing: !cmd.CommentsParsingFlags.CommentsParsingEnabled(),
DisableCommentsParsing: !cmd.CommentsParsingEnabled(),
MaxQueryLength: cmd.MaxQueryLength,
DisableQueryExamples: cmd.DisableQueryExamples,
MaxSlowlogFileSize: strconv.FormatInt(int64(cmd.MaxSlowlogFileSize), 10),
Expand All @@ -129,7 +129,7 @@ func (cmd *AddAgentQANMySQLSlowlogAgentCommand) RunCmd() (commands.Result, error
TLSCa: tlsCa,
TLSCert: tlsCert,
TLSKey: tlsKey,
LogLevel: cmd.LogLevelFatalFlags.LogLevel.EnumValue(),
LogLevel: cmd.LogLevel.EnumValue(),
},
},
Context: commands.Ctx,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -98,15 +98,15 @@ func (cmd *AddAgentQANPostgreSQLPgStatementsAgentCommand) RunCmd() (commands.Res
Password: cmd.Password,
CustomLabels: *customLabels,
SkipConnectionCheck: cmd.SkipConnectionCheck,
DisableCommentsParsing: !cmd.CommentsParsingFlags.CommentsParsingEnabled(),
DisableCommentsParsing: !cmd.CommentsParsingEnabled(),
MaxQueryLength: cmd.MaxQueryLength,

TLS: cmd.TLS,
TLSSkipVerify: cmd.TLSSkipVerify,
TLSCa: tlsCa,
TLSCert: tlsCert,
TLSKey: tlsKey,
LogLevel: cmd.LogLevelFatalFlags.LogLevel.EnumValue(),
LogLevel: cmd.LogLevel.EnumValue(),
},
},
Context: commands.Ctx,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,7 @@ func (cmd *AddAgentQANPostgreSQLPgStatMonitorAgentCommand) RunCmd() (commands.Re
Password: cmd.Password,
CustomLabels: *customLabels,
SkipConnectionCheck: cmd.SkipConnectionCheck,
DisableCommentsParsing: !cmd.CommentsParsingFlags.CommentsParsingEnabled(),
DisableCommentsParsing: !cmd.CommentsParsingEnabled(),
MaxQueryLength: cmd.MaxQueryLength,
DisableQueryExamples: cmd.QueryExamplesDisabled,

Expand All @@ -109,7 +109,7 @@ func (cmd *AddAgentQANPostgreSQLPgStatMonitorAgentCommand) RunCmd() (commands.Re
TLSCa: tlsCa,
TLSCert: tlsCert,
TLSKey: tlsKey,
LogLevel: cmd.LogLevelFatalFlags.LogLevel.EnumValue(),
LogLevel: cmd.LogLevel.EnumValue(),
},
},
Context: commands.Ctx,
Expand Down
2 changes: 1 addition & 1 deletion admin/commands/inventory/add_agent_rds_exporter.go
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ func (cmd *AddAgentRDSExporterCommand) RunCmd() (commands.Result, error) {
DisableBasicMetrics: cmd.DisableBasicMetrics,
DisableEnhancedMetrics: cmd.DisableEnhancedMetrics,
PushMetrics: cmd.PushMetrics,
LogLevel: cmd.LogLevelFatalFlags.LogLevel.EnumValue(),
LogLevel: cmd.LogLevel.EnumValue(),
},
},
Context: commands.Ctx,
Expand Down
2 changes: 1 addition & 1 deletion admin/commands/management/add_external.go
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,7 @@ func (cmd *AddExternalCommand) RunCmd() (commands.Result, error) {
Cluster: cmd.Cluster,
ReplicationSet: cmd.ReplicationSet,
CustomLabels: *customLabels,
MetricsMode: cmd.MetricsModeFlags.MetricsMode.EnumValue(),
MetricsMode: cmd.MetricsMode.EnumValue(),
Group: cmd.Group,
SkipConnectionCheck: cmd.SkipConnectionCheck,
TLSSkipVerify: cmd.TLSSkipVerify,
Expand Down
2 changes: 1 addition & 1 deletion admin/commands/management/add_haproxy.go
Original file line number Diff line number Diff line change
Expand Up @@ -118,7 +118,7 @@ func (cmd *AddHAProxyCommand) RunCmd() (commands.Result, error) {
Cluster: cmd.Cluster,
ReplicationSet: cmd.ReplicationSet,
CustomLabels: *customLabels,
MetricsMode: cmd.MetricsModeFlags.MetricsMode.EnumValue(),
MetricsMode: cmd.MetricsMode.EnumValue(),
SkipConnectionCheck: cmd.SkipConnectionCheck,
TLSSkipVerify: cmd.TLSSkipVerify,
},
Expand Down
2 changes: 1 addition & 1 deletion admin/commands/management/add_mongodb.go
Original file line number Diff line number Diff line change
Expand Up @@ -198,7 +198,7 @@ func (cmd *AddMongoDBCommand) RunCmd() (commands.Result, error) {
AuthenticationMechanism: cmd.AuthenticationMechanism,
AuthenticationDatabase: cmd.AuthenticationDatabase,

MetricsMode: cmd.MetricsModeFlags.MetricsMode.EnumValue(),
MetricsMode: cmd.MetricsMode.EnumValue(),

EnableAllCollectors: cmd.EnableAllCollectors,
DisableCollectors: commands.ParseDisableCollectors(cmd.DisableCollectors),
Expand Down
4 changes: 2 additions & 2 deletions admin/commands/management/add_mysql.go
Original file line number Diff line number Diff line change
Expand Up @@ -230,7 +230,7 @@ func (cmd *AddMySQLCommand) RunCmd() (commands.Result, error) {
QANMysqlPerfschema: cmd.QuerySource == MysqlQuerySourcePerfSchema,

SkipConnectionCheck: cmd.SkipConnectionCheck,
DisableCommentsParsing: !cmd.CommentsParsingFlags.CommentsParsingEnabled(),
DisableCommentsParsing: !cmd.CommentsParsingEnabled(),
MaxQueryLength: cmd.MaxQueryLength,
DisableQueryExamples: cmd.DisableQueryExamples,

Expand All @@ -241,7 +241,7 @@ func (cmd *AddMySQLCommand) RunCmd() (commands.Result, error) {
TLSCert: tlsCert,
TLSKey: tlsKey,
TablestatsGroupTableLimit: tablestatsGroupTableLimit,
MetricsMode: cmd.MetricsModeFlags.MetricsMode.EnumValue(),
MetricsMode: cmd.MetricsMode.EnumValue(),
DisableCollectors: commands.ParseDisableCollectors(cmd.DisableCollectors),
LogLevel: cmd.LogLevel.EnumValue(),
ConnectionTimeout: commands.DurationString(cmd.ConnectionTimeout),
Expand Down
4 changes: 2 additions & 2 deletions admin/commands/management/add_postgresql.go
Original file line number Diff line number Diff line change
Expand Up @@ -191,7 +191,7 @@ func (cmd *AddPostgreSQLCommand) RunCmd() (commands.Result, error) {
Database: cmd.Database,
AgentPassword: cmd.AgentPassword,
SkipConnectionCheck: cmd.SkipConnectionCheck,
DisableCommentsParsing: !cmd.CommentsParsingFlags.CommentsParsingEnabled(),
DisableCommentsParsing: !cmd.CommentsParsingEnabled(),

PMMAgentID: cmd.PMMAgentID,
Environment: cmd.Environment,
Expand All @@ -210,7 +210,7 @@ func (cmd *AddPostgreSQLCommand) RunCmd() (commands.Result, error) {

MaxQueryLength: cmd.MaxQueryLength,
DisableQueryExamples: cmd.DisableQueryExamples,
MetricsMode: cmd.MetricsModeFlags.MetricsMode.EnumValue(),
MetricsMode: cmd.MetricsMode.EnumValue(),
DisableCollectors: commands.ParseDisableCollectors(cmd.DisableCollectors),
AutoDiscoveryLimit: cmd.AutoDiscoveryLimit,
MaxExporterConnections: cmd.MaxExporterConnections,
Expand Down
2 changes: 1 addition & 1 deletion admin/commands/management/add_proxysql.go
Original file line number Diff line number Diff line change
Expand Up @@ -151,7 +151,7 @@ func (cmd *AddProxySQLCommand) RunCmd() (commands.Result, error) {
SkipConnectionCheck: cmd.SkipConnectionCheck,
TLS: cmd.TLS,
TLSSkipVerify: cmd.TLSSkipVerify,
MetricsMode: cmd.MetricsModeFlags.MetricsMode.EnumValue(),
MetricsMode: cmd.MetricsMode.EnumValue(),
DisableCollectors: commands.ParseDisableCollectors(cmd.DisableCollectors),
LogLevel: cmd.LogLevel.EnumValue(),
ConnectionTimeout: commands.DurationString(cmd.ConnectionTimeout),
Expand Down
2 changes: 1 addition & 1 deletion admin/commands/management/add_valkey.go
Original file line number Diff line number Diff line change
Expand Up @@ -160,7 +160,7 @@ func (cmd *AddValkeyCommand) RunCmd() (commands.Result, error) {
TLSCa: tlsCa,
TLSCert: tlsCert,
TLSKey: tlsKey,
MetricsMode: cmd.MetricsModeFlags.MetricsMode.EnumValue(),
MetricsMode: cmd.MetricsMode.EnumValue(),
LogLevel: cmd.LogLevel.EnumValue(),
ConnectionTimeout: commands.DurationString(cmd.ConnectionTimeout),
},
Expand Down
2 changes: 1 addition & 1 deletion admin/commands/management/register.go
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ func (cmd *RegisterCommand) RunCmd() (commands.Result, error) {
AgentPassword: cmd.AgentPassword,

Reregister: cmd.Force,
MetricsMode: cmd.MetricsModeFlags.MetricsMode.EnumValue(),
MetricsMode: cmd.MetricsMode.EnumValue(),
DisableCollectors: commands.ParseDisableCollectors(cmd.DisableCollectors),
},
Context: commands.Ctx,
Expand Down
32 changes: 21 additions & 11 deletions agent/agents/mongodb/mongolog/internal/monitor_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,7 @@ import (

"github.com/percona/percona-toolkit/src/go/mongolib/proto"
"github.com/sirupsen/logrus"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"go.mongodb.org/mongo-driver/bson"

Expand Down Expand Up @@ -63,9 +64,9 @@ func TestCollector(t *testing.T) {

file, err := os.Create(destination) //nolint:gosec
require.NoError(t, err)
file.Close() //nolint:errcheck
require.NoError(t, file.Close())
t.Cleanup(func() {
os.Remove(destination) //nolint:errcheck
assert.NoError(t, os.Remove(destination))
})

reader, err := filereader.NewContinuousFileReader(destination, l)
Expand All @@ -87,12 +88,11 @@ func TestCollector(t *testing.T) {
go readSourceWriteDestination(ctx, t, errChan, fmt.Sprintf("./testdata/logs/%s.log", test), destination, delay)

var wg sync.WaitGroup
wg.Add(2)
wg.Add(1)
monitor.Start(ctx, docsChan, doneChan, &wg)

var data []proto.SystemProfile
go func() {
defer wg.Done()
wg.Go(func() {
for {
select {
case <-ctx.Done():
Expand All @@ -106,7 +106,7 @@ func TestCollector(t *testing.T) {
data = append(data, row)
}
}
}()
})

err = <-errChan
require.NoError(t, err)
Expand All @@ -120,7 +120,8 @@ func TestCollector(t *testing.T) {

expectedFile := fmt.Sprintf("./testdata/expected/%s", test)
if os.Getenv("REFRESH_TEST_DATA") != "" {
writeData(t, data, expectedFile)
err = writeData(t, data, expectedFile)
require.NoError(t, err)
return
}

Expand Down Expand Up @@ -218,7 +219,9 @@ func writeData(t *testing.T, data []proto.SystemProfile, name string) error {
if err != nil {
return err
}
defer file.Close() //nolint:errcheck
t.Cleanup(func() {
assert.NoError(t, file.Close())
})

jsonData, err := dataToJSON(t, data)
if err != nil {
Expand All @@ -239,7 +242,9 @@ func readData(t *testing.T, name string) ([]proto.SystemProfile, error) {
if err != nil {
return nil, err
}
defer file.Close() //nolint:errcheck
t.Cleanup(func() {
assert.NoError(t, file.Close())
})

var data []proto.SystemProfile
err = json.NewDecoder(file).Decode(&data)
Expand All @@ -258,6 +263,10 @@ func readSourceWriteDestination(ctx context.Context, t *testing.T, errChan chan
errChan <- err
return
}
defer func() {
assert.NoError(t, srcFile.Close())
}()

scanner := bufio.NewScanner(srcFile)
var lines []string
for scanner.Scan() {
Expand All @@ -273,14 +282,15 @@ func readSourceWriteDestination(ctx context.Context, t *testing.T, errChan chan
errChan <- err
return
}
srcFile.Close() //nolint:errcheck

dstFile, err := os.Create(destination) //nolint:gosec
if err != nil {
errChan <- err
return
}
defer dstFile.Close() //nolint:errcheck
defer func() {
assert.NoError(t, dstFile.Close())
}()

writer := bufio.NewWriter(dstFile)
for _, line := range lines {
Expand Down
Loading
Loading