monitor

Documentation

Index

• Variables
• func ChooseActiveBackend(backendHealths map[*domain.Backend]*BackendStatus, useLowestIndex bool) *domain.Backend
• type BackendStatus
• type ClusterMonitor
  • func NewClusterMonitor(backends []*domain.Backend, healthcheckTimeout time.Duration, ...) *ClusterMonitor
  • func (c *ClusterMonitor) Monitor(stopChan <-chan interface{})
  • func (c *ClusterMonitor) QueryBackendHealth(backend *domain.Backend, healthMonitor *BackendStatus, client UrlGetter)
  • func (c *ClusterMonitor) RegisterBackendSubscriber(newSubscriber chan<- *domain.Backend)
  • func (c *ClusterMonitor) SetupCounters() *DecisionCounters
• type DecisionCounters
  • func NewDecisionCounters() *DecisionCounters
  • func (c *DecisionCounters) AddCondition(taskName string, predicate func() bool)
  • func (c *DecisionCounters) GetCount(name string) uint64
  • func (c *DecisionCounters) IncrementCount(name string)
  • func (c *DecisionCounters) ResetCount(name string)
  • func (c *DecisionCounters) Should(taskName string) bool
• type Monitor
• type Runner
  • func NewRunner(monitor Monitor, logger lager.Logger) Runner
  • func (pr Runner) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type UrlGetter
  • func HttpUrlGetterProvider(healthcheckTimeout time.Duration) UrlGetter

Variables

var UrlGetterProvider = HttpUrlGetterProvider

Functions

func ChooseActiveBackend

func ChooseActiveBackend(backendHealths map[*domain.Backend]*BackendStatus, useLowestIndex bool) *domain.Backend

Types

type BackendStatus

type BackendStatus struct {
	Index    int
	Healthy  bool
	Counters *DecisionCounters
}

type ClusterMonitor

type ClusterMonitor struct {
	// contains filtered or unexported fields
}

func NewClusterMonitor

func NewClusterMonitor(
	backends []*domain.Backend,
	healthcheckTimeout time.Duration,
	logger lager.Logger,
	useLowestIndex bool,
) *ClusterMonitor

func (*ClusterMonitor) Monitor

func (c *ClusterMonitor) Monitor(stopChan <-chan interface{})

func (*ClusterMonitor) QueryBackendHealth

func (c *ClusterMonitor) QueryBackendHealth(backend *domain.Backend, healthMonitor *BackendStatus, client UrlGetter)

func (*ClusterMonitor) RegisterBackendSubscriber

func (c *ClusterMonitor) RegisterBackendSubscriber(newSubscriber chan<- *domain.Backend)

func (*ClusterMonitor) SetupCounters

func (c *ClusterMonitor) SetupCounters() *DecisionCounters

type DecisionCounters

type DecisionCounters struct {
	// contains filtered or unexported fields
}

func NewDecisionCounters

func NewDecisionCounters() *DecisionCounters

func (*DecisionCounters) AddCondition

func (c *DecisionCounters) AddCondition(taskName string, predicate func() bool)

func (*DecisionCounters) GetCount

func (c *DecisionCounters) GetCount(name string) uint64

func (*DecisionCounters) IncrementCount

func (c *DecisionCounters) IncrementCount(name string)

func (*DecisionCounters) ResetCount

func (c *DecisionCounters) ResetCount(name string)

func (*DecisionCounters) Should

func (c *DecisionCounters) Should(taskName string) bool

type Monitor

type Monitor interface {
	Monitor(<-chan interface{})
}

type Runner

type Runner struct {
	// contains filtered or unexported fields
}

func NewRunner

func NewRunner(monitor Monitor, logger lager.Logger) Runner

func (Runner) Run

func (pr Runner) Run(signals <-chan os.Signal, ready chan<- struct{}) error

type UrlGetter

type UrlGetter interface {
	Get(url string) (*http.Response, error)
}

func HttpUrlGetterProvider

func HttpUrlGetterProvider(healthcheckTimeout time.Duration) UrlGetter