nomadWorker

Documentation

Index

• Constants
• type Connector
  • func New(nomadServerAddress, awsProfile string, options ...Option) (*Connector, error)
  • func (c *Connector) AdjustScalingObjectCount(datacenter string, min uint, max uint, from uint, to uint) error
  • func (c *Connector) GetScalingObjectCount(datacenter string) (uint, error)
  • func (c *Connector) IsScalingObjectDead(datacenter string) (bool, error)
  • func (c *Connector) String() string
• type Nodes
• type Option
  • func TimeoutForInstanceTermination(timeout time.Duration) Option
  • func WithAwsRegion(region string) Option
  • func WithLogger(logger zerolog.Logger) Option

Constants

const MaxInt = int(MaxUint >> 1)

const MaxUint = ^uint(0)

Types

type Connector

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

Connector is a object that allows to interact with nomad worker

func New

func New(nomadServerAddress, awsProfile string, options ...Option) (*Connector, error)

New creates a new nomad worker connector. The profile represents the name of the aws profile that shall be used to access the resources to scale the aws AutoScalingGroup. This parameter is optional. If the profile is NOT set the instance where sokar runs on has to have enough permissions to access the resources (ASG) for scaling (e.g. granted by a AWS Instance Profile). In this case the region parameter has to be specified instead (via WithAwsRegion()).

func (*Connector) AdjustScalingObjectCount

func (c *Connector) AdjustScalingObjectCount(datacenter string, min uint, max uint, from uint, to uint) error

AdjustScalingObjectCount will scale the nomad workers to the desired count (amount of instances)

func (*Connector) GetScalingObjectCount

func (c *Connector) GetScalingObjectCount(datacenter string) (uint, error)

GetScalingObjectCount will return the count of the nomad workers

func (*Connector) IsScalingObjectDead

func (c *Connector) IsScalingObjectDead(datacenter string) (bool, error)

IsScalingObjectDead will return if the nomad workers of the actual data-center are still available.

func (*Connector) String

func (c *Connector) String() string

type Nodes

type Nodes interface {
	List(q *nomadApi.QueryOptions) ([]*nomadApi.NodeListStub, *nomadApi.QueryMeta, error)
	ToggleEligibility(nodeID string, eligible bool, q *nomadApi.WriteOptions) (*nomadApi.NodeEligibilityUpdateResponse, error)
	UpdateDrain(nodeID string, spec *nomadApi.DrainSpec, markEligible bool, q *nomadApi.WriteOptions) (*nomadApi.NodeDrainUpdateResponse, error)
	MonitorDrain(ctx context.Context, nodeID string, index uint64, ignoreSys bool) <-chan *nomadApi.MonitorMessage
	Allocations(nodeID string, q *nomadApi.QueryOptions) ([]*nomadApi.Allocation, *nomadApi.QueryMeta, error)
}

Nodes represents the minimal interface used to gather information about nomad nodes

type Option

type Option func(c *Connector)

Option represents an option for the nomadWorker Connector

func TimeoutForInstanceTermination

func TimeoutForInstanceTermination(timeout time.Duration) Option

TimeoutForInstanceTermination sets the maximum time the instance termination will be monitored before assuming that this action failed.

func WithAwsRegion

func WithAwsRegion(region string) Option

WithAwsRegion sets the aws region in which the resource to be scaled can be found

func WithLogger

func WithLogger(logger zerolog.Logger) Option

WithLogger adds a configured Logger to the nomadWorker Connector