Skip to content

Commit

Permalink
rollback to previous version
Browse files Browse the repository at this point in the history
  • Loading branch information
mattdurham committed Dec 13, 2023
1 parent 9d4f828 commit d81d463
Showing 1 changed file with 2 additions and 11 deletions.
13 changes: 2 additions & 11 deletions pkg/flow/componenttest/componenttest.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,6 @@ import (
"time"

"github.com/grafana/agent/service/labelstore"
"github.com/grafana/ckit/memconn"
"github.com/prometheus/client_golang/prometheus"
"go.uber.org/atomic"

Expand All @@ -25,15 +24,12 @@ type Controller struct {
reg component.Registration
log log.Logger

httpport atomic.Int32

onRun sync.Once
running chan struct{}
runError atomic.Error

innerMut sync.Mutex
inner component.Component
httpService *memconn.Listener
innerMut sync.Mutex
inner component.Component

exportsMut sync.Mutex
exports component.Exports
Expand Down Expand Up @@ -67,11 +63,6 @@ func NewControllerFromReg(l log.Logger, reg component.Registration) *Controller
}
}

// HTTPPort returns the port exposed by the controller.
func (c *Controller) HTTPPort() int {
return int(c.httpport.Load())
}

func (c *Controller) onStateChange(e component.Exports) {
c.exportsMut.Lock()
changed := !reflect.DeepEqual(c.exports, e)
Expand Down

0 comments on commit d81d463

Please sign in to comment.