client

Documentation

Index

• func DefaultConfig() *config.Config
• 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) RestoreState() error
  • func (r *AllocRunner) Run()
  • func (r *AllocRunner) SaveState() error
  • func (r *AllocRunner) Update(update *structs.Allocation)
  • func (r *AllocRunner) WaitCh() <-chan struct{}
• type AllocStateUpdater
• type Client
  • func NewClient(cfg *config.Config) (*Client, error)
  • func (c *Client) GetAllocFS(allocID string) (allocdir.AllocDirFS, error)
  • 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) Servers() []string
  • func (c *Client) SetServers(servers []string)
  • func (c *Client) Shutdown() error
  • func (c *Client) Stats() map[string]map[string]string
• type ConsulService
  • func NewConsulService(config *consulServiceConfig) (*ConsulService, error)
  • func (c *ConsulService) Deregister(task *structs.Task, alloc *structs.Allocation) error
  • func (c *ConsulService) Register(task *structs.Task, alloc *structs.Allocation) error
  • func (c *ConsulService) ShutDown()
  • func (c *ConsulService) SyncWithConsul()
• type RestartTracker
  • 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) 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

Functions

func DefaultConfig

func DefaultConfig() *config.Config

DefaultConfig returns the default configuration

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, consulService *ConsulService) *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) 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) 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 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) (*Client, error)

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

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) 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) Servers

func (c *Client) Servers() []string

Servers is used to return the current known servers list. When an agent is first started, this list comes directly from configuration files.

func (*Client) SetServers

func (c *Client) SetServers(servers []string)

SetServers is used to modify the known servers list. This avoids forcing a config rollout + rolling restart and enables auto-join features. The full set of servers is passed to support adding and/or removing servers.

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

type ConsulService

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

ConsulService is the service which tracks tasks and syncs the services and checks defined in them with Consul Agent

func NewConsulService

func NewConsulService(config *consulServiceConfig) (*ConsulService, error)

A factory method to create new consul service

func (*ConsulService) Deregister

func (c *ConsulService) Deregister(task *structs.Task, alloc *structs.Allocation) error

Deregister stops tracking a task for changes to it's services and checks and removes all the services and checks associated with the Task

func (*ConsulService) Register

func (c *ConsulService) Register(task *structs.Task, alloc *structs.Allocation) error

Register starts tracking a task for changes to it's services and tasks and adds/removes services and checks associated with it.

func (*ConsulService) ShutDown

func (c *ConsulService) ShutDown()

func (*ConsulService) SyncWithConsul

func (c *ConsulService) SyncWithConsul()

SyncWithConsul is a long lived function that performs calls to sync checks and services periodically with Consul Agent

type RestartTracker

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

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,
	consulService *ConsulService) *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) 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.