director

Documentation

Index

• Constants
• type Director
  • func New(cfg *config.Config, stateChan <-chan bool, distributeChan <-chan bool, ...) (*Director, error)
  • func (d *Director) PickNextMember(checkTag string) (string, error)
  • func (d *Director) Start() error
  • func (d *Director) Stop() error
• type IDirector

Constants

const (
	COLLECT_CHECK_STATS_INTERVAL = time.Duration(5 * time.Second)
	UNTAGGED_MEMBER_MAP_ENTRY    = "!UNTAGGED!"
)

Types

type Director

type Director struct {
	MemberID         string
	Config           *config.Config
	Log              log.FieldLogger
	State            bool
	StateChan        <-chan bool
	DistributeChan   <-chan bool
	OverwatchChan    chan<- *overwatch.Message
	StateLock        *sync.Mutex
	DalClient        dal.IDal
	CheckStatsLooper looper.Looper

	CheckStats      map[string]*dal.MemberStat
	CheckStatsMutex *sync.Mutex

	base.Component
}

func New

func New(cfg *config.Config, stateChan <-chan bool, distributeChan <-chan bool, overwatchChan chan<- *overwatch.Message) (*Director, error)

func (*Director) PickNextMember

func (d *Director) PickNextMember(checkTag string) (string, error)

Return the least taxed cluster member

If check stats are blank; return our own memberid:

• if the check tag is blank and we have no tags
• if the check tag is the same as one of our own tags
• else, return a "no feasible members found" error

If check stats are not blank:

• build a 'feasible members' slice
• determine if any of the feasible members have the 'checkTag'
• if not, return a "no feasible members found" error

func (*Director) Start

func (d *Director) Start() error

func (*Director) Stop

func (d *Director) Stop() error

type IDirector

type IDirector interface {
	Start() error
}