Skip to content
Permalink

Comparing changes

This is a direct comparison between two commits made in this repository or its related repositories. View the default comparison for this range or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: Icinga/icinga-kubernetes
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: 4ce99a2041a988e176fb7b13eb446deed65263ac
Choose a base ref
..
head repository: Icinga/icinga-kubernetes
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: 604cfa12abcbac5cf7dd628c60179794ded44e7e
Choose a head ref
Showing with 6 additions and 5 deletions.
  1. +2 −2 pkg/sync/logs.go
  2. +4 −3 pkg/sync/sync.go
4 changes: 2 additions & 2 deletions pkg/sync/logs.go
View file
Original file line number Diff line number Diff line change
@@ -94,9 +94,9 @@ func (ls *LogSync) MaintainList(ctx context.Context, addChannel <-chan contracts
g, ctx := errgroup.WithContext(ctx)

deletes := make(chan any)
defer close(deletes)

g.Go(func() error {
defer close(deletes)

for {
select {
case <-ctx.Done():
7 changes: 4 additions & 3 deletions pkg/sync/sync.go
View file
Original file line number Diff line number Diff line change
@@ -181,9 +181,6 @@ func (s *sync) Run(ctx context.Context) error {
return multiplexDelete.Run(ctx)
})

deleteToStream := make(chan any)
defer close(deleteToStream)

g.Go(func() error {
for {
select {
@@ -201,7 +198,11 @@ func (s *sync) Run(ctx context.Context) error {
}
}
})

deleteToStream := make(chan any)
g.Go(func() error {
defer close(deleteToStream)

for {
select {
case kdelete, more := <-deleteChannel: