Documentation ¶
Index ¶
Constants ¶
View Source
const (
FlushARPBinPath = "/var/vcap/packages/switchboard/bin/flusharp"
)
Variables ¶
View Source
var UrlGetterProvider = HttpUrlGetterProvider
Functions ¶
func ChooseActiveBackend ¶
func ChooseActiveBackend(backendHealths map[*domain.Backend]*BackendStatus) *domain.Backend
Types ¶
type ARPFlusher ¶
type ARPFlusher struct {
// contains filtered or unexported fields
}
func (ARPFlusher) RemoveEntry ¶
func (a ARPFlusher) RemoveEntry(ip net.IP) error
type ArpEntryRemover ¶
func NewARPFlusher ¶
func NewARPFlusher(runner CmdRunner) ArpEntryRemover
type BackendStatus ¶
type BackendStatus struct { Index int Healthy bool Counters *DecisionCounters }
type Cluster ¶
type Cluster struct {
// contains filtered or unexported fields
}
func NewCluster ¶
func (*Cluster) QueryBackendHealth ¶
func (c *Cluster) QueryBackendHealth(backend *domain.Backend, healthMonitor *BackendStatus, client UrlGetter)
func (*Cluster) SetupCounters ¶
func (c *Cluster) 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 ExecCmdRunner ¶
type ExecCmdRunner struct{}
Directories ¶
Path | Synopsis |
---|---|
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
Click to show internal directories.
Click to hide internal directories.