structs

package

Go to main page

Versions in this module

v1

v1.1.0-beta1

Feb 22, 2018

v1.0.3

Sep 22, 2017

v1.0.2

Sep 15, 2017

v1.0.1

Sep 15, 2017

Changes in this version

+ type ScalingMetric struct

+ Capacity int

+ Type string

+ Utilization int

v1.0.0

Sep 11, 2017

Changes in this version

+ const NodeStatusDown

+ const NodeStatusInit

+ const NodeStatusReady

type Config

+ ClusterScalingDisable bool

+ ClusterScalingInterval int

+ ConsulKeyRoot string

+ JobScalingDisable bool

+ JobScalingInterval int

type ConsulClient

+ PersistState func(*ScalingState) error

+ ReadState func(*ScalingState, bool)

type GroupScalingPolicy

+ Cooldown time.Duration

+ Enabled bool

+ Max int

+ Min int

+ ScaleDirection string

+ ScaleInCPU float64

+ ScaleInMem float64

+ ScaleOutCPU float64

+ ScaleOutMem float64

+ UID string

+ func NewGroupScalingPolicy() *GroupScalingPolicy

type JobScalingPolicies

+ LastChangeIndex uint64

+ Lock sync.RWMutex

+ Policies map[string][]*GroupScalingPolicy

+ type NodeRegistry struct

+ LastChangeIndex uint64

+ Lock sync.RWMutex

+ RegisteredNodes map[string]string

+ RegisteredNodesHash uint64

+ WorkerPools map[string]*WorkerPool

type NomadClient

+ ClusterScalingSafe func(*ClusterCapacity, *WorkerPool) bool

+ EvaluatePoolScaling func(*ClusterCapacity, *WorkerPool, *JobScalingPolicies) (bool, error)

+ IsJobInDeployment func(string) bool

+ JobGroupScale func(string, *GroupScalingPolicy, *ScalingState)

+ JobWatcher func(*JobScalingPolicies)

+ NodeWatcher func(*NodeRegistry)

+ type ScalingState struct

+ FailsafeAdmin bool

+ FailsafeMode bool

+ FailureCount int

+ LastNotificationEvent time.Time

+ LastScalingEvent time.Time

+ LastUpdated time.Time

+ Lock sync.RWMutex

+ ProtectedNode string

+ ResourceName string

+ ResourceType string

+ ScaleInRequests int

+ ScaleOutRequests int

+ StatePath string

+ type WorkerPool struct

+ Cooldown int

+ FaultTolerance int

+ Max int

+ Min int

+ Name string

+ Nodes map[string]*nomad.Node

+ NotificationUID string

+ ProtectedNode string

+ Region string

+ RetryThreshold int

+ ScalingEnabled bool

+ ScalingThreshold int

+ func NewWorkerPool() *WorkerPool

v0

v0.0.3-alpha1

Sep 7, 2017

v0.0.2

Aug 3, 2017

Changes in this version

+ type ClusterCapacity struct

+ MaxAllowedUtilization int

+ NodeAllocations []*NodeAllocation

+ NodeCount int

+ NodeList []string

+ ScalingDirection string

+ ScalingMetric string

+ TaskAllocation AllocationResources

+ TotalCapacity AllocationResources

+ UsedCapacity AllocationResources

type ClusterScaling

+ RetryThreshold int

+ ScalingThreshold int

+ func (c *ClusterScaling) Merge(b *ClusterScaling) *ClusterScaling

type Config

+ ConsulKeyLocation string

+ ConsulToken string

+ Notification *Notification

+ ScalingInterval int

type ConsulClient

+ AcquireLeadership func(string, string) bool

+ CreateSession func(int, chan struct{}) (string, error)

+ LoadState func(*Config, *State) *State

+ ResignLeadership func(string, string)

+ WriteState func(*Config, *State) error

+ type FailsafeMode struct

+ Config *Config

+ Disable bool

+ Enable bool

+ Force bool

+ Verb string

type JobScaling

+ func (j *JobScaling) Merge(b *JobScaling) *JobScaling

type NomadClient

+ NodeReverseLookup func(string) (string, error)

+ VerifyNodeHealth func(string) bool

+ type Notification struct

+ ClusterIdentifier string

+ ClusterScalingUID string

+ Notifiers []notifier.Notifier

+ PagerDutyServiceKey string

+ func (n *Notification) Merge(b *Notification) *Notification

+ type State struct

+ ClusterScaleInRequests int

+ ClusterScaleOutRequests int

+ FailsafeMode bool

+ FailsafeModeAdmin bool

+ LastFailedNode string

+ LastNodeFailure time.Time

+ LastScalingEvent time.Time

+ LastUpdated time.Time

+ NodeFailureCount int

+ ProtectedNode string

type Telemetry

+ func (t *Telemetry) Merge(b *Telemetry) *Telemetry

v0.0.2-alpha2

Jun 19, 2017

v0.0.1

May 3, 2017

Changes in this version

+ type AllocationResources struct

+ CPUMHz int

+ CPUPercent float64

+ DiskMB int

+ DiskPercent float64

+ MemoryMB int

+ MemoryPercent float64

+ type ClusterAllocation struct

+ LastScalingEvent time.Time

+ MaxAllowedUtilization int

+ NodeAllocations []*NodeAllocation

+ NodeCount int

+ NodeList []string

+ ScalingDirection string

+ ScalingMetric string

+ TaskAllocation AllocationResources

+ TotalCapacity AllocationResources

+ UsedCapacity AllocationResources

+ type ClusterScaling struct

+ AutoscalingGroup string

+ CoolDown float64

+ Enabled bool

+ MaxSize int

+ MinSize int

+ NodeFaultTolerance int

+ type Config struct

+ ClusterScaling *ClusterScaling

+ Consul string

+ ConsulClient ConsulClient

+ Enforce bool

+ JobScaling *JobScaling

+ LogLevel string

+ Nomad string

+ NomadClient NomadClient

+ Region string

+ SetKeys map[string]struct{}

+ Telemetry *Telemetry

+ func (c *Config) Merge(o *Config)

+ func (c *Config) WasSet(key string) bool

+ type ConsulClient interface

+ GetJobScalingPolicies func(*Config, NomadClient) ([]*JobScalingPolicy, error)

+ type GroupScalingPolicy struct

+ GroupName string

+ Scaling *Scaling

+ ScalingMetric string

+ Tasks TaskAllocation

+ type JobScaling struct

+ ConsulKeyLocation string

+ ConsulToken string

+ Enabled bool

+ type JobScalingPolicies []*JobScalingPolicy

+ type JobScalingPolicy struct

+ Enabled bool

+ GroupScalingPolicies []*GroupScalingPolicy

+ JobName string

+ type NodeAllocation struct

+ NodeID string

+ NodeIP string

+ UsedCapacity AllocationResources

+ type NomadClient interface

+ ClusterAllocationCapacity func(*ClusterAllocation) error

+ ClusterAssignedAllocation func(*ClusterAllocation) error

+ DrainNode func(string) error

+ EvaluateClusterCapacity func(*ClusterAllocation, *Config) (bool, error)

+ EvaluateJobScaling func([]*JobScalingPolicy)

+ GetAllocationStats func(*nomad.Allocation, *GroupScalingPolicy)

+ GetJobAllocations func([]*nomad.AllocationListStub, *GroupScalingPolicy)

+ IsJobRunning func(string) bool

+ JobScale func(*JobScalingPolicy)

+ LeaderCheck func() bool

+ LeastAllocatedNode func(*ClusterAllocation) (string, string)

+ MostUtilizedResource func(*ClusterAllocation)

+ TaskAllocationTotals func(*ClusterAllocation) error

+ type Scaling struct

+ Max int

+ Min int

+ ScaleDirection string

+ ScaleIn *scalein

+ ScaleOut *scaleout

+ type TaskAllocation struct

+ Resources AllocationResources

+ TaskName string

+ type Telemetry struct

+ StatsdAddress string

v0.0.1-alpha

Apr 23, 2017

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