Versions in this module Expand all Collapse all v0 v0.9.0 Oct 8, 2020 Changes in this version + const DefaultConnectTimeout + const DefaultDownstreamBindAddr + const DefaultReadTimeout + const DefaultUpstreamBindAddr + type Config struct + Downstream Downstream + ServiceID string + ServiceName string + Upstreams []Upstream + type Downstream struct + AppNameHeaderName string + ConnectTimeout time.Duration + EnableForwardFor bool + LocalBindAddress string + LocalBindPort int + Protocol string + ReadTimeout time.Duration + TargetAddress string + TargetPort int + func (d Downstream) Equal(o Downstream) bool + type Logger interface + Debugf func(format string, args ...interface{}) + Errorf func(format string, args ...interface{}) + Infof func(format string, args ...interface{}) + Warnf func(format string, args ...interface{}) + func NewTestingLogger(t *testing.T) Logger + type TLS struct + CAs [][]byte + Cert []byte + Key []byte + func (t TLS) Equal(o TLS) bool + type Upstream struct + ConnectTimeout time.Duration + LocalBindAddress string + LocalBindPort int + Name string + Nodes []UpstreamNode + Protocol string + ReadTimeout time.Duration + func (n Upstream) Equal(o Upstream) bool + type UpstreamNode struct + Host string + Port int + Weight int + func (n UpstreamNode) Equal(o UpstreamNode) bool + func (n UpstreamNode) ID() string + type Watcher struct + C chan Config + func New(service string, consul *api.Client, log Logger) *Watcher + func (w *Watcher) Run() error