Versions in this module Expand all Collapse all v0 v0.7.0 Dec 22, 2014 Changes in this version + const Metrics + const PerfMon + type FileDescriptor struct + Address backend.Address + File *os.File + func (fd *FileDescriptor) String() string + func (fd *FileDescriptor) ToListener() (net.Listener, error) + type MuxServer struct + func NewMuxServerWithOptions(id int, o Options) (*MuxServer, error) + func (m *MuxServer) AddHostListener(h *backend.Host, l *backend.Listener) error + func (m *MuxServer) DeleteEndpoint(upstream *backend.Upstream, endpointId string) error + func (m *MuxServer) DeleteHost(hostname string) error + func (m *MuxServer) DeleteHostListener(host *backend.Host, listenerId string) error + func (m *MuxServer) DeleteLocation(host *backend.Host, locationId string) error + func (m *MuxServer) DeleteLocationMiddleware(host *backend.Host, loc *backend.Location, mType, mId string) error + func (m *MuxServer) DeleteUpstream(upstreamId string) error + func (m *MuxServer) GetEndpointStats(e *backend.Endpoint) (*backend.RoundTripStats, error) + func (m *MuxServer) GetFiles() ([]*FileDescriptor, error) + func (m *MuxServer) GetLocationStats(l *backend.Location) (*backend.RoundTripStats, error) + func (m *MuxServer) GetTopEndpoints(upstreamId string) ([]*backend.Endpoint, error) + func (m *MuxServer) GetTopLocations(hostname, upstreamId string) ([]*backend.Location, error) + func (m *MuxServer) GetUpstreamStats(u *backend.Upstream) (*backend.RoundTripStats, error) + func (m *MuxServer) Start() error + func (m *MuxServer) Stop(wait bool) + func (m *MuxServer) String() string + func (m *MuxServer) TakeFiles(files []*FileDescriptor) error + func (m *MuxServer) UpdateHostKeyPair(hostname string, keyPair *backend.KeyPair) error + func (m *MuxServer) UpdateLocationOptions(host *backend.Host, loc *backend.Location) error + func (m *MuxServer) UpdateLocationPath(host *backend.Host, loc *backend.Location, path string) error + func (m *MuxServer) UpdateLocationUpstream(host *backend.Host, loc *backend.Location) error + func (m *MuxServer) UpsertEndpoint(upstream *backend.Upstream, e *backend.Endpoint) error + func (m *MuxServer) UpsertHost(host *backend.Host) error + func (m *MuxServer) UpsertLocation(host *backend.Host, loc *backend.Location) error + func (m *MuxServer) UpsertLocationMiddleware(host *backend.Host, loc *backend.Location, mi *backend.MiddlewareInstance) error + func (m *MuxServer) UpsertUpstream(u *backend.Upstream) error + type NewServerFn func(id int) (Server, error) + type Options struct + DefaultListener *backend.Listener + DialTimeout time.Duration + Files []*FileDescriptor + MaxHeaderBytes int + MetricsClient metrics.Client + ReadTimeout time.Duration + TimeProvider timetools.TimeProvider + WriteTimeout time.Duration + type Reporter struct + func NewReporter(c metrics.Client, locationId string) *Reporter + func (rp *Reporter) ObserveRequest(r request.Request) + func (rp *Reporter) ObserveResponse(r request.Request, a request.Attempt) + type Server interface + AddHostListener func(host *backend.Host, l *backend.Listener) error + DeleteEndpoint func(upstream *backend.Upstream, endpointId string) error + DeleteHost func(hostname string) error + DeleteHostListener func(host *backend.Host, listenerId string) error + DeleteLocation func(host *backend.Host, locationId string) error + DeleteLocationMiddleware func(host *backend.Host, loc *backend.Location, mType, mId string) error + DeleteUpstream func(upstreamId string) error + GetFiles func() ([]*FileDescriptor, error) + Start func() error + Stop func(wait bool) + TakeFiles func([]*FileDescriptor) error + UpdateHostKeyPair func(hostname string, keyPair *backend.KeyPair) error + UpdateLocationOptions func(host *backend.Host, loc *backend.Location) error + UpdateLocationPath func(host *backend.Host, loc *backend.Location, path string) error + UpdateLocationUpstream func(host *backend.Host, loc *backend.Location) error + UpsertEndpoint func(upstream *backend.Upstream, e *backend.Endpoint) error + UpsertHost func(host *backend.Host) error + UpsertLocation func(host *backend.Host, loc *backend.Location) error + UpsertLocationMiddleware func(host *backend.Host, loc *backend.Location, mi *backend.MiddlewareInstance) error + UpsertUpstream func(u *backend.Upstream) error