balancer

Documentation

Index

• type Balancer
  • func New() *Balancer
  • func (b *Balancer) Next(minSpace int64) (*Volume, error)
  • func (b *Balancer) Track(pubURL string, volumes []*proto.VolumesAcknowledgeRequest_Volume) error
  • func (b *Balancer) Untrack(pubURL string, volumes []*proto.VolumesAcknowledgeRequest_Volume)
• type Volume
• type VolumeInfo

Types

type Balancer

type Balancer struct {
	Volumes *orderedmap.OrderedMap[int64, VolumeInfo]
}

Simple balancing to retrieve the next volume and its server's public URL, checking for free space

func New

func New() *Balancer

func (*Balancer) Next

func (b *Balancer) Next(minSpace int64) (*Volume, error)

Gets the next volume that has enough space to store the file

func (*Balancer) Track

func (b *Balancer) Track(pubURL string, volumes []*proto.VolumesAcknowledgeRequest_Volume) error

Tracks the given volumes in the balancer, sorting them by id

func (*Balancer) Untrack

func (b *Balancer) Untrack(pubURL string, volumes []*proto.VolumesAcknowledgeRequest_Volume)

Removes the given volumes from the balancer

type Volume

type Volume struct {
	Id int64
	VolumeInfo
}

type VolumeInfo

type VolumeInfo struct {
	PublicUrl string
	FreeSpace int64
}