Versions in this module Expand all Collapse all v0 v0.8.3 Apr 27, 2018 Changes in this version + const ACLClientToken + const ACLManagementToken + const APIMajorVersion + const APIMinorVersion + const AddressModeAuto + const AddressModeDriver + const AddressModeHost + const AllocClientStatusComplete + const AllocClientStatusFailed + const AllocClientStatusLost + const AllocClientStatusPending + const AllocClientStatusRunning + const AllocDesiredStatusEvict + const AllocDesiredStatusRun + const AllocDesiredStatusStop + const ApiMajorVersion + const ApiMinorVersion + const BytesInMegabyte + const ConstraintDistinctHosts + const ConstraintDistinctProperty + const ConstraintRegex + const ConstraintSetContains + const ConstraintVersion + const CoreJobDeploymentGC + const CoreJobEvalGC + const CoreJobForceGC + const CoreJobJobGC + const CoreJobNodeGC + const CoreJobPriority + const DefaultKillTimeout + const DefaultNamespace + const DefaultNamespaceDescription + const DeploymentStatusCancelled + const DeploymentStatusDescriptionFailedAllocations + const DeploymentStatusDescriptionFailedByUser + const DeploymentStatusDescriptionNewerJob + const DeploymentStatusDescriptionPaused + const DeploymentStatusDescriptionRunning + const DeploymentStatusDescriptionRunningNeedsPromotion + const DeploymentStatusDescriptionStoppedJob + const DeploymentStatusDescriptionSuccessful + const DeploymentStatusFailed + const DeploymentStatusPaused + const DeploymentStatusRunning + const DeploymentStatusSuccessful + const DispatchLaunchSuffix + const DispatchPayloadForbidden + const DispatchPayloadOptional + const DispatchPayloadRequired + const ErrUnknownAllocationPrefix + const ErrUnknownDeploymentPrefix + const ErrUnknownEvaluationPrefix + const ErrUnknownJobPrefix + const ErrUnknownNodePrefix + const EvalStatusBlocked + const EvalStatusCancelled + const EvalStatusComplete + const EvalStatusFailed + const EvalStatusPending + const EvalTriggerDeploymentWatcher + const EvalTriggerFailedFollowUp + const EvalTriggerJobDeregister + const EvalTriggerJobRegister + const EvalTriggerMaxPlans + const EvalTriggerNodeDrain + const EvalTriggerNodeUpdate + const EvalTriggerPeriodicJob + const EvalTriggerRetryFailedAlloc + const EvalTriggerRollingUpdate + const EvalTriggerScheduled + const GetterModeAny + const GetterModeDir + const GetterModeFile + const IgnoreUnknownTypeFlag + const JitterFraction + const JobDefaultPriority + const JobMaxPriority + const JobMinPriority + const JobStatusDead + const JobStatusPending + const JobStatusRunning + const JobTrackedVersions + const JobTypeBatch + const JobTypeCore + const JobTypeService + const JobTypeSystem + const MaxDynamicPort + const MaxRetainedNodeEvents + const MigrateStrategyHealthChecks + const MigrateStrategyHealthStates + const MinDynamicPort + const NodeEventSubsystemCluster + const NodeEventSubsystemDrain + const NodeEventSubsystemDriver + const NodeEventSubsystemHeartbeat + const NodeSchedulingEligible + const NodeSchedulingIneligible + const NodeStatusDown + const NodeStatusInit + const NodeStatusReady + const NodeUniqueNamespace + const PeriodicLaunchSuffix + const PeriodicSpecCron + const PeriodicSpecTest + const ProtocolVersion + const ReasonWithinPolicy + const ReschedulePolicyMinDelay + const ReschedulePolicyMinInterval + const RestartPolicyMinInterval + const RestartPolicyModeDelay + const RestartPolicyModeFail + const ServiceCheckHTTP + const ServiceCheckScript + const ServiceCheckTCP + const TaskArtifactDownloadFailed + const TaskBuildingTaskDir + const TaskDiskExceeded + const TaskDownloadingArtifacts + const TaskDriverFailure + const TaskDriverMessage + const TaskFailedValidation + const TaskKilled + const TaskKilling + const TaskLeaderDead + const TaskNotRestarting + const TaskReceived + const TaskRestartSignal + const TaskRestarting + const TaskSetup + const TaskSetupFailure + const TaskSiblingFailed + const TaskSignaling + const TaskStarted + const TaskStateDead + const TaskStatePending + const TaskStateRunning + const TaskTerminated + const TemplateChangeModeNoop + const TemplateChangeModeRestart + const TemplateChangeModeSignal + const UpdateStrategyHealthCheck_Checks + const UpdateStrategyHealthCheck_Manual + const UpdateStrategyHealthCheck_TaskStates + const VaultChangeModeNoop + const VaultChangeModeRestart + const VaultChangeModeSignal + var AnonymousACLToken = &ACLToken + var DefaultBatchJobReschedulePolicy = ReschedulePolicy + var DefaultBatchJobRestartPolicy = RestartPolicy + var DefaultServiceJobReschedulePolicy = ReschedulePolicy + var DefaultServiceJobRestartPolicy = RestartPolicy + var DefaultUpdateStrategy = &UpdateStrategy + var ErrNoLeader = errors.New(errNoLeader) + var ErrNoNodeConn = errors.New(errNoNodeConn) + var ErrNoRegionPath = errors.New(errNoRegionPath) + var ErrNodeLacksRpc = errors.New(errNodeLacksRpc) + var ErrPermissionDenied = errors.New(errPermissionDenied) + var ErrTokenNotFound = errors.New(errTokenNotFound) + var ErrUnknownMethod = errors.New(errUnknownMethod) + var ErrUnknownNomadVersion = errors.New(errUnknownNomadVersion) + var HashiMsgpackHandle = func() *hcodec.MsgpackHandle { ... }() + var JsonHandle = &codec.JsonHandle + var JsonHandlePretty = &codec.JsonHandle + var MsgpackHandle = func() *codec.MsgpackHandle { ... }() + var RescheduleDelayFunctions = [...]string + var TemplateChangeModeInvalidError = errors.New("Invalid change mode. Must be one of the following: noop, signal, restart") + var VaultUnrecoverableError = regexp.MustCompile(`Code:\s+40(0|3|4)`) + func ACLPolicyListHash(policies []*ACLPolicy) string + func AllocName(job, group string, idx uint) string + func Bridge(a, b io.ReadWriteCloser) + func CompareMigrateToken(allocID, nodeSecretID, otherMigrateToken string) bool + func CompileACLObject(cache *lru.TwoQueueCache, policies []*ACLPolicy) (*acl.ACL, error) + func CronParseNext(e *cronexpr.Expression, fromTime time.Time, spec string) (t time.Time, err error) + func Decode(buf []byte, out interface{}) error + func DenormalizeAllocationJobs(job *Job, allocs []*Allocation) + func DeploymentStatusDescriptionNoRollbackTarget(baseDescription string) string + func DeploymentStatusDescriptionRollback(baseDescription string, jobVersion uint64) string + func DeploymentStatusDescriptionRollbackNoop(baseDescription string, jobVersion uint64) string + func DispatchedID(templateID string, t time.Time) string + func Encode(t MessageType, msg interface{}) ([]byte, error) + func GenerateMigrateToken(allocID, nodeSecretID string) (string, error) + func IsErrNoLeader(err error) bool + func IsErrNoNodeConn(err error) bool + func IsErrNoRegionPath(err error) bool + func IsErrNodeLacksRpc(err error) bool + func IsErrPermissionDenied(err error) bool + func IsErrTokenNotFound(err error) bool + func IsErrUnknownAllocation(err error) bool + func IsErrUnknownDeployment(err error) bool + func IsErrUnknownEvaluation(err error) bool + func IsErrUnknownJob(err error) bool + func IsErrUnknownMethod(err error) bool + func IsErrUnknownNode(err error) bool + func IsErrUnknownNomadVersion(err error) bool + func IsRecoverable(e error) bool + func IsServerSide(e error) bool + func IsUniqueNamespace(key string) bool + func MergeMultierrorWarnings(warnings ...error) string + func NewErrUnknownAllocation(allocID string) error + func NewErrUnknownDeployment(deploymentID string) error + func NewErrUnknownEvaluation(evaluationID string) error + func NewErrUnknownJob(jobID string) error + func NewErrUnknownNode(nodeID string) error + func NewRecoverableError(e error, recoverable bool) error + func NewWrappedServerError(e error) error + func PathEscapesAllocDir(prefix, path string) (bool, error) + func ScoreFit(node *Node, util *Resources) float64 + func ShouldDrainNode(status string) bool + func UniqueNamespace(key string) string + func ValidNodeStatus(status string) bool + func VaultPoliciesSet(policies map[string]map[string]*Vault) []string + func WrapRecoverable(msg string, err error) error + type ACLPolicy struct + CreateIndex uint64 + Description string + Hash []byte + ModifyIndex uint64 + Name string + Rules string + func (a *ACLPolicy) Stub() *ACLPolicyListStub + func (a *ACLPolicy) Validate() error + func (c *ACLPolicy) SetHash() []byte + type ACLPolicyDeleteRequest struct + Names []string + type ACLPolicyListRequest struct + type ACLPolicyListResponse struct + Policies []*ACLPolicyListStub + type ACLPolicyListStub struct + CreateIndex uint64 + Description string + Hash []byte + ModifyIndex uint64 + Name string + type ACLPolicySetRequest struct + Names []string + type ACLPolicySetResponse struct + Policies map[string]*ACLPolicy + type ACLPolicySpecificRequest struct + Name string + type ACLPolicyUpsertRequest struct + Policies []*ACLPolicy + type ACLToken struct + AccessorID string + CreateIndex uint64 + CreateTime time.Time + Global bool + Hash []byte + ModifyIndex uint64 + Name string + Policies []string + SecretID string + Type string + func (a *ACLToken) PolicySubset(policies []string) bool + func (a *ACLToken) SetHash() []byte + func (a *ACLToken) Stub() *ACLTokenListStub + func (a *ACLToken) Validate() error + type ACLTokenBootstrapRequest struct + ResetIndex uint64 + Token *ACLToken + type ACLTokenDeleteRequest struct + AccessorIDs []string + type ACLTokenListRequest struct + GlobalOnly bool + type ACLTokenListResponse struct + Tokens []*ACLTokenListStub + type ACLTokenListStub struct + AccessorID string + CreateIndex uint64 + CreateTime time.Time + Global bool + Hash []byte + ModifyIndex uint64 + Name string + Policies []string + Type string + type ACLTokenSetRequest struct + AccessorIDS []string + type ACLTokenSetResponse struct + Tokens map[string]*ACLToken + type ACLTokenSpecificRequest struct + AccessorID string + type ACLTokenUpsertRequest struct + Tokens []*ACLToken + type ACLTokenUpsertResponse struct + Tokens []*ACLToken + type AllocDeploymentStatus struct + Healthy *bool + ModifyIndex uint64 + func (a *AllocDeploymentStatus) Copy() *AllocDeploymentStatus + func (a *AllocDeploymentStatus) HasHealth() bool + func (a *AllocDeploymentStatus) IsHealthy() bool + func (a *AllocDeploymentStatus) IsUnhealthy() bool + type AllocListRequest struct + type AllocListResponse struct + Allocations []*AllocListStub + type AllocListStub struct + ClientDescription string + ClientStatus string + CreateIndex uint64 + CreateTime int64 + DeploymentStatus *AllocDeploymentStatus + DesiredDescription string + DesiredStatus string + EvalID string + FollowupEvalID string + ID string + JobID string + JobVersion uint64 + ModifyIndex uint64 + ModifyTime int64 + Name string + NodeID string + TaskGroup string + TaskStates map[string]*TaskState + func (a *AllocListStub) SetEventDisplayMessages() + type AllocMetric struct + AllocationTime time.Duration + ClassExhausted map[string]int + ClassFiltered map[string]int + CoalescedFailures int + ConstraintFiltered map[string]int + DimensionExhausted map[string]int + NodesAvailable map[string]int + NodesEvaluated int + NodesExhausted int + NodesFiltered int + QuotaExhausted []string + Scores map[string]float64 + func (a *AllocMetric) Copy() *AllocMetric + func (a *AllocMetric) EvaluateNode() + func (a *AllocMetric) ExhaustQuota(dimensions []string) + 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 AllocUpdateDesiredTransitionRequest struct + Allocs map[string]*DesiredTransition + Evals []*Evaluation + type AllocUpdateRequest struct + Alloc []*Allocation + Evals []*Evaluation + Job *Job + type Allocation struct + AllocModifyIndex uint64 + ClientDescription string + ClientStatus string + CreateIndex uint64 + CreateTime int64 + DeploymentID string + DeploymentStatus *AllocDeploymentStatus + DesiredDescription string + DesiredStatus string + DesiredTransition DesiredTransition + EvalID string + FollowupEvalID string + ID string + Job *Job + JobID string + Metrics *AllocMetric + ModifyIndex uint64 + ModifyTime int64 + Name string + Namespace string + NextAllocation string + NodeID string + PreviousAllocation string + RescheduleTracker *RescheduleTracker + Resources *Resources + SharedResources *Resources + TaskGroup string + TaskResources map[string]*Resources + TaskStates map[string]*TaskState + func FilterTerminalAllocs(allocs []*Allocation) ([]*Allocation, map[string]*Allocation) + func RemoveAllocs(alloc []*Allocation, remove []*Allocation) []*Allocation + func (a *Allocation) ClientTerminalStatus() bool + func (a *Allocation) Copy() *Allocation + func (a *Allocation) CopySkipJob() *Allocation + func (a *Allocation) Index() uint + func (a *Allocation) LastEventTime() time.Time + func (a *Allocation) NextDelay() time.Duration + func (a *Allocation) NextRescheduleTime() (time.Time, bool) + func (a *Allocation) RanSuccessfully() bool + func (a *Allocation) RescheduleEligible(reschedulePolicy *ReschedulePolicy, failTime time.Time) bool + func (a *Allocation) ReschedulePolicy() *ReschedulePolicy + func (a *Allocation) SetEventDisplayMessages() + func (a *Allocation) ShouldMigrate() bool + func (a *Allocation) ShouldReschedule(reschedulePolicy *ReschedulePolicy, failTime time.Time) bool + func (a *Allocation) Stub() *AllocListStub + func (a *Allocation) TerminalStatus() bool + func (a *Allocation) Terminated() bool + type AllocsGetRequest struct + AllocIDs []string + type AllocsGetResponse struct + Allocs []*Allocation + type ApplyDeploymentAllocHealthRequest struct + DeploymentUpdate *DeploymentStatusUpdate + Eval *Evaluation + Job *Job + type ApplyDeploymentPromoteRequest struct + Eval *Evaluation + type ApplyPlanResultsRequest struct + Deployment *Deployment + DeploymentUpdates []*DeploymentStatusUpdate + EvalID string + type AutopilotConfig struct + CleanupDeadServers bool + CreateIndex uint64 + DisableUpgradeMigration bool + EnableCustomUpgrades bool + EnableRedundancyZones bool + LastContactThreshold time.Duration + MaxTrailingLogs uint64 + ModifyIndex uint64 + ServerStabilizationTime time.Duration + func (x *AutopilotConfig) CodecDecodeSelf(d *codec1978.Decoder) + func (x *AutopilotConfig) CodecEncodeSelf(e *codec1978.Encoder) + type AutopilotSetConfigRequest struct + CAS bool + Config AutopilotConfig + Datacenter string + func (op *AutopilotSetConfigRequest) RequestDatacenter() string + func (x *AutopilotSetConfigRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *AutopilotSetConfigRequest) CodecEncodeSelf(e *codec1978.Encoder) + type BatchFuture struct + func NewBatchFuture() *BatchFuture + func (b *BatchFuture) Error() error + func (b *BatchFuture) Index() uint64 + func (b *BatchFuture) Respond(index uint64, err error) + func (b *BatchFuture) Wait() error + func (b *BatchFuture) WaitCh() <-chan struct{} + type BatchNodeUpdateDrainRequest struct + Updates map[string]*DrainUpdate + type Bitmap []byte + func NewBitmap(size uint) (Bitmap, error) + func (b Bitmap) Check(idx uint) bool + func (b Bitmap) Clear() + func (b Bitmap) Copy() (Bitmap, error) + func (b Bitmap) IndexesInRange(set bool, from, to uint) []int + func (b Bitmap) Set(idx uint) + func (b Bitmap) Size() uint + func (b Bitmap) Unset(idx uint) + func (x *Bitmap) CodecDecodeSelf(d *codec1978.Decoder) + func (x Bitmap) CodecEncodeSelf(e *codec1978.Encoder) + type CheckRestart struct + Grace time.Duration + IgnoreWarnings bool + Limit int + func (c *CheckRestart) Copy() *CheckRestart + func (c *CheckRestart) Validate() error + type Constraint struct + LTarget string + Operand string + RTarget string + func CopySliceConstraints(s []*Constraint) []*Constraint + func EscapedConstraints(constraints []*Constraint) []*Constraint + func (c *Constraint) Copy() *Constraint + func (c *Constraint) Equal(o *Constraint) bool + func (c *Constraint) String() string + func (c *Constraint) Validate() error + type Context string + const All + const Allocs + const Deployments + const Evals + const Jobs + const Namespaces + const Nodes + const Quotas + type Deployment struct + CreateIndex uint64 + ID string + JobCreateIndex uint64 + JobID string + JobModifyIndex uint64 + JobVersion uint64 + ModifyIndex uint64 + Namespace string + Status string + StatusDescription string + TaskGroups map[string]*DeploymentState + func NewDeployment(job *Job) *Deployment + func (d *Deployment) Active() bool + func (d *Deployment) Copy() *Deployment + func (d *Deployment) GetID() string + func (d *Deployment) GoString() string + func (d *Deployment) HasPlacedCanaries() bool + func (d *Deployment) RequiresPromotion() bool + type DeploymentAllocHealthRequest struct + DeploymentID string + HealthyAllocationIDs []string + UnhealthyAllocationIDs []string + type DeploymentDeleteRequest struct + Deployments []string + type DeploymentFailRequest struct + DeploymentID string + type DeploymentListRequest struct + type DeploymentListResponse struct + Deployments []*Deployment + type DeploymentPauseRequest struct + DeploymentID string + Pause bool + type DeploymentPromoteRequest struct + All bool + DeploymentID string + Groups []string + type DeploymentSpecificRequest struct + DeploymentID string + type DeploymentState struct + AutoRevert bool + DesiredCanaries int + DesiredTotal int + HealthyAllocs int + PlacedAllocs int + PlacedCanaries []string + Promoted bool + UnhealthyAllocs int + func (d *DeploymentState) Copy() *DeploymentState + func (d *DeploymentState) GoString() string + type DeploymentStatusUpdate struct + DeploymentID string + Status string + StatusDescription string + type DeploymentStatusUpdateRequest struct + DeploymentUpdate *DeploymentStatusUpdate + Eval *Evaluation + Job *Job + type DeploymentUpdateResponse struct + DeploymentModifyIndex uint64 + EvalCreateIndex uint64 + EvalID string + RevertedJobVersion *uint64 + type DeriveVaultTokenRequest struct + AllocID string + NodeID string + SecretID string + Tasks []string + type DeriveVaultTokenResponse struct + Error *RecoverableError + Tasks map[string]string + type DesiredTransition struct + Migrate *bool + func (d *DesiredTransition) Merge(o *DesiredTransition) + func (d *DesiredTransition) ShouldMigrate() bool + type DesiredUpdates struct + Canary uint64 + DestructiveUpdate uint64 + Ignore uint64 + InPlaceUpdate uint64 + Migrate uint64 + Place uint64 + Stop uint64 + func (d *DesiredUpdates) GoString() string + 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 + func (x *DiffType) CodecDecodeSelf(d *codec1978.Decoder) + func (x DiffType) CodecEncodeSelf(e *codec1978.Encoder) + type DispatchPayloadConfig struct + File string + func (d *DispatchPayloadConfig) Copy() *DispatchPayloadConfig + func (d *DispatchPayloadConfig) Validate() error + type DrainSpec struct + Deadline time.Duration + IgnoreSystemJobs bool + type DrainStrategy struct + ForceDeadline time.Time + func (d *DrainStrategy) Copy() *DrainStrategy + func (d *DrainStrategy) DeadlineTime() (infinite bool, deadline time.Time) + func (d *DrainStrategy) Equal(o *DrainStrategy) bool + type DrainUpdate struct + DrainStrategy *DrainStrategy + MarkEligible bool + type DriverInfo struct + Attributes map[string]string + Detected bool + HealthDescription string + Healthy bool + UpdateTime time.Time + func (di *DriverInfo) Copy() *DriverInfo + func (di *DriverInfo) HealthCheckEquals(other *DriverInfo) bool + func (di *DriverInfo) MergeFingerprintInfo(other *DriverInfo) + func (di *DriverInfo) MergeHealthCheck(other *DriverInfo) + type EmitNodeEventsRequest struct + NodeEvents map[string][]*NodeEvent + type EmitNodeEventsResponse struct + Index uint64 + type EphemeralDisk struct + Migrate bool + SizeMB int + Sticky bool + func DefaultEphemeralDisk() *EphemeralDisk + func (d *EphemeralDisk) Copy() *EphemeralDisk + func (d *EphemeralDisk) Validate() error + type EvalAckRequest struct + EvalID string + Token string + type EvalAllocationsResponse struct + Allocations []*AllocListStub + type EvalDeleteRequest struct + Allocs []string + Evals []string + type EvalDequeueRequest struct + SchedulerVersion uint16 + Schedulers []string + Timeout time.Duration + type EvalDequeueResponse struct + Eval *Evaluation + Token string + WaitIndex uint64 + func (e *EvalDequeueResponse) GetWaitIndex() uint64 + type EvalListRequest struct + type EvalListResponse struct + Evaluations []*Evaluation + type EvalSpecificRequest struct + EvalID string + type EvalUpdateRequest struct + EvalToken string + Evals []*Evaluation + type Evaluation struct + AnnotatePlan bool + BlockedEval string + ClassEligibility map[string]bool + CreateIndex uint64 + DeploymentID string + EscapedComputedClass bool + FailedTGAllocs map[string]*AllocMetric + ID string + JobID string + JobModifyIndex uint64 + LeaderACL string + ModifyIndex uint64 + Namespace string + NextEval string + NodeID string + NodeModifyIndex uint64 + PreviousEval string + Priority int + QueuedAllocations map[string]int + QuotaLimitReached string + SnapshotIndex uint64 + Status string + StatusDescription string + TriggeredBy string + Type string + Wait time.Duration + WaitUntil time.Time + func (e *Evaluation) Copy() *Evaluation + func (e *Evaluation) CreateBlockedEval(classEligibility map[string]bool, escaped bool, quotaReached string) *Evaluation + func (e *Evaluation) CreateFailedFollowUpEval(wait time.Duration) *Evaluation + func (e *Evaluation) GoString() string + func (e *Evaluation) MakePlan(j *Job) *Plan + func (e *Evaluation) NextRollingEval(wait time.Duration) *Evaluation + func (e *Evaluation) ShouldBlock() bool + func (e *Evaluation) ShouldEnqueue() bool + func (e *Evaluation) TerminalStatus() bool + 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 + func (x *FieldDiff) CodecDecodeSelf(d *codec1978.Decoder) + func (x *FieldDiff) CodecEncodeSelf(e *codec1978.Encoder) + type FieldDiffs []*FieldDiff + func (f FieldDiffs) Len() int + func (f FieldDiffs) Less(i, j int) bool + func (f FieldDiffs) Swap(i, j int) + func (x *FieldDiffs) CodecDecodeSelf(d *codec1978.Decoder) + func (x FieldDiffs) CodecEncodeSelf(e *codec1978.Encoder) + type GenericRequest struct + type GenericResponse struct + type InternalRpcInfo struct + Forwarded bool + func (i *InternalRpcInfo) IsForwarded() bool + func (i *InternalRpcInfo) SetForwarded() + type Job struct + AllAtOnce bool + Constraints []*Constraint + CreateIndex uint64 + Datacenters []string + ID string + JobModifyIndex uint64 + Meta map[string]string + ModifyIndex uint64 + Name string + Namespace string + ParameterizedJob *ParameterizedJobConfig + ParentID string + Payload []byte + Periodic *PeriodicConfig + Priority int + Region string + Stable bool + Status string + StatusDescription string + Stop bool + SubmitTime int64 + TaskGroups []*TaskGroup + Type string + Update UpdateStrategy + VaultToken string + Version uint64 + func (j *Job) Canonicalize() (warnings error) + func (j *Job) CombinedTaskMeta(groupName, taskName string) map[string]string + func (j *Job) Copy() *Job + func (j *Job) Diff(other *Job, contextual bool) (*JobDiff, error) + func (j *Job) HasUpdateStrategy() bool + func (j *Job) IsParameterized() bool + func (j *Job) IsPeriodic() bool + func (j *Job) IsPeriodicActive() bool + func (j *Job) LookupTaskGroup(name string) *TaskGroup + func (j *Job) NamespacedID() *NamespacedID + func (j *Job) RequiredSignals() map[string]map[string][]string + func (j *Job) SetSubmitTime() + func (j *Job) SpecChanged(new *Job) bool + func (j *Job) Stopped() bool + func (j *Job) Stub(summary *JobSummary) *JobListStub + func (j *Job) Validate() error + func (j *Job) VaultPolicies() map[string]map[string]*Vault + func (j *Job) Warnings() error + type JobAllocationsResponse struct + Allocations []*AllocListStub + type JobBatchDeregisterRequest struct + Evals []*Evaluation + Jobs map[NamespacedID]*JobDeregisterOptions + type JobBatchDeregisterResponse struct + JobEvals map[NamespacedID]string + type JobChildrenSummary struct + Dead int64 + Pending int64 + Running int64 + func (jc *JobChildrenSummary) Copy() *JobChildrenSummary + type JobDeregisterOptions struct + Purge bool + type JobDeregisterRequest struct + JobID string + Purge bool + type JobDeregisterResponse struct + EvalCreateIndex uint64 + EvalID string + JobModifyIndex uint64 + type JobDiff struct + Fields []*FieldDiff + ID string + Objects []*ObjectDiff + TaskGroups []*TaskGroupDiff + Type DiffType + func (j *JobDiff) GoString() string + func (x *JobDiff) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobDiff) CodecEncodeSelf(e *codec1978.Encoder) + type JobDispatchRequest struct + JobID string + Meta map[string]string + Payload []byte + type JobDispatchResponse struct + DispatchedJobID string + EvalCreateIndex uint64 + EvalID string + JobCreateIndex 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 + JobModifyIndex uint64 + JobSummary *JobSummary + ModifyIndex uint64 + Name string + ParameterizedJob bool + ParentID string + Periodic bool + Priority int + Status string + StatusDescription string + Stop bool + SubmitTime int64 + Type string + type JobPlanRequest struct + Diff bool + Job *Job + PolicyOverride bool + type JobPlanResponse struct + Annotations *PlanAnnotations + CreatedEvals []*Evaluation + Diff *JobDiff + FailedTGAllocs map[string]*AllocMetric + JobModifyIndex uint64 + NextPeriodicLaunch time.Time + Warnings string + type JobRegisterRequest struct + EnforceIndex bool + Job *Job + JobModifyIndex uint64 + PolicyOverride bool + type JobRegisterResponse struct + EvalCreateIndex uint64 + EvalID string + JobModifyIndex uint64 + Warnings string + type JobRevertRequest struct + EnforcePriorVersion *uint64 + JobID string + JobVersion uint64 + type JobSpecificRequest struct + AllAllocs bool + JobID string + type JobStabilityRequest struct + JobID string + JobVersion uint64 + Stable bool + type JobStabilityResponse struct + type JobSummary struct + Children *JobChildrenSummary + CreateIndex uint64 + JobID string + ModifyIndex uint64 + Namespace string + Summary map[string]TaskGroupSummary + func (js *JobSummary) Copy() *JobSummary + type JobSummaryRequest struct + JobID string + type JobSummaryResponse struct + JobSummary *JobSummary + type JobValidateRequest struct + Job *Job + type JobValidateResponse struct + DriverConfigValidated bool + Error string + ValidationErrors []string + Warnings string + type JobVersionsRequest struct + Diffs bool + JobID string + type JobVersionsResponse struct + Diffs []*JobDiff + Versions []*Job + type KeyringRequest struct + Key string + type KeyringResponse struct + Keys map[string]int + Messages map[string]string + NumNodes int + type LogConfig struct + MaxFileSizeMB int + MaxFiles int + func DefaultLogConfig() *LogConfig + func (l *LogConfig) Validate() error + type MessageType uint8 + const ACLPolicyDeleteRequestType + const ACLPolicyUpsertRequestType + const ACLTokenBootstrapRequestType + const ACLTokenDeleteRequestType + const ACLTokenUpsertRequestType + const AllocClientUpdateRequestType + const AllocUpdateDesiredTransitionRequestType + const AllocUpdateRequestType + const ApplyPlanResultsRequestType + const AutopilotRequestType + const BatchNodeUpdateDrainRequestType + const DeploymentAllocHealthRequestType + const DeploymentDeleteRequestType + const DeploymentPromoteRequestType + const DeploymentStatusUpdateRequestType + const EvalDeleteRequestType + const EvalUpdateRequestType + const JobBatchDeregisterRequestType + const JobDeregisterRequestType + const JobRegisterRequestType + const JobStabilityRequestType + const NodeDeregisterRequestType + const NodeRegisterRequestType + const NodeUpdateDrainRequestType + const NodeUpdateEligibilityRequestType + const NodeUpdateStatusRequestType + const ReconcileJobSummariesRequestType + const UpsertNodeEventsType + const VaultAccessorDeregisterRequestType + const VaultAccessorRegisterRequestType + type MigrateStrategy struct + HealthCheck string + HealthyDeadline time.Duration + MaxParallel int + MinHealthyTime time.Duration + func DefaultMigrateStrategy() *MigrateStrategy + func (m *MigrateStrategy) Validate() error + type NamespacedID struct + ID string + Namespace string + func (n NamespacedID) String() string + type NetworkIndex struct + AvailBandwidth map[string]int + AvailNetworks []*NetworkResource + UsedBandwidth map[string]int + UsedPorts map[string]Bitmap + 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) Release() + func (idx *NetworkIndex) SetNode(node *Node) (collide bool) + func (x *NetworkIndex) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NetworkIndex) CodecEncodeSelf(e *codec1978.Encoder) + type NetworkResource struct + CIDR string + Device string + DynamicPorts []Port + IP string + MBits int + ReservedPorts []Port + func (n *NetworkResource) Add(delta *NetworkResource) + func (n *NetworkResource) Canonicalize() + func (n *NetworkResource) Copy() *NetworkResource + func (n *NetworkResource) GoString() string + func (n *NetworkResource) MeetsMinResources() error + func (n *NetworkResource) PortLabels() map[string]int + func (nr *NetworkResource) Equals(other *NetworkResource) bool + func (r *NetworkResource) Diff(other *NetworkResource, contextual bool) *ObjectDiff + type Networks []*NetworkResource + func (ns Networks) Port(label string) (string, int) + type Node struct + Attributes map[string]string + ComputedClass string + CreateIndex uint64 + Datacenter string + Drain bool + DrainStrategy *DrainStrategy + Drivers map[string]*DriverInfo + Events []*NodeEvent + HTTPAddr string + ID string + Links map[string]string + Meta map[string]string + ModifyIndex uint64 + Name string + NodeClass string + Reserved *Resources + Resources *Resources + SchedulingEligibility string + SecretID string + Status string + StatusDescription string + StatusUpdatedAt int64 + TLSEnabled bool + func (n *Node) Canonicalize() + func (n *Node) ComputeClass() error + func (n *Node) Copy() *Node + func (n *Node) Ready() bool + func (n *Node) Stub() *NodeListStub + func (n *Node) TerminalStatus() bool + func (n Node) HashInclude(field string, v interface{}) (bool, error) + func (n Node) HashIncludeMap(field string, k, v interface{}) (bool, error) + type NodeAllocsResponse struct + Allocs []*Allocation + type NodeClientAllocsResponse struct + Allocs map[string]uint64 + MigrateTokens map[string]string + type NodeConnQueryResponse struct + Connected bool + Established time.Time + type NodeDeregisterRequest struct + NodeID string + type NodeDrainUpdateResponse struct + EvalCreateIndex uint64 + EvalIDs []string + NodeModifyIndex uint64 + type NodeEligibilityUpdateResponse struct + EvalCreateIndex uint64 + EvalIDs []string + NodeModifyIndex uint64 + type NodeEvaluateRequest struct + NodeID string + type NodeEvent struct + CreateIndex uint64 + Details map[string]string + Message string + Subsystem string + Timestamp time.Time + func (ne *NodeEvent) Copy() *NodeEvent + func (ne *NodeEvent) String() string + type NodeListRequest struct + type NodeListResponse struct + Nodes []*NodeListStub + type NodeListStub struct + Address string + CreateIndex uint64 + Datacenter string + Drain bool + ID string + ModifyIndex uint64 + Name string + NodeClass string + SchedulingEligibility string + Status string + StatusDescription string + Version string + type NodeRegisterRequest struct + Node *Node + type NodeServerInfo struct + Datacenter string + RPCAdvertiseAddr string + RPCMajorVersion int32 + RPCMinorVersion int32 + type NodeSpecificRequest struct + NodeID string + SecretID string + type NodeUpdateDrainRequest struct + Drain bool + DrainStrategy *DrainStrategy + MarkEligible bool + NodeID string + type NodeUpdateEligibilityRequest struct + Eligibility string + NodeID string + type NodeUpdateResponse struct + EvalCreateIndex uint64 + EvalIDs []string + HeartbeatTTL time.Duration + LeaderRPCAddr string + NodeModifyIndex uint64 + NumNodes int32 + Servers []*NodeServerInfo + type NodeUpdateStatusRequest struct + NodeID string + Status string + type ObjectDiff struct + Fields []*FieldDiff + Name string + Objects []*ObjectDiff + Type DiffType + func (o *ObjectDiff) GoString() string + func (o *ObjectDiff) Less(other *ObjectDiff) bool + func (x *ObjectDiff) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ObjectDiff) CodecEncodeSelf(e *codec1978.Encoder) + type ObjectDiffs []*ObjectDiff + func (o ObjectDiffs) Len() int + func (o ObjectDiffs) Less(i, j int) bool + func (o ObjectDiffs) Swap(i, j int) + func (x *ObjectDiffs) CodecDecodeSelf(d *codec1978.Decoder) + func (x ObjectDiffs) CodecEncodeSelf(e *codec1978.Encoder) + type ParameterizedJobConfig struct + MetaOptional []string + MetaRequired []string + Payload string + func (d *ParameterizedJobConfig) Canonicalize() + func (d *ParameterizedJobConfig) Copy() *ParameterizedJobConfig + func (d *ParameterizedJobConfig) Validate() error + type PeriodicConfig struct + Enabled bool + ProhibitOverlap bool + Spec string + SpecType string + TimeZone string + func (p *PeriodicConfig) Canonicalize() + func (p *PeriodicConfig) Copy() *PeriodicConfig + func (p *PeriodicConfig) GetLocation() *time.Location + func (p *PeriodicConfig) Next(fromTime time.Time) (time.Time, error) + func (p *PeriodicConfig) Validate() error + type PeriodicForceRequest struct + JobID string + type PeriodicForceResponse struct + EvalCreateIndex uint64 + EvalID string + type PeriodicLaunch struct + CreateIndex uint64 + ID string + Launch time.Time + ModifyIndex uint64 + Namespace string + type Plan struct + AllAtOnce bool + Annotations *PlanAnnotations + Deployment *Deployment + DeploymentUpdates []*DeploymentStatusUpdate + EvalID string + EvalToken string + Job *Job + NodeAllocation map[string][]*Allocation + NodeUpdate map[string][]*Allocation + Priority int + func (p *Plan) AppendAlloc(alloc *Allocation) + func (p *Plan) AppendUpdate(alloc *Allocation, desiredStatus, desiredDesc, clientStatus string) + func (p *Plan) IsNoOp() bool + func (p *Plan) PopUpdate(alloc *Allocation) + type PlanAnnotations struct + DesiredTGUpdates map[string]*DesiredUpdates + type PlanRequest struct + Plan *Plan + type PlanResponse struct + Result *PlanResult + type PlanResult struct + AllocIndex uint64 + Deployment *Deployment + DeploymentUpdates []*DeploymentStatusUpdate + 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 Port struct + Label string + Value int + type QueryMeta struct + Index uint64 + KnownLeader bool + LastContact time.Duration + type QueryOptions struct + AllowStale bool + AuthToken string + MaxQueryTime time.Duration + MinQueryIndex uint64 + Namespace string + Prefix string + Region string + func (q QueryOptions) AllowStaleRead() bool + func (q QueryOptions) IsRead() bool + func (q QueryOptions) RequestNamespace() string + func (q QueryOptions) RequestRegion() string + type RPCInfo interface + AllowStaleRead func() bool + IsForwarded func() bool + IsRead func() bool + RequestRegion func() string + SetForwarded func() + type RaftConfigurationResponse struct + Index uint64 + Servers []*RaftServer + func (x *RaftConfigurationResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *RaftConfigurationResponse) CodecEncodeSelf(e *codec1978.Encoder) + type RaftPeerByAddressRequest struct + Address raft.ServerAddress + func (x *RaftPeerByAddressRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *RaftPeerByAddressRequest) CodecEncodeSelf(e *codec1978.Encoder) + type RaftPeerByIDRequest struct + ID raft.ServerID + func (x *RaftPeerByIDRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *RaftPeerByIDRequest) CodecEncodeSelf(e *codec1978.Encoder) + type RaftServer struct + Address raft.ServerAddress + ID raft.ServerID + Leader bool + Node string + RaftProtocol string + Voter bool + func (x *RaftServer) CodecDecodeSelf(d *codec1978.Decoder) + func (x *RaftServer) CodecEncodeSelf(e *codec1978.Encoder) + type Recoverable interface + IsRecoverable func() bool + type RecoverableError struct + Err string + Recoverable bool + func (r *RecoverableError) Error() string + func (r *RecoverableError) IsRecoverable() bool + type RescheduleEvent struct + Delay time.Duration + PrevAllocID string + PrevNodeID string + RescheduleTime int64 + func NewRescheduleEvent(rescheduleTime int64, prevAllocID string, prevNodeID string, ...) *RescheduleEvent + func (re *RescheduleEvent) Copy() *RescheduleEvent + type ReschedulePolicy struct + Attempts int + Delay time.Duration + DelayFunction string + Interval time.Duration + MaxDelay time.Duration + Unlimited bool + func NewReschedulePolicy(jobType string) *ReschedulePolicy + func (r *ReschedulePolicy) Copy() *ReschedulePolicy + func (r *ReschedulePolicy) Validate() error + type RescheduleTracker struct + Events []*RescheduleEvent + func (rt *RescheduleTracker) Copy() *RescheduleTracker + type ResolveACLTokenRequest struct + SecretID string + type ResolveACLTokenResponse struct + Token *ACLToken + type Resources struct + CPU int + DiskMB int + IOPS int + MemoryMB int + Networks Networks + func AllocsFit(node *Node, allocs []*Allocation, netIdx *NetworkIndex) (bool, string, *Resources, error) + func DefaultResources() *Resources + func MinResources() *Resources + func (r *Resources) Add(delta *Resources) error + func (r *Resources) Canonicalize() + func (r *Resources) Copy() *Resources + func (r *Resources) Diff(other *Resources, contextual bool) *ObjectDiff + func (r *Resources) DiskInBytes() int64 + func (r *Resources) GoString() string + func (r *Resources) MeetsMinResources() error + func (r *Resources) Merge(other *Resources) + func (r *Resources) NetIndex(n *NetworkResource) int + func (r *Resources) Superset(other *Resources) (bool, string) + type RestartPolicy struct + Attempts int + Delay time.Duration + Interval time.Duration + Mode string + func NewRestartPolicy(jobType string) *RestartPolicy + func (r *RestartPolicy) Copy() *RestartPolicy + func (r *RestartPolicy) Validate() error + type SearchRequest struct + Context Context + Prefix string + type SearchResponse struct + Matches map[Context][]string + Truncations map[Context]bool + 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 ServerSideError interface + IsServerSide func() bool + type Service struct + AddressMode string + Checks []*ServiceCheck + Name string + PortLabel string + Tags []string + func (s *Service) Canonicalize(job string, taskGroup string, task string) + func (s *Service) Copy() *Service + func (s *Service) Hash(allocID, taskName string) string + func (s *Service) Validate() error + func (s *Service) ValidateName(name string) error + type ServiceCheck struct + AddressMode string + Args []string + CheckRestart *CheckRestart + Command string + Header map[string][]string + InitialStatus string + Interval time.Duration + Method string + Name string + Path string + PortLabel string + Protocol string + TLSSkipVerify bool + Timeout time.Duration + Type string + func (sc *ServiceCheck) Canonicalize(serviceName string) + func (sc *ServiceCheck) Copy() *ServiceCheck + func (sc *ServiceCheck) Hash(serviceID string) string + func (sc *ServiceCheck) RequiresPort() bool + func (sc *ServiceCheck) TriggersRestarts() bool + type SingleACLPolicyResponse struct + Policy *ACLPolicy + type SingleACLTokenResponse struct + Token *ACLToken + type SingleAllocResponse struct + Alloc *Allocation + type SingleDeploymentResponse struct + Deployment *Deployment + type SingleEvalResponse struct + Eval *Evaluation + type SingleJobResponse struct + Job *Job + type SingleNodeResponse struct + Node *Node + type StreamingRpcAck struct + Error string + func (x *StreamingRpcAck) CodecDecodeSelf(d *codec1978.Decoder) + func (x *StreamingRpcAck) CodecEncodeSelf(e *codec1978.Encoder) + type StreamingRpcHandler func(conn io.ReadWriteCloser) + type StreamingRpcHeader struct + Method string + func (x *StreamingRpcHeader) CodecDecodeSelf(d *codec1978.Decoder) + func (x *StreamingRpcHeader) CodecEncodeSelf(e *codec1978.Encoder) + type StreamingRpcRegistry struct + func NewStreamingRpcRegistry() *StreamingRpcRegistry + func (s *StreamingRpcRegistry) GetHandler(method string) (StreamingRpcHandler, error) + func (s *StreamingRpcRegistry) Register(method string, handler StreamingRpcHandler) + func (x *StreamingRpcRegistry) CodecDecodeSelf(d *codec1978.Decoder) + func (x *StreamingRpcRegistry) CodecEncodeSelf(e *codec1978.Encoder) + type Task struct + Artifacts []*TaskArtifact + Config map[string]interface{} + Constraints []*Constraint + DispatchPayload *DispatchPayloadConfig + Driver string + Env map[string]string + KillSignal string + KillTimeout time.Duration + Leader bool + LogConfig *LogConfig + Meta map[string]string + Name string + Resources *Resources + Services []*Service + ShutdownDelay time.Duration + Templates []*Template + User string + Vault *Vault + func (t *Task) Canonicalize(job *Job, tg *TaskGroup) + func (t *Task) Copy() *Task + func (t *Task) Diff(other *Task, contextual bool) (*TaskDiff, error) + func (t *Task) GoString() string + func (t *Task) Validate(ephemeralDisk *EphemeralDisk) error + type TaskArtifact struct + GetterMode string + GetterOptions map[string]string + GetterSource string + RelativeDest string + func (ta *TaskArtifact) Copy() *TaskArtifact + func (ta *TaskArtifact) GoString() string + func (ta *TaskArtifact) Validate() error + type TaskDiff struct + Annotations []string + Fields []*FieldDiff + Name string + Objects []*ObjectDiff + Type DiffType + func (t *TaskDiff) GoString() string + func (x *TaskDiff) CodecDecodeSelf(d *codec1978.Decoder) + func (x *TaskDiff) CodecEncodeSelf(e *codec1978.Encoder) + type TaskDiffs []*TaskDiff + func (t TaskDiffs) Len() int + func (t TaskDiffs) Less(i, j int) bool + func (t TaskDiffs) Swap(i, j int) + func (x *TaskDiffs) CodecDecodeSelf(d *codec1978.Decoder) + func (x TaskDiffs) CodecEncodeSelf(e *codec1978.Encoder) + type TaskEvent struct + Details map[string]string + DiskLimit int64 + DisplayMessage string + DownloadError string + DriverError string + DriverMessage string + ExitCode int + FailedSibling string + FailsTask bool + GenericSource string + KillError string + KillReason string + KillTimeout time.Duration + Message string + RestartReason string + SetupError string + Signal int + StartDelay int64 + TaskSignal string + TaskSignalReason string + Time int64 + Type string + ValidationError string + VaultError string + func NewTaskEvent(event string) *TaskEvent + func (e *TaskEvent) SetDiskLimit(limit int64) *TaskEvent + func (e *TaskEvent) SetDownloadError(err error) *TaskEvent + func (e *TaskEvent) SetDriverError(err error) *TaskEvent + func (e *TaskEvent) SetDriverMessage(m string) *TaskEvent + func (e *TaskEvent) SetExitCode(c int) *TaskEvent + func (e *TaskEvent) SetExitMessage(err error) *TaskEvent + func (e *TaskEvent) SetFailedSibling(sibling string) *TaskEvent + func (e *TaskEvent) SetFailsTask() *TaskEvent + func (e *TaskEvent) SetKillError(err error) *TaskEvent + func (e *TaskEvent) SetKillReason(r string) *TaskEvent + func (e *TaskEvent) SetKillTimeout(timeout time.Duration) *TaskEvent + func (e *TaskEvent) SetRestartDelay(delay time.Duration) *TaskEvent + func (e *TaskEvent) SetRestartReason(reason string) *TaskEvent + func (e *TaskEvent) SetSetupError(err error) *TaskEvent + func (e *TaskEvent) SetSignal(s int) *TaskEvent + func (e *TaskEvent) SetTaskSignal(s os.Signal) *TaskEvent + func (e *TaskEvent) SetTaskSignalReason(r string) *TaskEvent + func (e *TaskEvent) SetValidationError(err error) *TaskEvent + func (e *TaskEvent) SetVaultRenewalError(err error) *TaskEvent + func (event *TaskEvent) PopulateEventDisplayMessage() + func (te *TaskEvent) Copy() *TaskEvent + func (te *TaskEvent) GoString() string + func (te *TaskEvent) SetMessage(msg string) *TaskEvent + type TaskGroup struct + Constraints []*Constraint + Count int + EphemeralDisk *EphemeralDisk + Meta map[string]string + Migrate *MigrateStrategy + Name string + ReschedulePolicy *ReschedulePolicy + RestartPolicy *RestartPolicy + Tasks []*Task + Update *UpdateStrategy + func (tg *TaskGroup) Canonicalize(job *Job) + func (tg *TaskGroup) CombinedResources() *Resources + func (tg *TaskGroup) Copy() *TaskGroup + func (tg *TaskGroup) Diff(other *TaskGroup, contextual bool) (*TaskGroupDiff, error) + func (tg *TaskGroup) GoString() string + func (tg *TaskGroup) LookupTask(name string) *Task + func (tg *TaskGroup) Validate(j *Job) error + func (tg *TaskGroup) Warnings(j *Job) error + type TaskGroupDiff struct + Fields []*FieldDiff + Name string + Objects []*ObjectDiff + Tasks []*TaskDiff + Type DiffType + Updates map[string]uint64 + func (tg *TaskGroupDiff) GoString() string + func (x *TaskGroupDiff) CodecDecodeSelf(d *codec1978.Decoder) + func (x *TaskGroupDiff) CodecEncodeSelf(e *codec1978.Encoder) + type TaskGroupDiffs []*TaskGroupDiff + func (tg TaskGroupDiffs) Len() int + func (tg TaskGroupDiffs) Less(i, j int) bool + func (tg TaskGroupDiffs) Swap(i, j int) + func (x *TaskGroupDiffs) CodecDecodeSelf(d *codec1978.Decoder) + func (x TaskGroupDiffs) CodecEncodeSelf(e *codec1978.Encoder) + type TaskGroupSummary struct + Complete int + Failed int + Lost int + Queued int + Running int + Starting int + type TaskState struct + Events []*TaskEvent + Failed bool + FinishedAt time.Time + LastRestart time.Time + Restarts uint64 + StartedAt time.Time + State string + func (ts *TaskState) Copy() *TaskState + func (ts *TaskState) Successful() bool + type Template struct + ChangeMode string + ChangeSignal string + DestPath string + EmbeddedTmpl string + Envvars bool + LeftDelim string + Perms string + RightDelim string + SourcePath string + Splay time.Duration + VaultGrace time.Duration + func DefaultTemplate() *Template + func (t *Template) Canonicalize() + func (t *Template) Copy() *Template + func (t *Template) Validate() error + type UpdateStrategy struct + AutoRevert bool + Canary int + HealthCheck string + HealthyDeadline time.Duration + MaxParallel int + MinHealthyTime time.Duration + Stagger time.Duration + func (u *UpdateStrategy) Copy() *UpdateStrategy + func (u *UpdateStrategy) Rolling() bool + func (u *UpdateStrategy) 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 + type VersionResponse struct + Build string + Versions map[string]int + type WrappedServerError struct + Err error + func (r *WrappedServerError) Error() string + func (r *WrappedServerError) IsRecoverable() bool + func (r *WrappedServerError) IsServerSide() bool + type WriteMeta struct + Index uint64 + type WriteRequest struct + AuthToken string + Namespace string + Region string + func (w WriteRequest) AllowStaleRead() bool + func (w WriteRequest) IsRead() bool + func (w WriteRequest) RequestNamespace() string + func (w WriteRequest) RequestRegion() string