structs

package

Go to main page

Versions in this module

v0

v0.8.1

Apr 17, 2018

Changes in this version

type DriverInfo

+ func (di *DriverInfo) Copy() *DriverInfo

v0.8.0

Apr 12, 2018

Changes in this version

+ const ErrUnknownAllocationPrefix

+ const ErrUnknownDeploymentPrefix

+ const ErrUnknownEvaluationPrefix

+ const ErrUnknownJobPrefix

+ const ErrUnknownNodePrefix

+ const EvalTriggerNodeDrain

+ const EvalTriggerRetryFailedAlloc

+ const JitterFraction

+ const MaxRetainedNodeEvents

+ const MigrateStrategyHealthChecks

+ const MigrateStrategyHealthStates

+ const NodeEventSubsystemCluster

+ const NodeEventSubsystemDrain

+ const NodeEventSubsystemDriver

+ const NodeEventSubsystemHeartbeat

+ const NodeSchedulingEligible

+ const NodeSchedulingIneligible

+ const ReschedulePolicyMinDelay

+ const ReschedulePolicyMinInterval

+ var DefaultBatchJobReschedulePolicy = ReschedulePolicy

+ var DefaultBatchJobRestartPolicy = RestartPolicy

+ var DefaultServiceJobReschedulePolicy = ReschedulePolicy

+ var DefaultServiceJobRestartPolicy = RestartPolicy

+ var ErrNoNodeConn = errors.New(errNoNodeConn)

+ var ErrNodeLacksRpc = errors.New(errNodeLacksRpc)

+ var ErrUnknownMethod = errors.New(errUnknownMethod)

+ var ErrUnknownNomadVersion = errors.New(errUnknownNomadVersion)

+ var RescheduleDelayFunctions = [...]string

+ var VaultUnrecoverableError = regexp.MustCompile(`Code:\s+40(0|3|4)`)

+ func Bridge(a, b io.ReadWriteCloser)

+ func CompareMigrateToken(allocID, nodeSecretID, otherMigrateToken string) bool

+ 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 IsServerSide(e error) bool

+ 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 NewWrappedServerError(e error) error

type AllocDeploymentStatus

+ func (a *AllocDeploymentStatus) HasHealth() bool

type AllocListStub

+ FollowupEvalID string

+ type AllocUpdateDesiredTransitionRequest struct

+ Allocs map[string]*DesiredTransition

+ Evals []*Evaluation

+ func (x *AllocUpdateDesiredTransitionRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *AllocUpdateDesiredTransitionRequest) CodecEncodeSelf(e *codec1978.Encoder)

type AllocUpdateRequest

+ Evals []*Evaluation

type Allocation

+ DesiredTransition DesiredTransition

+ FollowupEvalID string

+ NextAllocation string

+ RescheduleTracker *RescheduleTracker

+ func (a *Allocation) ClientTerminalStatus() bool

+ func (a *Allocation) LastEventTime() time.Time

+ func (a *Allocation) NextDelay() time.Duration

+ func (a *Allocation) NextRescheduleTime() (time.Time, bool)

+ func (a *Allocation) RescheduleEligible(reschedulePolicy *ReschedulePolicy, failTime time.Time) bool

+ func (a *Allocation) ReschedulePolicy() *ReschedulePolicy

+ func (a *Allocation) ShouldReschedule(reschedulePolicy *ReschedulePolicy, failTime time.Time) bool

+ type AutopilotConfig struct

+ CleanupDeadServers bool

+ CreateIndex uint64

+ DisableUpgradeMigration bool

+ EnableCustomUpgrades bool

+ EnableRedundancyZones bool

+ LastContactThreshold time.Duration

+ MaxTrailingLogs uint64

+ ModifyIndex uint64

+ ServerStabilizationTime time.Duration

+ type AutopilotSetConfigRequest struct

+ CAS bool

+ Config AutopilotConfig

+ Datacenter string

+ func (op *AutopilotSetConfigRequest) RequestDatacenter() string

+ 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

+ func (x *BatchNodeUpdateDrainRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *BatchNodeUpdateDrainRequest) CodecEncodeSelf(e *codec1978.Encoder)

+ type DesiredTransition struct

+ Migrate *bool

+ func (d *DesiredTransition) Merge(o *DesiredTransition)

+ func (d *DesiredTransition) ShouldMigrate() bool

+ func (x *DesiredTransition) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DesiredTransition) CodecEncodeSelf(e *codec1978.Encoder)

+ type DrainSpec struct

+ Deadline time.Duration

+ IgnoreSystemJobs bool

+ func (x *DrainSpec) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DrainSpec) CodecEncodeSelf(e *codec1978.Encoder)

+ 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

+ func (x *DrainStrategy) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DrainStrategy) CodecEncodeSelf(e *codec1978.Encoder)

+ type DrainUpdate struct

+ DrainStrategy *DrainStrategy

+ MarkEligible bool

+ func (x *DrainUpdate) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DrainUpdate) CodecEncodeSelf(e *codec1978.Encoder)

+ type DriverInfo struct

+ Attributes map[string]string

+ Detected bool

+ HealthDescription string

+ Healthy bool

+ UpdateTime time.Time

+ 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

+ func (x *EmitNodeEventsRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *EmitNodeEventsRequest) CodecEncodeSelf(e *codec1978.Encoder)

+ type EmitNodeEventsResponse struct

+ Index uint64

+ func (x *EmitNodeEventsResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *EmitNodeEventsResponse) CodecEncodeSelf(e *codec1978.Encoder)

type Evaluation

+ WaitUntil time.Time

+ type InternalRpcInfo struct

+ Forwarded bool

+ func (i *InternalRpcInfo) IsForwarded() bool

+ func (i *InternalRpcInfo) SetForwarded()

+ func (x *InternalRpcInfo) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *InternalRpcInfo) CodecEncodeSelf(e *codec1978.Encoder)

+ type JobBatchDeregisterRequest struct

+ Evals []*Evaluation

+ Jobs map[NamespacedID]*JobDeregisterOptions

+ func (x *JobBatchDeregisterRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobBatchDeregisterRequest) CodecEncodeSelf(e *codec1978.Encoder)

+ type JobBatchDeregisterResponse struct

+ JobEvals map[NamespacedID]string

+ func (x *JobBatchDeregisterResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobBatchDeregisterResponse) CodecEncodeSelf(e *codec1978.Encoder)

+ type JobDeregisterOptions struct

+ Purge bool

+ func (x *JobDeregisterOptions) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobDeregisterOptions) CodecEncodeSelf(e *codec1978.Encoder)

type MessageType

+ const AllocUpdateDesiredTransitionRequestType

+ const AutopilotRequestType

+ const BatchNodeUpdateDrainRequestType

+ const JobBatchDeregisterRequestType

+ const NodeUpdateEligibilityRequestType

+ const UpsertNodeEventsType

+ const VaultAccessorDeregisterRequestType

+ type MigrateStrategy struct

+ HealthCheck string

+ HealthyDeadline time.Duration

+ MaxParallel int

+ MinHealthyTime time.Duration

+ func DefaultMigrateStrategy() *MigrateStrategy

+ func (m *MigrateStrategy) Validate() error

+ func (x *MigrateStrategy) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *MigrateStrategy) CodecEncodeSelf(e *codec1978.Encoder)

type NamespacedID

+ func (n NamespacedID) String() string

type NetworkResource

+ func (nr *NetworkResource) Equals(other *NetworkResource) bool

type Node

+ DrainStrategy *DrainStrategy

+ Drivers map[string]*DriverInfo

+ Events []*NodeEvent

+ SchedulingEligibility string

+ func (n *Node) Canonicalize()

+ type NodeConnQueryResponse struct

+ Connected bool

+ Established time.Time

+ func (x *NodeConnQueryResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeConnQueryResponse) CodecEncodeSelf(e *codec1978.Encoder)

+ type NodeEligibilityUpdateResponse struct

+ EvalCreateIndex uint64

+ EvalIDs []string

+ NodeModifyIndex uint64

+ func (x *NodeEligibilityUpdateResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeEligibilityUpdateResponse) CodecEncodeSelf(e *codec1978.Encoder)

+ 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

+ func (x *NodeEvent) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeEvent) CodecEncodeSelf(e *codec1978.Encoder)

type NodeListStub

+ Address string

+ SchedulingEligibility string

type NodeUpdateDrainRequest

+ DrainStrategy *DrainStrategy

+ MarkEligible bool

+ type NodeUpdateEligibilityRequest struct

+ Eligibility string

+ NodeID string

+ func (x *NodeUpdateEligibilityRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeUpdateEligibilityRequest) CodecEncodeSelf(e *codec1978.Encoder)

type RPCInfo

+ IsForwarded func() bool

+ SetForwarded func()

+ type RaftPeerByIDRequest struct

+ ID raft.ServerID

type RaftServer

+ RaftProtocol string

+ 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

+ func (x *RescheduleEvent) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *RescheduleEvent) CodecEncodeSelf(e *codec1978.Encoder)

+ 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

+ func (x *ReschedulePolicy) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *ReschedulePolicy) CodecEncodeSelf(e *codec1978.Encoder)

+ type RescheduleTracker struct

+ Events []*RescheduleEvent

+ func (rt *RescheduleTracker) Copy() *RescheduleTracker

+ func (x *RescheduleTracker) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *RescheduleTracker) CodecEncodeSelf(e *codec1978.Encoder)

+ type ServerSideError interface

+ IsServerSide func() bool

+ type StreamingRpcAck struct

+ Error string

+ type StreamingRpcHandler func(conn io.ReadWriteCloser)

+ type StreamingRpcHeader struct

+ Method string

+ type StreamingRpcRegistry struct

+ func NewStreamingRpcRegistry() *StreamingRpcRegistry

+ func (s *StreamingRpcRegistry) GetHandler(method string) (StreamingRpcHandler, error)

+ func (s *StreamingRpcRegistry) Register(method string, handler StreamingRpcHandler)

type TaskGroup

+ Migrate *MigrateStrategy

+ ReschedulePolicy *ReschedulePolicy

+ type WrappedServerError struct

+ Err error

+ func (r *WrappedServerError) Error() string

+ func (r *WrappedServerError) IsRecoverable() bool

+ func (r *WrappedServerError) IsServerSide() bool

+ func (x *WrappedServerError) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *WrappedServerError) CodecEncodeSelf(e *codec1978.Encoder)

v0.8.0-rc1

Mar 30, 2018

v0.7.1

Dec 20, 2017

Changes in this version

+ const ReasonWithinPolicy

+ func DeploymentStatusDescriptionRollbackNoop(baseDescription string, jobVersion uint64) string

type AllocListStub

+ ModifyTime int64

+ func (a *AllocListStub) SetEventDisplayMessages()

type Allocation

+ ModifyTime int64

+ func (a *Allocation) SetEventDisplayMessages()

type ApplyPlanResultsRequest

+ EvalID string

type Job

+ func (j *Job) IsPeriodicActive() bool

type Resources

+ func MinResources() *Resources

type ServiceCheck

+ AddressMode string

type Task

+ KillSignal string

type TaskEvent

+ Details map[string]string

+ DisplayMessage string

+ func (event *TaskEvent) PopulateEventDisplayMessage()

v0.7.1-rc1

Dec 12, 2017

v0.7.0

Nov 1, 2017

Changes in this version

+ const ACLClientToken

+ const ACLManagementToken

+ const DefaultNamespace

+ const DefaultNamespaceDescription

+ var AnonymousACLToken = &ACLToken

+ var ErrPermissionDenied = errors.New("Permission denied")

+ var ErrTokenNotFound = errors.New("ACL token not found")

+ func ACLPolicyListHash(policies []*ACLPolicy) string

+ func CompileACLObject(cache *lru.TwoQueueCache, policies []*ACLPolicy) (*acl.ACL, 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 AllocMetric

+ QuotaExhausted []string

+ func (a *AllocMetric) ExhaustQuota(dimensions []string)

type Allocation

+ Namespace string

+ 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 Context

+ const Namespaces

+ const Quotas

type Deployment

+ Namespace string

type EvalDequeueResponse

+ WaitIndex uint64

+ func (e *EvalDequeueResponse) GetWaitIndex() uint64

type Evaluation

+ LeaderACL string

+ Namespace string

+ QuotaLimitReached string

type Job

+ Namespace string

type JobPlanRequest

+ PolicyOverride bool

type JobRegisterRequest

+ PolicyOverride bool

type JobSummary

+ Namespace string

type MessageType

+ const ACLPolicyDeleteRequestType

+ const ACLPolicyUpsertRequestType

+ const ACLTokenBootstrapRequestType

+ const ACLTokenDeleteRequestType

+ const ACLTokenUpsertRequestType

+ type NamespacedID struct

+ ID string

+ Namespace string

+ func (x *NamespacedID) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NamespacedID) CodecEncodeSelf(e *codec1978.Encoder)

type NodeClientAllocsResponse

+ MigrateTokens map[string]string

type PeriodicLaunch

+ Namespace string

type QueryOptions

+ AuthToken string

+ Namespace string

+ func (q QueryOptions) RequestNamespace() string

+ 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 ServiceCheck

+ CheckRestart *CheckRestart

+ func (sc *ServiceCheck) TriggersRestarts() bool

+ 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 TaskGroup

+ func (tg *TaskGroup) CombinedResources() *Resources

type WriteRequest

+ AuthToken string

+ Namespace string

+ func (w WriteRequest) RequestNamespace() string

v0.7.0-rc3

Oct 26, 2017

v0.7.0-rc2

Oct 26, 2017

v0.7.0-rc1

Oct 19, 2017

v0.7.0-beta1

Sep 19, 2017

v0.6.3

Sep 11, 2017

v0.6.3-rc1

Sep 6, 2017

v0.6.2

Aug 29, 2017

v0.6.1

Aug 28, 2017

Changes in this version

+ const TaskGenericMessage

+ func DeploymentStatusDescriptionNoRollbackTarget(baseDescription string) string

type AllocDeploymentStatus

+ func (x *AllocDeploymentStatus) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *AllocDeploymentStatus) CodecEncodeSelf(e *codec1978.Encoder)

type AllocListRequest

+ func (x *AllocListRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *AllocListRequest) CodecEncodeSelf(e *codec1978.Encoder)

type AllocListResponse

+ func (x *AllocListResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *AllocListResponse) CodecEncodeSelf(e *codec1978.Encoder)

type AllocListStub

+ func (x *AllocListStub) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *AllocListStub) CodecEncodeSelf(e *codec1978.Encoder)

type AllocMetric

+ func (x *AllocMetric) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *AllocMetric) CodecEncodeSelf(e *codec1978.Encoder)

type AllocSpecificRequest

+ func (x *AllocSpecificRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *AllocSpecificRequest) CodecEncodeSelf(e *codec1978.Encoder)

type AllocUpdateRequest

+ func (x *AllocUpdateRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *AllocUpdateRequest) CodecEncodeSelf(e *codec1978.Encoder)

type Allocation

+ func (x *Allocation) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *Allocation) CodecEncodeSelf(e *codec1978.Encoder)

type AllocsGetRequest

+ func (x *AllocsGetRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *AllocsGetRequest) CodecEncodeSelf(e *codec1978.Encoder)

type AllocsGetResponse

+ func (x *AllocsGetResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *AllocsGetResponse) CodecEncodeSelf(e *codec1978.Encoder)

type ApplyDeploymentAllocHealthRequest

+ func (x *ApplyDeploymentAllocHealthRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *ApplyDeploymentAllocHealthRequest) CodecEncodeSelf(e *codec1978.Encoder)

type ApplyDeploymentPromoteRequest

+ func (x *ApplyDeploymentPromoteRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *ApplyDeploymentPromoteRequest) CodecEncodeSelf(e *codec1978.Encoder)

type ApplyPlanResultsRequest

+ func (x *ApplyPlanResultsRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *ApplyPlanResultsRequest) CodecEncodeSelf(e *codec1978.Encoder)

type Constraint

+ 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 Nodes

+ func (x *Context) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x Context) CodecEncodeSelf(e *codec1978.Encoder)

type Deployment

+ func (x *Deployment) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *Deployment) CodecEncodeSelf(e *codec1978.Encoder)

type DeploymentAllocHealthRequest

+ func (x *DeploymentAllocHealthRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DeploymentAllocHealthRequest) CodecEncodeSelf(e *codec1978.Encoder)

type DeploymentDeleteRequest

+ func (x *DeploymentDeleteRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DeploymentDeleteRequest) CodecEncodeSelf(e *codec1978.Encoder)

type DeploymentFailRequest

+ func (x *DeploymentFailRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DeploymentFailRequest) CodecEncodeSelf(e *codec1978.Encoder)

type DeploymentListRequest

+ func (x *DeploymentListRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DeploymentListRequest) CodecEncodeSelf(e *codec1978.Encoder)

type DeploymentListResponse

+ func (x *DeploymentListResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DeploymentListResponse) CodecEncodeSelf(e *codec1978.Encoder)

type DeploymentPauseRequest

+ func (x *DeploymentPauseRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DeploymentPauseRequest) CodecEncodeSelf(e *codec1978.Encoder)

type DeploymentPromoteRequest

+ func (x *DeploymentPromoteRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DeploymentPromoteRequest) CodecEncodeSelf(e *codec1978.Encoder)

type DeploymentSpecificRequest

+ func (x *DeploymentSpecificRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DeploymentSpecificRequest) CodecEncodeSelf(e *codec1978.Encoder)

type DeploymentState

+ func (x *DeploymentState) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DeploymentState) CodecEncodeSelf(e *codec1978.Encoder)

type DeploymentStatusUpdate

+ func (x *DeploymentStatusUpdate) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DeploymentStatusUpdate) CodecEncodeSelf(e *codec1978.Encoder)

type DeploymentStatusUpdateRequest

+ func (x *DeploymentStatusUpdateRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DeploymentStatusUpdateRequest) CodecEncodeSelf(e *codec1978.Encoder)

type DeploymentUpdateResponse

+ func (x *DeploymentUpdateResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DeploymentUpdateResponse) CodecEncodeSelf(e *codec1978.Encoder)

type DeriveVaultTokenRequest

+ func (x *DeriveVaultTokenRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DeriveVaultTokenRequest) CodecEncodeSelf(e *codec1978.Encoder)

type DeriveVaultTokenResponse

+ func (x *DeriveVaultTokenResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DeriveVaultTokenResponse) CodecEncodeSelf(e *codec1978.Encoder)

type DesiredUpdates

+ func (x *DesiredUpdates) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DesiredUpdates) CodecEncodeSelf(e *codec1978.Encoder)

type DispatchPayloadConfig

+ func (x *DispatchPayloadConfig) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *DispatchPayloadConfig) CodecEncodeSelf(e *codec1978.Encoder)

type EphemeralDisk

+ func (x *EphemeralDisk) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *EphemeralDisk) CodecEncodeSelf(e *codec1978.Encoder)

type EvalAckRequest

+ func (x *EvalAckRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *EvalAckRequest) CodecEncodeSelf(e *codec1978.Encoder)

type EvalAllocationsResponse

+ func (x *EvalAllocationsResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *EvalAllocationsResponse) CodecEncodeSelf(e *codec1978.Encoder)

type EvalDeleteRequest

+ func (x *EvalDeleteRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *EvalDeleteRequest) CodecEncodeSelf(e *codec1978.Encoder)

type EvalDequeueRequest

+ func (x *EvalDequeueRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *EvalDequeueRequest) CodecEncodeSelf(e *codec1978.Encoder)

type EvalDequeueResponse

+ func (x *EvalDequeueResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *EvalDequeueResponse) CodecEncodeSelf(e *codec1978.Encoder)

type EvalListRequest

+ func (x *EvalListRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *EvalListRequest) CodecEncodeSelf(e *codec1978.Encoder)

type EvalListResponse

+ func (x *EvalListResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *EvalListResponse) CodecEncodeSelf(e *codec1978.Encoder)

type EvalSpecificRequest

+ func (x *EvalSpecificRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *EvalSpecificRequest) CodecEncodeSelf(e *codec1978.Encoder)

type EvalUpdateRequest

+ func (x *EvalUpdateRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *EvalUpdateRequest) CodecEncodeSelf(e *codec1978.Encoder)

type Evaluation

+ func (x *Evaluation) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *Evaluation) CodecEncodeSelf(e *codec1978.Encoder)

type GenericRequest

+ func (x *GenericRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *GenericRequest) CodecEncodeSelf(e *codec1978.Encoder)

type GenericResponse

+ func (x *GenericResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *GenericResponse) CodecEncodeSelf(e *codec1978.Encoder)

type Job

+ func (x *Job) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *Job) CodecEncodeSelf(e *codec1978.Encoder)

type JobAllocationsResponse

+ func (x *JobAllocationsResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobAllocationsResponse) CodecEncodeSelf(e *codec1978.Encoder)

type JobChildrenSummary

+ func (x *JobChildrenSummary) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobChildrenSummary) CodecEncodeSelf(e *codec1978.Encoder)

type JobDeregisterRequest

+ func (x *JobDeregisterRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobDeregisterRequest) CodecEncodeSelf(e *codec1978.Encoder)

type JobDeregisterResponse

+ func (x *JobDeregisterResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobDeregisterResponse) CodecEncodeSelf(e *codec1978.Encoder)

type JobDispatchRequest

+ func (x *JobDispatchRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobDispatchRequest) CodecEncodeSelf(e *codec1978.Encoder)

type JobDispatchResponse

+ func (x *JobDispatchResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobDispatchResponse) CodecEncodeSelf(e *codec1978.Encoder)

type JobEvaluateRequest

+ func (x *JobEvaluateRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobEvaluateRequest) CodecEncodeSelf(e *codec1978.Encoder)

type JobEvaluationsResponse

+ func (x *JobEvaluationsResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobEvaluationsResponse) CodecEncodeSelf(e *codec1978.Encoder)

type JobListRequest

+ func (x *JobListRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobListRequest) CodecEncodeSelf(e *codec1978.Encoder)

type JobListResponse

+ func (x *JobListResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobListResponse) CodecEncodeSelf(e *codec1978.Encoder)

type JobListStub

+ func (x *JobListStub) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobListStub) CodecEncodeSelf(e *codec1978.Encoder)

type JobPlanRequest

+ func (x *JobPlanRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobPlanRequest) CodecEncodeSelf(e *codec1978.Encoder)

type JobPlanResponse

+ func (x *JobPlanResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobPlanResponse) CodecEncodeSelf(e *codec1978.Encoder)

type JobRegisterRequest

+ func (x *JobRegisterRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobRegisterRequest) CodecEncodeSelf(e *codec1978.Encoder)

type JobRegisterResponse

+ func (x *JobRegisterResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobRegisterResponse) CodecEncodeSelf(e *codec1978.Encoder)

type JobRevertRequest

+ func (x *JobRevertRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobRevertRequest) CodecEncodeSelf(e *codec1978.Encoder)

type JobSpecificRequest

+ func (x *JobSpecificRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobSpecificRequest) CodecEncodeSelf(e *codec1978.Encoder)

type JobStabilityRequest

+ func (x *JobStabilityRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobStabilityRequest) CodecEncodeSelf(e *codec1978.Encoder)

type JobStabilityResponse

+ func (x *JobStabilityResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobStabilityResponse) CodecEncodeSelf(e *codec1978.Encoder)

type JobSummary

+ func (x *JobSummary) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobSummary) CodecEncodeSelf(e *codec1978.Encoder)

type JobSummaryRequest

+ func (x *JobSummaryRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobSummaryRequest) CodecEncodeSelf(e *codec1978.Encoder)

type JobSummaryResponse

+ func (x *JobSummaryResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobSummaryResponse) CodecEncodeSelf(e *codec1978.Encoder)

type JobValidateRequest

+ func (x *JobValidateRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobValidateRequest) CodecEncodeSelf(e *codec1978.Encoder)

type JobValidateResponse

+ func (x *JobValidateResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobValidateResponse) CodecEncodeSelf(e *codec1978.Encoder)

type JobVersionsRequest

+ func (x *JobVersionsRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobVersionsRequest) CodecEncodeSelf(e *codec1978.Encoder)

type JobVersionsResponse

+ func (x *JobVersionsResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *JobVersionsResponse) CodecEncodeSelf(e *codec1978.Encoder)

type KeyringRequest

+ func (x *KeyringRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *KeyringRequest) CodecEncodeSelf(e *codec1978.Encoder)

type KeyringResponse

+ func (x *KeyringResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *KeyringResponse) CodecEncodeSelf(e *codec1978.Encoder)

type LogConfig

+ func (x *LogConfig) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *LogConfig) CodecEncodeSelf(e *codec1978.Encoder)

type MessageType

+ func (x *MessageType) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x MessageType) CodecEncodeSelf(e *codec1978.Encoder)

type NetworkResource

+ func (x *NetworkResource) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NetworkResource) CodecEncodeSelf(e *codec1978.Encoder)

type Networks

+ func (x *Networks) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x Networks) CodecEncodeSelf(e *codec1978.Encoder)

type Node

+ func (x *Node) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *Node) CodecEncodeSelf(e *codec1978.Encoder)

type NodeAllocsResponse

+ func (x *NodeAllocsResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeAllocsResponse) CodecEncodeSelf(e *codec1978.Encoder)

type NodeClientAllocsResponse

+ func (x *NodeClientAllocsResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeClientAllocsResponse) CodecEncodeSelf(e *codec1978.Encoder)

type NodeDeregisterRequest

+ func (x *NodeDeregisterRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeDeregisterRequest) CodecEncodeSelf(e *codec1978.Encoder)

type NodeDrainUpdateResponse

+ func (x *NodeDrainUpdateResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeDrainUpdateResponse) CodecEncodeSelf(e *codec1978.Encoder)

type NodeEvaluateRequest

+ func (x *NodeEvaluateRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeEvaluateRequest) CodecEncodeSelf(e *codec1978.Encoder)

type NodeListRequest

+ func (x *NodeListRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeListRequest) CodecEncodeSelf(e *codec1978.Encoder)

type NodeListResponse

+ func (x *NodeListResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeListResponse) CodecEncodeSelf(e *codec1978.Encoder)

type NodeListStub

+ Version string

+ func (x *NodeListStub) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeListStub) CodecEncodeSelf(e *codec1978.Encoder)

type NodeRegisterRequest

+ func (x *NodeRegisterRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeRegisterRequest) CodecEncodeSelf(e *codec1978.Encoder)

type NodeServerInfo

+ func (x *NodeServerInfo) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeServerInfo) CodecEncodeSelf(e *codec1978.Encoder)

type NodeSpecificRequest

+ func (x *NodeSpecificRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeSpecificRequest) CodecEncodeSelf(e *codec1978.Encoder)

type NodeUpdateDrainRequest

+ func (x *NodeUpdateDrainRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeUpdateDrainRequest) CodecEncodeSelf(e *codec1978.Encoder)

type NodeUpdateResponse

+ func (x *NodeUpdateResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeUpdateResponse) CodecEncodeSelf(e *codec1978.Encoder)

type NodeUpdateStatusRequest

+ func (x *NodeUpdateStatusRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *NodeUpdateStatusRequest) CodecEncodeSelf(e *codec1978.Encoder)

type ParameterizedJobConfig

+ func (x *ParameterizedJobConfig) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *ParameterizedJobConfig) CodecEncodeSelf(e *codec1978.Encoder)

type PeriodicConfig

+ func (x *PeriodicConfig) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *PeriodicConfig) CodecEncodeSelf(e *codec1978.Encoder)

type PeriodicForceRequest

+ func (x *PeriodicForceRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *PeriodicForceRequest) CodecEncodeSelf(e *codec1978.Encoder)

type PeriodicForceResponse

+ func (x *PeriodicForceResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *PeriodicForceResponse) CodecEncodeSelf(e *codec1978.Encoder)

type PeriodicLaunch

+ func (x *PeriodicLaunch) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *PeriodicLaunch) CodecEncodeSelf(e *codec1978.Encoder)

type Plan

+ func (x *Plan) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *Plan) CodecEncodeSelf(e *codec1978.Encoder)

type PlanAnnotations

+ func (x *PlanAnnotations) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *PlanAnnotations) CodecEncodeSelf(e *codec1978.Encoder)

type PlanRequest

+ func (x *PlanRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *PlanRequest) CodecEncodeSelf(e *codec1978.Encoder)

type PlanResponse

+ func (x *PlanResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *PlanResponse) CodecEncodeSelf(e *codec1978.Encoder)

type PlanResult

+ func (x *PlanResult) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *PlanResult) CodecEncodeSelf(e *codec1978.Encoder)

type Port

+ func (x *Port) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *Port) CodecEncodeSelf(e *codec1978.Encoder)

type QueryMeta

+ func (x *QueryMeta) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *QueryMeta) CodecEncodeSelf(e *codec1978.Encoder)

type QueryOptions

+ func (x *QueryOptions) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *QueryOptions) CodecEncodeSelf(e *codec1978.Encoder)

type RecoverableError

+ func (x *RecoverableError) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *RecoverableError) CodecEncodeSelf(e *codec1978.Encoder)

type Resources

+ func (x *Resources) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *Resources) CodecEncodeSelf(e *codec1978.Encoder)

type RestartPolicy

+ 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

+ func (x *ServerMember) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *ServerMember) CodecEncodeSelf(e *codec1978.Encoder)

type ServerMembersResponse

+ func (x *ServerMembersResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *ServerMembersResponse) CodecEncodeSelf(e *codec1978.Encoder)

type Service

+ func (x *Service) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *Service) CodecEncodeSelf(e *codec1978.Encoder)

type ServiceCheck

+ Header map[string][]string

+ Method string

+ func (x *ServiceCheck) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *ServiceCheck) CodecEncodeSelf(e *codec1978.Encoder)

type SingleAllocResponse

+ func (x *SingleAllocResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *SingleAllocResponse) CodecEncodeSelf(e *codec1978.Encoder)

type SingleDeploymentResponse

+ func (x *SingleDeploymentResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *SingleDeploymentResponse) CodecEncodeSelf(e *codec1978.Encoder)

type SingleEvalResponse

+ func (x *SingleEvalResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *SingleEvalResponse) CodecEncodeSelf(e *codec1978.Encoder)

type SingleJobResponse

+ func (x *SingleJobResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *SingleJobResponse) CodecEncodeSelf(e *codec1978.Encoder)

type SingleNodeResponse

+ func (x *SingleNodeResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *SingleNodeResponse) CodecEncodeSelf(e *codec1978.Encoder)

type Task

+ ShutdownDelay time.Duration

+ func (x *Task) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *Task) CodecEncodeSelf(e *codec1978.Encoder)

type TaskArtifact

+ func (x *TaskArtifact) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *TaskArtifact) CodecEncodeSelf(e *codec1978.Encoder)

type TaskEvent

+ GenericSource string

+ func (e *TaskEvent) SetGenericSource(s string) *TaskEvent

+ func (x *TaskEvent) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *TaskEvent) CodecEncodeSelf(e *codec1978.Encoder)

type TaskGroup

+ func (x *TaskGroup) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *TaskGroup) CodecEncodeSelf(e *codec1978.Encoder)

type TaskGroupSummary

+ func (x *TaskGroupSummary) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *TaskGroupSummary) CodecEncodeSelf(e *codec1978.Encoder)

type TaskState

+ func (x *TaskState) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *TaskState) CodecEncodeSelf(e *codec1978.Encoder)

type Template

+ VaultGrace time.Duration

+ func (x *Template) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *Template) CodecEncodeSelf(e *codec1978.Encoder)

type UpdateStrategy

+ func (x *UpdateStrategy) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *UpdateStrategy) CodecEncodeSelf(e *codec1978.Encoder)

type Vault

+ func (x *Vault) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *Vault) CodecEncodeSelf(e *codec1978.Encoder)

type VaultAccessor

+ func (x *VaultAccessor) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *VaultAccessor) CodecEncodeSelf(e *codec1978.Encoder)

type VaultAccessorsRequest

+ func (x *VaultAccessorsRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *VaultAccessorsRequest) CodecEncodeSelf(e *codec1978.Encoder)

type VersionResponse

+ func (x *VersionResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *VersionResponse) CodecEncodeSelf(e *codec1978.Encoder)

type WriteMeta

+ func (x *WriteMeta) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *WriteMeta) CodecEncodeSelf(e *codec1978.Encoder)

type WriteRequest

+ func (x *WriteRequest) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *WriteRequest) CodecEncodeSelf(e *codec1978.Encoder)

v0.6.0

Jul 26, 2017

Changes in this version

+ const AddressModeAuto

+ const AddressModeDriver

+ const AddressModeHost

+ const CoreJobDeploymentGC

+ 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 EvalTriggerDeploymentWatcher

+ const EvalTriggerFailedFollowUp

+ const GetterModeAny

+ const GetterModeDir

+ const GetterModeFile

+ const JobTrackedVersions

+ const UpdateStrategyHealthCheck_Checks

+ const UpdateStrategyHealthCheck_Manual

+ const UpdateStrategyHealthCheck_TaskStates

+ var DefaultUpdateStrategy = &UpdateStrategy

+ var JsonHandle = &codec.JsonHandle

+ var JsonHandlePretty = &codec.JsonHandle

+ func AllocName(job, group string, idx uint) string

+ func DenormalizeAllocationJobs(job *Job, allocs []*Allocation)

+ func DeploymentStatusDescriptionRollback(baseDescription string, jobVersion uint64) string

+ func MergeMultierrorWarnings(warnings, canonicalizeWarnings error) string

+ type AllocDeploymentStatus struct

+ Healthy *bool

+ ModifyIndex uint64

+ func (a *AllocDeploymentStatus) Copy() *AllocDeploymentStatus

+ func (a *AllocDeploymentStatus) IsHealthy() bool

+ func (a *AllocDeploymentStatus) IsUnhealthy() bool

type AllocListStub

+ DeploymentStatus *AllocDeploymentStatus

+ JobVersion uint64

type Allocation

+ DeploymentID string

+ DeploymentStatus *AllocDeploymentStatus

+ func (a *Allocation) CopySkipJob() *Allocation

+ type ApplyDeploymentAllocHealthRequest struct

+ DeploymentUpdate *DeploymentStatusUpdate

+ Eval *Evaluation

+ Job *Job

+ type ApplyDeploymentPromoteRequest struct

+ Eval *Evaluation

+ type ApplyPlanResultsRequest struct

+ Deployment *Deployment

+ DeploymentUpdates []*DeploymentStatusUpdate

type Bitmap

+ func (b Bitmap) Unset(idx uint)

+ type Deployment struct

+ CreateIndex uint64

+ ID string

+ JobCreateIndex uint64

+ JobID string

+ JobModifyIndex uint64

+ JobVersion uint64

+ ModifyIndex uint64

+ 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 DesiredUpdates

+ Canary uint64

+ func (d *DesiredUpdates) GoString() string

type Evaluation

+ DeploymentID string

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

type Job

+ Stable bool

+ Stop bool

+ SubmitTime int64

+ Version uint64

+ func (j *Job) HasUpdateStrategy() bool

+ func (j *Job) SetSubmitTime()

+ func (j *Job) SpecChanged(new *Job) bool

+ func (j *Job) Stopped() bool

+ func (j *Job) Warnings() error

type JobDeregisterRequest

+ Purge bool

type JobListStub

+ ParameterizedJob bool

+ Periodic bool

+ Stop bool

+ SubmitTime int64

type JobPlanResponse

+ Warnings string

type JobRegisterResponse

+ Warnings string

+ type JobRevertRequest struct

+ EnforcePriorVersion *uint64

+ JobID string

+ JobVersion uint64

+ type JobStabilityRequest struct

+ JobID string

+ JobVersion uint64

+ Stable bool

+ type JobStabilityResponse struct

type JobValidateResponse

+ Warnings string

+ type JobVersionsRequest struct

+ Diffs bool

+ JobID string

+ type JobVersionsResponse struct

+ Diffs []*JobDiff

+ Versions []*Job

type MessageType

+ const ApplyPlanResultsRequestType

+ const DeploymentAllocHealthRequestType

+ const DeploymentDeleteRequestType

+ const DeploymentPromoteRequestType

+ const DeploymentStatusUpdateRequestType

+ const JobStabilityRequestType

type NetworkResource

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

+ type Networks []*NetworkResource

+ func (ns Networks) Port(label string) (string, int)

type Plan

+ Deployment *Deployment

+ DeploymentUpdates []*DeploymentStatusUpdate

type PlanResult

+ Deployment *Deployment

+ DeploymentUpdates []*DeploymentStatusUpdate

type Service

+ AddressMode string

type ServiceCheck

+ TLSSkipVerify bool

+ type SingleDeploymentResponse struct

+ Deployment *Deployment

type TaskArtifact

+ GetterMode string

type TaskGroup

+ Update *UpdateStrategy

+ func (tg *TaskGroup) Warnings(j *Job) error

type TaskState

+ LastRestart time.Time

+ Restarts uint64

type Template

+ Envvars bool

type UpdateStrategy

+ AutoRevert bool

+ Canary int

+ HealthCheck string

+ HealthyDeadline time.Duration

+ MinHealthyTime time.Duration

+ func (u *UpdateStrategy) Copy() *UpdateStrategy

+ func (u *UpdateStrategy) Validate() error

v0.6.0-rc2

Jul 21, 2017

v0.6.0-rc1

Jul 8, 2017

v0.5.6

Apr 1, 2017

Changes in this version

+ func WrapRecoverable(msg string, err error) error

+ type Recoverable interface

+ IsRecoverable func() bool

type RecoverableError

+ func (r *RecoverableError) IsRecoverable() bool

type TaskState

+ FinishedAt time.Time

+ StartedAt time.Time

v0.5.6-rc1

Mar 28, 2017

v0.5.5

Mar 14, 2017

Changes in this version

+ const ConstraintDistinctProperty

+ const RestartPolicyMinInterval

+ const TaskBuildingTaskDir

+ const TaskLeaderDead

+ const TaskSetup

+ type JobValidateRequest struct

+ Job *Job

+ type JobValidateResponse struct

+ DriverConfigValidated bool

+ Error string

+ ValidationErrors []string

type PeriodicConfig

+ TimeZone string

+ func (p *PeriodicConfig) Canonicalize()

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

+ type RaftConfigurationResponse struct

+ Index uint64

+ Servers []*RaftServer

+ type RaftPeerByAddressRequest struct

+ Address raft.ServerAddress

+ type RaftServer struct

+ Address raft.ServerAddress

+ ID raft.ServerID

+ Leader bool

+ Node string

+ Voter bool

type Task

+ Leader bool

type TaskEvent

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

type Template

+ LeftDelim string

+ Perms string

+ RightDelim string

v0.5.5-rc2

Mar 4, 2017

v0.5.5-rc1

Feb 24, 2017

v0.5.4

Feb 1, 2017

v0.5.3

Jan 30, 2017

Changes in this version

+ const DispatchLaunchSuffix

+ const DispatchPayloadForbidden

+ const DispatchPayloadOptional

+ const DispatchPayloadRequired

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

+ func IsRecoverable(e error) bool

+ type DispatchPayloadConfig struct

+ File string

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

+ func (d *DispatchPayloadConfig) Validate() error

type Job

+ ParameterizedJob *ParameterizedJobConfig

+ Payload []byte

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

+ func (j *Job) IsParameterized() bool

+ type JobChildrenSummary struct

+ Dead int64

+ Pending int64

+ Running int64

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

+ type JobDispatchRequest struct

+ JobID string

+ Meta map[string]string

+ Payload []byte

+ type JobDispatchResponse struct

+ DispatchedJobID string

+ EvalCreateIndex uint64

+ EvalID string

+ JobCreateIndex uint64

type JobSummary

+ Children *JobChildrenSummary

+ type ParameterizedJobConfig struct

+ MetaOptional []string

+ MetaRequired []string

+ Payload string

+ func (d *ParameterizedJobConfig) Canonicalize()

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

+ func (d *ParameterizedJobConfig) Validate() error

type Task

+ DispatchPayload *DispatchPayloadConfig

v0.5.3-rc1

Jan 24, 2017

v0.5.2

Dec 21, 2016

Changes in this version

+ const TaskDriverMessage

type JobSpecificRequest

+ AllAllocs bool

type TaskEvent

+ DriverMessage string

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

v0.5.2-rc1

Dec 13, 2016

v0.5.1

Dec 12, 2016

v0.5.1-rc2

Dec 10, 2016

v0.5.1-rc1

Dec 6, 2016

v0.5.0

Nov 16, 2016

Changes in this version

+ const BytesInMegabyte

+ const ConstraintSetContains

+ const TaskDiskExceeded

+ const TaskRestartSignal

+ const TaskSetupFailure

+ const TaskSiblingFailed

+ const TaskSignaling

+ const TemplateChangeModeNoop

+ const TemplateChangeModeRestart

+ const TemplateChangeModeSignal

+ const VaultChangeModeNoop

+ const VaultChangeModeRestart

+ const VaultChangeModeSignal

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

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

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

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

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

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

type Allocation

+ PreviousAllocation string

+ SharedResources *Resources

+ func (a *Allocation) ShouldMigrate() bool

+ func (a *Allocation) Terminated() bool

type Constraint

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

+ type DeriveVaultTokenRequest struct

+ AllocID string

+ NodeID string

+ SecretID string

+ Tasks []string

+ type DeriveVaultTokenResponse struct

+ Error *RecoverableError

+ Tasks map[string]string

+ type EphemeralDisk struct

+ Migrate bool

+ SizeMB int

+ Sticky bool

+ func DefaultEphemeralDisk() *EphemeralDisk

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

+ func (d *EphemeralDisk) Validate() error

type EvalDequeueRequest

+ SchedulerVersion uint16

type Job

+ VaultToken string

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

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

+ type KeyringRequest struct

+ Key string

+ type KeyringResponse struct

+ Keys map[string]int

+ Messages map[string]string

+ NumNodes int

type MessageType

+ const VaultAccessorDegisterRequestType

+ const VaultAccessorRegisterRequestType

type Node

+ SecretID string

+ TLSEnabled bool

+ func (n *Node) Ready() bool

type NodeSpecificRequest

+ SecretID string

+ type RecoverableError struct

+ Err string

+ Recoverable bool

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

+ func (r *RecoverableError) Error() string

type Resources

+ func (r *Resources) DiskInBytes() int64

+ type ServerMember struct

+ Addr net.IP

+ DelegateCur uint8

+ DelegateMax uint8

+ DelegateMin uint8

+ Name string

+ Port uint16

+ ProtocolCur uint8

+ ProtocolMax uint8

+ ProtocolMin uint8

+ Status string

+ Tags map[string]string

+ type ServerMembersResponse struct

+ Members []*ServerMember

+ ServerDC string

+ ServerName string

+ ServerRegion string

type Service

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

type Task

+ Templates []*Template

+ Vault *Vault

type TaskEvent

+ DiskLimit int64

+ FailedSibling string

+ FailsTask bool

+ KillReason string

+ SetupError string

+ TaskSignal string

+ TaskSignalReason string

+ VaultError string

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

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

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

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

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

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

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

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

type TaskGroup

+ EphemeralDisk *EphemeralDisk

+ type Template struct

+ ChangeMode string

+ ChangeSignal string

+ DestPath string

+ EmbeddedTmpl string

+ SourcePath string

+ Splay time.Duration

+ func DefaultTemplate() *Template

+ func (t *Template) Canonicalize()

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

+ func (t *Template) Validate() error

+ type Vault struct

+ ChangeMode string

+ ChangeSignal string

+ Env bool

+ Policies []string

+ func DefaultVaultBlock() *Vault

+ func (v *Vault) Canonicalize()

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

+ func (v *Vault) Validate() error

+ type VaultAccessor struct

+ Accessor string

+ AllocID string

+ CreateIndex uint64

+ CreationTTL int

+ NodeID string

+ Task string

+ type VaultAccessorsRequest struct

+ Accessors []*VaultAccessor

v0.5.0-rc2

Nov 10, 2016

v0.5.0-rc1

Nov 2, 2016

v0.4.3

Sep 22, 2016

v0.4.2

Sep 21, 2016

v0.4.1

Aug 17, 2016

Changes in this version

+ const AllocClientStatusLost

+ const TaskKilling

type Bitmap

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

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

+ func (b Bitmap) Size() uint

type Evaluation

+ QueuedAllocations map[string]int

type Job

+ func (j *Job) Canonicalize()

type JobListStub

+ JobSummary *JobSummary

+ type JobSummary struct

+ CreateIndex uint64

+ JobID string

+ ModifyIndex uint64

+ Summary map[string]TaskGroupSummary

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

+ type JobSummaryRequest struct

+ JobID string

+ type JobSummaryResponse struct

+ JobSummary *JobSummary

type MessageType

+ const ReconcileJobSummariesRequestType

type NetworkResource

+ func (n *NetworkResource) Canonicalize()

type Node

+ StatusUpdatedAt int64

type Resources

+ func (r *Resources) Canonicalize()

type Service

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

type ServiceCheck

+ InitialStatus string

+ PortLabel string

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

type Task

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

type TaskEvent

+ KillTimeout time.Duration

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

type TaskGroup

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

+ type TaskGroupSummary struct

+ Complete int

+ Failed int

+ Lost int

+ Queued int

+ Running int

+ Starting int

v0.4.1-rc1

Aug 13, 2016

v0.4.0

Jun 28, 2016

Changes in this version

+ const ApiMajorVersion

+ const ApiMinorVersion

+ const EvalTriggerMaxPlans

type Allocation

+ func (a *Allocation) RanSuccessfully() bool

+ type DesiredUpdates struct

+ DestructiveUpdate uint64

+ Ignore uint64

+ InPlaceUpdate uint64

+ Migrate uint64

+ Place uint64

+ Stop uint64

+ type DiffType string

+ var DiffTypeAdded DiffType = "Added"

+ var DiffTypeDeleted DiffType = "Deleted"

+ var DiffTypeEdited DiffType = "Edited"

+ var DiffTypeNone DiffType = "None"

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

type Evaluation

+ AnnotatePlan bool

+ FailedTGAllocs map[string]*AllocMetric

+ SnapshotIndex uint64

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

+ type FieldDiff struct

+ Annotations []string

+ Name string

+ New string

+ Old string

+ Type DiffType

+ func (f *FieldDiff) GoString() string

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

+ type FieldDiffs []*FieldDiff

+ func (f FieldDiffs) Len() int

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

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

type Job

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

+ type JobDiff struct

+ Fields []*FieldDiff

+ ID string

+ Objects []*ObjectDiff

+ TaskGroups []*TaskGroupDiff

+ Type DiffType

+ func (j *JobDiff) GoString() string

type JobListStub

+ JobModifyIndex uint64

+ type JobPlanRequest struct

+ Diff bool

+ Job *Job

+ type JobPlanResponse struct

+ Annotations *PlanAnnotations

+ CreatedEvals []*Evaluation

+ Diff *JobDiff

+ FailedTGAllocs map[string]*AllocMetric

+ JobModifyIndex uint64

+ NextPeriodicLaunch time.Time

type JobRegisterRequest

+ EnforceIndex bool

+ JobModifyIndex uint64

type NetworkResource

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

+ type NodeServerInfo struct

+ Datacenter string

+ RPCAdvertiseAddr string

+ RPCMajorVersion int32

+ RPCMinorVersion int32

type NodeUpdateResponse

+ LeaderRPCAddr string

+ NumNodes int32

+ Servers []*NodeServerInfo

+ type ObjectDiff struct

+ Fields []*FieldDiff

+ Name string

+ Objects []*ObjectDiff

+ Type DiffType

+ func (o *ObjectDiff) GoString() string

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

+ type ObjectDiffs []*ObjectDiff

+ func (o ObjectDiffs) Len() int

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

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

type Plan

+ Annotations *PlanAnnotations

+ type PlanAnnotations struct

+ DesiredTGUpdates map[string]*DesiredUpdates

type Resources

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

type Task

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

+ type TaskDiff struct

+ Annotations []string

+ Fields []*FieldDiff

+ Name string

+ Objects []*ObjectDiff

+ Type DiffType

+ func (t *TaskDiff) GoString() string

+ type TaskDiffs []*TaskDiff

+ func (t TaskDiffs) Len() int

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

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

type TaskGroup

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

+ type TaskGroupDiff struct

+ Fields []*FieldDiff

+ Name string

+ Objects []*ObjectDiff

+ Tasks []*TaskDiff

+ Type DiffType

+ Updates map[string]uint64

+ func (tg *TaskGroupDiff) GoString() string

+ type TaskGroupDiffs []*TaskGroupDiff

+ func (tg TaskGroupDiffs) Len() int

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

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

type TaskState

+ func (ts *TaskState) Successful() bool

v0.4.0-rc2

Jun 22, 2016

v0.4.0-rc1

Jun 14, 2016

v0.3.2

Apr 22, 2016

Changes in this version

+ const AllocClientStatusComplete

+ const CoreJobForceGC

+ const TaskFailedValidation

type Service

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

type ServiceCheck

+ Args []string

+ Command string

+ func (sc *ServiceCheck) RequiresPort() bool

type Task

+ User string

type TaskArtifact

+ RelativeDest string

+ func (ta *TaskArtifact) GoString() string

type TaskEvent

+ RestartReason string

+ ValidationError string

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

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

v0.3.2-rc2

Apr 20, 2016

v0.3.2-rc1

Apr 14, 2016

v0.3.1

Mar 16, 2016

Changes in this version

+ const TaskArtifactDownloadFailed

+ const TaskDownloadingArtifacts

+ const TaskNotRestarting

+ const TaskRestarting

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

type Allocation

+ func (a *Allocation) Index() int

type Task

+ Artifacts []*TaskArtifact

+ type TaskArtifact struct

+ GetterOptions map[string]string

+ GetterSource string

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

+ func (ta *TaskArtifact) Validate() error

type TaskEvent

+ DownloadError string

+ StartDelay int64

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

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

+ func (te *TaskEvent) GoString() string

type TaskState

+ func (ts *TaskState) Failed() bool

v0.3.0

Feb 25, 2016

Changes in this version

+ const CoreJobJobGC

+ const DefaultKillTimeout

+ const EvalStatusBlocked

+ const EvalStatusCancelled

+ const EvalTriggerForceGC

+ const EvalTriggerPeriodicJob

+ const NodeUniqueNamespace

+ const PeriodicLaunchSuffix

+ const PeriodicSpecTest

+ const RestartPolicyModeDelay

+ const RestartPolicyModeFail

+ const TaskReceived

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

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

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

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

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

+ func IsUniqueNamespace(key string) bool

+ func UniqueNamespace(key string) string

type AllocListStub

+ CreateTime int64

type AllocMetric

+ NodesAvailable map[string]int

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

type AllocUpdateRequest

+ Job *Job

type Allocation

+ AllocModifyIndex uint64

+ CreateTime int64

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

+ type AllocsGetRequest struct

+ AllocIDs []string

+ type AllocsGetResponse struct

+ Allocs []*Allocation

+ type Bitmap []byte

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

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

+ func (b Bitmap) Clear()

+ func (b Bitmap) Set(idx uint)

type Constraint

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

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

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

type Evaluation

+ ClassEligibility map[string]bool

+ EscapedComputedClass bool

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

+ func (e *Evaluation) ShouldBlock() bool

type Job

+ GC bool

+ JobModifyIndex uint64

+ ParentID string

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

+ func (j *Job) InitFields()

type JobListStub

+ ParentID string

+ type LogConfig struct

+ MaxFileSizeMB int

+ MaxFiles int

+ func DefaultLogConfig() *LogConfig

+ func (l *LogConfig) Validate() error

type NetworkIndex

+ func (idx *NetworkIndex) Release()

type NetworkResource

+ func (n *NetworkResource) MeetsMinResources() error

type Node

+ ComputedClass string

+ HTTPAddr string

+ func (n *Node) ComputeClass() error

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

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

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

+ type NodeClientAllocsResponse struct

+ Allocs map[string]uint64

type PeriodicConfig

+ ProhibitOverlap bool

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

+ type PeriodicForceRequest struct

+ JobID string

+ type PeriodicForceResponse struct

+ EvalCreateIndex uint64

+ EvalID string

+ type PeriodicLaunch struct

+ CreateIndex uint64

+ ID string

+ Launch time.Time

+ ModifyIndex uint64

type Plan

+ Job *Job

type QueryOptions

+ Prefix string

type Resources

+ func DefaultResources() *Resources

+ func (r *Resources) MeetsMinResources() error

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

type RestartPolicy

+ Mode string

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

type Service

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

type ServiceCheck

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

type Task

+ KillTimeout time.Duration

+ LogConfig *LogConfig

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

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

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

type TaskEvent

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

type TaskGroup

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

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

type TaskState

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

v0.3.0-rc2

Feb 23, 2016

v0.2.3

Dec 18, 2015

Changes in this version

type Allocation

+ Services map[string]string

+ func (a *Allocation) PopulateServiceIDs()

v0.2.3-rc1

Dec 16, 2015

v0.2.2

Dec 11, 2015

Changes in this version

+ const NomadConsulPrefix

+ const PeriodicSpecCron

type Job

+ Periodic *PeriodicConfig

+ func (j *Job) InitAllServiceFields()

+ func (j *Job) IsPeriodic() bool

+ type PeriodicConfig struct

+ Enabled bool

+ Spec string

+ SpecType string

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

+ func (p *PeriodicConfig) Validate() error

type Service

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

type Task

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

type TaskGroup

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

v0.2.1

Nov 28, 2015

Changes in this version

type Job

+ func (j *Job) ExpandAllServiceNames()

type Service

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

+ func (s *Service) Hash() string

type ServiceCheck

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

type Task

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

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

type TaskGroup

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

v0.2.0

Nov 19, 2015

Changes in this version

+ const ConstraintDistinctHosts

+ const ConstraintRegex

+ const ConstraintVersion

+ const JobTypeSystem

+ const ServiceCheckDocker

+ const ServiceCheckHTTP

+ const ServiceCheckScript

+ const ServiceCheckTCP

+ const TaskDriverFailure

+ const TaskKilled

+ const TaskStarted

+ const TaskStateDead

+ const TaskStatePending

+ const TaskStateRunning

+ const TaskTerminated

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

type AllocListStub

+ TaskStates map[string]*TaskState

type Allocation

+ TaskStates map[string]*TaskState

type Constraint

+ func (c *Constraint) Validate() error

type NetworkResource

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

+ type Port struct

+ Label string

+ Value int

+ type RestartPolicy struct

+ Attempts int

+ Delay time.Duration

+ Interval time.Duration

+ func NewRestartPolicy(jobType string) *RestartPolicy

+ func (r *RestartPolicy) Validate() error

+ type Service struct

+ Checks []ServiceCheck

+ Id string

+ Name string

+ PortLabel string

+ Tags []string

+ func (s *Service) Validate() error

+ type ServiceCheck struct

+ Id string

+ Interval time.Duration

+ Name string

+ Path string

+ Protocol string

+ Script string

+ Timeout time.Duration

+ Type string

+ func (sc *ServiceCheck) Validate() error

type Task

+ Services []*Service

+ type TaskEvent struct

+ DriverError string

+ ExitCode int

+ KillError string

+ Message string

+ Signal int

+ Time int64

+ Type string

+ func NewTaskEvent(event string) *TaskEvent

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

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

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

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

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

type TaskGroup

+ RestartPolicy *RestartPolicy

+ type TaskState struct

+ Events []*TaskEvent

+ State string

v0.1.2

Oct 6, 2015

v0.1.1

Oct 5, 2015

Changes in this version

type Task

+ Env map[string]string

v0.1.0

Sep 28, 2015

Changes in this version

+ const APIMajorVersion

+ const APIMinorVersion

+ const AllocClientStatusDead

+ const AllocClientStatusFailed

+ const AllocClientStatusPending

+ const AllocClientStatusRunning

+ const AllocDesiredStatusEvict

+ const AllocDesiredStatusFailed

+ const AllocDesiredStatusRun

+ const AllocDesiredStatusStop

+ const CoreJobEvalGC

+ const CoreJobNodeGC

+ const CoreJobPriority

+ const EvalStatusComplete

+ const EvalStatusFailed

+ const EvalStatusPending

+ const EvalTriggerJobDeregister

+ const EvalTriggerJobRegister

+ const EvalTriggerNodeUpdate

+ const EvalTriggerRollingUpdate

+ const EvalTriggerScheduled

+ const JobDefaultPriority

+ const JobMaxPriority

+ const JobMinPriority

+ const JobStatusComplete

+ const JobStatusDead

+ const JobStatusPending

+ const JobStatusRunning

+ const JobTypeBatch

+ const JobTypeCore

+ const JobTypeService

+ const MaxDynamicPort

+ const MinDynamicPort

+ const NodeStatusDown

+ const NodeStatusInit

+ const NodeStatusReady

+ const ProtocolVersion

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

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

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

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

+ func GenerateUUID() string

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

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

+ func ShouldDrainNode(status string) bool

+ func ValidNodeStatus(status string) bool

+ type AllocListRequest struct

+ type AllocListResponse struct

+ Allocations []*AllocListStub

+ type AllocListStub struct

+ ClientDescription string

+ ClientStatus string

+ CreateIndex uint64

+ DesiredDescription string

+ DesiredStatus string

+ EvalID string

+ ID string

+ JobID string

+ ModifyIndex uint64

+ Name string

+ NodeID string

+ TaskGroup string

+ type AllocMetric struct

+ AllocationTime time.Duration

+ ClassExhausted map[string]int

+ ClassFiltered map[string]int

+ CoalescedFailures int

+ ConstraintFiltered map[string]int

+ DimensionExhausted map[string]int

+ NodesEvaluated int

+ NodesExhausted int

+ NodesFiltered int

+ Scores map[string]float64

+ func (a *AllocMetric) EvaluateNode()

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

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

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

+ type AllocSpecificRequest struct

+ AllocID string

+ type AllocUpdateRequest struct

+ Alloc []*Allocation

+ type Allocation struct

+ ClientDescription string

+ ClientStatus string

+ CreateIndex uint64

+ DesiredDescription string

+ DesiredStatus string

+ EvalID string

+ ID string

+ Job *Job

+ JobID string

+ Metrics *AllocMetric

+ ModifyIndex uint64

+ Name string

+ NodeID string

+ Resources *Resources

+ TaskGroup string

+ TaskResources map[string]*Resources

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

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

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

+ func (a *Allocation) TerminalStatus() bool

+ type Constraint struct

+ Hard bool

+ LTarget string

+ Operand string

+ RTarget string

+ Weight int

+ func (c *Constraint) String() string

+ type EvalAckRequest struct

+ EvalID string

+ Token string

+ type EvalAllocationsResponse struct

+ Allocations []*AllocListStub

+ type EvalDeleteRequest struct

+ Allocs []string

+ Evals []string

+ type EvalDequeueRequest struct

+ Schedulers []string

+ Timeout time.Duration

+ type EvalDequeueResponse struct

+ Eval *Evaluation

+ Token string

+ type EvalListRequest struct

+ type EvalListResponse struct

+ Evaluations []*Evaluation

+ type EvalSpecificRequest struct

+ EvalID string

+ type EvalUpdateRequest struct

+ EvalToken string

+ Evals []*Evaluation

+ type Evaluation struct

+ CreateIndex uint64

+ ID string

+ JobID string

+ JobModifyIndex uint64

+ ModifyIndex uint64

+ NextEval string

+ NodeID string

+ NodeModifyIndex uint64

+ PreviousEval string

+ Priority int

+ Status string

+ StatusDescription string

+ TriggeredBy string

+ Type string

+ Wait time.Duration

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

+ func (e *Evaluation) GoString() string

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

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

+ func (e *Evaluation) ShouldEnqueue() bool

+ func (e *Evaluation) TerminalStatus() bool

+ type GenericRequest struct

+ type GenericResponse struct

+ type Job struct

+ AllAtOnce bool

+ Constraints []*Constraint

+ CreateIndex uint64

+ Datacenters []string

+ ID string

+ Meta map[string]string

+ ModifyIndex uint64

+ Name string

+ Priority int

+ Region string

+ Status string

+ StatusDescription string

+ TaskGroups []*TaskGroup

+ Type string

+ Update UpdateStrategy

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

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

+ func (j *Job) Validate() error

+ type JobAllocationsResponse struct

+ Allocations []*AllocListStub

+ type JobDeregisterRequest struct

+ JobID string

+ type JobDeregisterResponse struct

+ EvalCreateIndex uint64

+ EvalID string

+ JobModifyIndex uint64

+ type JobEvaluateRequest struct

+ JobID string

+ type JobEvaluationsResponse struct

+ Evaluations []*Evaluation

+ type JobListRequest struct

+ type JobListResponse struct

+ Jobs []*JobListStub

+ type JobListStub struct

+ CreateIndex uint64

+ ID string

+ ModifyIndex uint64

+ Name string

+ Priority int

+ Status string

+ StatusDescription string

+ Type string

+ type JobRegisterRequest struct

+ Job *Job

+ type JobRegisterResponse struct

+ EvalCreateIndex uint64

+ EvalID string

+ JobModifyIndex uint64

+ type JobSpecificRequest struct

+ JobID string

+ type MessageType uint8

+ const AllocClientUpdateRequestType

+ const AllocUpdateRequestType

+ const EvalDeleteRequestType

+ const EvalUpdateRequestType

+ const IgnoreUnknownTypeFlag

+ const JobDeregisterRequestType

+ const JobRegisterRequestType

+ const NodeDeregisterRequestType

+ const NodeRegisterRequestType

+ const NodeUpdateDrainRequestType

+ const NodeUpdateStatusRequestType

+ type NetworkIndex struct

+ AvailBandwidth map[string]int

+ AvailNetworks []*NetworkResource

+ UsedBandwidth map[string]int

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

+ func NewNetworkIndex() *NetworkIndex

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

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

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

+ func (idx *NetworkIndex) Overcommitted() bool

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

+ type NetworkResource struct

+ CIDR string

+ Device string

+ DynamicPorts []string

+ IP string

+ MBits int

+ ReservedPorts []int

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

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

+ func (n *NetworkResource) GoString() string

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

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

+ type Node struct

+ Attributes map[string]string

+ CreateIndex uint64

+ Datacenter string

+ Drain bool

+ ID string

+ Links map[string]string

+ Meta map[string]string

+ ModifyIndex uint64

+ Name string

+ NodeClass string

+ Reserved *Resources

+ Resources *Resources

+ Status string

+ StatusDescription string

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

+ func (n *Node) TerminalStatus() bool

+ type NodeAllocsResponse struct

+ Allocs []*Allocation

+ type NodeDeregisterRequest struct

+ NodeID string

+ type NodeDrainUpdateResponse struct

+ EvalCreateIndex uint64

+ EvalIDs []string

+ NodeModifyIndex uint64

+ type NodeEvaluateRequest struct

+ NodeID string

+ type NodeListRequest struct

+ type NodeListResponse struct

+ Nodes []*NodeListStub

+ type NodeListStub struct

+ CreateIndex uint64

+ Datacenter string

+ Drain bool

+ ID string

+ ModifyIndex uint64

+ Name string

+ NodeClass string

+ Status string

+ StatusDescription string

+ type NodeRegisterRequest struct

+ Node *Node

+ type NodeSpecificRequest struct

+ NodeID string

+ type NodeUpdateDrainRequest struct

+ Drain bool

+ NodeID string

+ type NodeUpdateResponse struct

+ EvalCreateIndex uint64

+ EvalIDs []string

+ HeartbeatTTL time.Duration

+ NodeModifyIndex uint64

+ type NodeUpdateStatusRequest struct

+ NodeID string

+ Status string

+ type Plan struct

+ AllAtOnce bool

+ EvalID string

+ EvalToken string

+ FailedAllocs []*Allocation

+ NodeAllocation map[string][]*Allocation

+ NodeUpdate map[string][]*Allocation

+ Priority int

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

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

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

+ func (p *Plan) IsNoOp() bool

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

+ type PlanRequest struct

+ Plan *Plan

+ type PlanResponse struct

+ Result *PlanResult

+ type PlanResult struct

+ AllocIndex uint64

+ FailedAllocs []*Allocation

+ NodeAllocation map[string][]*Allocation

+ NodeUpdate map[string][]*Allocation

+ RefreshIndex uint64

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

+ func (p *PlanResult) IsNoOp() bool

+ type QueryMeta struct

+ Index uint64

+ KnownLeader bool

+ LastContact time.Duration

+ type QueryOptions struct

+ AllowStale bool

+ MaxQueryTime time.Duration

+ MinQueryIndex uint64

+ Region string

+ func (q QueryOptions) AllowStaleRead() bool

+ func (q QueryOptions) IsRead() bool

+ func (q QueryOptions) RequestRegion() string

+ type RPCInfo interface

+ AllowStaleRead func() bool

+ IsRead func() bool

+ RequestRegion func() string

+ type Resources struct

+ CPU int

+ DiskMB int

+ IOPS int

+ MemoryMB int

+ Networks []*NetworkResource

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

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

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

+ func (r *Resources) GoString() string

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

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

+ type SingleAllocResponse struct

+ Alloc *Allocation

+ type SingleEvalResponse struct

+ Eval *Evaluation

+ type SingleJobResponse struct

+ Job *Job

+ type SingleNodeResponse struct

+ Node *Node

+ type Task struct

+ Config map[string]string

+ Constraints []*Constraint

+ Driver string

+ Meta map[string]string

+ Name string

+ Resources *Resources

+ func (t *Task) GoString() string

+ func (t *Task) Validate() error

+ type TaskGroup struct

+ Constraints []*Constraint

+ Count int

+ Meta map[string]string

+ Name string

+ Tasks []*Task

+ func (tg *TaskGroup) GoString() string

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

+ func (tg *TaskGroup) Validate() error

+ type UpdateStrategy struct

+ MaxParallel int

+ Stagger time.Duration

+ func (u *UpdateStrategy) Rolling() bool

+ type VersionResponse struct

+ Build string

+ Versions map[string]int

+ type WriteMeta struct

+ Index uint64

+ type WriteRequest struct

+ Region string

+ func (w WriteRequest) AllowStaleRead() bool

+ func (w WriteRequest) IsRead() bool

+ func (w WriteRequest) RequestRegion() string

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