supervisor

Documentation

Index

• type Options
• type Supervisor
  • func NewSupervisor(newSrv server.NewServerFn, backend backend.Backend, errorC chan error) (s *Supervisor)
  • func NewSupervisorWithOptions(newSrv server.NewServerFn, backend backend.Backend, errorC chan error, ...) (s *Supervisor)
  • func (s *Supervisor) GetEndpointStats(e *backend.Endpoint) (*backend.RoundTripStats, error)
  • func (s *Supervisor) GetFiles() ([]*server.FileDescriptor, error)
  • func (s *Supervisor) GetLocationStats(l *backend.Location) (*backend.RoundTripStats, error)
  • func (s *Supervisor) GetTopEndpoints(upstreamId string) ([]*backend.Endpoint, error)
  • func (s *Supervisor) GetTopLocations(hostname, upstreamId string) ([]*backend.Location, error)
  • func (s *Supervisor) GetUpstreamStats(u *backend.Upstream) (*backend.RoundTripStats, error)
  • func (s *Supervisor) Start() error
  • func (s *Supervisor) Stop(wait bool)
  • func (s *Supervisor) String() string

Types

type Options

type Options struct {
	TimeProvider timetools.TimeProvider
	Files        []*server.FileDescriptor
}

type Supervisor

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

Supervisor watches changes to the dynamic backends and applies those changes to the server in real time. Supervisor handles lifetime of the proxy as well, and does graceful restarts and recoveries in case of failures.

func NewSupervisor

func NewSupervisor(newSrv server.NewServerFn, backend backend.Backend, errorC chan error) (s *Supervisor)

func NewSupervisorWithOptions

func NewSupervisorWithOptions(newSrv server.NewServerFn, backend backend.Backend, errorC chan error, options Options) (s *Supervisor)

func (*Supervisor) GetEndpointStats

func (s *Supervisor) GetEndpointStats(e *backend.Endpoint) (*backend.RoundTripStats, error)

func (*Supervisor) GetFiles

func (s *Supervisor) GetFiles() ([]*server.FileDescriptor, error)

func (*Supervisor) GetLocationStats

func (s *Supervisor) GetLocationStats(l *backend.Location) (*backend.RoundTripStats, error)

func (*Supervisor) GetTopEndpoints

func (s *Supervisor) GetTopEndpoints(upstreamId string) ([]*backend.Endpoint, error)

func (*Supervisor) GetTopLocations

func (s *Supervisor) GetTopLocations(hostname, upstreamId string) ([]*backend.Location, error)

func (*Supervisor) GetUpstreamStats

func (s *Supervisor) GetUpstreamStats(u *backend.Upstream) (*backend.RoundTripStats, error)

func (*Supervisor) Start

func (s *Supervisor) Start() error

func (*Supervisor) Stop

func (s *Supervisor) Stop(wait bool)

func (*Supervisor) String

func (s *Supervisor) String() string