balance

Documentation

Overview

balance handles the load balancing portion of portal.

Index

• Variables
• func DeleteServer(svcId, srvId string) error
• func DeleteService(id string) error
• func GetServer(svcId, srvId string) (*core.Server, error)
• func GetService(id string) (*core.Service, error)
• func GetServices() ([]core.Service, error)
• func Init() error
• func SetServer(svcId string, server *core.Server) error
• func SetServers(svcId string, servers []core.Server) error
• func SetService(service *core.Service) error
• func SetServices(services []core.Service) error
• func Sync() error
• type Lvs
  • func (l *Lvs) DeleteServer(svcId, srvId string) error
  • func (l *Lvs) DeleteService(id string) error
  • func (l *Lvs) GetServer(svcId, srvId string) (*core.Server, error)
  • func (l *Lvs) GetService(id string) (*core.Service, error)
  • func (l *Lvs) GetServices() ([]core.Service, error)
  • func (l *Lvs) Init() error
  • func (l *Lvs) SetServer(svcId string, server *core.Server) error
  • func (l *Lvs) SetServers(svcId string, servers []core.Server) error
  • func (l *Lvs) SetService(service *core.Service) error
  • func (l *Lvs) SetServices(services []core.Service) error
• type Nginx
  • func (n *Nginx) DeleteServer(svcId, srvId string) error
  • func (n *Nginx) DeleteService(id string) error
  • func (n Nginx) GetServer(svcId, srvId string) (*core.Server, error)
  • func (n Nginx) GetService(id string) (*core.Service, error)
  • func (n *Nginx) GetServices() ([]core.Service, error)
  • func (n *Nginx) Init() error
  • func (n *Nginx) SetServer(svcId string, server *core.Server) error
  • func (n *Nginx) SetServers(svcId string, servers []core.Server) error
  • func (n *Nginx) SetService(service *core.Service) error
  • func (n *Nginx) SetServices(services []core.Service) error

Variables

var (
	Balancer       core.Backender
	NoServiceError = errors.New("No Service Found")
	NoServerError  = errors.New("No Server Found")
)

Functions

func DeleteServer

func DeleteServer(svcId, srvId string) error

func DeleteService

func DeleteService(id string) error

func GetServer

func GetServer(svcId, srvId string) (*core.Server, error)

func GetService

func GetService(id string) (*core.Service, error)

func GetServices

func GetServices() ([]core.Service, error)

func Init

func Init() error

func SetServer

func SetServer(svcId string, server *core.Server) error

func SetServers

func SetServers(svcId string, servers []core.Server) error

func SetService

func SetService(service *core.Service) error

func SetServices

func SetServices(services []core.Service) error

func Sync

func Sync() error

Sync - takes applies ipvsadm rules and save them to lvs.DefaultIpvs.Services which should already have the same information Deprecated: Use `SetServices(common.GetServices())` instead

Types

type Lvs

type Lvs struct {
}

func (*Lvs) DeleteServer

func (l *Lvs) DeleteServer(svcId, srvId string) error

DeleteServer

func (*Lvs) DeleteService

func (l *Lvs) DeleteService(id string) error

DeleteService

func (*Lvs) GetServer

func (l *Lvs) GetServer(svcId, srvId string) (*core.Server, error)

GetServer

func (*Lvs) GetService

func (l *Lvs) GetService(id string) (*core.Service, error)

GetService

func (*Lvs) GetServices

func (l *Lvs) GetServices() ([]core.Service, error)

GetServices doesn't need to be a pointer method because it doesn't modify original object

func (*Lvs) Init

func (l *Lvs) Init() error

func (*Lvs) SetServer

func (l *Lvs) SetServer(svcId string, server *core.Server) error

SetServer

func (*Lvs) SetServers

func (l *Lvs) SetServers(svcId string, servers []core.Server) error

SetServers

func (*Lvs) SetService

func (l *Lvs) SetService(service *core.Service) error

SetService

func (*Lvs) SetServices

func (l *Lvs) SetServices(services []core.Service) error

SetServices used also to sync to core (`SetServices(core.GetServices())`)

type Nginx

type Nginx struct {
	Services []core.Service
	// contains filtered or unexported fields
}

func (*Nginx) DeleteServer

func (n *Nginx) DeleteServer(svcId, srvId string) error

DeleteServer deletes the server from the service in nginx.

func (*Nginx) DeleteService

func (n *Nginx) DeleteService(id string) error

func (Nginx) GetServer

func (n Nginx) GetServer(svcId, srvId string) (*core.Server, error)

GetServer gets server from the service.

func (Nginx) GetService

func (n Nginx) GetService(id string) (*core.Service, error)

func (*Nginx) GetServices

func (n *Nginx) GetServices() ([]core.Service, error)

func (*Nginx) Init

func (n *Nginx) Init() error

func (*Nginx) SetServer

func (n *Nginx) SetServer(svcId string, server *core.Server) error

SetServer adds or updates the server for the service in nginx.

func (*Nginx) SetServers

func (n *Nginx) SetServers(svcId string, servers []core.Server) error

SetServers updates the servers for the service in nginx.

func (*Nginx) SetService

func (n *Nginx) SetService(service *core.Service) error

SetService updates or adds the service

func (*Nginx) SetServices

func (n *Nginx) SetServices(services []core.Service) error