cluster

Documentation

Index

• Constants
• type Cluster
  • func New(cfg *config.Config, stateChan, distributeChan chan<- bool, ...) (*Cluster, error)
  • func (c *Cluster) Start() error
  • func (c *Cluster) Stop() error
• type DirectorJSON
• type ICluster
• type MemberJSON

Constants

const (
	// change state actions
	START int = iota
	STOP

	// etcd actions
	CREATE int = iota
	UPDATE
	NOOP

	DIRECTOR_KEY = "cluster/director"
)

Types

type Cluster

type Cluster struct {
	Config         *config.Config
	Log            log.FieldLogger
	DirectorState  bool
	DirectorLock   *sync.Mutex
	MemberID       string
	DalClient      dal.IDal // etcd client is/should-be thread safe
	Hostname       string
	StateChan      chan<- bool
	DistributeChan chan<- bool
	OverwatchChan  chan<- *overwatch.Message

	DirectorMonitorLooper   looper.Looper
	DirectorHeartbeatLooper looper.Looper
	MemberHeartbeatLooper   looper.Looper

	base.Component
	// contains filtered or unexported fields
}

func New

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

func (*Cluster) Start

func (c *Cluster) Start() error

func (*Cluster) Stop

func (c *Cluster) Stop() error

type DirectorJSON

type DirectorJSON struct {
	MemberID   string
	LastUpdate time.Time
}

type ICluster

type ICluster interface {
	Start() error
	// contains filtered or unexported methods
}

type MemberJSON

type MemberJSON struct {
	MemberID      string
	Hostname      string
	ListenAddress string
	LastUpdated   time.Time
	Tags          []string
	Version       string
	SemVer        string
}