backend

package

v1.8.3 Latest Latest Go to latest Published: Jul 9, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/bfenetworks/bfe

Links

Open Source Insights

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 NewBfeBackendByAddrinfo(subClusterName string, name string, addrinfo string) *BfeBackend
type CheckConfFetcher

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CheckConnect ¶

func CheckConnect(backend *BfeBackend, checkConf *cluster_conf.BackendCheck, httpsConf *cluster_conf.BackendHTTPS) (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 NewBfeBackendByAddrinfo ¶ added in v1.8.2

func NewBfeBackendByAddrinfo(subClusterName string, name string, addrinfo string) *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 ¶ added in v1.1.0

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) InitSimpleByAddrinfo ¶ added in v1.8.2

func (back *BfeBackend) InitSimpleByAddrinfo(subClusterName string, name string, addrinfo string)

func (*BfeBackend) OnFail ¶

func (back *BfeBackend) OnFail(cluster string)

OnFail is called when request backend fail

func (*BfeBackend) OnFailByCluster ¶ added in v1.8.1

func (back *BfeBackend) OnFailByCluster(cluster *bfe_cluster.BfeCluster)

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 ¶ added in v1.1.0

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(name string) (*cluster_conf.BackendCheck, *cluster_conf.BackendHTTPS)

CheckConfFetcher returns current health check conf for cluster.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL