Remove File Plugin #1521
Conversation
Codecov Report❌ Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## refactor-instance-watcher #1521 +/- ##
============================================================
Coverage ? 84.85%
============================================================
Files ? 102
Lines ? 13466
Branches ? 0
============================================================
Hits ? 11427
Misses ? 1523
Partials ? 516
Continue to review full report in Codecov by Sentry.
🚀 New features to boost your workflow:
|
internal/nginx/nginx_plugin.go
Outdated
| } | ||
| n.nginxService.UpdateResource(ctx, resourceUpdate) | ||
| slog.DebugContext(ctx, "Nginx plugin received update resource message") | ||
| slog.DebugContext(ctx, "NginxPlugin plugin received update resource message") |
There was a problem hiding this comment.
| slog.DebugContext(ctx, "NginxPlugin plugin received update resource message") | |
| slog.DebugContext(ctx, "NGINX plugin received update resource message") |
Probably should update other similar debug messages
internal/nginx/nginx_plugin.go
Outdated
| } | ||
| case bus.ConnectionCreatedTopic: | ||
| if logger.ServerType(ctxWithMetadata) == n.serverType.String() { | ||
| slog.DebugContext(ctxWithMetadata, "Resource plugin received connection created message") |
There was a problem hiding this comment.
| slog.DebugContext(ctxWithMetadata, "Resource plugin received connection created message") | |
| slog.DebugContext(ctxWithMetadata, "NGINX plugin received connection created message") |
internal/nginx/nginx_plugin.go
Outdated
| n.handleConfigApplyRequest(ctxWithMetadata, msg) | ||
| } | ||
| default: | ||
| slog.DebugContext(ctx, "Unknown topic", "topic", msg.Topic) |
There was a problem hiding this comment.
| slog.DebugContext(ctx, "Unknown topic", "topic", msg.Topic) | |
| slog.DebugContext(ctx, "NGINX plugin received message from unknown topic", "topic", msg.Topic) |
internal/nginx/nginx_plugin.go
Outdated
| func (n *Nginx) Reconfigure(ctx context.Context, agentConfig *config.Config) error { | ||
| slog.DebugContext(ctx, "Nginx plugin is reconfiguring to update agent configuration") | ||
| func (n *NginxPlugin) Reconfigure(ctx context.Context, agentConfig *config.Config) error { | ||
| slog.DebugContext(ctx, "NginxPlugin plugin is reconfiguring to update agent configuration") |
There was a problem hiding this comment.
| slog.DebugContext(ctx, "NginxPlugin plugin is reconfiguring to update agent configuration") | |
| slog.DebugContext(ctx, "NGINX plugin is reconfiguring to update agent configuration") |
internal/nginx/nginx_plugin.go
Outdated
| "github.com/nginx/agent/v3/internal/config" | ||
| response "github.com/nginx/agent/v3/internal/datasource/proto" | ||
| "github.com/nginx/agent/v3/internal/file" | ||
| grpc2 "github.com/nginx/agent/v3/internal/grpc" |
There was a problem hiding this comment.
do you have to name this import grpc2? I dont think it is conflicting with any other import.
internal/nginx/nginx_plugin.go
Outdated
| n.reloadSuccessful(ctx, configContext, dpResponse) | ||
| } | ||
|
|
||
| func (n *NginxPlugin) failedConfigApply(ctx context.Context, correlationID, instanceID string, applyErr error) { |
There was a problem hiding this comment.
| func (n *NginxPlugin) failedConfigApply(ctx context.Context, correlationID, instanceID string, applyErr error) { | |
| func (n *NginxPlugin) rollbackConfigApply(ctx context.Context, correlationID, instanceID string, applyErr error) { |
internal/nginx/nginx_plugin.go
Outdated
|
|
||
| n.agentConfigMutex.Lock() | ||
| defer n.agentConfigMutex.Unlock() | ||
| func (n *NginxPlugin) reloadSuccessful(ctx context.Context, |
There was a problem hiding this comment.
I wonder would it be possible to combine the reloadSuccessful & completeConfigApply into one function?
Proposed changes
Checklist
Before creating a PR, run through this checklist and mark each as complete.
CONTRIBUTINGdocumentmake install-toolsand have attached any dependency changes to this pull requestREADME.md)