Documentation
¶
Index ¶
- type FailoverStrategy
- type FailoverTarget
- type Forwarder
- func (f *Forwarder) CancelPendingWrite(svcName string)
- func (f *Forwarder) GetCachedStrategies(svcName string) (string, string)
- func (f *Forwarder) Run(ctx context.Context) error
- func (f *Forwarder) SetRedirector(r writeCanceler)
- func (f *Forwarder) UpdateConfig(failoverStrategies map[string]FailoverStrategy, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FailoverStrategy ¶
type FailoverStrategy struct {
ConnectTimeout string `yaml:"connect_timeout" json:"connect_timeout" mapstructure:"connect_timeout"`
Targets []FailoverTarget `yaml:"targets" json:"targets" mapstructure:"targets"`
}
type FailoverTarget ¶
type FailoverTarget struct {
Service string `yaml:"service" json:"service" mapstructure:"service"`
Datacenter string `yaml:"datacenter" json:"datacenter" mapstructure:"datacenter"`
Namespace string `yaml:"namespace" json:"namespace" mapstructure:"namespace"`
ServiceSubset string `yaml:"service_subset" json:"service_subset" mapstructure:"service_subset"`
}
type Forwarder ¶
type Forwarder struct {
// contains filtered or unexported fields
}
func (*Forwarder) CancelPendingWrite ¶
func (*Forwarder) GetCachedStrategies ¶
func (*Forwarder) SetRedirector ¶
func (f *Forwarder) SetRedirector(r writeCanceler)
func (*Forwarder) UpdateConfig ¶
func (f *Forwarder) UpdateConfig(failoverStrategies map[string]FailoverStrategy, dampeningPeriod, minDampeningPeriod string)
Click to show internal directories.
Click to hide internal directories.