proxy

Documentation

Overview

Based on net/http/internal

Index

• Constants
• Variables
• type ChunkedReader
  • func NewChunkedReader(r io.Reader) *ChunkedReader
  • func (cr *ChunkedReader) Chunk() io.Reader
  • func (cr *ChunkedReader) Err() error
  • func (cr *ChunkedReader) Next() bool
• type Config
• type ErrNoSuchImage
  • func (err *ErrNoSuchImage) Error() string
• type Proxy
  • func NewProxy(c Config) (*Proxy, error)
  • func (proxy *Proxy) AttachExistingContainers()
  • func (proxy *Proxy) ContainerDestroyed(ident string)
  • func (proxy *Proxy) ContainerDied(ident string)
  • func (proxy *Proxy) ContainerStarted(ident string)
  • func (proxy *Proxy) Dial() (net.Conn, error)
  • func (proxy *Proxy) Intercept(i interceptor, w http.ResponseWriter, r *http.Request)
  • func (proxy *Proxy) Listen() []net.Listener
  • func (proxy *Proxy) ListenAndServeStatus(socket string)
  • func (proxy *Proxy) Serve(listeners []net.Listener)
  • func (proxy *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (proxy *Proxy) StatusHTTP(w http.ResponseWriter, r *http.Request)
  • func (proxy *Proxy) Stop()
• type TLSConfig
  • func (c *TLSConfig) IsEnabled() bool
  • func (c *TLSConfig) LoadCerts() error
• type UnmarshalWrongTypeError
  • func (e *UnmarshalWrongTypeError) Error() string

Constants

const MaxDockerHostname = 64

Variables

var (
	ErrLineTooLong        = errors.New("header line too long")
	ErrInvalidChunkLength = errors.New("invalid byte in chunk length")
)

var (
	ErrWeaveCIDRNone = errors.New("the container was created with the '-e WEAVE_CIDR=none' option")
	ErrNoDefaultIPAM = errors.New("the container was created without specifying an IP address with '-e WEAVE_CIDR=...' and the proxy was started with the '--no-default-ipalloc' option")
)

var (
	ErrNoCommandSpecified = errors.New("No command specified")
)

var (
	Log = common.Log
)

Types

type ChunkedReader

type ChunkedReader struct {
	// contains filtered or unexported fields
}

func NewChunkedReader

func NewChunkedReader(r io.Reader) *ChunkedReader

Unlike net/http/internal.chunkedReader, this has an interface where we can handle individual chunks. The interface is based on database/sql.Rows.

func (*ChunkedReader) Chunk

func (cr *ChunkedReader) Chunk() io.Reader

Chunk returns the io.Reader of the current chunk. On each call, this returns the same io.Reader for a given chunk.

func (*ChunkedReader) Err

func (cr *ChunkedReader) Err() error

Err returns the error, if any, that was encountered during iteration.

func (*ChunkedReader) Next

func (cr *ChunkedReader) Next() bool

Next prepares the next chunk for reading. It returns true on success, or false if there is no next chunk or an error happened while preparing it. Err should be consulted to distinguish between the two cases.

Every call to Chunk, even the first one, must be preceded by a call to Next.

Calls to Next will discard any unread bytes in the current Chunk.

type Config

type Config struct {
	HostnameFromLabel   string
	HostnameMatch       string
	HostnameReplacement string
	Image               string
	ListenAddrs         []string
	RewriteInspect      bool
	NoDefaultIPAM       bool
	NoRewriteHosts      bool
	TLSConfig           TLSConfig
	Version             string
	WithoutDNS          bool
	NoMulticastRoute    bool
	DockerBridge        string
	DockerHost          string
}

type ErrNoSuchImage

type ErrNoSuchImage struct {
	Name string
}

ErrNoSuchImage replaces docker.NoSuchImage, which does not contain the image name, which in turn breaks docker clients post 1.7.0 since they expect the image name to be present in errors.

func (*ErrNoSuchImage) Error

func (err *ErrNoSuchImage) Error() string

type Proxy

type Proxy struct {
	sync.Mutex
	Config
	// contains filtered or unexported fields
}

func NewProxy

func NewProxy(c Config) (*Proxy, error)

func (*Proxy) AttachExistingContainers

func (proxy *Proxy) AttachExistingContainers()

func (*Proxy) ContainerDestroyed

func (proxy *Proxy) ContainerDestroyed(ident string)

func (*Proxy) ContainerDied

func (proxy *Proxy) ContainerDied(ident string)

func (*Proxy) ContainerStarted

func (proxy *Proxy) ContainerStarted(ident string)

weavedocker.ContainerObserver interface

func (*Proxy) Dial

func (proxy *Proxy) Dial() (net.Conn, error)

func (*Proxy) Intercept

func (proxy *Proxy) Intercept(i interceptor, w http.ResponseWriter, r *http.Request)

func (*Proxy) Listen

func (proxy *Proxy) Listen() []net.Listener

func (*Proxy) ListenAndServeStatus

func (proxy *Proxy) ListenAndServeStatus(socket string)

func (*Proxy) Serve

func (proxy *Proxy) Serve(listeners []net.Listener)

func (*Proxy) ServeHTTP

func (proxy *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*Proxy) StatusHTTP

func (proxy *Proxy) StatusHTTP(w http.ResponseWriter, r *http.Request)

func (*Proxy) Stop

func (proxy *Proxy) Stop()

type TLSConfig

type TLSConfig struct {
	Enabled, Verify   bool
	Cert, Key, CACert string
	*tls.Config
}

func (*TLSConfig) IsEnabled

func (c *TLSConfig) IsEnabled() bool

IsEnabled returns true if TLS is enable, according to the config.

func (*TLSConfig) LoadCerts

func (c *TLSConfig) LoadCerts() error

LoadCerts loads the certificates into c.Config, if TLS is enabled.

type UnmarshalWrongTypeError

type UnmarshalWrongTypeError struct {
	Field, Expected string
	Got             interface{}
}

func (*UnmarshalWrongTypeError) Error

func (e *UnmarshalWrongTypeError) Error() string