structs

package

Go to main page

Versions in this module

v0

v0.11.3

Jun 5, 2020

Changes in this version

+ const ConnectNativePrefix

type CSIVolume

+ Context map[string]string

+ Parameters map[string]string

type TaskKind

+ func NewTaskKind(name, identifier string) TaskKind

+ func (k TaskKind) IsConnectNative() bool

v0.11.2

May 14, 2020

Changes in this version

+ const CoreJobCSIPluginGC

+ func ScoreFitBinPack(node *Node, util *ComparableResources) float64

+ func ScoreFitSpread(node *Node, util *ComparableResources) float64

+ type AllocState struct

+ Field AllocStateField

+ Time time.Time

+ Value string

+ type AllocStateField uint8

+ const AllocStateFieldClientStatus

type Allocation

+ AllocStates []*AllocState

+ func (a *Allocation) AppendState(field AllocStateField, value string)

+ func (a *Allocation) SetStop(clientStatus, clientDesc string)

+ func (a *Allocation) ShouldClientStop() bool

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

+ type CSIPluginDeleteRequest struct

+ ID string

+ type CSIPluginDeleteResponse struct

+ type CSISecrets map[string]string

+ func (s *CSISecrets) GoString() string

+ func (s *CSISecrets) String() string

type CSIVolume

+ PastClaims map[string]*CSIVolumeClaim

+ ReadClaims map[string]*CSIVolumeClaim

+ Secrets CSISecrets

+ WriteClaims map[string]*CSIVolumeClaim

+ type CSIVolumeClaim struct

+ AllocationID string

+ Mode CSIVolumeClaimMode

+ NodeID string

+ State CSIVolumeClaimState

+ type CSIVolumeClaimBatchRequest struct

+ Claims []CSIVolumeClaimRequest

type CSIVolumeClaimRequest

+ NodeID string

+ State CSIVolumeClaimState

+ func (req *CSIVolumeClaimRequest) ToClaim() *CSIVolumeClaim

+ type CSIVolumeClaimState int

+ const CSIVolumeClaimStateControllerDetached

+ const CSIVolumeClaimStateNodeDetached

+ const CSIVolumeClaimStateReadyToFree

+ const CSIVolumeClaimStateTaken

type MessageType

+ const CSIPluginDeleteRequestType

+ const CSIVolumeClaimBatchRequestType

+ type SchedulerAlgorithm string

+ const SchedulerAlgorithmBinpack

+ const SchedulerAlgorithmSpread

type SchedulerConfiguration

+ SchedulerAlgorithm SchedulerAlgorithm

+ func (s *SchedulerConfiguration) Canonicalize()

+ func (s *SchedulerConfiguration) EffectiveSchedulerAlgorithm() SchedulerAlgorithm

+ func (s *SchedulerConfiguration) Validate() error

type TaskGroup

+ StopAfterClientDisconnect *time.Duration

v0.11.1

Apr 22, 2020

v0.11.0

Apr 8, 2020

Changes in this version

+ const CSIIntermediaryDirname

+ const CSISocketName

+ const CoreJobCSIVolumeClaimGC

+ const EvalTriggerScaling

+ const JobTrackedScalingEvents

+ const NodeEventSubsystemStorage

+ const ScalingTargetGroup

+ const ScalingTargetJob

+ const ScalingTargetNamespace

+ const TaskLifecycleHookPrestart

+ const TaskPluginHealthy

+ const TaskPluginUnhealthy

+ const VolumeTypeCSI

+ func CSIPluginTypeIsValid(pt CSIPluginType) bool

+ func ValidCSIVolumeAccessMode(accessMode CSIVolumeAccessMode) bool

+ func ValidCSIVolumeAttachmentMode(attachmentMode CSIVolumeAttachmentMode) bool

+ func ValidCSIVolumeWriteAccessMode(accessMode CSIVolumeAccessMode) bool

type AllocatedCpuResources

+ func (a *AllocatedCpuResources) Max(other *AllocatedCpuResources)

type AllocatedMemoryResources

+ func (a *AllocatedMemoryResources) Max(other *AllocatedMemoryResources)

type AllocatedResources

+ TaskLifecycles map[string]*TaskLifecycleConfig

type AllocatedTaskResources

+ func (a *AllocatedTaskResources) Max(other *AllocatedTaskResources)

type AutopilotConfig

+ MinQuorum uint

+ type CSIControllerInfo struct

+ SupportsAttachDetach bool

+ SupportsListVolumes bool

+ SupportsListVolumesAttachedNodes bool

+ SupportsReadOnlyAttach bool

+ func (c *CSIControllerInfo) Copy() *CSIControllerInfo

+ type CSIInfo struct

+ AllocID string

+ ControllerInfo *CSIControllerInfo

+ HealthDescription string

+ Healthy bool

+ NodeInfo *CSINodeInfo

+ PluginID string

+ Provider string

+ ProviderVersion string

+ RequiresControllerPlugin bool

+ RequiresTopologies bool

+ UpdateTime time.Time

+ func (c *CSIInfo) Copy() *CSIInfo

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

+ func (c *CSIInfo) IsController() bool

+ func (c *CSIInfo) IsNode() bool

+ func (c *CSIInfo) SetHealthy(hs bool)

+ type CSIMountOptions struct

+ FSType string

+ MountFlags []string

+ func (o *CSIMountOptions) Copy() *CSIMountOptions

+ func (o *CSIMountOptions) Merge(p *CSIMountOptions)

+ func (v *CSIMountOptions) GoString() string

+ func (v *CSIMountOptions) String() string

+ type CSINodeInfo struct

+ AccessibleTopology *CSITopology

+ ID string

+ MaxVolumes int64

+ RequiresNodeStageVolume bool

+ func (n *CSINodeInfo) Copy() *CSINodeInfo

+ type CSIPlugin struct

+ Allocations []*AllocListStub

+ ControllerRequired bool

+ Controllers map[string]*CSIInfo

+ ControllersHealthy int

+ CreateIndex uint64

+ ID string

+ ModifyIndex uint64

+ Nodes map[string]*CSIInfo

+ NodesHealthy int

+ Provider string

+ Version string

+ func NewCSIPlugin(id string, index uint64) *CSIPlugin

+ func (p *CSIPlugin) AddPlugin(nodeID string, info *CSIInfo) error

+ func (p *CSIPlugin) Copy() *CSIPlugin

+ func (p *CSIPlugin) DeleteAlloc(allocID, nodeID string) error

+ func (p *CSIPlugin) DeleteNode(nodeID string) error

+ func (p *CSIPlugin) DeleteNodeForType(nodeID string, pluginType CSIPluginType) error

+ func (p *CSIPlugin) IsEmpty() bool

+ func (p *CSIPlugin) Stub() *CSIPluginListStub

+ type CSIPluginGetRequest struct

+ ID string

+ type CSIPluginGetResponse struct

+ Plugin *CSIPlugin

+ type CSIPluginListRequest struct

+ type CSIPluginListResponse struct

+ Plugins []*CSIPluginListStub

+ type CSIPluginListStub struct

+ ControllerRequired bool

+ ControllersExpected int

+ ControllersHealthy int

+ CreateIndex uint64

+ ID string

+ ModifyIndex uint64

+ NodesExpected int

+ NodesHealthy int

+ Provider string

+ type CSIPluginType string

+ const CSIPluginTypeController

+ const CSIPluginTypeMonolith

+ const CSIPluginTypeNode

+ type CSITopology struct

+ Segments map[string]string

+ func (t *CSITopology) Copy() *CSITopology

+ func (t *CSITopology) Equal(o *CSITopology) bool

+ type CSIVolListStub struct

+ AccessMode CSIVolumeAccessMode

+ AttachmentMode CSIVolumeAttachmentMode

+ ControllersExpected int

+ ControllersHealthy int

+ CreateIndex uint64

+ CurrentReaders int

+ CurrentWriters int

+ ExternalID string

+ ID string

+ ModifyIndex uint64

+ MountOptions *CSIMountOptions

+ Name string

+ Namespace string

+ NodesExpected int

+ NodesHealthy int

+ PluginID string

+ Provider string

+ Schedulable bool

+ Topologies []*CSITopology

+ type CSIVolume struct

+ AccessMode CSIVolumeAccessMode

+ AttachmentMode CSIVolumeAttachmentMode

+ ControllerRequired bool

+ ControllersExpected int

+ ControllersHealthy int

+ CreateIndex uint64

+ ExternalID string

+ ID string

+ ModifyIndex uint64

+ MountOptions *CSIMountOptions

+ Name string

+ Namespace string

+ NodesExpected int

+ NodesHealthy int

+ PluginID string

+ Provider string

+ ProviderVersion string

+ ReadAllocs map[string]*Allocation

+ ResourceExhausted time.Time

+ Schedulable bool

+ Topologies []*CSITopology

+ WriteAllocs map[string]*Allocation

+ func NewCSIVolume(volumeID string, index uint64) *CSIVolume

+ func (v *CSIVolume) Claim(claim CSIVolumeClaimMode, alloc *Allocation) error

+ func (v *CSIVolume) ClaimRead(alloc *Allocation) error

+ func (v *CSIVolume) ClaimRelease(alloc *Allocation) error

+ func (v *CSIVolume) ClaimWrite(alloc *Allocation) error

+ func (v *CSIVolume) Copy() *CSIVolume

+ func (v *CSIVolume) Equal(o *CSIVolume) bool

+ func (v *CSIVolume) InUse() bool

+ func (v *CSIVolume) ReadSchedulable() bool

+ func (v *CSIVolume) RemoteID() string

+ func (v *CSIVolume) Stub() *CSIVolListStub

+ func (v *CSIVolume) Validate() error

+ func (v *CSIVolume) WriteFreeClaims() bool

+ func (v *CSIVolume) WriteSchedulable() bool

+ type CSIVolumeAccessMode string

+ const CSIVolumeAccessModeMultiNodeMultiWriter

+ const CSIVolumeAccessModeMultiNodeReader

+ const CSIVolumeAccessModeMultiNodeSingleWriter

+ const CSIVolumeAccessModeSingleNodeReader

+ const CSIVolumeAccessModeSingleNodeWriter

+ const CSIVolumeAccessModeUnknown

+ type CSIVolumeAttachmentMode string

+ const CSIVolumeAttachmentModeBlockDevice

+ const CSIVolumeAttachmentModeFilesystem

+ const CSIVolumeAttachmentModeUnknown

+ type CSIVolumeClaimMode int

+ const CSIVolumeClaimRead

+ const CSIVolumeClaimRelease

+ const CSIVolumeClaimWrite

+ type CSIVolumeClaimRequest struct

+ AllocationID string

+ Claim CSIVolumeClaimMode

+ VolumeID string

+ type CSIVolumeClaimResponse struct

+ PublishContext map[string]string

+ Volume *CSIVolume

+ type CSIVolumeDeregisterRequest struct

+ VolumeIDs []string

+ type CSIVolumeDeregisterResponse struct

+ type CSIVolumeGetRequest struct

+ ID string

+ type CSIVolumeGetResponse struct

+ Volume *CSIVolume

+ type CSIVolumeListRequest struct

+ NodeID string

+ PluginID string

+ type CSIVolumeListResponse struct

+ Volumes []*CSIVolListStub

+ type CSIVolumeRegisterRequest struct

+ Volumes []*CSIVolume

+ type CSIVolumeRegisterResponse struct

+ type ConsulExposeConfig struct

+ Paths []ConsulExposePath

+ func (e *ConsulExposeConfig) Copy() *ConsulExposeConfig

+ func (e *ConsulExposeConfig) Equals(o *ConsulExposeConfig) bool

+ type ConsulExposePath struct

+ ListenerPort string

+ LocalPathPort int

+ Path string

+ Protocol string

type ConsulProxy

+ Expose *ConsulExposeConfig

type Context

+ const Plugins

+ const Volumes

type Job

+ func (j *Job) GetScalingPolicies() []*ScalingPolicy

type JobDeregisterResponse

+ VolumeEvalID string

+ VolumeEvalIndex uint64

+ type JobScaleRequest struct

+ Count *int64

+ Error bool

+ JobID string

+ Message string

+ Meta map[string]interface{}

+ Namespace string

+ PolicyOverride bool

+ Target map[string]string

+ type JobScaleStatus struct

+ JobCreateIndex uint64

+ JobID string

+ JobModifyIndex uint64

+ JobStopped bool

+ TaskGroups map[string]*TaskGroupScaleStatus

+ type JobScaleStatusRequest struct

+ JobID string

+ type JobScaleStatusResponse struct

+ JobScaleStatus *JobScaleStatus

+ type JobScalingEvents struct

+ JobID string

+ ModifyIndex uint64

+ Namespace string

+ ScalingEvents map[string][]*ScalingEvent

type MessageType

+ const CSIVolumeClaimRequestType

+ const CSIVolumeDeregisterRequestType

+ const CSIVolumeRegisterRequestType

+ const ScalingEventRegisterRequestType

type Node

+ CSIControllerPlugins map[string]*CSIInfo

+ CSINodePlugins map[string]*CSIInfo

type NodeListStub

+ HostVolumes map[string]*ClientHostVolumeConfig

+ type ScalingEvent struct

+ Count *int64

+ CreateIndex uint64

+ Error bool

+ EvalID *string

+ Message string

+ Meta map[string]interface{}

+ Time int64

+ func NewScalingEvent(message string) *ScalingEvent

+ func (e *ScalingEvent) SetError(error bool) *ScalingEvent

+ func (e *ScalingEvent) SetEvalID(evalID string) *ScalingEvent

+ func (e *ScalingEvent) SetMeta(meta map[string]interface{}) *ScalingEvent

+ type ScalingEventRequest struct

+ JobID string

+ Namespace string

+ ScalingEvent *ScalingEvent

+ TaskGroup string

+ type ScalingPolicy struct

+ CreateIndex uint64

+ Enabled bool

+ ID string

+ Max int64

+ Min int64

+ ModifyIndex uint64

+ Policy map[string]interface{}

+ Target map[string]string

+ func CopyScalingPolicy(p *ScalingPolicy) *ScalingPolicy

+ func (p *ScalingPolicy) Diff(p2 *ScalingPolicy) bool

+ func (p *ScalingPolicy) Stub() *ScalingPolicyListStub

+ func (p *ScalingPolicy) TargetTaskGroup(job *Job, tg *TaskGroup) *ScalingPolicy

+ type ScalingPolicyListRequest struct

+ type ScalingPolicyListResponse struct

+ Policies []*ScalingPolicyListStub

+ type ScalingPolicyListStub struct

+ CreateIndex uint64

+ Enabled bool

+ ID string

+ ModifyIndex uint64

+ Target map[string]string

+ type ScalingPolicySpecificRequest struct

+ ID string

type Service

+ EnableTagOverride bool

type ServiceCheck

+ Expose bool

+ type SingleScalingPolicyResponse struct

+ Policy *ScalingPolicy

type Task

+ CSIPluginConfig *TaskCSIPluginConfig

+ Lifecycle *TaskLifecycleConfig

+ RestartPolicy *RestartPolicy

+ type TaskCSIPluginConfig struct

+ ID string

+ MountDir string

+ Type CSIPluginType

+ func (t *TaskCSIPluginConfig) Copy() *TaskCSIPluginConfig

type TaskGroup

+ Scaling *ScalingPolicy

+ type TaskGroupScaleStatus struct

+ Desired int

+ Events []*ScalingEvent

+ Healthy int

+ Placed int

+ Running int

+ Unhealthy int

+ type TaskLifecycleConfig struct

+ Hook string

+ Sidecar bool

+ func (d *TaskLifecycleConfig) Copy() *TaskLifecycleConfig

+ func (d *TaskLifecycleConfig) Validate() error

type Template

+ func (t *Template) Warnings() error

type VolumeRequest

+ MountOptions *CSIMountOptions

v0.11.0-rc1

Apr 7, 2020

v0.11.0-beta2

Apr 1, 2020

v0.11.0-beta1

Mar 25, 2020

v0.10.5

Mar 24, 2020

v0.10.4

Feb 19, 2020

Changes in this version

+ func IsErrRPCCoded(err error) bool

+ type AgentPprofRequest struct

+ Debug int

+ GC int

+ NodeID string

+ Profile string

+ ReqType pprof.ReqType

+ Seconds int

+ ServerID string

+ type AgentPprofResponse struct

+ AgentID string

+ HTTPHeaders map[string]string

+ Payload []byte

type Allocation

+ func (a *Allocation) Canonicalize()

+ type ClusterMetadata struct

+ ClusterID string

+ CreateTime int64

+ type DeriveSITokenRequest struct

+ AllocID string

+ NodeID string

+ SecretID string

+ Tasks []string

+ func (r *DeriveSITokenRequest) Validate() error

+ type DeriveSITokenResponse struct

+ Error *RecoverableError

+ Tokens map[string]string

type Job

+ ConsulToken string

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

type JobRevertRequest

+ ConsulToken string

type MessageType

+ const ClusterMetadataRequestType

+ const ServiceIdentityAccessorDeregisterRequestType

+ const ServiceIdentityAccessorRegisterRequestType

+ type SIToken struct

+ AccessorID string

+ SecretID string

+ TaskName string

+ type SITokenAccessor struct

+ AccessorID string

+ AllocID string

+ CreateIndex uint64

+ NodeID string

+ TaskName string

+ type SITokenAccessorsRequest struct

+ Accessors []*SITokenAccessor

type Service

+ CanaryMeta map[string]string

type Task

+ func (t *Task) UsesConnect() bool

type TaskGroup

+ ShutdownDelay *time.Duration

+ func (tg *TaskGroup) UsesConnect() bool

v0.10.4-rc1

Feb 12, 2020

v0.10.3

Jan 29, 2020

v0.10.2

Dec 4, 2019

Changes in this version

+ const ConstraintSemver

+ const VolumeMountPropagationBidirectional

+ const VolumeMountPropagationHostToTask

+ const VolumeMountPropagationPrivate

+ func CodeFromRPCCodedErr(err error) (code int, msg string, ok bool)

+ func MountPropagationModeIsValid(propagationMode string) bool

+ func NewErrRPCCoded(code int, msg string) error

+ func NewErrRPCCodedf(code int, format string, args ...interface{}) error

type ACLPolicy

+ RulesJSON *acl.Policy

type ConsulSidecarService

+ Tags []string

type DrainStrategy

+ StartedAt time.Time

type VolumeMount

+ PropagationMode string

v0.10.2-rc1

Nov 22, 2019

v0.10.1

Nov 4, 2019

v0.10.0

Oct 22, 2019

Changes in this version

+ const ConnectProxyPrefix

+ const EnvoyBootstrapPath

+ const VolumeTypeHost

+ var ErrNotReadyForConsistentReads = errors.New(errNotReadyForConsistentReads)

+ func CopyMapStringClientHostVolumeConfig(m map[string]*ClientHostVolumeConfig) map[string]*ClientHostVolumeConfig

+ func CopyMapVolumeRequest(s map[string]*VolumeRequest) map[string]*VolumeRequest

+ func ValidateConnectProxyService(serviceName string, tgServices []*Service) error

type AllocatedSharedResources

+ Networks Networks

+ func (a AllocatedSharedResources) Copy() AllocatedSharedResources

type CheckRestart

+ func (c *CheckRestart) Equals(o *CheckRestart) bool

+ type ClientHostVolumeConfig struct

+ Name string

+ Path string

+ ReadOnly bool

+ func CopySliceClientHostVolumeConfig(s []*ClientHostVolumeConfig) []*ClientHostVolumeConfig

+ func HostVolumeSliceMerge(a, b []*ClientHostVolumeConfig) []*ClientHostVolumeConfig

+ func (p *ClientHostVolumeConfig) Copy() *ClientHostVolumeConfig

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

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

+ type ConsulConnect struct

+ Native bool

+ SidecarService *ConsulSidecarService

+ SidecarTask *SidecarTask

+ func (c *ConsulConnect) Copy() *ConsulConnect

+ func (c *ConsulConnect) Equals(o *ConsulConnect) bool

+ func (c *ConsulConnect) HasSidecar() bool

+ func (c *ConsulConnect) Validate() error

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

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

+ type ConsulProxy struct

+ Config map[string]interface{}

+ LocalServiceAddress string

+ LocalServicePort int

+ Upstreams []ConsulUpstream

+ func (p *ConsulProxy) Copy() *ConsulProxy

+ func (p *ConsulProxy) Equals(o *ConsulProxy) bool

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

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

+ type ConsulSidecarService struct

+ Port string

+ Proxy *ConsulProxy

+ func (s *ConsulSidecarService) Copy() *ConsulSidecarService

+ func (s *ConsulSidecarService) Equals(o *ConsulSidecarService) bool

+ func (s *ConsulSidecarService) HasUpstreams() bool

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

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

+ type ConsulUpstream struct

+ DestinationName string

+ LocalBindPort int

+ func (u *ConsulUpstream) Copy() *ConsulUpstream

+ func (u *ConsulUpstream) Equals(o *ConsulUpstream) bool

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

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

type LogConfig

+ func (l *LogConfig) Copy() *LogConfig

type NetworkResource

+ Mode string

+ func (n *NetworkResource) PortForService(serviceName string) (Port, bool)

type Networks

+ func (ns Networks) Copy() Networks

type Node

+ HostVolumes map[string]*ClientHostVolumeConfig

type Port

+ To int

type Service

+ Connect *ConsulConnect

+ Meta map[string]string

+ func (s *Service) Equals(o *Service) bool

type ServiceCheck

+ TaskName string

+ func (sc *ServiceCheck) Equals(o *ServiceCheck) bool

+ type SidecarTask struct

+ Config map[string]interface{}

+ Driver string

+ Env map[string]string

+ KillSignal string

+ KillTimeout *time.Duration

+ LogConfig *LogConfig

+ Meta map[string]string

+ Name string

+ Resources *Resources

+ ShutdownDelay *time.Duration

+ User string

+ func (t *SidecarTask) Copy() *SidecarTask

+ func (t *SidecarTask) MergeIntoTask(task *Task)

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

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

type Task

+ Kind TaskKind

+ VolumeMounts []*VolumeMount

type TaskGroup

+ Networks Networks

+ Services []*Service

+ Volumes map[string]*VolumeRequest

+ type TaskKind string

+ func (k TaskKind) IsConnectProxy() bool

+ func (k TaskKind) Name() string

+ func (k TaskKind) Value() string

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

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

type UpdateStrategy

+ func (u *UpdateStrategy) IsEmpty() bool

+ type VolumeMount struct

+ Destination string

+ ReadOnly bool

+ Volume string

+ func CopySliceVolumeMount(s []*VolumeMount) []*VolumeMount

+ func (v *VolumeMount) Copy() *VolumeMount

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

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

+ type VolumeRequest struct

+ Name string

+ ReadOnly bool

+ Source string

+ Type string

+ func (v *VolumeRequest) Copy() *VolumeRequest

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

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

v0.10.0-rc1

Oct 10, 2019

v0.10.0-patched

Oct 29, 2019

v0.10.0-connect1

Jul 9, 2019

v0.10.0-beta1

Sep 6, 2019

v0.9.7

Dec 4, 2019

v0.9.6

Oct 7, 2019

Changes in this version

+ var ErrMissingAllocID = errors.New(errMissingAllocID)

v0.9.5

Aug 21, 2019

Changes in this version

type Evaluation

+ CreateTime int64

+ ModifyTime int64

+ func (e *Evaluation) UpdateModifyTime()

v0.9.4

Jul 30, 2019

Changes in this version

type MessageType

+ const NodeBatchDeregisterRequestType

+ type NodeBatchDeregisterRequest struct

+ NodeIDs []string

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

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

type Plan

+ SnapshotIndex uint64

v0.9.4-rc1

Jul 23, 2019

v0.9.3

Jun 12, 2019

Changes in this version

type BatchNodeUpdateDrainRequest

+ UpdatedAt int64

type NodeUpdateDrainRequest

+ UpdatedAt int64

type NodeUpdateEligibilityRequest

+ UpdatedAt int64

type NodeUpdateStatusRequest

+ UpdatedAt int64

v0.9.2

Jun 5, 2019

Changes in this version

+ const DeploymentStatusDescriptionRunningAutoPromotion

+ const EvalTriggerAllocStop

+ const TaskRestoreFailed

+ type Affinities []*Affinity

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

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

+ func (xs *Affinities) Equals(ys *Affinities) bool

type Affinity

+ func (a *Affinity) Equals(o *Affinity) bool

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

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

type AllocListStub

+ NodeName string

+ PreemptedAllocations []string

+ PreemptedByAllocation string

+ type AllocRestartRequest struct

+ AllocID string

+ TaskName string

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

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

+ type AllocSignalRequest struct

+ AllocID string

+ Signal string

+ Task string

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

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

+ type AllocStopRequest struct

+ AllocID string

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

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

+ type AllocStopResponse struct

+ EvalID string

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

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

type AllocUpdateRequest

+ AllocsStopped []*AllocationDiff

+ AllocsUpdated []*Allocation

type AllocatedCpuResources

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

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

type AllocatedDeviceResource

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

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

type AllocatedDevices

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

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

type AllocatedMemoryResources

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

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

type AllocatedResources

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

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

type AllocatedSharedResources

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

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

type AllocatedTaskResources

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

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

type Allocation

+ NodeName string

+ func (a *Allocation) AllocationDiff() *AllocationDiff

+ type AllocationDiff Allocation

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

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

type ApplyPlanResultsRequest

+ AllocsPreempted []*AllocationDiff

type BatchFuture

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

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

type ComparableResources

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

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

type Constraint

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

+ type Constraints []*Constraint

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

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

+ func (xs *Constraints) Equals(ys *Constraints) bool

type Deployment

+ func (d *Deployment) HasAutoPromote() bool

type DeploymentState

+ AutoPromote bool

type DeviceAccounter

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

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

type DeviceAccounterInstance

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

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

type DeviceIdTuple

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

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

type DriverInfo

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

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

type EvalOptions

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

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

type JobRevertRequest

+ VaultToken string

type JobSpecificRequest

+ All bool

type Networks

+ func (n *Networks) Equals(o *Networks) bool

type NodeCpuResources

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

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

type NodeDevice

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

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

type NodeDeviceLocality

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

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

type NodeDeviceResource

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

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

type NodeDiskResources

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

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

type NodeMemoryResources

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

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

type NodeReservedCpuResources

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

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

type NodeReservedDiskResources

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

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

type NodeReservedMemoryResources

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

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

type NodeReservedNetworkResources

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

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

type NodeReservedResources

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

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

type NodeResources

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

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

type NodeScoreMeta

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

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

type Plan

+ func (p *Plan) AppendStoppedAlloc(alloc *Allocation, desiredDesc, clientStatus string)

+ func (p *Plan) NormalizeAllocations()

type PreemptionConfig

+ BatchSchedulerEnabled bool

+ ServiceSchedulerEnabled bool

type RequestedDevice

+ func (r *RequestedDevice) Equals(o *RequestedDevice) bool

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

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

+ type ResourceDevices []*RequestedDevice

+ func (d *ResourceDevices) Equals(o *ResourceDevices) bool

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

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

type Resources

+ func (r *Resources) Equals(o *Resources) bool

type Spread

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

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

type SpreadTarget

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

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

type TaskEvent

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

type UpdateStrategy

+ AutoPromote bool

v0.9.2-rc1

May 23, 2019

v0.9.1

Apr 29, 2019

v0.9.1-rc1

Apr 23, 2019

v0.9.0

Apr 9, 2019

Changes in this version

+ const ConstraintAttributeIsNotSet

+ const ConstraintAttributeIsSet

+ const ConstraintSetContainsAll

+ const ConstraintSetContainsAny

+ const EvalTriggerPreemption

+ const MaxRetainedNodeScores

+ const NormScorerName

+ const TaskHookFailed

+ func DevicesEquals(d1, d2 []*NodeDeviceResource) bool

+ func ParsePortRanges(spec string) ([]uint64, error)

+ type Affinity struct

+ LTarget string

+ Operand string

+ RTarget string

+ Weight int8

+ func CopySliceAffinities(s []*Affinity) []*Affinity

+ func (a *Affinity) Copy() *Affinity

+ func (a *Affinity) Equal(o *Affinity) bool

+ func (a *Affinity) String() string

+ func (a *Affinity) Validate() error

type AllocListStub

+ JobType string

+ Namespace string

type AllocMetric

+ ScoreMetaData []*NodeScoreMeta

+ func (a *AllocMetric) PopulateScoreMetaData()

+ type AllocatedCpuResources struct

+ CpuShares int64

+ func (a *AllocatedCpuResources) Add(delta *AllocatedCpuResources)

+ func (a *AllocatedCpuResources) Subtract(delta *AllocatedCpuResources)

+ type AllocatedDeviceResource struct

+ DeviceIDs []string

+ Name string

+ Type string

+ Vendor string

+ func (a *AllocatedDeviceResource) Add(delta *AllocatedDeviceResource)

+ func (a *AllocatedDeviceResource) Copy() *AllocatedDeviceResource

+ func (a *AllocatedDeviceResource) ID() *DeviceIdTuple

+ type AllocatedDevices []*AllocatedDeviceResource

+ func (a AllocatedDevices) Index(d *AllocatedDeviceResource) int

+ type AllocatedMemoryResources struct

+ MemoryMB int64

+ func (a *AllocatedMemoryResources) Add(delta *AllocatedMemoryResources)

+ func (a *AllocatedMemoryResources) Subtract(delta *AllocatedMemoryResources)

+ type AllocatedResources struct

+ Shared AllocatedSharedResources

+ Tasks map[string]*AllocatedTaskResources

+ func NodeResourcesToAllocatedResources(n *NodeResources) *AllocatedResources

+ func (a *AllocatedResources) Comparable() *ComparableResources

+ func (a *AllocatedResources) Copy() *AllocatedResources

+ func (a *AllocatedResources) OldTaskResources() map[string]*Resources

+ type AllocatedSharedResources struct

+ DiskMB int64

+ func (a *AllocatedSharedResources) Add(delta *AllocatedSharedResources)

+ func (a *AllocatedSharedResources) Subtract(delta *AllocatedSharedResources)

+ type AllocatedTaskResources struct

+ Cpu AllocatedCpuResources

+ Devices []*AllocatedDeviceResource

+ Memory AllocatedMemoryResources

+ Networks Networks

+ func (a *AllocatedTaskResources) Add(delta *AllocatedTaskResources)

+ func (a *AllocatedTaskResources) Comparable() *ComparableResources

+ func (a *AllocatedTaskResources) Copy() *AllocatedTaskResources

+ func (a *AllocatedTaskResources) NetIndex(n *NetworkResource) int

+ func (a *AllocatedTaskResources) Subtract(delta *AllocatedTaskResources)

type Allocation

+ AllocatedResources *AllocatedResources

+ PreemptedAllocations []string

+ PreemptedByAllocation string

+ func MockAlloc() *Allocation

+ func (a *Allocation) ComparableResources() *ComparableResources

+ func (a *Allocation) LookupTask(name string) *Task

+ func (a *Allocation) ServerTerminalStatus() bool

type ApplyPlanResultsRequest

+ NodePreemptions []*Allocation

+ PreemptionEvals []*Evaluation

+ type ComparableResources struct

+ Flattened AllocatedTaskResources

+ Shared AllocatedSharedResources

+ func (c *ComparableResources) Add(delta *ComparableResources)

+ func (c *ComparableResources) Copy() *ComparableResources

+ func (c *ComparableResources) NetIndex(n *NetworkResource) int

+ func (c *ComparableResources) Subtract(delta *ComparableResources)

+ func (c *ComparableResources) Superset(other *ComparableResources) (bool, string)

type DesiredUpdates

+ Preemptions uint64

+ type DeviceAccounter struct

+ Devices map[DeviceIdTuple]*DeviceAccounterInstance

+ func NewDeviceAccounter(n *Node) *DeviceAccounter

+ func (d *DeviceAccounter) AddAllocs(allocs []*Allocation) (collision bool)

+ func (d *DeviceAccounter) AddReserved(res *AllocatedDeviceResource) (collision bool)

+ type DeviceAccounterInstance struct

+ Device *NodeDeviceResource

+ Instances map[string]int

+ func (i *DeviceAccounterInstance) FreeCount() int

+ type DeviceIdTuple struct

+ Name string

+ Type string

+ Vendor string

+ func (d *DeviceIdTuple) String() string

+ func (id *DeviceIdTuple) Equals(o *DeviceIdTuple) bool

+ func (id *DeviceIdTuple) Matches(other *DeviceIdTuple) bool

type Job

+ Affinities []*Affinity

+ Spreads []*Spread

+ func MockJob() *Job

type JobListStub

+ Datacenters []string

type MessageType

+ const SchedulerConfigRequestType

type NetworkIndex

+ func (idx *NetworkIndex) AddReservedPortRange(ports string) (collide bool)

type Networks

+ func (ns Networks) NetIndex(n *NetworkResource) int

type Node

+ NodeResources *NodeResources

+ ReservedResources *NodeReservedResources

+ func MockNode() *Node

+ func MockNvidiaNode() *Node

+ func (n *Node) ComparableReservedResources() *ComparableResources

+ func (n *Node) ComparableResources() *ComparableResources

+ type NodeCpuResources struct

+ CpuShares int64

+ func (n *NodeCpuResources) Equals(o *NodeCpuResources) bool

+ func (n *NodeCpuResources) Merge(o *NodeCpuResources)

+ type NodeDevice struct

+ HealthDescription string

+ Healthy bool

+ ID string

+ Locality *NodeDeviceLocality

+ func (n *NodeDevice) Copy() *NodeDevice

+ func (n *NodeDevice) Equals(o *NodeDevice) bool

+ type NodeDeviceLocality struct

+ PciBusID string

+ func (n *NodeDeviceLocality) Copy() *NodeDeviceLocality

+ func (n *NodeDeviceLocality) Equals(o *NodeDeviceLocality) bool

+ type NodeDeviceResource struct

+ Attributes map[string]*psstructs.Attribute

+ Instances []*NodeDevice

+ Name string

+ Type string

+ Vendor string

+ func (n *NodeDeviceResource) Copy() *NodeDeviceResource

+ func (n *NodeDeviceResource) Equals(o *NodeDeviceResource) bool

+ func (n *NodeDeviceResource) ID() *DeviceIdTuple

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

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

+ type NodeDiskResources struct

+ DiskMB int64

+ func (n *NodeDiskResources) Equals(o *NodeDiskResources) bool

+ func (n *NodeDiskResources) Merge(o *NodeDiskResources)

+ type NodeMemoryResources struct

+ MemoryMB int64

+ func (n *NodeMemoryResources) Equals(o *NodeMemoryResources) bool

+ func (n *NodeMemoryResources) Merge(o *NodeMemoryResources)

+ type NodeReservedCpuResources struct

+ CpuShares int64

+ type NodeReservedDiskResources struct

+ DiskMB int64

+ type NodeReservedMemoryResources struct

+ MemoryMB int64

+ type NodeReservedNetworkResources struct

+ ReservedHostPorts string

+ func (n *NodeReservedNetworkResources) ParseReservedHostPorts() ([]uint64, error)

+ type NodeReservedResources struct

+ Cpu NodeReservedCpuResources

+ Disk NodeReservedDiskResources

+ Memory NodeReservedMemoryResources

+ Networks NodeReservedNetworkResources

+ func (n *NodeReservedResources) Comparable() *ComparableResources

+ func (n *NodeReservedResources) Copy() *NodeReservedResources

+ type NodeResources struct

+ Cpu NodeCpuResources

+ Devices []*NodeDeviceResource

+ Disk NodeDiskResources

+ Memory NodeMemoryResources

+ Networks Networks

+ func (n *NodeResources) Comparable() *ComparableResources

+ func (n *NodeResources) Copy() *NodeResources

+ func (n *NodeResources) Equals(o *NodeResources) bool

+ func (n *NodeResources) Merge(o *NodeResources)

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

+ type NodeScoreMeta struct

+ NodeID string

+ NormScore float64

+ Scores map[string]float64

+ func CopySliceNodeScoreMeta(s []*NodeScoreMeta) []*NodeScoreMeta

+ func (s *NodeScoreMeta) Copy() *NodeScoreMeta

+ func (s *NodeScoreMeta) Data() interface{}

+ func (s *NodeScoreMeta) Score() float64

+ func (s *NodeScoreMeta) String() string

type Plan

+ NodePreemptions map[string][]*Allocation

+ func (p *Plan) AppendPreemptedAlloc(alloc *Allocation, desiredStatus, preemptingAllocID string)

type PlanAnnotations

+ PreemptedAllocs []*AllocListStub

type PlanResult

+ NodePreemptions map[string][]*Allocation

+ type PreemptionConfig struct

+ SystemSchedulerEnabled bool

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

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

type RecoverableError

+ func (r *RecoverableError) IsUnrecoverable() bool

+ type RequestedDevice struct

+ Affinities []*Affinity

+ Constraints []*Constraint

+ Count uint64

+ Name string

+ func (r *RequestedDevice) Copy() *RequestedDevice

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

+ func (r *RequestedDevice) ID() *DeviceIdTuple

+ func (r *RequestedDevice) Validate() error

type Resources

+ Devices []*RequestedDevice

+ func (r *Resources) Validate() error

+ type SchedulerConfiguration struct

+ CreateIndex uint64

+ ModifyIndex uint64

+ PreemptionConfig PreemptionConfig

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

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

+ type SchedulerConfigurationResponse struct

+ SchedulerConfig *SchedulerConfiguration

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

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

+ type SchedulerSetConfigRequest struct

+ CAS bool

+ Config SchedulerConfiguration

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

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

+ type SchedulerSetConfigurationResponse struct

+ Updated bool

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

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

+ type Spread struct

+ Attribute string

+ SpreadTarget []*SpreadTarget

+ Weight int8

+ func CopySliceSpreads(s []*Spread) []*Spread

+ func (s *Spread) Copy() *Spread

+ func (s *Spread) String() string

+ func (s *Spread) Validate() error

+ type SpreadTarget struct

+ Percent uint8

+ Value string

+ func CopySliceSpreadTarget(s []*SpreadTarget) []*SpreadTarget

+ func (s *SpreadTarget) Copy() *SpreadTarget

+ func (s *SpreadTarget) String() string

type Task

+ Affinities []*Affinity

+ func (t *Task) Warnings() error

type TaskArtifact

+ func (ta *TaskArtifact) Hash() string

type TaskEvent

+ func (e *TaskEvent) SetOOMKilled(oom bool) *TaskEvent

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

type TaskGroup

+ Affinities []*Affinity

+ Spreads []*Spread

type TaskState

+ func NewTaskState() *TaskState

+ func (ts *TaskState) Canonicalize()

v0.9.0-rc2

Apr 3, 2019

v0.9.0-rc1

Mar 22, 2019

v0.9.0-beta3

Feb 26, 2019

v0.9.0-beta2

Jan 30, 2019

v0.9.0-beta1

Jan 30, 2019

v0.8.7

Jan 11, 2019

Changes in this version

type NamespacedID

+ func NewNamespacedID(id, ns string) NamespacedID

v0.8.7-rc1

Dec 10, 2018

v0.8.6

Sep 26, 2018

Changes in this version

+ const EvalTriggerQueuedAllocs

v0.8.5

Sep 13, 2018

v0.8.4

Jun 11, 2018

Changes in this version

+ const DeploymentStatusDescriptionProgressDeadline

+ const ServiceCheckGRPC

type AllocDeploymentStatus

+ Canary bool

+ Timestamp time.Time

+ func (a *AllocDeploymentStatus) IsCanary() bool

type AllocListStub

+ DesiredTransition DesiredTransition

+ RescheduleTracker *RescheduleTracker

type ApplyDeploymentAllocHealthRequest

+ Timestamp time.Time

type BatchNodeUpdateDrainRequest

+ NodeEvents map[string]*NodeEvent

type Deployment

+ JobSpecModifyIndex uint64

type DeploymentState

+ ProgressDeadline time.Duration

+ RequireProgressBy time.Time

type DesiredTransition

+ ForceReschedule *bool

+ Reschedule *bool

+ func (d *DesiredTransition) ShouldForceReschedule() bool

+ func (d *DesiredTransition) ShouldReschedule() bool

+ type EvalOptions struct

+ ForceReschedule bool

type Job

+ Dispatched bool

type JobEvaluateRequest

+ EvalOptions EvalOptions

type NodeEvent

+ func NewNodeEvent() *NodeEvent

+ func (ne *NodeEvent) AddDetail(k, v string) *NodeEvent

+ func (ne *NodeEvent) SetMessage(msg string) *NodeEvent

+ func (ne *NodeEvent) SetSubsystem(sys string) *NodeEvent

+ func (ne *NodeEvent) SetTimestamp(ts time.Time) *NodeEvent

type NodeListStub

+ Drivers map[string]*DriverInfo

type NodeRegisterRequest

+ NodeEvent *NodeEvent

type NodeUpdateDrainRequest

+ NodeEvent *NodeEvent

type NodeUpdateEligibilityRequest

+ NodeEvent *NodeEvent

type NodeUpdateStatusRequest

+ NodeEvent *NodeEvent

type ReschedulePolicy

+ func (r *ReschedulePolicy) Enabled() bool

type Service

+ CanaryTags []string

type ServiceCheck

+ GRPCService string

+ GRPCUseTLS bool

type UpdateStrategy

+ ProgressDeadline time.Duration

v0.8.4-rc1

Jun 1, 2018

v0.8.3

Apr 27, 2018

v0.8.2

Apr 26, 2018

Changes in this version

+ func CronParseNext(e *cronexpr.Expression, fromTime time.Time, spec string) (t time.Time, err error)

type AutopilotConfig

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

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

type AutopilotSetConfigRequest

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

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

type Bitmap

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

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

type DiffType

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

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

type FieldDiff

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

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

type FieldDiffs

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

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

type Job

+ func (j *Job) NamespacedID() *NamespacedID

type JobDiff

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

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

type NetworkIndex

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

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

type ObjectDiff

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

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

type ObjectDiffs

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

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

type RaftConfigurationResponse

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

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

type RaftPeerByAddressRequest

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

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

type RaftPeerByIDRequest

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

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

type RaftServer

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

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

type StreamingRpcAck

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

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

type StreamingRpcHeader

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

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

type StreamingRpcRegistry

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

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

type TaskDiff

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

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

type TaskDiffs

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

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

type TaskGroupDiff

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

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

type TaskGroupDiffs

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

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

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