director

package

v0.0.0-...-7cb0e1f Latest Latest Go to latest Published: Jul 11, 2017 License: MIT Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/9corp/9volt

Documentation ¶

Index ¶

Constants
type Director
- func New(cfg *config.Config, stateChan <-chan bool, distributeChan <-chan bool, ...) (*Director, error)
type IDirector

Constants ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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
}

Source Files ¶

View all Source files

director.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL