cluster

Documentation

Index

• Constants
• type BBHost
• type BBResult
• type DynamicBBManager
  • func NewDynamicBBManager(bbHosts []string) *DynamicBBManager
  • func (c *DynamicBBManager) GetCurrentEra() Era
  • func (c *DynamicBBManager) GetEra(t time.Time) Era
• type Era
• type GoServiceNode
• type Manager
• type Node
• type SimpleEra
  • func NewSimpleEra() *SimpleEra
  • func (s *SimpleEra) Add(n Node)
  • func (s *SimpleEra) GetNodes() []Node
• type SimpleNode
  • func NewSimpleNode(name string, ip string, port string) *SimpleNode
  • func (n *SimpleNode) Ip() string
  • func (n *SimpleNode) Name() string
  • func (n *SimpleNode) Port() string
• type StaticManager
  • func NewStaticManager(e Era) *StaticManager
  • func (c *StaticManager) GetCurrentEra() Era
  • func (c *StaticManager) GetEra(t time.Time) Era
• type WeightedEra
  • func NewWeightedEra() *WeightedEra
  • func (s *WeightedEra) Add(n Node)
  • func (s *WeightedEra) GetNode(posit int) *WeightedNode
  • func (s *WeightedEra) GetNodes() []Node
  • func (s *WeightedEra) NormalizeAndPopulateMap()
• type WeightedNode
  • func NewWeightedNode(name string, ip string, port string, disk float32, load float32) *WeightedNode
  • func (n *WeightedNode) Ip() string
  • func (n *WeightedNode) Name() string
  • func (n *WeightedNode) Port() string

Constants

const (
	MAX_WEIGHT        = 100
	MEDIAN_WEIGHT     = 50
	MIN_DISK_TO_WORRY = 0.000809804
	DEGRADED_WEIGHT   = 30
)

const (
	MAX_ERAS_SAVED = 10
)

Types

type BBHost

type BBHost struct {
	Disk_free float32
	Load      float32
	Name      string
	Ip        string
	Port      int
}

type BBResult

type BBResult struct {
	Nodes []BBHost
}

type DynamicBBManager

type DynamicBBManager struct {
	Eras        map[time.Time]Era
	ErasAdded   []time.Time
	BBHosts     []string
	CurrentTime time.Time
}

func NewDynamicBBManager

func NewDynamicBBManager(bbHosts []string) *DynamicBBManager

func (*DynamicBBManager) GetCurrentEra

func (c *DynamicBBManager) GetCurrentEra() Era

func (*DynamicBBManager) GetEra

func (c *DynamicBBManager) GetEra(t time.Time) Era

type Era

type Era interface {
	GetNodes() []Node
}

type GoServiceNode

type GoServiceNode interface {
	Name() string
	Ip() string
	Port() string
}

type Manager

type Manager interface {
	GetEra(t time.Time) Era
	GetCurrentEra() Era
}

There should be a separate manager for each service

type Node

type Node interface {
	Name() string
}

type SimpleEra

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

func NewSimpleEra

func NewSimpleEra() *SimpleEra

func (*SimpleEra) Add

func (s *SimpleEra) Add(n Node)

func (*SimpleEra) GetNodes

func (s *SimpleEra) GetNodes() []Node

type SimpleNode

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

func NewSimpleNode

func NewSimpleNode(name string, ip string, port string) *SimpleNode

func (*SimpleNode) Ip

func (n *SimpleNode) Ip() string

func (*SimpleNode) Name

func (n *SimpleNode) Name() string

func (*SimpleNode) Port

func (n *SimpleNode) Port() string

type StaticManager

type StaticManager struct {
	E Era
}

func NewStaticManager

func NewStaticManager(e Era) *StaticManager

func (*StaticManager) GetCurrentEra

func (c *StaticManager) GetCurrentEra() Era

func (*StaticManager) GetEra

func (c *StaticManager) GetEra(t time.Time) Era

type WeightedEra

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

func NewWeightedEra

func NewWeightedEra() *WeightedEra

func (*WeightedEra) Add

func (s *WeightedEra) Add(n Node)

func (*WeightedEra) GetNode

func (s *WeightedEra) GetNode(posit int) *WeightedNode

func (*WeightedEra) GetNodes

func (s *WeightedEra) GetNodes() []Node

func (*WeightedEra) NormalizeAndPopulateMap

func (s *WeightedEra) NormalizeAndPopulateMap()

type WeightedNode

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

func NewWeightedNode

func NewWeightedNode(name string, ip string, port string, disk float32, load float32) *WeightedNode

func (*WeightedNode) Ip

func (n *WeightedNode) Ip() string

func (*WeightedNode) Name

func (n *WeightedNode) Name() string

func (*WeightedNode) Port

func (n *WeightedNode) Port() string