Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

userspace

package

Go to main page

Versions in this module

v1

v1.5.1

Apr 28, 2017

v1.5.0

Apr 21, 2017

v1.5.0-rc.0

Mar 9, 2017

v1.4.0-alpha.1

Nov 4, 2016

v1.3.3

Dec 21, 2016

v1.3.0

Sep 16, 2016

Changes in this version

+ var EndpointDialTimeout = []time.Duration

+ var ErrMissingEndpoints = errors.New("missing endpoints")

+ var ErrMissingServiceEntry = errors.New("missing service entry")

+ var ErrProxyOnLocalhost = fmt.Errorf("cannot proxy on localhost")

+ func CleanupLeftovers(ipt iptables.Interface) (encounteredError bool)

+ func IsProxyLocked(err error) bool

+ func ProxyTCP(in, out *net.TCPConn)

+ func TryConnectEndpoints(service proxy.ServicePortName, srcAddr net.Addr, protocol string, ...) (net.Conn, error)

+ type ClientCache struct

+ Clients map[string]net.Conn

+ type LoadBalancer interface

+ CleanupStaleStickySessions func(service proxy.ServicePortName)

+ NewService func(service proxy.ServicePortName, sessionAffinityType api.ServiceAffinity, ...) error

+ NextEndpoint func(service proxy.ServicePortName, srcAddr net.Addr, sessionAffinityReset bool) (string, error)

+ ServiceHasEndpoints func(service proxy.ServicePortName) bool

+ type LoadBalancerRR struct

+ func NewLoadBalancerRR() *LoadBalancerRR

+ func (lb *LoadBalancerRR) CleanupStaleStickySessions(svcPort proxy.ServicePortName)

+ func (lb *LoadBalancerRR) NewService(svcPort proxy.ServicePortName, affinityType api.ServiceAffinity, ...) error

+ func (lb *LoadBalancerRR) NextEndpoint(svcPort proxy.ServicePortName, srcAddr net.Addr, sessionAffinityReset bool) (string, error)

+ func (lb *LoadBalancerRR) OnEndpointsUpdate(allEndpoints []api.Endpoints)

+ func (lb *LoadBalancerRR) ServiceHasEndpoints(svcPort proxy.ServicePortName) bool

+ type PortAllocator interface

+ AllocateNext func() (int, error)

+ Release func(int)

+ type Proxier struct

+ func NewCustomProxier(loadBalancer LoadBalancer, listenIP net.IP, iptables iptables.Interface, ...) (*Proxier, error)

+ func NewProxier(loadBalancer LoadBalancer, listenIP net.IP, iptables iptables.Interface, ...) (*Proxier, error)

+ func (proxier *Proxier) OnServiceUpdate(services []api.Service)

+ func (proxier *Proxier) Sync()

+ func (proxier *Proxier) SyncLoop()

+ type ProxySocket interface

+ Addr func() net.Addr

+ Close func() error

+ ListenPort func() int

+ ProxyLoop func(service proxy.ServicePortName, info *ServiceInfo, loadBalancer LoadBalancer)

+ func NewProxySocket(protocol api.Protocol, ip net.IP, port int) (ProxySocket, error)

+ type ProxySocketFunc func(protocol api.Protocol, ip net.IP, port int) (ProxySocket, error)

+ type ServiceInfo struct

+ ActiveClients *ClientCache

+ ServiceRef api.ObjectReference

+ Timeout time.Duration

+ func (info *ServiceInfo) IsAlive() bool