Skip to content

Commit

Permalink
Update
Browse files Browse the repository at this point in the history
  • Loading branch information
jgwest committed Aug 14, 2024
1 parent b9f765d commit 4bfde1a
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
2 changes: 1 addition & 1 deletion agent/connection.go
Original file line number Diff line number Diff line change
Expand Up @@ -176,7 +176,7 @@ func (a *Agent) handleStreamEvents() error {
})
logCtx.Info("Starting to send events to event stream")
var err error
// Continously read events from the 'outbox', and send them to principal, while the stream is connected
// Continuously read events from the 'outbox', and send them to principal, while the stream is connected
for a.IsConnected() && err == nil {
err = a.sender(stream)
if err != nil {
Expand Down
3 changes: 2 additions & 1 deletion internal/manager/application/application.go
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,8 @@ type ApplicationManager struct {
Metrics *metrics.ApplicationClientMetrics
Role manager.ManagerRole
// Mode is only set when Role is ManagerRoleAgent
Mode manager.ManagerMode
Mode manager.ManagerMode
// Namespace is not guaranteed to have a value in all cases. For instance, this value is empty for principal when the principal is running on cluster.
Namespace string
// managedApps is a list of apps we manage, key is qualified name in form '(namespace of Application CR)/(name of Application CR)', value is not used.
// - acquire 'lock' before accessing
Expand Down

0 comments on commit 4bfde1a

Please sign in to comment.