backend

Documentation

Index

• func CheckConnect(backend *BfeBackend, checkConf *cluster_conf.BackendCheck) (bool, error)
• func SetCheckConfFetcher(confFetcher CheckConfFetcher)
• func UpdateStatus(backend *BfeBackend, cluster string) bool
• type BfeBackend
  • func NewBfeBackend() *BfeBackend
  • func (back *BfeBackend) AddFailNum()
  • func (back *BfeBackend) AddSuccNum()
  • func (back *BfeBackend) Avail() bool
  • func (back *BfeBackend) CheckAvail(succThreshold int) bool
  • func (back *BfeBackend) Close()
  • func (back *BfeBackend) CloseChan() <-chan bool
  • func (back *BfeBackend) ConnNum() int
  • func (back *BfeBackend) DecConnNum()
  • func (back *BfeBackend) FailNum() int
  • func (back *BfeBackend) GetAddr() string
  • func (back *BfeBackend) GetAddrInfo() string
  • func (back *BfeBackend) GetRestart() bool
  • func (back *BfeBackend) IncConnNum()
  • func (back *BfeBackend) Init(subCluster string, conf *cluster_table_conf.BackendConf)
  • func (back *BfeBackend) OnFail(cluster string)
  • func (back *BfeBackend) OnSuccess()
  • func (back *BfeBackend) Release()
  • func (back *BfeBackend) ResetFailNum()
  • func (back *BfeBackend) ResetSuccNum()
  • func (back *BfeBackend) SetAvail(avail bool)
  • func (back *BfeBackend) SetRestart(restart bool)
  • func (back *BfeBackend) SuccNum() int
  • func (back *BfeBackend) UpdateStatus(failThreshold int) bool
• type CheckConfFetcher

Functions

func CheckConnect

func CheckConnect(backend *BfeBackend, checkConf *cluster_conf.BackendCheck) (bool, error)

CheckConnect checks whether backend server become available.

func SetCheckConfFetcher

func SetCheckConfFetcher(confFetcher CheckConfFetcher)

SetCheckConfFetcher initializes CheckConfFetcher handler.

func UpdateStatus

func UpdateStatus(backend *BfeBackend, cluster string) bool

Types

type BfeBackend

type BfeBackend struct {
	// immutable
	Name       string // backend's name
	Addr       string // backend's address, e.g., "10.1.1.1"
	Port       int    // backend's port, e.g., 8080
	AddrInfo   string // backend's address and port, e.g., "10.1.1.1:8080"
	SubCluster string // name of sub-cluster

	sync.RWMutex // guards following fields
	// contains filtered or unexported fields
}

BfeBackend is a backend server.

func NewBfeBackend

func NewBfeBackend() *BfeBackend

func (*BfeBackend) AddFailNum

func (back *BfeBackend) AddFailNum()

func (*BfeBackend) AddSuccNum

func (back *BfeBackend) AddSuccNum()

func (*BfeBackend) Avail

func (back *BfeBackend) Avail() bool

func (*BfeBackend) CheckAvail

func (back *BfeBackend) CheckAvail(succThreshold int) bool

CheckAvail check whether backend becomes available.

func (*BfeBackend) Close

func (back *BfeBackend) Close()

func (*BfeBackend) CloseChan

func (back *BfeBackend) CloseChan() <-chan bool

func (*BfeBackend) ConnNum

func (back *BfeBackend) ConnNum() int

func (*BfeBackend) DecConnNum

func (back *BfeBackend) DecConnNum()

func (*BfeBackend) FailNum

func (back *BfeBackend) FailNum() int

func (*BfeBackend) GetAddr

func (back *BfeBackend) GetAddr() string

func (*BfeBackend) GetAddrInfo

func (back *BfeBackend) GetAddrInfo() string

func (*BfeBackend) GetRestart

func (back *BfeBackend) GetRestart() bool

func (*BfeBackend) IncConnNum

func (back *BfeBackend) IncConnNum()

func (*BfeBackend) Init

func (back *BfeBackend) Init(subCluster string, conf *cluster_table_conf.BackendConf)

Init initializes BfeBackend with BackendConf

func (*BfeBackend) OnFail

func (back *BfeBackend) OnFail(cluster string)

OnFail is called when request backend fail

func (*BfeBackend) OnSuccess

func (back *BfeBackend) OnSuccess()

OnSuccess is called when request backend success

func (*BfeBackend) Release

func (back *BfeBackend) Release()

func (*BfeBackend) ResetFailNum

func (back *BfeBackend) ResetFailNum()

func (*BfeBackend) ResetSuccNum

func (back *BfeBackend) ResetSuccNum()

func (*BfeBackend) SetAvail

func (back *BfeBackend) SetAvail(avail bool)

func (*BfeBackend) SetRestart

func (back *BfeBackend) SetRestart(restart bool)

func (*BfeBackend) SuccNum

func (back *BfeBackend) SuccNum() int

func (*BfeBackend) UpdateStatus

func (back *BfeBackend) UpdateStatus(failThreshold int) bool

type CheckConfFetcher

type CheckConfFetcher func(cluster string) *cluster_conf.BackendCheck

CheckConfFetcher returns current health check conf for cluster.