backend

Documentation

Index

• Constants
• func IsValidStatus(s string) bool
• func StatusWeight(s string) uint32
• type ConnectionMetrics
  • func NewConnectionMetrics() ConnectionMetrics
  • func (c *ConnectionMetrics) ConnectionDone()
  • func (c *ConnectionMetrics) ConnectionStart()
  • func (c *ConnectionMetrics) GetActiveConnections() uint32
  • func (c *ConnectionMetrics) GetTotalConnections() uint64
• type Pool
  • func DummyPool(name string) *Pool
  • func NewPool(name string, config PoolConfig) *Pool
  • func (p *Pool) AddServer(name string, server *Server)
  • func (p *Pool) DelServer(name string)
  • func (p *Pool) Handle(logRecord *logger.HAProxyLogRecord)
  • func (p Pool) Next() *Server
  • func (p *Pool) Reconfigure(config PoolConfig)
  • func (p *Pool) RunChecks()
  • func (p *Pool) Shutdown()
• type PoolConfig
• type ResponseError
• type Server
  • func NewServer(address string) *Server
  • func (s *Server) CheckStatus(tout time.Duration)
  • func (s *Server) Cost(accept string) uint32
  • func (s *Server) Handle(logRecord *logger.HAProxyLogRecord, tout time.Duration)
  • func (s *Server) RoundTrip(req *http.Request, ch chan ResponseError)
• type ServerMetrics
  • func NewServerMetrics() ServerMetrics
  • func (s *ServerMetrics) Cost() uint32
  • func (s *ServerMetrics) RequestDone()
  • func (s *ServerMetrics) RequestStart()
• type ServerStatus
  • func NewServerStatus() ServerStatus
  • func (s *ServerStatus) Cost(accept string) uint32
  • func (s *ServerStatus) ParseAndSet(res *http.Response) bool
  • func (s *ServerStatus) Set(status string) bool
  • func (s *ServerStatus) SlowStartFactor() uint32

Constants

const (
	StatusOk          = "OK"
	StatusDegraded    = "DEGRADED"
	StatusCritical    = "CRITICAL"
	StatusMaintenance = "MAINTENANCE"
	StatusUnknown     = "UNKNOWN"
)

const (
	Tstartup = 60   // Startup time in seconds
	Kstartup = 4096 // Maximum slow start cost
)

Functions

func IsValidStatus

func IsValidStatus(s string) bool

func StatusWeight

func StatusWeight(s string) uint32

Types

type ConnectionMetrics

type ConnectionMetrics struct {
	ActiveConnections uint32
	TotalConnections  uint64
}

func NewConnectionMetrics

func NewConnectionMetrics() ConnectionMetrics

func (*ConnectionMetrics) ConnectionDone

func (c *ConnectionMetrics) ConnectionDone()

func (*ConnectionMetrics) ConnectionStart

func (c *ConnectionMetrics) ConnectionStart()

func (*ConnectionMetrics) GetActiveConnections

func (c *ConnectionMetrics) GetActiveConnections() uint32

func (*ConnectionMetrics) GetTotalConnections

func (c *ConnectionMetrics) GetTotalConnections() uint64

type Pool

type Pool struct {
	Name    string
	Dummy   bool
	Servers map[string]*Server
	Config  PoolConfig

	Metrics ConnectionMetrics
	// contains filtered or unexported fields
}

func DummyPool

func DummyPool(name string) *Pool

func NewPool

func NewPool(name string, config PoolConfig) *Pool

func (*Pool) AddServer

func (p *Pool) AddServer(name string, server *Server)

func (*Pool) DelServer

func (p *Pool) DelServer(name string)

func (*Pool) Handle

func (p *Pool) Handle(logRecord *logger.HAProxyLogRecord)

func (Pool) Next

func (p Pool) Next() *Server

func (*Pool) Reconfigure

func (p *Pool) Reconfigure(config PoolConfig)

func (*Pool) RunChecks

func (p *Pool) RunChecks()

func (*Pool) Shutdown

func (p *Pool) Shutdown()

type PoolConfig

type PoolConfig struct {
	HealthzEvery   time.Duration
	HealthzTimeout time.Duration
	RequestTimeout time.Duration
	Status         string
}

type ResponseError

type ResponseError struct {
	Response *http.Response
	Error    error
}

type Server

type Server struct {
	Address   string
	Status    ServerStatus
	Metrics   ServerMetrics
	Transport *http.Transport
}

func NewServer

func NewServer(address string) *Server

func (*Server) CheckStatus

func (s *Server) CheckStatus(tout time.Duration)

func (*Server) Cost

func (s *Server) Cost(accept string) uint32

func (*Server) Handle

func (s *Server) Handle(logRecord *logger.HAProxyLogRecord, tout time.Duration)

func (*Server) RoundTrip

func (s *Server) RoundTrip(req *http.Request, ch chan ResponseError)

type ServerMetrics

type ServerMetrics struct {
	RequestsInFlight uint32
	RequestsServiced uint64
}

func NewServerMetrics

func NewServerMetrics() ServerMetrics

func (*ServerMetrics) Cost

func (s *ServerMetrics) Cost() uint32

func (*ServerMetrics) RequestDone

func (s *ServerMetrics) RequestDone()

func (*ServerMetrics) RequestStart

func (s *ServerMetrics) RequestStart()

type ServerStatus

type ServerStatus struct {
	Current string
	Checked time.Time
	Changed time.Time
}

func NewServerStatus

func NewServerStatus() ServerStatus

func (*ServerStatus) Cost

func (s *ServerStatus) Cost(accept string) uint32

func (*ServerStatus) ParseAndSet

func (s *ServerStatus) ParseAndSet(res *http.Response) bool

func (*ServerStatus) Set

func (s *ServerStatus) Set(status string) bool

Returns a bool representing if the status changed

func (*ServerStatus) SlowStartFactor

func (s *ServerStatus) SlowStartFactor() uint32