Versions in this module Expand all Collapse all v0 v0.1.0 Sep 28, 2015 Changes in this version + func DefaultConfig() *config.Config + type AllocRunner struct + 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) + type AllocStateUpdater func(alloc *structs.Allocation) error + type Client struct + func NewClient(cfg *config.Config) (*Client, 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 TaskRunner struct + 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.Task) + func (r *TaskRunner) WaitCh() <-chan struct{} + type TaskStateUpdater func(taskName, status, desc string)
Go to main page