balancer

Documentation

Index

• type Balancer
  • func New(idb influxdb.QueryAPI, config *config.BalancerConfig, idbConfig *config.IDB) Balancer
• type InfluxDBBalancer
  • func (b *InfluxDBBalancer) ClusterStatus(instances []string) ([]InstanceStatus, error)
  • func (b *InfluxDBBalancer) Process(instances []string) (string, error)
• type InstanceStatus

Types

type Balancer

type Balancer interface {
	Process(instances []string) (string, error)
	ClusterStatus(instances []string) ([]InstanceStatus, error)
}

Balancer find the right server to use

func New

func New(idb influxdb.QueryAPI, config *config.BalancerConfig, idbConfig *config.IDB) Balancer

New creates a new Balancer object

type InfluxDBBalancer

type InfluxDBBalancer struct {
	Client    influxdb.QueryAPI
	Config    *config.BalancerConfig
	IDBConfig *config.IDB
}

InfluxDBBalancer is the InfluxDB implementation of Balancer

func (*InfluxDBBalancer) ClusterStatus

func (b *InfluxDBBalancer) ClusterStatus(instances []string) ([]InstanceStatus, error)

ClusterStatus retrieve the cluster status. It returns a list containing all bbb instance with its status

func (*InfluxDBBalancer) Process

func (b *InfluxDBBalancer) Process(instances []string) (string, error)

Process compute data to find a bigbluebutton server

type InstanceStatus

type InstanceStatus struct {
	Host               string  `json:"host"`
	CPU                float64 `json:"cpu"`
	Mem                float64 `json:"mem"`
	ActiveMeeting      int64   `json:"active_meetings"`
	ActiveParticipants int64   `json:"active_participants"`
	APIStatus          string  `json:"api_status"`
}

InstanceStatus represents a cluster instance status at a time