balancer

README

balancer

TODO

---

Copyright (c) 2022 Archivage Numérique

Documentation

Overview

Package balancer TODO

Index

• type Balancer
• type Config
  • func (c *Config) NewEndpoints(fn breaker.OnStateChangeFunc) (*Endpoints, error)
• type Endpoint
  • func (e *Endpoint) Update(success bool)
  • func (e *Endpoint) Usable() bool
• type EndpointConfig
• type Endpoints
  • func (es *Endpoints) List() []*Endpoint
  • func (es *Endpoints) RoundRobin() Balancer

Types

type Balancer

type Balancer interface {
	Next() []*Endpoint
}

type Config

type Config struct {
	CertFile  string            `dm:"cert_file"`
	KeyFile   string            `dm:"key_file"`
	Endpoints []*EndpointConfig `dm:"endpoints"`
}

func (*Config) NewEndpoints

func (c *Config) NewEndpoints(fn breaker.OnStateChangeFunc) (*Endpoints, error)

type Endpoint

type Endpoint struct {
	URL      string
	Username string
	Password string
	Client   *http.Client
	// contains filtered or unexported fields
}

func (*Endpoint) Update

func (e *Endpoint) Update(success bool)

func (*Endpoint) Usable

func (e *Endpoint) Usable() bool

type EndpointConfig

type EndpointConfig struct {
	Breaker  breaker.Config `dm:"breaker"`
	URL      string         `dm:"url"`
	Username string         `dm:"username"`
	Password string         `dm:"password"`
	CAFile   string         `dm:"ca_file"`
}

type Endpoints

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

func (*Endpoints) List

func (es *Endpoints) List() []*Endpoint

func (*Endpoints) RoundRobin

func (es *Endpoints) RoundRobin() Balancer