domain

Documentation

Index

• Variables
• func BroadcastBool(in <-chan bool, outs []chan<- bool)
• type Backend
  • func NewBackend(name string, host string, port uint, statusPort uint, statusEndpoint string, ...) *Backend
  • func NewBackends(backendConfigs []config.Backend, logger lager.Logger) (backends []*Backend)
  • func (b *Backend) AsJSON() BackendJSON
  • func (b *Backend) Bridge(clientConn net.Conn) error
  • func (b *Backend) HealthcheckUrl() string
  • func (b *Backend) Healthy() bool
  • func (b *Backend) SetHealthy()
  • func (b *Backend) SetUnhealthy()
  • func (b *Backend) SeverConnections()
• type BackendJSON
• type Bridge
  • func NewBridge(client, backend net.Conn, logger lager.Logger) Bridge
• type Bridges
  • func NewBridges(logger lager.Logger) Bridges

Variables

var BackendProvider = NewBackend

var BridgeProvider = NewBridge

var BridgesProvider = NewBridges

var Dialer = net.Dial

Functions

func BroadcastBool

func BroadcastBool(in <-chan bool, outs []chan<- bool)

Types

type Backend

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

func NewBackend

func NewBackend(
	name string,
	host string,
	port uint,
	statusPort uint,
	statusEndpoint string,
	logger lager.Logger) *Backend

func NewBackends

func NewBackends(backendConfigs []config.Backend, logger lager.Logger) (backends []*Backend)

func (*Backend) AsJSON

func (b *Backend) AsJSON() BackendJSON

func (*Backend) Bridge

func (b *Backend) Bridge(clientConn net.Conn) error

func (*Backend) HealthcheckUrl

func (b *Backend) HealthcheckUrl() string

func (*Backend) Healthy

func (b *Backend) Healthy() bool

func (*Backend) SetHealthy

func (b *Backend) SetHealthy()

func (*Backend) SetUnhealthy

func (b *Backend) SetUnhealthy()

func (*Backend) SeverConnections

func (b *Backend) SeverConnections()

type BackendJSON

type BackendJSON struct {
	Host                string `json:"host"`
	Port                uint   `json:"port"`
	StatusPort          uint   `json:"status_port"`
	Healthy             bool   `json:"healthy"`
	Name                string `json:"name"`
	CurrentSessionCount uint   `json:"currentSessionCount"`
}

type Bridge

type Bridge interface {
	Connect()
	Close()
}

func NewBridge

func NewBridge(client, backend net.Conn, logger lager.Logger) Bridge

type Bridges

type Bridges interface {
	Create(clientConn, backendConn net.Conn) Bridge
	Remove(bridge Bridge) error
	RemoveAndCloseAll()
	Size() uint
	Contains(bridge Bridge) bool
}

func NewBridges

func NewBridges(logger lager.Logger) Bridges