Versions in this module Expand all Collapse all v1 v1.2.0 Jun 25, 2018 Changes in this version + func TestEchoConn(t testing.T, conn net.Conn, prefix string) + func TestLocalAddr(port int) string + func UpstreamResolverFromClient(client *api.Client, cfg UpstreamConfig) connect.Resolver + type AgentConfigWatcher struct + func NewAgentConfigWatcher(client *api.Client, proxyID string, logger *log.Logger) (*AgentConfigWatcher, error) + func (w *AgentConfigWatcher) Close() error + func (w *AgentConfigWatcher) Watch() <-chan *Config + type Config struct + ProxiedServiceName string + ProxiedServiceNamespace string + PublicListener PublicListenerConfig + Telemetry lib.TelemetryConfig + Token string + Upstreams []UpstreamConfig + func ParseConfigFile(filename string) (*Config, error) + func (c *Config) Service(client *api.Client, logger *log.Logger) (*connect.Service, error) + type ConfigWatcher interface + Watch func() <-chan *Config + type Conn struct + func NewConn(src, dst net.Conn) *Conn + func (c *Conn) Close() error + func (c *Conn) CopyBytes() error + func (c *Conn) Stats() (txBytes, rxBytes uint64) + type Listener struct + Service *connect.Service + func NewPublicListener(svc *connect.Service, cfg PublicListenerConfig, logger *log.Logger) *Listener + func NewUpstreamListener(svc *connect.Service, cfg UpstreamConfig, logger *log.Logger) *Listener + func (l *Listener) BindAddr() string + func (l *Listener) Close() error + func (l *Listener) Serve() error + func (l *Listener) Wait() + type Proxy struct + func New(client *api.Client, cw ConfigWatcher, logger *log.Logger) (*Proxy, error) + func (p *Proxy) Close() + func (p *Proxy) Serve() error + type PublicListenerConfig struct + BindAddress string + BindPort int + HandshakeTimeoutMs int + LocalConnectTimeoutMs int + LocalServiceAddress string + type StaticConfigWatcher struct + func NewStaticConfigWatcher(cfg *Config) *StaticConfigWatcher + func (sc *StaticConfigWatcher) Watch() <-chan *Config + type TestTCPServer struct + func NewTestTCPServer(t testing.T) *TestTCPServer + func (s *TestTCPServer) Addr() net.Addr + func (s *TestTCPServer) Close() + type UpstreamConfig struct + ConnectTimeoutMs int + DestinationDatacenter string + DestinationName string + DestinationNamespace string + DestinationType string + LocalBindAddress string + LocalBindPort int + func (uc *UpstreamConfig) String() string