ip_manager

Documentation

Index

• Constants
• Variables
• func AllInUse(ips []throttledIP) bool
• func AllThrottled(ips []throttledIP) bool
• type IPPool
  • func GetIPPool(stopGrp *stop.Group) (*IPPool, error)
  • func (i *IPPool) GetIP(forVideo string) (string, error)
  • func (i *IPPool) ReleaseAll()
  • func (i *IPPool) ReleaseIP(ip string)
  • func (i *IPPool) SetThrottled(ip string)

Constants

const IPCooldownPeriod = 20 * time.Second

Variables

var ErrAllInUse = errors.Base("all IPs are in use, try again")

var ErrAllThrottled = errors.Base("all IPs are throttled")

var ErrInterruptedByUser = errors.Base("interrupted by user")

var ErrResourceLock = errors.Base("error getting next ip, did you forget to lock on the resource?")

Functions

func AllInUse

func AllInUse(ips []throttledIP) bool

AllInUse checks whether the IPs provided are all currently in use. returns false if at least one IP is not in use AND is not throttled Not thread safe, should use locking when called

func AllThrottled

func AllThrottled(ips []throttledIP) bool

AllThrottled checks whether the IPs provided are all throttled. returns false if at least one IP is not throttled Not thread safe, should use locking when called

Types

type IPPool

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

func GetIPPool

func GetIPPool(stopGrp *stop.Group) (*IPPool, error)

func (*IPPool) GetIP

func (i *IPPool) GetIP(forVideo string) (string, error)

func (*IPPool) ReleaseAll

func (i *IPPool) ReleaseAll()

func (*IPPool) ReleaseIP

func (i *IPPool) ReleaseIP(ip string)

func (*IPPool) SetThrottled

func (i *IPPool) SetThrottled(ip string)