client

Documentation

Index

• Constants
• type AllocRunner
  • func NewAllocRunner(logger *log.Logger, config *config.Config, updater AllocStateUpdater, ...) *AllocRunner
  • func (r *AllocRunner) Alloc() *structs.Allocation
  • func (r *AllocRunner) Destroy()
  • func (r *AllocRunner) DestroyContext() error
  • func (r *AllocRunner) DestroyState() error
  • func (r *AllocRunner) LatestAllocStats(taskFilter string) (*cstructs.AllocResourceUsage, error)
  • func (r *AllocRunner) RestoreState() error
  • func (r *AllocRunner) Run()
  • func (r *AllocRunner) SaveState() error
  • func (r *AllocRunner) StatsReporter() AllocStatsReporter
  • func (r *AllocRunner) Update(update *structs.Allocation)
  • func (r *AllocRunner) WaitCh() <-chan struct{}
• type AllocStateUpdater
• type AllocStatsReporter
• type Client
  • func NewClient(cfg *config.Config, consulSyncer *consul.Syncer, logger *log.Logger) (*Client, error)
  • func (c *Client) AddPrimaryServerToRPCProxy(serverAddr string) *rpcproxy.ServerEndpoint
  • func (c *Client) Datacenter() string
  • func (c *Client) GetAllocFS(allocID string) (allocdir.AllocDirFS, error)
  • func (c *Client) GetAllocStats(allocID string) (AllocStatsReporter, error)
  • func (c *Client) LatestHostStats() *stats.HostStats
  • func (c *Client) Leave() error
  • func (c *Client) Node() *structs.Node
  • func (c *Client) RPC(method string, args interface{}, reply interface{}) error
  • func (c *Client) RPCMajorVersion() int
  • func (c *Client) RPCMinorVersion() int
  • func (c *Client) RPCProxy() *rpcproxy.RPCProxy
  • func (c *Client) Region() string
  • func (c *Client) Shutdown() error
  • func (c *Client) Stats() map[string]map[string]string
  • func (c *Client) StatsReporter() ClientStatsReporter
• type ClientStatsReporter
• type RestartTracker
  • func (r *RestartTracker) GetReason() string
  • func (r *RestartTracker) GetState() (string, time.Duration)
  • func (r *RestartTracker) SetPolicy(policy *structs.RestartPolicy)
  • func (r *RestartTracker) SetStartError(err error) *RestartTracker
  • func (r *RestartTracker) SetWaitResult(res *cstructs.WaitResult) *RestartTracker
• type TaskRunner
  • func NewTaskRunner(logger *log.Logger, config *config.Config, updater TaskStateUpdater, ...) *TaskRunner
  • func (r *TaskRunner) Destroy()
  • func (r *TaskRunner) DestroyState() error
  • func (r *TaskRunner) LatestResourceUsage() *cstructs.TaskResourceUsage
  • func (r *TaskRunner) MarkReceived()
  • func (r *TaskRunner) RestoreState() error
  • func (r *TaskRunner) Run()
  • func (r *TaskRunner) SaveState() error
  • func (r *TaskRunner) Update(update *structs.Allocation)
  • func (r *TaskRunner) WaitCh() <-chan struct{}
• type TaskStateUpdater

Constants

const (
	ReasonNoRestartsAllowed   = "Policy allows no restarts"
	ReasonUnrecoverableErrror = "Error was unrecoverable"
	ReasonWithinPolicy        = "Restart within policy"
	ReasonDelay               = "Exceeded allowed attempts, applying a delay"
)

Types

type AllocRunner

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

AllocRunner is used to wrap an allocation and provide the execution context.

func NewAllocRunner

func NewAllocRunner(logger *log.Logger, config *config.Config, updater AllocStateUpdater,
	alloc *structs.Allocation) *AllocRunner

NewAllocRunner is used to create a new allocation context

func (*AllocRunner) Alloc

func (r *AllocRunner) Alloc() *structs.Allocation

Alloc returns the associated allocation

func (*AllocRunner) Destroy

func (r *AllocRunner) Destroy()

Destroy is used to indicate that the allocation context should be destroyed

func (*AllocRunner) DestroyContext

func (r *AllocRunner) DestroyContext() error

DestroyContext is used to destroy the context

func (*AllocRunner) DestroyState

func (r *AllocRunner) DestroyState() error

DestroyState is used to cleanup after ourselves

func (*AllocRunner) LatestAllocStats

func (r *AllocRunner) LatestAllocStats(taskFilter string) (*cstructs.AllocResourceUsage, error)

LatestAllocStats returns the latest allocation stats. If the optional taskFilter is set the allocation stats will only include the given task.

func (*AllocRunner) RestoreState

func (r *AllocRunner) RestoreState() error

RestoreState is used to restore the state of the alloc runner

func (*AllocRunner) Run

func (r *AllocRunner) Run()

Run is a long running goroutine used to manage an allocation

func (*AllocRunner) SaveState

func (r *AllocRunner) SaveState() error

SaveState is used to snapshot the state of the alloc runner if the fullSync is marked as false only the state of the Alloc Runner is snapshotted. If fullSync is marked as true, we snapshot all the Task Runners associated with the Alloc

func (*AllocRunner) StatsReporter

func (r *AllocRunner) StatsReporter() AllocStatsReporter

StatsReporter returns an interface to query resource usage statistics of an allocation

func (*AllocRunner) Update

func (r *AllocRunner) Update(update *structs.Allocation)

Update is used to update the allocation of the context

func (*AllocRunner) WaitCh

func (r *AllocRunner) WaitCh() <-chan struct{}

WaitCh returns a channel to wait for termination

type AllocStateUpdater

type AllocStateUpdater func(alloc *structs.Allocation)

AllocStateUpdater is used to update the status of an allocation

type AllocStatsReporter

type AllocStatsReporter interface {
	LatestAllocStats(taskFilter string) (*cstructs.AllocResourceUsage, error)
}

type Client

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

Client is used to implement the client interaction with Nomad. Clients are expected to register as a schedulable node to the servers, and to run allocations as determined by the servers.

func NewClient

func NewClient(cfg *config.Config, consulSyncer *consul.Syncer, logger *log.Logger) (*Client, error)

NewClient is used to create a new client from the given configuration

func (*Client) AddPrimaryServerToRPCProxy

func (c *Client) AddPrimaryServerToRPCProxy(serverAddr string) *rpcproxy.ServerEndpoint

AddPrimaryServerToRPCProxy adds serverAddr to the RPC Proxy's primary server list.

func (*Client) Datacenter

func (c *Client) Datacenter() string

Datacenter returns the datacenter for the given client

func (*Client) GetAllocFS

func (c *Client) GetAllocFS(allocID string) (allocdir.AllocDirFS, error)

GetAllocFS returns the AllocFS interface for the alloc dir of an allocation

func (*Client) GetAllocStats

func (c *Client) GetAllocStats(allocID string) (AllocStatsReporter, error)

func (*Client) LatestHostStats

func (c *Client) LatestHostStats() *stats.HostStats

HostStats returns all the stats related to a Nomad client

func (*Client) Leave

func (c *Client) Leave() error

Leave is used to prepare the client to leave the cluster

func (*Client) Node

func (c *Client) Node() *structs.Node

Node returns the locally registered node

func (*Client) RPC

func (c *Client) RPC(method string, args interface{}, reply interface{}) error

RPC is used to forward an RPC call to a nomad server, or fail if no servers

func (*Client) RPCMajorVersion

func (c *Client) RPCMajorVersion() int

RPCMajorVersion returns the structs.ApiMajorVersion supported by the client.

func (*Client) RPCMinorVersion

func (c *Client) RPCMinorVersion() int

RPCMinorVersion returns the structs.ApiMinorVersion supported by the client.

func (*Client) RPCProxy

func (c *Client) RPCProxy() *rpcproxy.RPCProxy

RPCProxy returns the Client's RPCProxy instance

func (*Client) Region

func (c *Client) Region() string

Region returns the region for the given client

func (*Client) Shutdown

func (c *Client) Shutdown() error

Shutdown is used to tear down the client

func (*Client) Stats

func (c *Client) Stats() map[string]map[string]string

Stats is used to return statistics for debugging and insight for various sub-systems

func (*Client) StatsReporter

func (c *Client) StatsReporter() ClientStatsReporter

StatsReporter exposes the various APIs related resource usage of a Nomad client

type ClientStatsReporter

type ClientStatsReporter interface {
	// GetAllocStats returns the AllocStatsReporter for the passed allocation.
	// If it does not exist an error is reported.
	GetAllocStats(allocID string) (AllocStatsReporter, error)

	// LatestHostStats returns the latest resource usage stats for the host
	LatestHostStats() *stats.HostStats
}

ClientStatsReporter exposes all the APIs related to resource usage of a Nomad Client

type RestartTracker

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

func (*RestartTracker) GetReason

func (r *RestartTracker) GetReason() string

GetReason returns a human-readable description for the last state returned by GetState.

func (*RestartTracker) GetState

func (r *RestartTracker) GetState() (string, time.Duration)

GetState returns the tasks next state given the set exit code and start error. One of the following states are returned:

• TaskRestarting - Task should be restarted
• TaskNotRestarting - Task should not be restarted and has exceeded its restart policy.
• TaskTerminated - Task has terminated successfully and does not need a restart.

If TaskRestarting is returned, the duration is how long to wait until starting the task again.

func (*RestartTracker) SetPolicy

func (r *RestartTracker) SetPolicy(policy *structs.RestartPolicy)

SetPolicy updates the policy used to determine restarts.

func (*RestartTracker) SetStartError

func (r *RestartTracker) SetStartError(err error) *RestartTracker

SetStartError is used to mark the most recent start error. If starting was successful the error should be nil.

func (*RestartTracker) SetWaitResult

func (r *RestartTracker) SetWaitResult(res *cstructs.WaitResult) *RestartTracker

SetWaitResult is used to mark the most recent wait result.

type TaskRunner

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

TaskRunner is used to wrap a task within an allocation and provide the execution context.

func NewTaskRunner

func NewTaskRunner(logger *log.Logger, config *config.Config,
	updater TaskStateUpdater, ctx *driver.ExecContext,
	alloc *structs.Allocation, task *structs.Task) *TaskRunner

NewTaskRunner is used to create a new task context

func (*TaskRunner) Destroy

func (r *TaskRunner) Destroy()

Destroy is used to indicate that the task context should be destroyed

func (*TaskRunner) DestroyState

func (r *TaskRunner) DestroyState() error

DestroyState is used to cleanup after ourselves

func (*TaskRunner) LatestResourceUsage

func (r *TaskRunner) LatestResourceUsage() *cstructs.TaskResourceUsage

LatestResourceUsage returns the last resource utilization datapoint collected

func (*TaskRunner) MarkReceived

func (r *TaskRunner) MarkReceived()

MarkReceived marks the task as received.

func (*TaskRunner) RestoreState

func (r *TaskRunner) RestoreState() error

RestoreState is used to restore our state

func (*TaskRunner) Run

func (r *TaskRunner) Run()

Run is a long running routine used to manage the task

func (*TaskRunner) SaveState

func (r *TaskRunner) SaveState() error

SaveState is used to snapshot our state

func (*TaskRunner) Update

func (r *TaskRunner) Update(update *structs.Allocation)

Update is used to update the task of the context

func (*TaskRunner) WaitCh

func (r *TaskRunner) WaitCh() <-chan struct{}

WaitCh returns a channel to wait for termination

type TaskStateUpdater

type TaskStateUpdater func(taskName, state string, event *structs.TaskEvent)

TaskStateUpdater is used to signal that tasks state has changed.