structs

package

Go to main page

Versions in this module

v0

v0.5.5

Mar 14, 2017

Changes in this version

+ const ConstraintDistinctProperty

+ const RestartPolicyMinInterval

+ const TaskBuildingTaskDir

+ const TaskLeaderDead

+ const TaskSetup

+ type JobValidateRequest struct

+ Job *Job

+ type JobValidateResponse struct

+ DriverConfigValidated bool

+ Error string

+ ValidationErrors []string

type PeriodicConfig

+ TimeZone string

+ func (p *PeriodicConfig) Canonicalize()

+ func (p *PeriodicConfig) GetLocation() *time.Location

+ type RaftConfigurationResponse struct

+ Index uint64

+ Servers []*RaftServer

+ type RaftPeerByAddressRequest struct

+ Address raft.ServerAddress

+ type RaftServer struct

+ Address raft.ServerAddress

+ ID raft.ServerID

+ Leader bool

+ Node string

+ Voter bool

type Task

+ Leader bool

type TaskEvent

+ func (te *TaskEvent) SetMessage(msg string) *TaskEvent

type Template

+ LeftDelim string

+ Perms string

+ RightDelim string

v0.5.5-rc2

Mar 4, 2017

v0.5.5-rc1

Feb 24, 2017

v0.5.4

Feb 1, 2017

v0.5.3

Jan 30, 2017

Changes in this version

+ const DispatchLaunchSuffix

+ const DispatchPayloadForbidden

+ const DispatchPayloadOptional

+ const DispatchPayloadRequired

+ func DispatchedID(templateID string, t time.Time) string

+ func IsRecoverable(e error) bool

+ type DispatchPayloadConfig struct

+ File string

+ func (d *DispatchPayloadConfig) Copy() *DispatchPayloadConfig

+ func (d *DispatchPayloadConfig) Validate() error

type Job

+ ParameterizedJob *ParameterizedJobConfig

+ Payload []byte

+ func (j *Job) CombinedTaskMeta(groupName, taskName string) map[string]string

+ func (j *Job) IsParameterized() bool

+ type JobChildrenSummary struct

+ Dead int64

+ Pending int64

+ Running int64

+ func (jc *JobChildrenSummary) Copy() *JobChildrenSummary

+ type JobDispatchRequest struct

+ JobID string

+ Meta map[string]string

+ Payload []byte

+ type JobDispatchResponse struct

+ DispatchedJobID string

+ EvalCreateIndex uint64

+ EvalID string

+ JobCreateIndex uint64

type JobSummary

+ Children *JobChildrenSummary

+ type ParameterizedJobConfig struct

+ MetaOptional []string

+ MetaRequired []string

+ Payload string

+ func (d *ParameterizedJobConfig) Canonicalize()

+ func (d *ParameterizedJobConfig) Copy() *ParameterizedJobConfig

+ func (d *ParameterizedJobConfig) Validate() error

type Task

+ DispatchPayload *DispatchPayloadConfig

v0.5.3-rc1

Jan 24, 2017

v0.5.2

Dec 21, 2016

Changes in this version

+ const TaskDriverMessage

type JobSpecificRequest

+ AllAllocs bool

type TaskEvent

+ DriverMessage string

+ func (e *TaskEvent) SetDriverMessage(m string) *TaskEvent

v0.5.2-rc1

Dec 13, 2016

v0.5.1

Dec 12, 2016

v0.5.1-rc2

Dec 10, 2016

v0.5.1-rc1

Dec 6, 2016

v0.5.0

Nov 16, 2016

Changes in this version

+ const BytesInMegabyte

+ const ConstraintSetContains

+ const TaskDiskExceeded

+ const TaskRestartSignal

+ const TaskSetupFailure

+ const TaskSiblingFailed

+ const TaskSignaling

+ const TemplateChangeModeNoop

+ const TemplateChangeModeRestart

+ const TemplateChangeModeSignal

+ const VaultChangeModeNoop

+ const VaultChangeModeRestart

+ const VaultChangeModeSignal

+ var TemplateChangeModeInvalidError = errors.New("Invalid change mode. Must be one of the following: noop, signal, restart")

+ func CopySliceInt(s []int) []int

+ func MapStringStringSliceValueSet(m map[string][]string) []string

+ func PathEscapesAllocDir(path string) (bool, error)

+ func SliceStringIsSubset(larger, smaller []string) (bool, []string)

+ func VaultPoliciesSet(policies map[string]map[string]*Vault) []string

type Allocation

+ PreviousAllocation string

+ SharedResources *Resources

+ func (a *Allocation) ShouldMigrate() bool

+ func (a *Allocation) Terminated() bool

type Constraint

+ func (c *Constraint) Equal(o *Constraint) bool

+ type DeriveVaultTokenRequest struct

+ AllocID string

+ NodeID string

+ SecretID string

+ Tasks []string

+ type DeriveVaultTokenResponse struct

+ Error *RecoverableError

+ Tasks map[string]string

+ type EphemeralDisk struct

+ Migrate bool

+ SizeMB int

+ Sticky bool

+ func DefaultEphemeralDisk() *EphemeralDisk

+ func (d *EphemeralDisk) Copy() *EphemeralDisk

+ func (d *EphemeralDisk) Validate() error

type EvalDequeueRequest

+ SchedulerVersion uint16

type Job

+ VaultToken string

+ func (j *Job) RequiredSignals() map[string]map[string][]string

+ func (j *Job) VaultPolicies() map[string]map[string]*Vault

+ type KeyringRequest struct

+ Key string

+ type KeyringResponse struct

+ Keys map[string]int

+ Messages map[string]string

+ NumNodes int

type MessageType

+ const VaultAccessorDegisterRequestType

+ const VaultAccessorRegisterRequestType

type Node

+ SecretID string

+ TLSEnabled bool

+ func (n *Node) Ready() bool

type NodeSpecificRequest

+ SecretID string

+ type RecoverableError struct

+ Err string

+ Recoverable bool

+ func NewRecoverableError(e error, recoverable bool) *RecoverableError

+ func (r *RecoverableError) Error() string

type Resources

+ func (r *Resources) DiskInBytes() int64

+ type ServerMember struct

+ Addr net.IP

+ DelegateCur uint8

+ DelegateMax uint8

+ DelegateMin uint8

+ Name string

+ Port uint16

+ ProtocolCur uint8

+ ProtocolMax uint8

+ ProtocolMin uint8

+ Status string

+ Tags map[string]string

+ type ServerMembersResponse struct

+ Members []*ServerMember

+ ServerDC string

+ ServerName string

+ ServerRegion string

type Service

+ func (s *Service) ValidateName(name string) error

type Task

+ Templates []*Template

+ Vault *Vault

type TaskEvent

+ DiskLimit int64

+ FailedSibling string

+ FailsTask bool

+ KillReason string

+ SetupError string

+ TaskSignal string

+ TaskSignalReason string

+ VaultError string

+ func (e *TaskEvent) SetDiskLimit(limit int64) *TaskEvent

+ func (e *TaskEvent) SetFailedSibling(sibling string) *TaskEvent

+ func (e *TaskEvent) SetFailsTask() *TaskEvent

+ func (e *TaskEvent) SetKillReason(r string) *TaskEvent

+ func (e *TaskEvent) SetSetupError(err error) *TaskEvent

+ func (e *TaskEvent) SetTaskSignal(s os.Signal) *TaskEvent

+ func (e *TaskEvent) SetTaskSignalReason(r string) *TaskEvent

+ func (e *TaskEvent) SetVaultRenewalError(err error) *TaskEvent

type TaskGroup

+ EphemeralDisk *EphemeralDisk

+ type Template struct

+ ChangeMode string

+ ChangeSignal string

+ DestPath string

+ EmbeddedTmpl string

+ SourcePath string

+ Splay time.Duration

+ func DefaultTemplate() *Template

+ func (t *Template) Canonicalize()

+ func (t *Template) Copy() *Template

+ func (t *Template) Validate() error

+ type Vault struct

+ ChangeMode string

+ ChangeSignal string

+ Env bool

+ Policies []string

+ func DefaultVaultBlock() *Vault

+ func (v *Vault) Canonicalize()

+ func (v *Vault) Copy() *Vault

+ func (v *Vault) Validate() error

+ type VaultAccessor struct

+ Accessor string

+ AllocID string

+ CreateIndex uint64

+ CreationTTL int

+ NodeID string

+ Task string

+ type VaultAccessorsRequest struct

+ Accessors []*VaultAccessor

v0.5.0-rc2

Nov 10, 2016

v0.5.0-rc1

Nov 2, 2016

v0.4.3

Sep 22, 2016

v0.4.2

Sep 21, 2016

v0.4.1

Aug 17, 2016

Changes in this version

+ const AllocClientStatusLost

+ const TaskKilling

type Bitmap

+ func (b Bitmap) Copy() (Bitmap, error)

+ func (b Bitmap) IndexesInRange(set bool, from, to uint) []int

+ func (b Bitmap) Size() uint

type Evaluation

+ QueuedAllocations map[string]int

type Job

+ func (j *Job) Canonicalize()

type JobListStub

+ JobSummary *JobSummary

+ type JobSummary struct

+ CreateIndex uint64

+ JobID string

+ ModifyIndex uint64

+ Summary map[string]TaskGroupSummary

+ func (js *JobSummary) Copy() *JobSummary

+ type JobSummaryRequest struct

+ JobID string

+ type JobSummaryResponse struct

+ JobSummary *JobSummary

type MessageType

+ const ReconcileJobSummariesRequestType

type NetworkResource

+ func (n *NetworkResource) Canonicalize()

type Node

+ StatusUpdatedAt int64

type Resources

+ func (r *Resources) Canonicalize()

type Service

+ func (s *Service) Canonicalize(job string, taskGroup string, task string)

type ServiceCheck

+ InitialStatus string

+ PortLabel string

+ func (sc *ServiceCheck) Canonicalize(serviceName string)

type Task

+ func (t *Task) Canonicalize(job *Job, tg *TaskGroup)

type TaskEvent

+ KillTimeout time.Duration

+ func (e *TaskEvent) SetKillTimeout(timeout time.Duration) *TaskEvent

type TaskGroup

+ func (tg *TaskGroup) Canonicalize(job *Job)

+ type TaskGroupSummary struct

+ Complete int

+ Failed int

+ Lost int

+ Queued int

+ Running int

+ Starting int

v0.4.1-rc1

Aug 13, 2016

v0.4.0

Jun 28, 2016

Changes in this version

+ const ApiMajorVersion

+ const ApiMinorVersion

+ const EvalTriggerMaxPlans

type Allocation

+ func (a *Allocation) RanSuccessfully() bool

+ type DesiredUpdates struct

+ DestructiveUpdate uint64

+ Ignore uint64

+ InPlaceUpdate uint64

+ Migrate uint64

+ Place uint64

+ Stop uint64

+ type DiffType string

+ var DiffTypeAdded DiffType = "Added"

+ var DiffTypeDeleted DiffType = "Deleted"

+ var DiffTypeEdited DiffType = "Edited"

+ var DiffTypeNone DiffType = "None"

+ func (d DiffType) Less(other DiffType) bool

type Evaluation

+ AnnotatePlan bool

+ FailedTGAllocs map[string]*AllocMetric

+ SnapshotIndex uint64

+ func (e *Evaluation) CreateBlockedEval(classEligibility map[string]bool, escaped bool) *Evaluation

+ type FieldDiff struct

+ Annotations []string

+ Name string

+ New string

+ Old string

+ Type DiffType

+ func (f *FieldDiff) GoString() string

+ func (f *FieldDiff) Less(other *FieldDiff) bool

+ type FieldDiffs []*FieldDiff

+ func (f FieldDiffs) Len() int

+ func (f FieldDiffs) Less(i, j int) bool

+ func (f FieldDiffs) Swap(i, j int)

type Job

+ func (j *Job) Diff(other *Job, contextual bool) (*JobDiff, error)

+ type JobDiff struct

+ Fields []*FieldDiff

+ ID string

+ Objects []*ObjectDiff

+ TaskGroups []*TaskGroupDiff

+ Type DiffType

+ func (j *JobDiff) GoString() string

type JobListStub

+ JobModifyIndex uint64

+ type JobPlanRequest struct

+ Diff bool

+ Job *Job

+ type JobPlanResponse struct

+ Annotations *PlanAnnotations

+ CreatedEvals []*Evaluation

+ Diff *JobDiff

+ FailedTGAllocs map[string]*AllocMetric

+ JobModifyIndex uint64

+ NextPeriodicLaunch time.Time

type JobRegisterRequest

+ EnforceIndex bool

+ JobModifyIndex uint64

type NetworkResource

+ func (r *NetworkResource) Diff(other *NetworkResource, contextual bool) *ObjectDiff

+ type NodeServerInfo struct

+ Datacenter string

+ RPCAdvertiseAddr string

+ RPCMajorVersion int32

+ RPCMinorVersion int32

type NodeUpdateResponse

+ LeaderRPCAddr string

+ NumNodes int32

+ Servers []*NodeServerInfo

+ type ObjectDiff struct

+ Fields []*FieldDiff

+ Name string

+ Objects []*ObjectDiff

+ Type DiffType

+ func (o *ObjectDiff) GoString() string

+ func (o *ObjectDiff) Less(other *ObjectDiff) bool

+ type ObjectDiffs []*ObjectDiff

+ func (o ObjectDiffs) Len() int

+ func (o ObjectDiffs) Less(i, j int) bool

+ func (o ObjectDiffs) Swap(i, j int)

type Plan

+ Annotations *PlanAnnotations

+ type PlanAnnotations struct

+ DesiredTGUpdates map[string]*DesiredUpdates

type Resources

+ func (r *Resources) Diff(other *Resources, contextual bool) *ObjectDiff

type Task

+ func (t *Task) Diff(other *Task, contextual bool) (*TaskDiff, error)

+ type TaskDiff struct

+ Annotations []string

+ Fields []*FieldDiff

+ Name string

+ Objects []*ObjectDiff

+ Type DiffType

+ func (t *TaskDiff) GoString() string

+ type TaskDiffs []*TaskDiff

+ func (t TaskDiffs) Len() int

+ func (t TaskDiffs) Less(i, j int) bool

+ func (t TaskDiffs) Swap(i, j int)

type TaskGroup

+ func (tg *TaskGroup) Diff(other *TaskGroup, contextual bool) (*TaskGroupDiff, error)

+ type TaskGroupDiff struct

+ Fields []*FieldDiff

+ Name string

+ Objects []*ObjectDiff

+ Tasks []*TaskDiff

+ Type DiffType

+ Updates map[string]uint64

+ func (tg *TaskGroupDiff) GoString() string

+ type TaskGroupDiffs []*TaskGroupDiff

+ func (tg TaskGroupDiffs) Len() int

+ func (tg TaskGroupDiffs) Less(i, j int) bool

+ func (tg TaskGroupDiffs) Swap(i, j int)

type TaskState

+ func (ts *TaskState) Successful() bool

v0.4.0-rc2

Jun 22, 2016

v0.4.0-rc1

Jun 14, 2016

v0.3.2

Apr 22, 2016

Changes in this version

+ const AllocClientStatusComplete

+ const CoreJobForceGC

+ const TaskFailedValidation

type Service

+ func (s *Service) ID(allocID string, taskName string) string

type ServiceCheck

+ Args []string

+ Command string

+ func (sc *ServiceCheck) RequiresPort() bool

type Task

+ User string

type TaskArtifact

+ RelativeDest string

+ func (ta *TaskArtifact) GoString() string

type TaskEvent

+ RestartReason string

+ ValidationError string

+ func (e *TaskEvent) SetRestartReason(reason string) *TaskEvent

+ func (e *TaskEvent) SetValidationError(err error) *TaskEvent

v0.3.2-rc2

Apr 20, 2016

v0.3.2-rc1

Apr 14, 2016

v0.3.1

Mar 16, 2016

Changes in this version

+ const TaskArtifactDownloadFailed

+ const TaskDownloadingArtifacts

+ const TaskNotRestarting

+ const TaskRestarting

+ var AllocationIndexRegex = regexp.MustCompile(".+\\[(\\d+)\\]$")

type Allocation

+ func (a *Allocation) Index() int

type Task

+ Artifacts []*TaskArtifact

+ type TaskArtifact struct

+ GetterOptions map[string]string

+ GetterSource string

+ func (ta *TaskArtifact) Copy() *TaskArtifact

+ func (ta *TaskArtifact) Validate() error

type TaskEvent

+ DownloadError string

+ StartDelay int64

+ func (e *TaskEvent) SetDownloadError(err error) *TaskEvent

+ func (e *TaskEvent) SetRestartDelay(delay time.Duration) *TaskEvent

+ func (te *TaskEvent) GoString() string

type TaskState

+ func (ts *TaskState) Failed() bool

v0.3.0

Feb 25, 2016

Changes in this version

+ const CoreJobJobGC

+ const DefaultKillTimeout

+ const EvalStatusBlocked

+ const EvalStatusCancelled

+ const EvalTriggerForceGC

+ const EvalTriggerPeriodicJob

+ const NodeUniqueNamespace

+ const PeriodicLaunchSuffix

+ const PeriodicSpecTest

+ const RestartPolicyModeDelay

+ const RestartPolicyModeFail

+ const TaskReceived

+ var HashiMsgpackHandle = func() *hcodec.MsgpackHandle { ... }()

+ func CopyMapStringFloat64(m map[string]float64) map[string]float64

+ func CopyMapStringInt(m map[string]int) map[string]int

+ func CopyMapStringString(m map[string]string) map[string]string

+ func CopySliceString(s []string) []string

+ func IsUniqueNamespace(key string) bool

+ func UniqueNamespace(key string) string

type AllocListStub

+ CreateTime int64

type AllocMetric

+ NodesAvailable map[string]int

+ func (a *AllocMetric) Copy() *AllocMetric

type AllocUpdateRequest

+ Job *Job

type Allocation

+ AllocModifyIndex uint64

+ CreateTime int64

+ func (a *Allocation) Copy() *Allocation

+ type AllocsGetRequest struct

+ AllocIDs []string

+ type AllocsGetResponse struct

+ Allocs []*Allocation

+ type Bitmap []byte

+ func NewBitmap(size int) (Bitmap, error)

+ func (b Bitmap) Check(idx uint) bool

+ func (b Bitmap) Clear()

+ func (b Bitmap) Set(idx uint)

type Constraint

+ func CopySliceConstraints(s []*Constraint) []*Constraint

+ func EscapedConstraints(constraints []*Constraint) []*Constraint

+ func (c *Constraint) Copy() *Constraint

type Evaluation

+ ClassEligibility map[string]bool

+ EscapedComputedClass bool

+ func (e *Evaluation) BlockedEval(classEligibility map[string]bool, escaped bool) *Evaluation

+ func (e *Evaluation) ShouldBlock() bool

type Job

+ GC bool

+ JobModifyIndex uint64

+ ParentID string

+ func (j *Job) Copy() *Job

+ func (j *Job) InitFields()

type JobListStub

+ ParentID string

+ type LogConfig struct

+ MaxFileSizeMB int

+ MaxFiles int

+ func DefaultLogConfig() *LogConfig

+ func (l *LogConfig) Validate() error

type NetworkIndex

+ func (idx *NetworkIndex) Release()

type NetworkResource

+ func (n *NetworkResource) MeetsMinResources() error

type Node

+ ComputedClass string

+ HTTPAddr string

+ func (n *Node) ComputeClass() error

+ func (n *Node) Copy() *Node

+ func (n Node) HashInclude(field string, v interface{}) (bool, error)

+ func (n Node) HashIncludeMap(field string, k, v interface{}) (bool, error)

+ type NodeClientAllocsResponse struct

+ Allocs map[string]uint64

type PeriodicConfig

+ ProhibitOverlap bool

+ func (p *PeriodicConfig) Copy() *PeriodicConfig

+ type PeriodicForceRequest struct

+ JobID string

+ type PeriodicForceResponse struct

+ EvalCreateIndex uint64

+ EvalID string

+ type PeriodicLaunch struct

+ CreateIndex uint64

+ ID string

+ Launch time.Time

+ ModifyIndex uint64

type Plan

+ Job *Job

type QueryOptions

+ Prefix string

type Resources

+ func DefaultResources() *Resources

+ func (r *Resources) MeetsMinResources() error

+ func (r *Resources) Merge(other *Resources)

type RestartPolicy

+ Mode string

+ func (r *RestartPolicy) Copy() *RestartPolicy

type Service

+ func (s *Service) Copy() *Service

type ServiceCheck

+ func (sc *ServiceCheck) Copy() *ServiceCheck

type Task

+ KillTimeout time.Duration

+ LogConfig *LogConfig

+ func (t *Task) Copy() *Task

+ func (t *Task) InitFields(job *Job, tg *TaskGroup)

+ func (t *Task) InitServiceFields(job string, taskGroup string)

type TaskEvent

+ func (te *TaskEvent) Copy() *TaskEvent

type TaskGroup

+ func (tg *TaskGroup) Copy() *TaskGroup

+ func (tg *TaskGroup) InitFields(job *Job)

type TaskState

+ func (ts *TaskState) Copy() *TaskState

v0.3.0-rc2

Feb 23, 2016

v0.2.3

Dec 18, 2015

Changes in this version

type Allocation

+ Services map[string]string

+ func (a *Allocation) PopulateServiceIDs()

v0.2.3-rc1

Dec 16, 2015

v0.2.2

Dec 11, 2015

Changes in this version

+ const NomadConsulPrefix

+ const PeriodicSpecCron

type Job

+ Periodic *PeriodicConfig

+ func (j *Job) InitAllServiceFields()

+ func (j *Job) IsPeriodic() bool

+ type PeriodicConfig struct

+ Enabled bool

+ Spec string

+ SpecType string

+ func (p *PeriodicConfig) Next(fromTime time.Time) time.Time

+ func (p *PeriodicConfig) Validate() error

type Service

+ func (s *Service) InitFields(job string, taskGroup string, task string)

type Task

+ func (t *Task) InitAllServiceFields(job string, taskGroup string)

type TaskGroup

+ func (tg *TaskGroup) InitAllServiceFields(job string)

v0.2.1

Nov 28, 2015

Changes in this version

type Job

+ func (j *Job) ExpandAllServiceNames()

type Service

+ func (s *Service) ExpandName(job string, taskGroup string, task string)

+ func (s *Service) Hash() string

type ServiceCheck

+ func (sc *ServiceCheck) Hash(serviceId string) string

type Task

+ func (t *Task) ExpandAllServiceNames(job string, taskGroup string)

+ func (t *Task) FindHostAndPortFor(portLabel string) (string, int)

type TaskGroup

+ func (tg *TaskGroup) ExpandAllServiceNames(job string)

v0.2.0

Nov 19, 2015

Changes in this version

+ const ConstraintDistinctHosts

+ const ConstraintRegex

+ const ConstraintVersion

+ const JobTypeSystem

+ const ServiceCheckDocker

+ const ServiceCheckHTTP

+ const ServiceCheckScript

+ const ServiceCheckTCP

+ const TaskDriverFailure

+ const TaskKilled

+ const TaskStarted

+ const TaskStateDead

+ const TaskStatePending

+ const TaskStateRunning

+ const TaskTerminated

+ var MsgpackHandle = func() *codec.MsgpackHandle { ... }()

type AllocListStub

+ TaskStates map[string]*TaskState

type Allocation

+ TaskStates map[string]*TaskState

type Constraint

+ func (c *Constraint) Validate() error

type NetworkResource

+ func (n *NetworkResource) MapLabelToValues() map[string]int

+ type Port struct

+ Label string

+ Value int

+ type RestartPolicy struct

+ Attempts int

+ Delay time.Duration

+ Interval time.Duration

+ func NewRestartPolicy(jobType string) *RestartPolicy

+ func (r *RestartPolicy) Validate() error

+ type Service struct

+ Checks []ServiceCheck

+ Id string

+ Name string

+ PortLabel string

+ Tags []string

+ func (s *Service) Validate() error

+ type ServiceCheck struct

+ Id string

+ Interval time.Duration

+ Name string

+ Path string

+ Protocol string

+ Script string

+ Timeout time.Duration

+ Type string

+ func (sc *ServiceCheck) Validate() error

type Task

+ Services []*Service

+ type TaskEvent struct

+ DriverError string

+ ExitCode int

+ KillError string

+ Message string

+ Signal int

+ Time int64

+ Type string

+ func NewTaskEvent(event string) *TaskEvent

+ func (e *TaskEvent) SetDriverError(err error) *TaskEvent

+ func (e *TaskEvent) SetExitCode(c int) *TaskEvent

+ func (e *TaskEvent) SetExitMessage(err error) *TaskEvent

+ func (e *TaskEvent) SetKillError(err error) *TaskEvent

+ func (e *TaskEvent) SetSignal(s int) *TaskEvent

type TaskGroup

+ RestartPolicy *RestartPolicy

+ type TaskState struct

+ Events []*TaskEvent

+ State string

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 APIMajorVersion

+ const APIMinorVersion

+ const AllocClientStatusDead

+ const AllocClientStatusFailed

+ const AllocClientStatusPending

+ const AllocClientStatusRunning

+ const AllocDesiredStatusEvict

+ const AllocDesiredStatusFailed

+ const AllocDesiredStatusRun

+ const AllocDesiredStatusStop

+ const CoreJobEvalGC

+ const CoreJobNodeGC

+ const CoreJobPriority

+ const EvalStatusComplete

+ const EvalStatusFailed

+ const EvalStatusPending

+ const EvalTriggerJobDeregister

+ const EvalTriggerJobRegister

+ const EvalTriggerNodeUpdate

+ const EvalTriggerRollingUpdate

+ const EvalTriggerScheduled

+ const JobDefaultPriority

+ const JobMaxPriority

+ const JobMinPriority

+ const JobStatusComplete

+ const JobStatusDead

+ const JobStatusPending

+ const JobStatusRunning

+ const JobTypeBatch

+ const JobTypeCore

+ const JobTypeService

+ const MaxDynamicPort

+ const MinDynamicPort

+ const NodeStatusDown

+ const NodeStatusInit

+ const NodeStatusReady

+ const ProtocolVersion

+ var ErrNoLeader = fmt.Errorf("No cluster leader")

+ var ErrNoRegionPath = fmt.Errorf("No path to region")

+ func Decode(buf []byte, out interface{}) error

+ func Encode(t MessageType, msg interface{}) ([]byte, error)

+ func GenerateUUID() string

+ func IntContains(haystack []int, needle int) bool

+ func ScoreFit(node *Node, util *Resources) float64

+ func ShouldDrainNode(status string) bool

+ func ValidNodeStatus(status string) bool

+ type AllocListRequest struct

+ type AllocListResponse struct

+ Allocations []*AllocListStub

+ type AllocListStub 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 AllocMetric 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

+ func (a *AllocMetric) EvaluateNode()

+ func (a *AllocMetric) ExhaustedNode(node *Node, dimension string)

+ func (a *AllocMetric) FilterNode(node *Node, constraint string)

+ func (a *AllocMetric) ScoreNode(node *Node, name string, score float64)

+ type AllocSpecificRequest struct

+ AllocID string

+ type AllocUpdateRequest struct

+ Alloc []*Allocation

+ type Allocation struct

+ ClientDescription string

+ ClientStatus string

+ CreateIndex uint64

+ DesiredDescription string

+ DesiredStatus string

+ EvalID string

+ ID string

+ Job *Job

+ JobID string

+ Metrics *AllocMetric

+ ModifyIndex uint64

+ Name string

+ NodeID string

+ Resources *Resources

+ TaskGroup string

+ TaskResources map[string]*Resources

+ func FilterTerminalAllocs(allocs []*Allocation) []*Allocation

+ func RemoveAllocs(alloc []*Allocation, remove []*Allocation) []*Allocation

+ func (a *Allocation) Stub() *AllocListStub

+ func (a *Allocation) TerminalStatus() bool

+ type Constraint struct

+ Hard bool

+ LTarget string

+ Operand string

+ RTarget string

+ Weight int

+ func (c *Constraint) String() string

+ type EvalAckRequest struct

+ EvalID string

+ Token string

+ type EvalAllocationsResponse struct

+ Allocations []*AllocListStub

+ type EvalDeleteRequest struct

+ Allocs []string

+ Evals []string

+ type EvalDequeueRequest struct

+ Schedulers []string

+ Timeout time.Duration

+ type EvalDequeueResponse struct

+ Eval *Evaluation

+ Token string

+ type EvalListRequest struct

+ type EvalListResponse struct

+ Evaluations []*Evaluation

+ type EvalSpecificRequest struct

+ EvalID string

+ type EvalUpdateRequest struct

+ EvalToken string

+ Evals []*Evaluation

+ 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

+ func (e *Evaluation) Copy() *Evaluation

+ func (e *Evaluation) GoString() string

+ func (e *Evaluation) MakePlan(j *Job) *Plan

+ func (e *Evaluation) NextRollingEval(wait time.Duration) *Evaluation

+ func (e *Evaluation) ShouldEnqueue() bool

+ func (e *Evaluation) TerminalStatus() bool

+ type GenericRequest struct

+ type GenericResponse struct

+ 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

+ Update UpdateStrategy

+ func (j *Job) LookupTaskGroup(name string) *TaskGroup

+ func (j *Job) Stub() *JobListStub

+ func (j *Job) Validate() error

+ type JobAllocationsResponse struct

+ Allocations []*AllocListStub

+ type JobDeregisterRequest struct

+ JobID string

+ type JobDeregisterResponse struct

+ EvalCreateIndex uint64

+ EvalID string

+ JobModifyIndex uint64

+ type JobEvaluateRequest struct

+ JobID string

+ type JobEvaluationsResponse struct

+ Evaluations []*Evaluation

+ type JobListRequest struct

+ type JobListResponse struct

+ Jobs []*JobListStub

+ type JobListStub struct

+ CreateIndex uint64

+ ID string

+ ModifyIndex uint64

+ Name string

+ Priority int

+ Status string

+ StatusDescription string

+ Type string

+ type JobRegisterRequest struct

+ Job *Job

+ type JobRegisterResponse struct

+ EvalCreateIndex uint64

+ EvalID string

+ JobModifyIndex uint64

+ type JobSpecificRequest struct

+ JobID string

+ type MessageType uint8

+ const AllocClientUpdateRequestType

+ const AllocUpdateRequestType

+ const EvalDeleteRequestType

+ const EvalUpdateRequestType

+ const IgnoreUnknownTypeFlag

+ const JobDeregisterRequestType

+ const JobRegisterRequestType

+ const NodeDeregisterRequestType

+ const NodeRegisterRequestType

+ const NodeUpdateDrainRequestType

+ const NodeUpdateStatusRequestType

+ type NetworkIndex struct

+ AvailBandwidth map[string]int

+ AvailNetworks []*NetworkResource

+ UsedBandwidth map[string]int

+ UsedPorts map[string]map[int]struct{}

+ func NewNetworkIndex() *NetworkIndex

+ func (idx *NetworkIndex) AddAllocs(allocs []*Allocation) (collide bool)

+ func (idx *NetworkIndex) AddReserved(n *NetworkResource) (collide bool)

+ func (idx *NetworkIndex) AssignNetwork(ask *NetworkResource) (out *NetworkResource, err error)

+ func (idx *NetworkIndex) Overcommitted() bool

+ func (idx *NetworkIndex) SetNode(node *Node) (collide bool)

+ type NetworkResource struct

+ CIDR string

+ Device string

+ DynamicPorts []string

+ IP string

+ MBits int

+ ReservedPorts []int

+ func (n *NetworkResource) Add(delta *NetworkResource)

+ func (n *NetworkResource) Copy() *NetworkResource

+ func (n *NetworkResource) GoString() string

+ func (n *NetworkResource) ListStaticPorts() []int

+ func (n *NetworkResource) MapDynamicPorts() map[string]int

+ type Node struct

+ Attributes map[string]string

+ CreateIndex uint64

+ Datacenter string

+ Drain bool

+ ID string

+ Links map[string]string

+ Meta map[string]string

+ ModifyIndex uint64

+ Name string

+ NodeClass string

+ Reserved *Resources

+ Resources *Resources

+ Status string

+ StatusDescription string

+ func (n *Node) Stub() *NodeListStub

+ func (n *Node) TerminalStatus() bool

+ type NodeAllocsResponse struct

+ Allocs []*Allocation

+ type NodeDeregisterRequest struct

+ NodeID string

+ type NodeDrainUpdateResponse struct

+ EvalCreateIndex uint64

+ EvalIDs []string

+ NodeModifyIndex uint64

+ type NodeEvaluateRequest struct

+ NodeID string

+ type NodeListRequest struct

+ type NodeListResponse struct

+ Nodes []*NodeListStub

+ type NodeListStub struct

+ CreateIndex uint64

+ Datacenter string

+ Drain bool

+ ID string

+ ModifyIndex uint64

+ Name string

+ NodeClass string

+ Status string

+ StatusDescription string

+ type NodeRegisterRequest struct

+ Node *Node

+ type NodeSpecificRequest struct

+ NodeID string

+ type NodeUpdateDrainRequest struct

+ Drain bool

+ NodeID string

+ type NodeUpdateResponse struct

+ EvalCreateIndex uint64

+ EvalIDs []string

+ HeartbeatTTL time.Duration

+ NodeModifyIndex uint64

+ type NodeUpdateStatusRequest struct

+ NodeID string

+ Status string

+ type Plan struct

+ AllAtOnce bool

+ EvalID string

+ EvalToken string

+ FailedAllocs []*Allocation

+ NodeAllocation map[string][]*Allocation

+ NodeUpdate map[string][]*Allocation

+ Priority int

+ func (p *Plan) AppendAlloc(alloc *Allocation)

+ func (p *Plan) AppendFailed(alloc *Allocation)

+ func (p *Plan) AppendUpdate(alloc *Allocation, status, desc string)

+ func (p *Plan) IsNoOp() bool

+ func (p *Plan) PopUpdate(alloc *Allocation)

+ type PlanRequest struct

+ Plan *Plan

+ type PlanResponse struct

+ Result *PlanResult

+ type PlanResult struct

+ AllocIndex uint64

+ FailedAllocs []*Allocation

+ NodeAllocation map[string][]*Allocation

+ NodeUpdate map[string][]*Allocation

+ RefreshIndex uint64

+ func (p *PlanResult) FullCommit(plan *Plan) (bool, int, int)

+ func (p *PlanResult) IsNoOp() bool

+ type QueryMeta struct

+ Index uint64

+ KnownLeader bool

+ LastContact time.Duration

+ type QueryOptions struct

+ AllowStale bool

+ MaxQueryTime time.Duration

+ MinQueryIndex uint64

+ Region string

+ func (q QueryOptions) AllowStaleRead() bool

+ func (q QueryOptions) IsRead() bool

+ func (q QueryOptions) RequestRegion() string

+ type RPCInfo interface

+ AllowStaleRead func() bool

+ IsRead func() bool

+ RequestRegion func() string

+ type Resources struct

+ CPU int

+ DiskMB int

+ IOPS int

+ MemoryMB int

+ Networks []*NetworkResource

+ func AllocsFit(node *Node, allocs []*Allocation, netIdx *NetworkIndex) (bool, string, *Resources, error)

+ func (r *Resources) Add(delta *Resources) error

+ func (r *Resources) Copy() *Resources

+ func (r *Resources) GoString() string

+ func (r *Resources) NetIndex(n *NetworkResource) int

+ func (r *Resources) Superset(other *Resources) (bool, string)

+ type SingleAllocResponse struct

+ Alloc *Allocation

+ type SingleEvalResponse struct

+ Eval *Evaluation

+ type SingleJobResponse struct

+ Job *Job

+ type SingleNodeResponse struct

+ Node *Node

+ type Task struct

+ Config map[string]string

+ Constraints []*Constraint

+ Driver string

+ Meta map[string]string

+ Name string

+ Resources *Resources

+ func (t *Task) GoString() string

+ func (t *Task) Validate() error

+ type TaskGroup struct

+ Constraints []*Constraint

+ Count int

+ Meta map[string]string

+ Name string

+ Tasks []*Task

+ func (tg *TaskGroup) GoString() string

+ func (tg *TaskGroup) LookupTask(name string) *Task

+ func (tg *TaskGroup) Validate() error

+ type UpdateStrategy struct

+ MaxParallel int

+ Stagger time.Duration

+ func (u *UpdateStrategy) Rolling() bool

+ type VersionResponse struct

+ Build string

+ Versions map[string]int

+ type WriteMeta struct

+ Index uint64

+ type WriteRequest struct

+ Region string

+ func (w WriteRequest) AllowStaleRead() bool

+ func (w WriteRequest) IsRead() bool

+ func (w WriteRequest) RequestRegion() string

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