api

package

Go to main page

Versions in this module

v0

v0.3.0

Feb 25, 2016

Changes in this version

+ type AllocFS struct

+ func (a *AllocFS) List(alloc *Allocation, path string, q *QueryOptions) ([]*AllocFileInfo, *QueryMeta, error)

+ func (a *AllocFS) ReadAt(alloc *Allocation, path string, offset int64, limit int64, q *QueryOptions) (io.Reader, *QueryMeta, error)

+ func (a *AllocFS) Stat(alloc *Allocation, path string, q *QueryOptions) (*AllocFileInfo, *QueryMeta, error)

+ type AllocFileInfo struct

+ FileMode string

+ IsDir bool

+ ModTime time.Time

+ Name string

+ Size int64

type Allocation

+ CreateTime int64

type AllocationListStub

+ CreateTime int64

type AllocationMetric

+ NodesAvailable map[string]int

type Allocations

+ func (a *Allocations) PrefixList(prefix string) ([]*AllocationListStub, *QueryMeta, error)

type Client

+ func (c *Client) AllocFS() *AllocFS

+ func (c *Client) System() *System

type Evaluations

+ func (e *Evaluations) PrefixList(prefix string) ([]*Evaluation, *QueryMeta, error)

type Job

+ Periodic *PeriodicConfig

+ func (j *Job) AddPeriodicConfig(cfg *PeriodicConfig) *Job

type JobListStub

+ ParentID string

type Jobs

+ func (j *Jobs) PeriodicForce(jobID string, q *WriteOptions) (string, *WriteMeta, error)

+ func (j *Jobs) PrefixList(prefix string) ([]*JobListStub, *QueryMeta, error)

+ type LogConfig struct

+ MaxFileSizeMB int

+ MaxFiles int

type Node

+ HTTPAddr string

type Nodes

+ func (n *Nodes) PrefixList(prefix string) ([]*NodeListStub, *QueryMeta, error)

+ type PeriodicConfig struct

+ Enabled bool

+ ProhibitOverlap bool

+ Spec string

+ SpecType string

type QueryOptions

+ Prefix string

type RestartPolicy

+ Mode string

+ type System struct

+ func (s *System) GarbageCollect() error

type Task

+ KillTimeout time.Duration

+ LogConfig *LogConfig

+ func (t *Task) SetLogConfig(l *LogConfig) *Task

v0.3.0-rc2

Feb 23, 2016

v0.2.3

Dec 18, 2015

Changes in this version

type Allocation

+ Services map[string]string

v0.2.3-rc1

Dec 16, 2015

v0.2.2

Dec 11, 2015

Changes in this version

type Node

+ Meta map[string]string

v0.2.1

Nov 28, 2015

Changes in this version

type Client

+ func (c *Client) Regions() *Regions

+ type Regions struct

+ func (r *Regions) List() ([]string, error)

v0.2.0

Nov 19, 2015

Changes in this version

+ const TaskDriverFailure

+ const TaskKilled

+ const TaskStarted

+ const TaskTerminated

+ type AgentMembersNameSort []*AgentMember

+ func (a AgentMembersNameSort) Len() int

+ func (a AgentMembersNameSort) Less(i, j int) bool

+ func (a AgentMembersNameSort) Swap(i, j int)

type Allocation

+ TaskStates map[string]*TaskState

type AllocationListStub

+ TaskStates map[string]*TaskState

+ type AllocationSort []*Allocation

+ func (a AllocationSort) Len() int

+ func (a AllocationSort) Less(i, j int) bool

+ func (a AllocationSort) Swap(i, j int)

type Constraint

+ func NewConstraint(left, operand, right string) *Constraint

type Job

+ Update *UpdateStrategy

+ type Port struct

+ Label string

+ Value int

+ type RestartPolicy struct

+ Attempts int

+ Delay time.Duration

+ Interval time.Duration

+ func NewRestartPolicy() *RestartPolicy

+ type Service struct

+ Checks []ServiceCheck

+ Id string

+ Name string

+ PortLabel string

+ Tags []string

+ type ServiceCheck struct

+ Id string

+ Interval time.Duration

+ Name string

+ Path string

+ Protocol string

+ Script string

+ Timeout time.Duration

+ Type string

type Task

+ Services []Service

+ type TaskEvent struct

+ DriverError string

+ ExitCode int

+ KillError string

+ Message string

+ Signal int

+ Time int64

+ Type string

type TaskGroup

+ RestartPolicy *RestartPolicy

+ type TaskState struct

+ Events []*TaskEvent

+ State string

+ type UpdateStrategy struct

+ MaxParallel int

+ Stagger time.Duration

v0.1.2

Oct 6, 2015

v0.1.1

Oct 5, 2015

Changes in this version

type Task

+ Env map[string]string

v0.1.0

Sep 28, 2015

Changes in this version

+ const JobTypeBatch

+ const JobTypeService

+ type Agent struct

+ func (a *Agent) Datacenter() (string, error)

+ func (a *Agent) ForceLeave(node string) error

+ func (a *Agent) Join(addrs ...string) (int, error)

+ func (a *Agent) Members() ([]*AgentMember, error)

+ func (a *Agent) NodeName() (string, error)

+ func (a *Agent) Region() (string, error)

+ func (a *Agent) Self() (map[string]map[string]interface{}, error)

+ func (a *Agent) Servers() ([]string, error)

+ func (a *Agent) SetServers(addrs []string) error

+ type AgentMember struct

+ Addr string

+ DelegateCur uint8

+ DelegateMax uint8

+ DelegateMin uint8

+ Name string

+ Port uint16

+ ProtocolCur uint8

+ ProtocolMax uint8

+ ProtocolMin uint8

+ Status string

+ Tags map[string]string

+ type AllocIndexSort []*AllocationListStub

+ func (a AllocIndexSort) Len() int

+ func (a AllocIndexSort) Less(i, j int) bool

+ func (a AllocIndexSort) Swap(i, j int)

+ type Allocation struct

+ ClientDescription string

+ ClientStatus string

+ CreateIndex uint64

+ DesiredDescription string

+ DesiredStatus string

+ EvalID string

+ ID string

+ Job *Job

+ JobID string

+ Metrics *AllocationMetric

+ ModifyIndex uint64

+ Name string

+ NodeID string

+ Resources *Resources

+ TaskGroup string

+ TaskResources map[string]*Resources

+ type AllocationListStub struct

+ ClientDescription string

+ ClientStatus string

+ CreateIndex uint64

+ DesiredDescription string

+ DesiredStatus string

+ EvalID string

+ ID string

+ JobID string

+ ModifyIndex uint64

+ Name string

+ NodeID string

+ TaskGroup string

+ type AllocationMetric struct

+ AllocationTime time.Duration

+ ClassExhausted map[string]int

+ ClassFiltered map[string]int

+ CoalescedFailures int

+ ConstraintFiltered map[string]int

+ DimensionExhausted map[string]int

+ NodesEvaluated int

+ NodesExhausted int

+ NodesFiltered int

+ Scores map[string]float64

+ type Allocations struct

+ func (a *Allocations) Info(allocID string, q *QueryOptions) (*Allocation, *QueryMeta, error)

+ func (a *Allocations) List(q *QueryOptions) ([]*AllocationListStub, *QueryMeta, error)

+ type Client struct

+ func NewClient(config *Config) (*Client, error)

+ func (c *Client) Agent() *Agent

+ func (c *Client) Allocations() *Allocations

+ func (c *Client) Evaluations() *Evaluations

+ func (c *Client) Jobs() *Jobs

+ func (c *Client) Nodes() *Nodes

+ func (c *Client) Raw() *Raw

+ func (c *Client) Status() *Status

+ type Config struct

+ Address string

+ HttpClient *http.Client

+ Region string

+ WaitTime time.Duration

+ func DefaultConfig() *Config

+ type Constraint struct

+ Hard bool

+ LTarget string

+ Operand string

+ RTarget string

+ Weight int

+ func HardConstraint(left, operand, right string) *Constraint

+ func SoftConstraint(left, operand, right string, weight int) *Constraint

+ type EvalIndexSort []*Evaluation

+ func (e EvalIndexSort) Len() int

+ func (e EvalIndexSort) Less(i, j int) bool

+ func (e EvalIndexSort) Swap(i, j int)

+ type Evaluation struct

+ CreateIndex uint64

+ ID string

+ JobID string

+ JobModifyIndex uint64

+ ModifyIndex uint64

+ NextEval string

+ NodeID string

+ NodeModifyIndex uint64

+ PreviousEval string

+ Priority int

+ Status string

+ StatusDescription string

+ TriggeredBy string

+ Type string

+ Wait time.Duration

+ type Evaluations struct

+ func (e *Evaluations) Allocations(evalID string, q *QueryOptions) ([]*AllocationListStub, *QueryMeta, error)

+ func (e *Evaluations) Info(evalID string, q *QueryOptions) (*Evaluation, *QueryMeta, error)

+ func (e *Evaluations) List(q *QueryOptions) ([]*Evaluation, *QueryMeta, error)

+ type Job struct

+ AllAtOnce bool

+ Constraints []*Constraint

+ CreateIndex uint64

+ Datacenters []string

+ ID string

+ Meta map[string]string

+ ModifyIndex uint64

+ Name string

+ Priority int

+ Region string

+ Status string

+ StatusDescription string

+ TaskGroups []*TaskGroup

+ Type string

+ func NewBatchJob(id, name, region string, pri int) *Job

+ func NewServiceJob(id, name, region string, pri int) *Job

+ func (j *Job) AddDatacenter(dc string) *Job

+ func (j *Job) AddTaskGroup(grp *TaskGroup) *Job

+ func (j *Job) Constrain(c *Constraint) *Job

+ func (j *Job) SetMeta(key, val string) *Job

+ type JobIDSort []*JobListStub

+ func (j JobIDSort) Len() int

+ func (j JobIDSort) Less(a, b int) bool

+ func (j JobIDSort) Swap(a, b int)

+ type JobListStub struct

+ CreateIndex uint64

+ ID string

+ ModifyIndex uint64

+ Name string

+ Priority int

+ Status string

+ StatusDescription string

+ Type string

+ type Jobs struct

+ func (j *Jobs) Allocations(jobID string, q *QueryOptions) ([]*AllocationListStub, *QueryMeta, error)

+ func (j *Jobs) Deregister(jobID string, q *WriteOptions) (string, *WriteMeta, error)

+ func (j *Jobs) Evaluations(jobID string, q *QueryOptions) ([]*Evaluation, *QueryMeta, error)

+ func (j *Jobs) ForceEvaluate(jobID string, q *WriteOptions) (string, *WriteMeta, error)

+ func (j *Jobs) Info(jobID string, q *QueryOptions) (*Job, *QueryMeta, error)

+ func (j *Jobs) List(q *QueryOptions) ([]*JobListStub, *QueryMeta, error)

+ func (j *Jobs) Register(job *Job, q *WriteOptions) (string, *WriteMeta, error)

+ type NetworkResource struct

+ CIDR string

+ DynamicPorts []string

+ MBits int

+ Public bool

+ ReservedPorts []int

+ type Node struct

+ Attributes map[string]string

+ CreateIndex uint64

+ Datacenter string

+ Drain bool

+ ID string

+ Links map[string]string

+ ModifyIndex uint64

+ Name string

+ NodeClass string

+ Reserved *Resources

+ Resources *Resources

+ Status string

+ StatusDescription string

+ type NodeIndexSort []*NodeListStub

+ func (n NodeIndexSort) Len() int

+ func (n NodeIndexSort) Less(i, j int) bool

+ func (n NodeIndexSort) Swap(i, j int)

+ type NodeListStub struct

+ CreateIndex uint64

+ Datacenter string

+ Drain bool

+ ID string

+ ModifyIndex uint64

+ Name string

+ NodeClass string

+ Status string

+ StatusDescription string

+ type Nodes struct

+ func (n *Nodes) Allocations(nodeID string, q *QueryOptions) ([]*AllocationListStub, *QueryMeta, error)

+ func (n *Nodes) ForceEvaluate(nodeID string, q *WriteOptions) (string, *WriteMeta, error)

+ func (n *Nodes) Info(nodeID string, q *QueryOptions) (*Node, *QueryMeta, error)

+ func (n *Nodes) List(q *QueryOptions) ([]*NodeListStub, *QueryMeta, error)

+ func (n *Nodes) ToggleDrain(nodeID string, drain bool, q *WriteOptions) (*WriteMeta, error)

+ type QueryMeta struct

+ KnownLeader bool

+ LastContact time.Duration

+ LastIndex uint64

+ RequestTime time.Duration

+ type QueryOptions struct

+ AllowStale bool

+ Region string

+ WaitIndex uint64

+ WaitTime time.Duration

+ type Raw struct

+ func (raw *Raw) Delete(endpoint string, out interface{}, q *WriteOptions) (*WriteMeta, error)

+ func (raw *Raw) Query(endpoint string, out interface{}, q *QueryOptions) (*QueryMeta, error)

+ func (raw *Raw) Write(endpoint string, in, out interface{}, q *WriteOptions) (*WriteMeta, error)

+ type Resources struct

+ CPU int

+ DiskMB int

+ IOPS int

+ MemoryMB int

+ Networks []*NetworkResource

+ type Status struct

+ func (s *Status) Leader() (string, error)

+ func (s *Status) Peers() ([]string, error)

+ type Task struct

+ Config map[string]string

+ Constraints []*Constraint

+ Driver string

+ Meta map[string]string

+ Name string

+ Resources *Resources

+ func NewTask(name, driver string) *Task

+ func (t *Task) Constrain(c *Constraint) *Task

+ func (t *Task) Require(r *Resources) *Task

+ func (t *Task) SetConfig(key, val string) *Task

+ func (t *Task) SetMeta(key, val string) *Task

+ type TaskGroup struct

+ Constraints []*Constraint

+ Count int

+ Meta map[string]string

+ Name string

+ Tasks []*Task

+ func NewTaskGroup(name string, count int) *TaskGroup

+ func (g *TaskGroup) AddTask(t *Task) *TaskGroup

+ func (g *TaskGroup) Constrain(c *Constraint) *TaskGroup

+ func (g *TaskGroup) SetMeta(key, val string) *TaskGroup

+ type WriteMeta struct

+ LastIndex uint64

+ RequestTime time.Duration

+ type WriteOptions struct

+ Region string

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