Versions in this module Expand all Collapse all v0 v0.7.1 Dec 20, 2017 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 EvalStatusBlocked + const EvalStatusCancelled + const EvalStatusComplete + const EvalStatusFailed + const EvalStatusPending + const EvalTriggerDeploymentWatcher + const EvalTriggerFailedFollowUp + const EvalTriggerJobDeregister + const EvalTriggerJobRegister + const EvalTriggerMaxPlans + const EvalTriggerNodeUpdate + const EvalTriggerPeriodicJob + const EvalTriggerRollingUpdate + const EvalTriggerScheduled + const GetterModeAny + const GetterModeDir + const GetterModeFile + const IgnoreUnknownTypeFlag + 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 MinDynamicPort + const NodeStatusDown + const NodeStatusInit + const NodeStatusReady + const NodeUniqueNamespace + const PeriodicLaunchSuffix + const PeriodicSpecCron + const PeriodicSpecTest + const ProtocolVersion + const ReasonWithinPolicy + 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 DefaultUpdateStrategy = &UpdateStrategy + var ErrNoLeader = fmt.Errorf("No cluster leader") + var ErrNoRegionPath = fmt.Errorf("No path to region") + var ErrPermissionDenied = errors.New("Permission denied") + var ErrTokenNotFound = errors.New("ACL token not found") + var HashiMsgpackHandle = func() *hcodec.MsgpackHandle { ... }() + var JsonHandle = &codec.JsonHandle + var JsonHandlePretty = &codec.JsonHandle + var MsgpackHandle = func() *codec.MsgpackHandle { ... }() + var TemplateChangeModeInvalidError = errors.New("Invalid change mode. Must be one of the following: noop, signal, restart") + func ACLPolicyListHash(policies []*ACLPolicy) string + func AllocName(job, group string, idx uint) string + func CompileACLObject(cache *lru.TwoQueueCache, policies []*ACLPolicy) (*acl.ACL, 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 IsRecoverable(e error) bool + func IsUniqueNamespace(key string) bool + func MergeMultierrorWarnings(warnings ...error) string + func NewRecoverableError(e error, recoverable bool) 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 + func (x *ACLPolicy) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLPolicy) CodecEncodeSelf(e *codec1978.Encoder) + type ACLPolicyDeleteRequest struct + Names []string + func (x *ACLPolicyDeleteRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLPolicyDeleteRequest) CodecEncodeSelf(e *codec1978.Encoder) + type ACLPolicyListRequest struct + func (x *ACLPolicyListRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLPolicyListRequest) CodecEncodeSelf(e *codec1978.Encoder) + type ACLPolicyListResponse struct + Policies []*ACLPolicyListStub + func (x *ACLPolicyListResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLPolicyListResponse) CodecEncodeSelf(e *codec1978.Encoder) + type ACLPolicyListStub struct + CreateIndex uint64 + Description string + Hash []byte + ModifyIndex uint64 + Name string + func (x *ACLPolicyListStub) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLPolicyListStub) CodecEncodeSelf(e *codec1978.Encoder) + type ACLPolicySetRequest struct + Names []string + func (x *ACLPolicySetRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLPolicySetRequest) CodecEncodeSelf(e *codec1978.Encoder) + type ACLPolicySetResponse struct + Policies map[string]*ACLPolicy + func (x *ACLPolicySetResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLPolicySetResponse) CodecEncodeSelf(e *codec1978.Encoder) + type ACLPolicySpecificRequest struct + Name string + func (x *ACLPolicySpecificRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLPolicySpecificRequest) CodecEncodeSelf(e *codec1978.Encoder) + type ACLPolicyUpsertRequest struct + Policies []*ACLPolicy + func (x *ACLPolicyUpsertRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLPolicyUpsertRequest) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *ACLToken) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLToken) CodecEncodeSelf(e *codec1978.Encoder) + type ACLTokenBootstrapRequest struct + ResetIndex uint64 + Token *ACLToken + func (x *ACLTokenBootstrapRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLTokenBootstrapRequest) CodecEncodeSelf(e *codec1978.Encoder) + type ACLTokenDeleteRequest struct + AccessorIDs []string + func (x *ACLTokenDeleteRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLTokenDeleteRequest) CodecEncodeSelf(e *codec1978.Encoder) + type ACLTokenListRequest struct + GlobalOnly bool + func (x *ACLTokenListRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLTokenListRequest) CodecEncodeSelf(e *codec1978.Encoder) + type ACLTokenListResponse struct + Tokens []*ACLTokenListStub + func (x *ACLTokenListResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLTokenListResponse) CodecEncodeSelf(e *codec1978.Encoder) + type ACLTokenListStub struct + AccessorID string + CreateIndex uint64 + CreateTime time.Time + Global bool + Hash []byte + ModifyIndex uint64 + Name string + Policies []string + Type string + func (x *ACLTokenListStub) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLTokenListStub) CodecEncodeSelf(e *codec1978.Encoder) + type ACLTokenSetRequest struct + AccessorIDS []string + func (x *ACLTokenSetRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLTokenSetRequest) CodecEncodeSelf(e *codec1978.Encoder) + type ACLTokenSetResponse struct + Tokens map[string]*ACLToken + func (x *ACLTokenSetResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLTokenSetResponse) CodecEncodeSelf(e *codec1978.Encoder) + type ACLTokenSpecificRequest struct + AccessorID string + func (x *ACLTokenSpecificRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLTokenSpecificRequest) CodecEncodeSelf(e *codec1978.Encoder) + type ACLTokenUpsertRequest struct + Tokens []*ACLToken + func (x *ACLTokenUpsertRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLTokenUpsertRequest) CodecEncodeSelf(e *codec1978.Encoder) + type ACLTokenUpsertResponse struct + Tokens []*ACLToken + func (x *ACLTokenUpsertResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ACLTokenUpsertResponse) CodecEncodeSelf(e *codec1978.Encoder) + type AllocDeploymentStatus struct + Healthy *bool + ModifyIndex uint64 + func (a *AllocDeploymentStatus) Copy() *AllocDeploymentStatus + func (a *AllocDeploymentStatus) IsHealthy() bool + func (a *AllocDeploymentStatus) IsUnhealthy() bool + func (x *AllocDeploymentStatus) CodecDecodeSelf(d *codec1978.Decoder) + func (x *AllocDeploymentStatus) CodecEncodeSelf(e *codec1978.Encoder) + type AllocListRequest struct + func (x *AllocListRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *AllocListRequest) CodecEncodeSelf(e *codec1978.Encoder) + type AllocListResponse struct + Allocations []*AllocListStub + func (x *AllocListResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *AllocListResponse) CodecEncodeSelf(e *codec1978.Encoder) + type AllocListStub struct + ClientDescription string + ClientStatus string + CreateIndex uint64 + CreateTime int64 + DeploymentStatus *AllocDeploymentStatus + DesiredDescription string + DesiredStatus string + EvalID 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() + func (x *AllocListStub) CodecDecodeSelf(d *codec1978.Decoder) + func (x *AllocListStub) CodecEncodeSelf(e *codec1978.Encoder) + 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) + func (x *AllocMetric) CodecDecodeSelf(d *codec1978.Decoder) + func (x *AllocMetric) CodecEncodeSelf(e *codec1978.Encoder) + type AllocSpecificRequest struct + AllocID string + func (x *AllocSpecificRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *AllocSpecificRequest) CodecEncodeSelf(e *codec1978.Encoder) + type AllocUpdateRequest struct + Alloc []*Allocation + Job *Job + func (x *AllocUpdateRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *AllocUpdateRequest) CodecEncodeSelf(e *codec1978.Encoder) + type Allocation struct + AllocModifyIndex uint64 + ClientDescription string + ClientStatus string + CreateIndex uint64 + CreateTime int64 + DeploymentID string + DeploymentStatus *AllocDeploymentStatus + DesiredDescription string + DesiredStatus string + EvalID string + ID string + Job *Job + JobID string + Metrics *AllocMetric + ModifyIndex uint64 + ModifyTime int64 + Name string + Namespace string + NodeID string + PreviousAllocation string + 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) Copy() *Allocation + func (a *Allocation) CopySkipJob() *Allocation + func (a *Allocation) Index() uint + func (a *Allocation) RanSuccessfully() bool + func (a *Allocation) SetEventDisplayMessages() + func (a *Allocation) ShouldMigrate() bool + func (a *Allocation) Stub() *AllocListStub + func (a *Allocation) TerminalStatus() bool + func (a *Allocation) Terminated() bool + func (x *Allocation) CodecDecodeSelf(d *codec1978.Decoder) + func (x *Allocation) CodecEncodeSelf(e *codec1978.Encoder) + type AllocsGetRequest struct + AllocIDs []string + func (x *AllocsGetRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *AllocsGetRequest) CodecEncodeSelf(e *codec1978.Encoder) + type AllocsGetResponse struct + Allocs []*Allocation + func (x *AllocsGetResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *AllocsGetResponse) CodecEncodeSelf(e *codec1978.Encoder) + type ApplyDeploymentAllocHealthRequest struct + DeploymentUpdate *DeploymentStatusUpdate + Eval *Evaluation + Job *Job + func (x *ApplyDeploymentAllocHealthRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ApplyDeploymentAllocHealthRequest) CodecEncodeSelf(e *codec1978.Encoder) + type ApplyDeploymentPromoteRequest struct + Eval *Evaluation + func (x *ApplyDeploymentPromoteRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ApplyDeploymentPromoteRequest) CodecEncodeSelf(e *codec1978.Encoder) + type ApplyPlanResultsRequest struct + Deployment *Deployment + DeploymentUpdates []*DeploymentStatusUpdate + EvalID string + func (x *ApplyPlanResultsRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ApplyPlanResultsRequest) CodecEncodeSelf(e *codec1978.Encoder) + 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) + type CheckRestart struct + Grace time.Duration + IgnoreWarnings bool + Limit int + func (c *CheckRestart) Copy() *CheckRestart + func (c *CheckRestart) Validate() error + func (x *CheckRestart) CodecDecodeSelf(d *codec1978.Decoder) + func (x *CheckRestart) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *Constraint) CodecDecodeSelf(d *codec1978.Decoder) + func (x *Constraint) CodecEncodeSelf(e *codec1978.Encoder) + type Context string + const All + const Allocs + const Deployments + const Evals + const Jobs + const Namespaces + const Nodes + const Quotas + func (x *Context) CodecDecodeSelf(d *codec1978.Decoder) + func (x Context) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *Deployment) CodecDecodeSelf(d *codec1978.Decoder) + func (x *Deployment) CodecEncodeSelf(e *codec1978.Encoder) + type DeploymentAllocHealthRequest struct + DeploymentID string + HealthyAllocationIDs []string + UnhealthyAllocationIDs []string + func (x *DeploymentAllocHealthRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DeploymentAllocHealthRequest) CodecEncodeSelf(e *codec1978.Encoder) + type DeploymentDeleteRequest struct + Deployments []string + func (x *DeploymentDeleteRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DeploymentDeleteRequest) CodecEncodeSelf(e *codec1978.Encoder) + type DeploymentFailRequest struct + DeploymentID string + func (x *DeploymentFailRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DeploymentFailRequest) CodecEncodeSelf(e *codec1978.Encoder) + type DeploymentListRequest struct + func (x *DeploymentListRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DeploymentListRequest) CodecEncodeSelf(e *codec1978.Encoder) + type DeploymentListResponse struct + Deployments []*Deployment + func (x *DeploymentListResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DeploymentListResponse) CodecEncodeSelf(e *codec1978.Encoder) + type DeploymentPauseRequest struct + DeploymentID string + Pause bool + func (x *DeploymentPauseRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DeploymentPauseRequest) CodecEncodeSelf(e *codec1978.Encoder) + type DeploymentPromoteRequest struct + All bool + DeploymentID string + Groups []string + func (x *DeploymentPromoteRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DeploymentPromoteRequest) CodecEncodeSelf(e *codec1978.Encoder) + type DeploymentSpecificRequest struct + DeploymentID string + func (x *DeploymentSpecificRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DeploymentSpecificRequest) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *DeploymentState) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DeploymentState) CodecEncodeSelf(e *codec1978.Encoder) + type DeploymentStatusUpdate struct + DeploymentID string + Status string + StatusDescription string + func (x *DeploymentStatusUpdate) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DeploymentStatusUpdate) CodecEncodeSelf(e *codec1978.Encoder) + type DeploymentStatusUpdateRequest struct + DeploymentUpdate *DeploymentStatusUpdate + Eval *Evaluation + Job *Job + func (x *DeploymentStatusUpdateRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DeploymentStatusUpdateRequest) CodecEncodeSelf(e *codec1978.Encoder) + type DeploymentUpdateResponse struct + DeploymentModifyIndex uint64 + EvalCreateIndex uint64 + EvalID string + RevertedJobVersion *uint64 + func (x *DeploymentUpdateResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DeploymentUpdateResponse) CodecEncodeSelf(e *codec1978.Encoder) + type DeriveVaultTokenRequest struct + AllocID string + NodeID string + SecretID string + Tasks []string + func (x *DeriveVaultTokenRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DeriveVaultTokenRequest) CodecEncodeSelf(e *codec1978.Encoder) + type DeriveVaultTokenResponse struct + Error *RecoverableError + Tasks map[string]string + func (x *DeriveVaultTokenResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DeriveVaultTokenResponse) CodecEncodeSelf(e *codec1978.Encoder) + type DesiredUpdates struct + Canary uint64 + DestructiveUpdate uint64 + Ignore uint64 + InPlaceUpdate uint64 + Migrate uint64 + Place uint64 + Stop uint64 + func (d *DesiredUpdates) GoString() string + func (x *DesiredUpdates) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DesiredUpdates) CodecEncodeSelf(e *codec1978.Encoder) + 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 DispatchPayloadConfig struct + File string + func (d *DispatchPayloadConfig) Copy() *DispatchPayloadConfig + func (d *DispatchPayloadConfig) Validate() error + func (x *DispatchPayloadConfig) CodecDecodeSelf(d *codec1978.Decoder) + func (x *DispatchPayloadConfig) CodecEncodeSelf(e *codec1978.Encoder) + type EphemeralDisk struct + Migrate bool + SizeMB int + Sticky bool + func DefaultEphemeralDisk() *EphemeralDisk + func (d *EphemeralDisk) Copy() *EphemeralDisk + func (d *EphemeralDisk) Validate() error + func (x *EphemeralDisk) CodecDecodeSelf(d *codec1978.Decoder) + func (x *EphemeralDisk) CodecEncodeSelf(e *codec1978.Encoder) + type EvalAckRequest struct + EvalID string + Token string + func (x *EvalAckRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *EvalAckRequest) CodecEncodeSelf(e *codec1978.Encoder) + type EvalAllocationsResponse struct + Allocations []*AllocListStub + func (x *EvalAllocationsResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *EvalAllocationsResponse) CodecEncodeSelf(e *codec1978.Encoder) + type EvalDeleteRequest struct + Allocs []string + Evals []string + func (x *EvalDeleteRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *EvalDeleteRequest) CodecEncodeSelf(e *codec1978.Encoder) + type EvalDequeueRequest struct + SchedulerVersion uint16 + Schedulers []string + Timeout time.Duration + func (x *EvalDequeueRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *EvalDequeueRequest) CodecEncodeSelf(e *codec1978.Encoder) + type EvalDequeueResponse struct + Eval *Evaluation + Token string + WaitIndex uint64 + func (e *EvalDequeueResponse) GetWaitIndex() uint64 + func (x *EvalDequeueResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *EvalDequeueResponse) CodecEncodeSelf(e *codec1978.Encoder) + type EvalListRequest struct + func (x *EvalListRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *EvalListRequest) CodecEncodeSelf(e *codec1978.Encoder) + type EvalListResponse struct + Evaluations []*Evaluation + func (x *EvalListResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *EvalListResponse) CodecEncodeSelf(e *codec1978.Encoder) + type EvalSpecificRequest struct + EvalID string + func (x *EvalSpecificRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *EvalSpecificRequest) CodecEncodeSelf(e *codec1978.Encoder) + type EvalUpdateRequest struct + EvalToken string + Evals []*Evaluation + func (x *EvalUpdateRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *EvalUpdateRequest) CodecEncodeSelf(e *codec1978.Encoder) + 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 + 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 + func (x *Evaluation) CodecDecodeSelf(d *codec1978.Decoder) + func (x *Evaluation) CodecEncodeSelf(e *codec1978.Encoder) + 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 GenericRequest struct + func (x *GenericRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *GenericRequest) CodecEncodeSelf(e *codec1978.Encoder) + type GenericResponse struct + func (x *GenericResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *GenericResponse) CodecEncodeSelf(e *codec1978.Encoder) + 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) 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 + func (x *Job) CodecDecodeSelf(d *codec1978.Decoder) + func (x *Job) CodecEncodeSelf(e *codec1978.Encoder) + type JobAllocationsResponse struct + Allocations []*AllocListStub + func (x *JobAllocationsResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobAllocationsResponse) CodecEncodeSelf(e *codec1978.Encoder) + type JobChildrenSummary struct + Dead int64 + Pending int64 + Running int64 + func (jc *JobChildrenSummary) Copy() *JobChildrenSummary + func (x *JobChildrenSummary) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobChildrenSummary) CodecEncodeSelf(e *codec1978.Encoder) + type JobDeregisterRequest struct + JobID string + Purge bool + func (x *JobDeregisterRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobDeregisterRequest) CodecEncodeSelf(e *codec1978.Encoder) + type JobDeregisterResponse struct + EvalCreateIndex uint64 + EvalID string + JobModifyIndex uint64 + func (x *JobDeregisterResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobDeregisterResponse) CodecEncodeSelf(e *codec1978.Encoder) + type JobDiff struct + Fields []*FieldDiff + ID string + Objects []*ObjectDiff + TaskGroups []*TaskGroupDiff + Type DiffType + func (j *JobDiff) GoString() string + type JobDispatchRequest struct + JobID string + Meta map[string]string + Payload []byte + func (x *JobDispatchRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobDispatchRequest) CodecEncodeSelf(e *codec1978.Encoder) + type JobDispatchResponse struct + DispatchedJobID string + EvalCreateIndex uint64 + EvalID string + JobCreateIndex uint64 + func (x *JobDispatchResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobDispatchResponse) CodecEncodeSelf(e *codec1978.Encoder) + type JobEvaluateRequest struct + JobID string + func (x *JobEvaluateRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobEvaluateRequest) CodecEncodeSelf(e *codec1978.Encoder) + type JobEvaluationsResponse struct + Evaluations []*Evaluation + func (x *JobEvaluationsResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobEvaluationsResponse) CodecEncodeSelf(e *codec1978.Encoder) + type JobListRequest struct + func (x *JobListRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobListRequest) CodecEncodeSelf(e *codec1978.Encoder) + type JobListResponse struct + Jobs []*JobListStub + func (x *JobListResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobListResponse) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *JobListStub) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobListStub) CodecEncodeSelf(e *codec1978.Encoder) + type JobPlanRequest struct + Diff bool + Job *Job + PolicyOverride bool + func (x *JobPlanRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobPlanRequest) CodecEncodeSelf(e *codec1978.Encoder) + type JobPlanResponse struct + Annotations *PlanAnnotations + CreatedEvals []*Evaluation + Diff *JobDiff + FailedTGAllocs map[string]*AllocMetric + JobModifyIndex uint64 + NextPeriodicLaunch time.Time + Warnings string + func (x *JobPlanResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobPlanResponse) CodecEncodeSelf(e *codec1978.Encoder) + type JobRegisterRequest struct + EnforceIndex bool + Job *Job + JobModifyIndex uint64 + PolicyOverride bool + func (x *JobRegisterRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobRegisterRequest) CodecEncodeSelf(e *codec1978.Encoder) + type JobRegisterResponse struct + EvalCreateIndex uint64 + EvalID string + JobModifyIndex uint64 + Warnings string + func (x *JobRegisterResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobRegisterResponse) CodecEncodeSelf(e *codec1978.Encoder) + type JobRevertRequest struct + EnforcePriorVersion *uint64 + JobID string + JobVersion uint64 + func (x *JobRevertRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobRevertRequest) CodecEncodeSelf(e *codec1978.Encoder) + type JobSpecificRequest struct + AllAllocs bool + JobID string + func (x *JobSpecificRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobSpecificRequest) CodecEncodeSelf(e *codec1978.Encoder) + type JobStabilityRequest struct + JobID string + JobVersion uint64 + Stable bool + func (x *JobStabilityRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobStabilityRequest) CodecEncodeSelf(e *codec1978.Encoder) + type JobStabilityResponse struct + func (x *JobStabilityResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobStabilityResponse) CodecEncodeSelf(e *codec1978.Encoder) + type JobSummary struct + Children *JobChildrenSummary + CreateIndex uint64 + JobID string + ModifyIndex uint64 + Namespace string + Summary map[string]TaskGroupSummary + func (js *JobSummary) Copy() *JobSummary + func (x *JobSummary) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobSummary) CodecEncodeSelf(e *codec1978.Encoder) + type JobSummaryRequest struct + JobID string + func (x *JobSummaryRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobSummaryRequest) CodecEncodeSelf(e *codec1978.Encoder) + type JobSummaryResponse struct + JobSummary *JobSummary + func (x *JobSummaryResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobSummaryResponse) CodecEncodeSelf(e *codec1978.Encoder) + type JobValidateRequest struct + Job *Job + func (x *JobValidateRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobValidateRequest) CodecEncodeSelf(e *codec1978.Encoder) + type JobValidateResponse struct + DriverConfigValidated bool + Error string + ValidationErrors []string + Warnings string + func (x *JobValidateResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobValidateResponse) CodecEncodeSelf(e *codec1978.Encoder) + type JobVersionsRequest struct + Diffs bool + JobID string + func (x *JobVersionsRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobVersionsRequest) CodecEncodeSelf(e *codec1978.Encoder) + type JobVersionsResponse struct + Diffs []*JobDiff + Versions []*Job + func (x *JobVersionsResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *JobVersionsResponse) CodecEncodeSelf(e *codec1978.Encoder) + type KeyringRequest struct + Key string + func (x *KeyringRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *KeyringRequest) CodecEncodeSelf(e *codec1978.Encoder) + type KeyringResponse struct + Keys map[string]int + Messages map[string]string + NumNodes int + func (x *KeyringResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *KeyringResponse) CodecEncodeSelf(e *codec1978.Encoder) + type LogConfig struct + MaxFileSizeMB int + MaxFiles int + func DefaultLogConfig() *LogConfig + func (l *LogConfig) Validate() error + func (x *LogConfig) CodecDecodeSelf(d *codec1978.Decoder) + func (x *LogConfig) CodecEncodeSelf(e *codec1978.Encoder) + type MessageType uint8 + const ACLPolicyDeleteRequestType + const ACLPolicyUpsertRequestType + const ACLTokenBootstrapRequestType + const ACLTokenDeleteRequestType + const ACLTokenUpsertRequestType + const AllocClientUpdateRequestType + const AllocUpdateRequestType + const ApplyPlanResultsRequestType + const DeploymentAllocHealthRequestType + const DeploymentDeleteRequestType + const DeploymentPromoteRequestType + const DeploymentStatusUpdateRequestType + const EvalDeleteRequestType + const EvalUpdateRequestType + const JobDeregisterRequestType + const JobRegisterRequestType + const JobStabilityRequestType + const NodeDeregisterRequestType + const NodeRegisterRequestType + const NodeUpdateDrainRequestType + const NodeUpdateStatusRequestType + const ReconcileJobSummariesRequestType + const VaultAccessorDegisterRequestType + const VaultAccessorRegisterRequestType + func (x *MessageType) CodecDecodeSelf(d *codec1978.Decoder) + func (x MessageType) CodecEncodeSelf(e *codec1978.Encoder) + type NamespacedID struct + ID string + Namespace string + func (x *NamespacedID) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NamespacedID) CodecEncodeSelf(e *codec1978.Encoder) + 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) + 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 (r *NetworkResource) Diff(other *NetworkResource, contextual bool) *ObjectDiff + func (x *NetworkResource) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NetworkResource) CodecEncodeSelf(e *codec1978.Encoder) + type Networks []*NetworkResource + func (ns Networks) Port(label string) (string, int) + func (x *Networks) CodecDecodeSelf(d *codec1978.Decoder) + func (x Networks) CodecEncodeSelf(e *codec1978.Encoder) + type Node struct + Attributes map[string]string + ComputedClass string + CreateIndex uint64 + Datacenter string + Drain bool + HTTPAddr string + ID string + Links map[string]string + Meta map[string]string + ModifyIndex uint64 + Name string + NodeClass string + Reserved *Resources + Resources *Resources + SecretID string + Status string + StatusDescription string + StatusUpdatedAt int64 + TLSEnabled bool + 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) + func (x *Node) CodecDecodeSelf(d *codec1978.Decoder) + func (x *Node) CodecEncodeSelf(e *codec1978.Encoder) + type NodeAllocsResponse struct + Allocs []*Allocation + func (x *NodeAllocsResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NodeAllocsResponse) CodecEncodeSelf(e *codec1978.Encoder) + type NodeClientAllocsResponse struct + Allocs map[string]uint64 + MigrateTokens map[string]string + func (x *NodeClientAllocsResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NodeClientAllocsResponse) CodecEncodeSelf(e *codec1978.Encoder) + type NodeDeregisterRequest struct + NodeID string + func (x *NodeDeregisterRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NodeDeregisterRequest) CodecEncodeSelf(e *codec1978.Encoder) + type NodeDrainUpdateResponse struct + EvalCreateIndex uint64 + EvalIDs []string + NodeModifyIndex uint64 + func (x *NodeDrainUpdateResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NodeDrainUpdateResponse) CodecEncodeSelf(e *codec1978.Encoder) + type NodeEvaluateRequest struct + NodeID string + func (x *NodeEvaluateRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NodeEvaluateRequest) CodecEncodeSelf(e *codec1978.Encoder) + type NodeListRequest struct + func (x *NodeListRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NodeListRequest) CodecEncodeSelf(e *codec1978.Encoder) + type NodeListResponse struct + Nodes []*NodeListStub + func (x *NodeListResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NodeListResponse) CodecEncodeSelf(e *codec1978.Encoder) + type NodeListStub struct + CreateIndex uint64 + Datacenter string + Drain bool + ID string + ModifyIndex uint64 + Name string + NodeClass string + Status string + StatusDescription string + Version string + func (x *NodeListStub) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NodeListStub) CodecEncodeSelf(e *codec1978.Encoder) + type NodeRegisterRequest struct + Node *Node + func (x *NodeRegisterRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NodeRegisterRequest) CodecEncodeSelf(e *codec1978.Encoder) + type NodeServerInfo struct + Datacenter string + RPCAdvertiseAddr string + RPCMajorVersion int32 + RPCMinorVersion int32 + func (x *NodeServerInfo) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NodeServerInfo) CodecEncodeSelf(e *codec1978.Encoder) + type NodeSpecificRequest struct + NodeID string + SecretID string + func (x *NodeSpecificRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NodeSpecificRequest) CodecEncodeSelf(e *codec1978.Encoder) + type NodeUpdateDrainRequest struct + Drain bool + NodeID string + func (x *NodeUpdateDrainRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NodeUpdateDrainRequest) CodecEncodeSelf(e *codec1978.Encoder) + type NodeUpdateResponse struct + EvalCreateIndex uint64 + EvalIDs []string + HeartbeatTTL time.Duration + LeaderRPCAddr string + NodeModifyIndex uint64 + NumNodes int32 + Servers []*NodeServerInfo + func (x *NodeUpdateResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NodeUpdateResponse) CodecEncodeSelf(e *codec1978.Encoder) + type NodeUpdateStatusRequest struct + NodeID string + Status string + func (x *NodeUpdateStatusRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *NodeUpdateStatusRequest) CodecEncodeSelf(e *codec1978.Encoder) + 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 ParameterizedJobConfig struct + MetaOptional []string + MetaRequired []string + Payload string + func (d *ParameterizedJobConfig) Canonicalize() + func (d *ParameterizedJobConfig) Copy() *ParameterizedJobConfig + func (d *ParameterizedJobConfig) Validate() error + func (x *ParameterizedJobConfig) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ParameterizedJobConfig) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (p *PeriodicConfig) Validate() error + func (x *PeriodicConfig) CodecDecodeSelf(d *codec1978.Decoder) + func (x *PeriodicConfig) CodecEncodeSelf(e *codec1978.Encoder) + type PeriodicForceRequest struct + JobID string + func (x *PeriodicForceRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *PeriodicForceRequest) CodecEncodeSelf(e *codec1978.Encoder) + type PeriodicForceResponse struct + EvalCreateIndex uint64 + EvalID string + func (x *PeriodicForceResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *PeriodicForceResponse) CodecEncodeSelf(e *codec1978.Encoder) + type PeriodicLaunch struct + CreateIndex uint64 + ID string + Launch time.Time + ModifyIndex uint64 + Namespace string + func (x *PeriodicLaunch) CodecDecodeSelf(d *codec1978.Decoder) + func (x *PeriodicLaunch) CodecEncodeSelf(e *codec1978.Encoder) + 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) + func (x *Plan) CodecDecodeSelf(d *codec1978.Decoder) + func (x *Plan) CodecEncodeSelf(e *codec1978.Encoder) + type PlanAnnotations struct + DesiredTGUpdates map[string]*DesiredUpdates + func (x *PlanAnnotations) CodecDecodeSelf(d *codec1978.Decoder) + func (x *PlanAnnotations) CodecEncodeSelf(e *codec1978.Encoder) + type PlanRequest struct + Plan *Plan + func (x *PlanRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *PlanRequest) CodecEncodeSelf(e *codec1978.Encoder) + type PlanResponse struct + Result *PlanResult + func (x *PlanResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *PlanResponse) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *PlanResult) CodecDecodeSelf(d *codec1978.Decoder) + func (x *PlanResult) CodecEncodeSelf(e *codec1978.Encoder) + type Port struct + Label string + Value int + func (x *Port) CodecDecodeSelf(d *codec1978.Decoder) + func (x *Port) CodecEncodeSelf(e *codec1978.Encoder) + type QueryMeta struct + Index uint64 + KnownLeader bool + LastContact time.Duration + func (x *QueryMeta) CodecDecodeSelf(d *codec1978.Decoder) + func (x *QueryMeta) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *QueryOptions) CodecDecodeSelf(d *codec1978.Decoder) + func (x *QueryOptions) CodecEncodeSelf(e *codec1978.Encoder) + type RPCInfo interface + AllowStaleRead func() bool + IsRead func() bool + RequestRegion func() string + 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 Recoverable interface + IsRecoverable func() bool + type RecoverableError struct + Err string + Recoverable bool + func (r *RecoverableError) Error() string + func (r *RecoverableError) IsRecoverable() bool + func (x *RecoverableError) CodecDecodeSelf(d *codec1978.Decoder) + func (x *RecoverableError) CodecEncodeSelf(e *codec1978.Encoder) + type ResolveACLTokenRequest struct + SecretID string + func (x *ResolveACLTokenRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ResolveACLTokenRequest) CodecEncodeSelf(e *codec1978.Encoder) + type ResolveACLTokenResponse struct + Token *ACLToken + func (x *ResolveACLTokenResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ResolveACLTokenResponse) CodecEncodeSelf(e *codec1978.Encoder) + 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) + func (x *Resources) CodecDecodeSelf(d *codec1978.Decoder) + func (x *Resources) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *RestartPolicy) CodecDecodeSelf(d *codec1978.Decoder) + func (x *RestartPolicy) CodecEncodeSelf(e *codec1978.Encoder) + type SearchRequest struct + Context Context + Prefix string + func (x *SearchRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *SearchRequest) CodecEncodeSelf(e *codec1978.Encoder) + type SearchResponse struct + Matches map[Context][]string + Truncations map[Context]bool + func (x *SearchResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *SearchResponse) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *ServerMember) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ServerMember) CodecEncodeSelf(e *codec1978.Encoder) + type ServerMembersResponse struct + Members []*ServerMember + ServerDC string + ServerName string + ServerRegion string + func (x *ServerMembersResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ServerMembersResponse) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *Service) CodecDecodeSelf(d *codec1978.Decoder) + func (x *Service) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *ServiceCheck) CodecDecodeSelf(d *codec1978.Decoder) + func (x *ServiceCheck) CodecEncodeSelf(e *codec1978.Encoder) + type SingleACLPolicyResponse struct + Policy *ACLPolicy + func (x *SingleACLPolicyResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *SingleACLPolicyResponse) CodecEncodeSelf(e *codec1978.Encoder) + type SingleACLTokenResponse struct + Token *ACLToken + func (x *SingleACLTokenResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *SingleACLTokenResponse) CodecEncodeSelf(e *codec1978.Encoder) + type SingleAllocResponse struct + Alloc *Allocation + func (x *SingleAllocResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *SingleAllocResponse) CodecEncodeSelf(e *codec1978.Encoder) + type SingleDeploymentResponse struct + Deployment *Deployment + func (x *SingleDeploymentResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *SingleDeploymentResponse) CodecEncodeSelf(e *codec1978.Encoder) + type SingleEvalResponse struct + Eval *Evaluation + func (x *SingleEvalResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *SingleEvalResponse) CodecEncodeSelf(e *codec1978.Encoder) + type SingleJobResponse struct + Job *Job + func (x *SingleJobResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *SingleJobResponse) CodecEncodeSelf(e *codec1978.Encoder) + type SingleNodeResponse struct + Node *Node + func (x *SingleNodeResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *SingleNodeResponse) 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 + func (x *Task) CodecDecodeSelf(d *codec1978.Decoder) + func (x *Task) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *TaskArtifact) CodecDecodeSelf(d *codec1978.Decoder) + func (x *TaskArtifact) CodecEncodeSelf(e *codec1978.Encoder) + 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 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 + func (x *TaskEvent) CodecDecodeSelf(d *codec1978.Decoder) + func (x *TaskEvent) CodecEncodeSelf(e *codec1978.Encoder) + type TaskGroup struct + Constraints []*Constraint + Count int + EphemeralDisk *EphemeralDisk + Meta map[string]string + Name string + 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 + func (x *TaskGroup) CodecDecodeSelf(d *codec1978.Decoder) + func (x *TaskGroup) CodecEncodeSelf(e *codec1978.Encoder) + 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 TaskGroupSummary struct + Complete int + Failed int + Lost int + Queued int + Running int + Starting int + func (x *TaskGroupSummary) CodecDecodeSelf(d *codec1978.Decoder) + func (x *TaskGroupSummary) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *TaskState) CodecDecodeSelf(d *codec1978.Decoder) + func (x *TaskState) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *Template) CodecDecodeSelf(d *codec1978.Decoder) + func (x *Template) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *UpdateStrategy) CodecDecodeSelf(d *codec1978.Decoder) + func (x *UpdateStrategy) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *Vault) CodecDecodeSelf(d *codec1978.Decoder) + func (x *Vault) CodecEncodeSelf(e *codec1978.Encoder) + type VaultAccessor struct + Accessor string + AllocID string + CreateIndex uint64 + CreationTTL int + NodeID string + Task string + func (x *VaultAccessor) CodecDecodeSelf(d *codec1978.Decoder) + func (x *VaultAccessor) CodecEncodeSelf(e *codec1978.Encoder) + type VaultAccessorsRequest struct + Accessors []*VaultAccessor + func (x *VaultAccessorsRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *VaultAccessorsRequest) CodecEncodeSelf(e *codec1978.Encoder) + type VersionResponse struct + Build string + Versions map[string]int + func (x *VersionResponse) CodecDecodeSelf(d *codec1978.Decoder) + func (x *VersionResponse) CodecEncodeSelf(e *codec1978.Encoder) + type WriteMeta struct + Index uint64 + func (x *WriteMeta) CodecDecodeSelf(d *codec1978.Decoder) + func (x *WriteMeta) CodecEncodeSelf(e *codec1978.Encoder) + 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 + func (x *WriteRequest) CodecDecodeSelf(d *codec1978.Decoder) + func (x *WriteRequest) CodecEncodeSelf(e *codec1978.Encoder)