structs

Jan 15, 2024 GO-2024-2538

  GO-2024-2538: Symlink attack in github.com/hashicorp/nomad

Jan 15, 2024 GO-2024-2538

  GO-2024-2538: Symlink attack in github.com/hashicorp/nomad

Dec 13, 2023 GO-2024-2538

  GO-2024-2538: Symlink attack in github.com/hashicorp/nomad

Dec 7, 2023 GO-2024-2538

  GO-2024-2538: Symlink attack in github.com/hashicorp/nomad

Oct 30, 2023 GO-2024-2538

  GO-2024-2538: Symlink attack in github.com/hashicorp/nomad

Changes in this version

+ type CSIVolumeExpandRequest struct

+ RequestedCapacityMax int64

+ RequestedCapacityMin int64

+ Secrets CSISecrets

+ VolumeID string

+ type CSIVolumeExpandResponse struct

+ CapacityBytes int64

Sep 13, 2023 GO-2024-2538

  GO-2024-2538: Symlink attack in github.com/hashicorp/nomad

Changes in this version

+ const JobDefaultTrackedVersions

type ConsulUpstream

+ DestinationPeer string

+ DestinationType string

+ LocalBindSocketMode string

+ LocalBindSocketPath string

type PeriodicConfig

+ Specs []string

type RestartPolicy

+ RenderTemplates bool

Jul 21, 2023 GO-2024-2538

  GO-2024-2538: Symlink attack in github.com/hashicorp/nomad

Jul 18, 2023 GO-2024-2538

  GO-2024-2538: Symlink attack in github.com/hashicorp/nomad

Changes in this version

+ const NodePoolAll

+ const NodePoolAllDescription

+ const NodePoolDefault

+ const NodePoolDefaultDescription

+ const SystemInitializationType

+ const TopicNodePool

+ const TypeNodePoolDeleted

+ const TypeNodePoolUpserted

+ func ValidateNodePoolName(pool string) error

type AllocDeploymentStatus

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

type AllocListStub

+ NextAllocation string

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

type AllocMetric

+ NodesInPool int

type AllocNetworkStatus

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

+ func (a *AllocNetworkStatus) IsZero() bool

type Context

+ const NodePools

type DNSConfig

+ func (d *DNSConfig) IsZero() bool

type Job

+ NodePool string

type JobListStub

+ NodePool string

type JobRegisterRequest

+ Submission *JobSubmission

+ type JobSubmission struct

+ Format string

+ JobID string

+ JobModifyIndex uint64

+ Namespace string

+ Source string

+ VariableFlags map[string]string

+ Variables string

+ Version uint64

+ func (js *JobSubmission) Copy() *JobSubmission

+ func (js *JobSubmission) Hash() string

+ type JobSubmissionRequest struct

+ JobID string

+ Version uint64

+ type JobSubmissionResponse struct

+ Submission *JobSubmission

type MessageType

+ const NodePoolDeleteRequestType

+ const NodePoolUpsertRequestType

type MultiregionRegion

+ NodePool string

type Namespace

+ NodePoolConfiguration *NamespaceNodePoolConfiguration

+ func (n *Namespace) Canonicalize()

+ type NamespaceNodePoolConfiguration struct

+ Allowed []string

+ Default string

+ Denied []string

+ func (n *NamespaceNodePoolConfiguration) Canonicalize()

+ func (n *NamespaceNodePoolConfiguration) Validate() error

type Node

+ NodePool string

+ func (n *Node) HasEvent(msg string) bool

+ func (n *Node) IsInPool(pool string) bool

type NodeListStub

+ NodePool string

+ type NodePool struct

+ CreateIndex uint64

+ Description string

+ Hash []byte

+ Meta map[string]string

+ ModifyIndex uint64

+ Name string

+ SchedulerConfiguration *NodePoolSchedulerConfiguration

+ func (n *NodePool) Copy() *NodePool

+ func (n *NodePool) GetID() string

+ func (n *NodePool) IsBuiltIn() bool

+ func (n *NodePool) MemoryOversubscriptionEnabled(global *SchedulerConfiguration) bool

+ func (n *NodePool) SetHash() []byte

+ func (n *NodePool) Validate() error

+ type NodePoolDeleteRequest struct

+ Names []string

+ type NodePoolEvent struct

+ NodePool *NodePool

+ type NodePoolJobsRequest struct

+ Fields *JobStubFields

+ Name string

+ type NodePoolJobsResponse struct

+ Jobs []*JobListStub

+ type NodePoolListRequest struct

+ type NodePoolListResponse struct

+ NodePools []*NodePool

+ type NodePoolNodesRequest struct

+ Fields *NodeStubFields

+ Name string

+ type NodePoolNodesResponse struct

+ Nodes []*NodeListStub

+ type NodePoolSchedulerConfiguration struct

+ MemoryOversubscriptionEnabled *bool

+ SchedulerAlgorithm SchedulerAlgorithm

+ func (n *NodePoolSchedulerConfiguration) Copy() *NodePoolSchedulerConfiguration

+ func (n *NodePoolSchedulerConfiguration) Validate() error

+ type NodePoolSpecificRequest struct

+ Name string

+ type NodePoolUpsertRequest struct

+ NodePools []*NodePool

type NodeRegisterRequest

+ CreateNodePool bool

type RescheduleTracker

+ func (rt *RescheduleTracker) RescheduleEligible(reschedulePolicy *ReschedulePolicy, failTime time.Time) bool

type SchedulerConfiguration

+ func (s *SchedulerConfiguration) WithNodePool(pool *NodePool) *SchedulerConfiguration

type ServiceCheck

+ TLSServerName string

+ type SingleNodePoolResponse struct

+ NodePool *NodePool

type TaskEvent

+ func (e *TaskEvent) Equal(o *TaskEvent) bool

type TaskHandle

+ func (h *TaskHandle) Equal(o *TaskHandle) bool

type TaskState

+ func (ts *TaskState) Equal(o *TaskState) bool

type Vault

+ DisableFile bool

Jan 15, 2024 GO-2024-2538

  GO-2024-2538: Symlink attack in github.com/hashicorp/nomad

Dec 7, 2023

Changes in this version

type JobBatchDeregisterRequest

+ SubmitTime int64

type JobDeregisterRequest

+ SubmitTime int64

May 19, 2023 GO-2024-2669GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

May 5, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type LogConfig

+ Disabled bool

May 2, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const ACLAuthMethodTokenLocalityGlobal

+ const ACLAuthMethodTokenLocalityLocal

+ const ACLAuthMethodTypeJWT

+ const ACLAuthMethodTypeOIDC

+ const ACLLoginRPCMethod

+ var ValidACLAuthMethodTypes = []string

type ACLAuthMethodConfig

+ BoundIssuer []string

+ ClockSkewLeeway time.Duration

+ ExpirationLeeway time.Duration

+ JWKSCACert string

+ JWKSURL string

+ JWTValidationPubKeys []string

+ NotBeforeLeeway time.Duration

+ func (a *ACLAuthMethodConfig) MarshalJSON() ([]byte, error)

+ func (a *ACLAuthMethodConfig) UnmarshalJSON(data []byte) (err error)

+ type ACLLoginRequest struct

+ AuthMethodName string

+ LoginToken string

+ func (a *ACLLoginRequest) Validate() error

+ type ACLLoginResponse struct

+ ACLToken *ACLToken

type ConsulSidecarService

+ Meta map[string]string

type LogConfig

+ Enabled bool

Apr 4, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Mar 21, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type AllocatedPortMapping

+ func (m *AllocatedPortMapping) Copy() *AllocatedPortMapping

+ func (m *AllocatedPortMapping) Equal(o *AllocatedPortMapping) bool

type AllocatedPorts

+ func (p AllocatedPorts) Equal(o AllocatedPorts) bool

type ChangeScript

+ func (cs *ChangeScript) Equal(o *ChangeScript) bool

type DNSConfig

+ func (d *DNSConfig) Equal(o *DNSConfig) bool

type EphemeralDisk

+ func (d *EphemeralDisk) Equal(o *EphemeralDisk) bool

type Spread

+ func (s *Spread) Equal(o *Spread) bool

type SpreadTarget

+ func (s *SpreadTarget) Equal(o *SpreadTarget) bool

type TaskArtifact

+ func (ta *TaskArtifact) Equal(o *TaskArtifact) bool

type TaskCSIPluginConfig

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

type Template

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

type Vault

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

type VolumeMount

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

type VolumeRequest

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

Mar 10, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const TaskSkippingShutdownDelay

type Node

+ func (n *Node) IsInAnyDC(datacenters []string) bool

Mar 1, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const ACLBindingRuleBindTypeManagement

+ const ACLBindingRuleBindTypePolicy

+ const ACLBindingRuleBindTypeRole

+ const ACLDeleteAuthMethodsRPCMethod

+ const ACLDeleteBindingRulesRPCMethod

+ const ACLGetAuthMethodRPCMethod

+ const ACLGetAuthMethodsRPCMethod

+ const ACLGetBindingRuleRPCMethod

+ const ACLGetBindingRulesRPCMethod

+ const ACLListAuthMethodsRPCMethod

+ const ACLListBindingRulesRPCMethod

+ const ACLOIDCAuthURLRPCMethod

+ const ACLOIDCCompleteAuthRPCMethod

+ const ACLUpsertAuthMethodsRPCMethod

+ const ACLUpsertBindingRulesRPCMethod

+ const JobDefaultMaxPriority

+ const RateMetricList

+ const RateMetricRead

+ const RateMetricWrite

+ const TaskWaitingShuttingDownDelay

+ const TopicACLAuthMethod

+ const TopicACLBindingRule

+ const TypeACLAuthMethodDeleted

+ const TypeACLAuthMethodUpserted

+ const TypeACLBindingRuleDeleted

+ const TypeACLBindingRuleUpserted

+ var ErrTokenInvalid = errors.New(errTokenInvalid)

+ var LeaderACLToken = &ACLToken

+ var ValidACLAuthMethod = regexp.MustCompile("^[a-zA-Z0-9-]{1,128}$")

+ var ValidACLRoleName = regexp.MustCompile("^[a-zA-Z0-9-]{1,128}$")

+ var ValidPolicyName = regexp.MustCompile("^[a-zA-Z0-9-]{1,128}$")

+ type ACLAuthClaims struct

+ List map[string][]string

+ Value map[string]string

+ type ACLAuthMethod struct

+ Config *ACLAuthMethodConfig

+ CreateIndex uint64

+ CreateTime time.Time

+ Default bool

+ Hash []byte

+ MaxTokenTTL time.Duration

+ ModifyIndex uint64

+ ModifyTime time.Time

+ Name string

+ TokenLocality string

+ Type string

+ func (a *ACLAuthMethod) Canonicalize()

+ func (a *ACLAuthMethod) Copy() *ACLAuthMethod

+ func (a *ACLAuthMethod) Equal(other *ACLAuthMethod) bool

+ func (a *ACLAuthMethod) MarshalJSON() ([]byte, error)

+ func (a *ACLAuthMethod) Merge(b *ACLAuthMethod)

+ func (a *ACLAuthMethod) SetHash() []byte

+ func (a *ACLAuthMethod) Stub() *ACLAuthMethodStub

+ func (a *ACLAuthMethod) TokenLocalityIsGlobal() bool

+ func (a *ACLAuthMethod) UnmarshalJSON(data []byte) (err error)

+ func (a *ACLAuthMethod) Validate(minTTL, maxTTL time.Duration) error

+ type ACLAuthMethodConfig struct

+ AllowedRedirectURIs []string

+ BoundAudiences []string

+ ClaimMappings map[string]string

+ DiscoveryCaPem []string

+ ListClaimMappings map[string]string

+ OIDCClientID string

+ OIDCClientSecret string

+ OIDCDiscoveryURL string

+ OIDCScopes []string

+ SigningAlgs []string

+ func (a *ACLAuthMethodConfig) Copy() *ACLAuthMethodConfig

+ type ACLAuthMethodDeleteRequest struct

+ Names []string

+ type ACLAuthMethodDeleteResponse struct

+ type ACLAuthMethodEvent struct

+ AuthMethod *ACLAuthMethod

+ type ACLAuthMethodGetRequest struct

+ MethodName string

+ type ACLAuthMethodGetResponse struct

+ AuthMethod *ACLAuthMethod

+ type ACLAuthMethodListRequest struct

+ type ACLAuthMethodListResponse struct

+ AuthMethods []*ACLAuthMethodStub

+ type ACLAuthMethodStub struct

+ CreateIndex uint64

+ Default bool

+ Hash []byte

+ ModifyIndex uint64

+ Name string

+ Type string

+ type ACLAuthMethodUpsertRequest struct

+ AuthMethods []*ACLAuthMethod

+ type ACLAuthMethodUpsertResponse struct

+ AuthMethods []*ACLAuthMethod

+ type ACLAuthMethodsGetRequest struct

+ Names []string

+ type ACLAuthMethodsGetResponse struct

+ AuthMethods map[string]*ACLAuthMethod

+ type ACLBindingRule struct

+ AuthMethod string

+ BindName string

+ BindType string

+ CreateIndex uint64

+ CreateTime time.Time

+ Description string

+ Hash []byte

+ ID string

+ ModifyIndex uint64

+ ModifyTime time.Time

+ Selector string

+ func (a *ACLBindingRule) Canonicalize()

+ func (a *ACLBindingRule) Copy() *ACLBindingRule

+ func (a *ACLBindingRule) Equal(other *ACLBindingRule) bool

+ func (a *ACLBindingRule) Merge(b *ACLBindingRule)

+ func (a *ACLBindingRule) SetHash() []byte

+ func (a *ACLBindingRule) Stub() *ACLBindingRuleListStub

+ func (a *ACLBindingRule) Validate() error

+ type ACLBindingRuleEvent struct

+ ACLBindingRule *ACLBindingRule

+ type ACLBindingRuleListStub struct

+ AuthMethod string

+ CreateIndex uint64

+ Description string

+ Hash []byte

+ ID string

+ ModifyIndex uint64

+ type ACLBindingRuleRequest struct

+ ACLBindingRuleID string

+ type ACLBindingRuleResponse struct

+ ACLBindingRule *ACLBindingRule

+ type ACLBindingRulesDeleteRequest struct

+ ACLBindingRuleIDs []string

+ type ACLBindingRulesDeleteResponse struct

+ type ACLBindingRulesListRequest struct

+ type ACLBindingRulesListResponse struct

+ ACLBindingRules []*ACLBindingRuleListStub

+ type ACLBindingRulesRequest struct

+ ACLBindingRuleIDs []string

+ type ACLBindingRulesResponse struct

+ ACLBindingRules map[string]*ACLBindingRule

+ type ACLBindingRulesUpsertRequest struct

+ ACLBindingRules []*ACLBindingRule

+ AllowMissingAuthMethods bool

+ type ACLBindingRulesUpsertResponse struct

+ ACLBindingRules []*ACLBindingRule

+ type ACLCache struct

+ func NewACLCache(size int) *ACLCache[T]

+ func (c *ACLCache[T]) Add(key string, item T)

+ func (c *ACLCache[T]) AddAtTime(key string, item T, now time.Time)

+ type ACLCacheEntry lang.Pair[T, time.Time]

+ func (e ACLCacheEntry[T]) Age() time.Duration

+ func (e ACLCacheEntry[T]) Get() T

+ type ACLOIDCAuthURLRequest struct

+ AuthMethodName string

+ ClientNonce string

+ RedirectURI string

+ func (a *ACLOIDCAuthURLRequest) Validate() error

+ type ACLOIDCAuthURLResponse struct

+ AuthURL string

+ type ACLOIDCCompleteAuthRequest struct

+ AuthMethodName string

+ ClientNonce string

+ Code string

+ RedirectURI string

+ State string

+ func (a *ACLOIDCCompleteAuthRequest) Validate() error

+ type ACLOIDCCompleteAuthResponse struct

+ ACLToken *ACLToken

type ACLRole

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

+ type ACLWhoAmIResponse struct

+ Identity *AuthenticatedIdentity

type Affinities

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

+ type AuthenticatedIdentity struct

+ ACLToken *ACLToken

+ Claims *IdentityClaims

+ ClientID string

+ RemoteIP net.IP

+ TLSName string

+ func (ai *AuthenticatedIdentity) GetACLToken() *ACLToken

+ func (ai *AuthenticatedIdentity) GetClaims() *IdentityClaims

+ func (ai *AuthenticatedIdentity) IsExpired(now time.Time) bool

+ func (ai *AuthenticatedIdentity) String() string

type CheckRestart

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

type Constraints

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

type Consul

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

type ConsulConnect

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

type ConsulExposeConfig

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

type ConsulGateway

+ func (g *ConsulGateway) Equal(o *ConsulGateway) bool

type ConsulGatewayBindAddress

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

type ConsulGatewayProxy

+ func (p *ConsulGatewayProxy) Equal(o *ConsulGatewayProxy) bool

type ConsulGatewayTLSConfig

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

type ConsulIngressConfigEntry

+ func (e *ConsulIngressConfigEntry) Equal(o *ConsulIngressConfigEntry) bool

type ConsulIngressListener

+ func (l *ConsulIngressListener) Equal(o *ConsulIngressListener) bool

type ConsulIngressService

+ func (s *ConsulIngressService) Equal(o *ConsulIngressService) bool

type ConsulLinkedService

+ func (s *ConsulLinkedService) Equal(o *ConsulLinkedService) bool

type ConsulMeshConfigEntry

+ func (e *ConsulMeshConfigEntry) Equal(o *ConsulMeshConfigEntry) bool

type ConsulMeshGateway

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

type ConsulProxy

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

type ConsulSidecarService

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

type ConsulTerminatingConfigEntry

+ func (e *ConsulTerminatingConfigEntry) Equal(o *ConsulTerminatingConfigEntry) bool

type ConsulUpstream

+ Config map[string]any

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

+ func (u ConsulUpstream) Hash() string

type DeviceIdTuple

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

type LogConfig

+ func (l *LogConfig) Equal(o *LogConfig) bool

type MessageType

+ const ACLAuthMethodsDeleteRequestType

+ const ACLAuthMethodsUpsertRequestType

+ const ACLBindingRulesDeleteRequestType

+ const ACLBindingRulesUpsertRequestType

type NetworkResource

+ func (n *NetworkResource) Equal(other *NetworkResource) bool

type Networks

+ func (ns *Networks) Equal(o *Networks) bool

type Node

+ func (n *Node) IsInDC(dc string) bool

type NodeCpuResources

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

type NodeDevice

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

type NodeDeviceLocality

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

type NodeDeviceResource

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

type NodeDiskResources

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

type NodeMemoryResources

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

+ type NodeMetaApplyRequest struct

+ Meta map[string]*string

+ NodeID string

+ func (n *NodeMetaApplyRequest) Validate() error

+ type NodeMetaResponse struct

+ Dynamic map[string]*string

+ Meta map[string]string

+ Static map[string]string

type NodeNetworkResource

+ func (n *NodeNetworkResource) Equal(o *NodeNetworkResource) bool

type NodeResources

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

type QueryOptions

+ func (q *QueryOptions) GetAuthToken() string

+ func (q *QueryOptions) SetIdentity(identity *AuthenticatedIdentity)

+ func (q QueryOptions) GetIdentity() *AuthenticatedIdentity

+ type RequestWithIdentity interface

+ GetAuthToken func() string

+ GetIdentity func() *AuthenticatedIdentity

+ SetIdentity func(identity *AuthenticatedIdentity)

type RequestedDevice

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

type ResourceDevices

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

type Resources

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

type Service

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

type ServiceCheck

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

type ServiceRegistration

+ func (s *ServiceRegistration) Equal(o *ServiceRegistration) bool

type SidecarTask

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

type Task

+ Identity *WorkloadIdentity

type VariableData

+ func (d1 VariableData) Equal(d2 VariableData) bool

type VariableDecrypted

+ func (v1 VariableDecrypted) Equal(v2 VariableDecrypted) bool

type VariableEncrypted

+ func (v1 VariableEncrypted) Equal(v2 VariableEncrypted) bool

type VariableItems

+ func (i1 VariableItems) Equal(i2 VariableItems) bool

type VariableMetadata

+ func (sv VariableMetadata) Equal(sv2 VariableMetadata) bool

type WaitConfig

+ func (wc *WaitConfig) Equal(o *WaitConfig) bool

+ type WorkloadIdentity struct

+ Env bool

+ File bool

+ func (wi *WorkloadIdentity) Copy() *WorkloadIdentity

+ func (wi *WorkloadIdentity) Equal(other *WorkloadIdentity) bool

type WriteRequest

+ func (w *WriteRequest) GetAuthToken() string

+ func (w *WriteRequest) SetIdentity(identity *AuthenticatedIdentity)

+ func (w WriteRequest) GetIdentity() *AuthenticatedIdentity

Oct 30, 2023

Changes in this version

+ const VaultNamespaceHeaderName

+ func AllocIndexFromName(allocName, jobID, taskGroup string) uint

type Allocation

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

Jul 18, 2023

Changes in this version

type VolumeRequest

+ func (v *VolumeRequest) VolumeID(tgName string) string

May 19, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

May 2, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Apr 4, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Mar 21, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Mar 10, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Mar 1, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type ACLToken

+ func (a *ACLToken) MarshalJSON() ([]byte, error)

+ func (a *ACLToken) UnmarshalJSON(data []byte) (err error)

type RecoverableError

+ func (r *RecoverableError) Unwrap() error

type TaskGroup

+ func (tg *TaskGroup) ConsulServices() []*Service

Feb 14, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Feb 15, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Nov 21, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type Allocation

+ SigningKeyID string

+ type EvalCountRequest struct

+ type EvalCountResponse struct

+ Count int

type EvalDeleteRequest

+ Filter string

type EvalDeleteResponse

+ Count int

type EvalReapRequest

+ Filter string

+ NextToken string

+ PerPage int32

type JobListRequest

+ Fields *JobStubFields

type JobListStub

+ Meta map[string]string

+ type JobStubFields struct

+ Meta bool

type RootKeyMeta

+ func (rkm *RootKeyMeta) Inactive() bool

type Template

+ ErrMissingKey bool

Oct 26, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const TopicACLRole

+ const TypeACLRoleDeleted

+ const TypeACLRoleUpserted

+ type ACLRoleStreamEvent struct

+ ACLRole *ACLRole

type ACLToken

+ func (a *ACLToken) HasRoles(roleIDs []string) bool

type JobDispatchRequest

+ IdPrefixTemplate string

+ type NativeServiceDiscoveryUsage struct

+ Basic *set.Set[string]

+ Checks *set.Set[string]

+ func (u *NativeServiceDiscoveryUsage) Empty() bool

Oct 6, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Oct 4, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const ACLDeleteRolesByIDRPCMethod

+ const ACLDeleteTokensRPCMethod

+ const ACLGetRoleByIDRPCMethod

+ const ACLGetRoleByNameRPCMethod

+ const ACLGetRolesByIDRPCMethod

+ const ACLListRolesRPCMethod

+ const ACLMaxExpiredBatchSize

+ const ACLUpsertPoliciesRPCMethod

+ const ACLUpsertRolesRPCMethod

+ const ACLUpsertTokensRPCMethod

+ const CoreJobGlobalTokenExpiredGC

+ const CoreJobLocalTokenExpiredGC

+ const CoreJobRootKeyRotateOrGC

+ const CoreJobVariablesRekey

+ const RootKeyStateActive

+ const RootKeyStateDeprecated

+ const RootKeyStateInactive

+ const RootKeyStateRekeying

+ const VariablesApplyRPCMethod

+ const VariablesListRPCMethod

+ const VariablesReadRPCMethod

+ var ErrTokenExpired = errors.New(errTokenExpired)

type ACLPolicy

+ JobACL *JobACL

+ type ACLRole struct

+ CreateIndex uint64

+ Description string

+ Hash []byte

+ ID string

+ ModifyIndex uint64

+ Name string

+ Policies []*ACLRolePolicyLink

+ func (a *ACLRole) Canonicalize()

+ func (a *ACLRole) Copy() *ACLRole

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

+ func (a *ACLRole) SetHash() []byte

+ func (a *ACLRole) Stub() *ACLRoleListStub

+ func (a *ACLRole) Validate() error

+ type ACLRoleByIDRequest struct

+ RoleID string

+ type ACLRoleByIDResponse struct

+ ACLRole *ACLRole

+ type ACLRoleByNameRequest struct

+ RoleName string

+ type ACLRoleByNameResponse struct

+ ACLRole *ACLRole

+ type ACLRoleListStub struct

+ CreateIndex uint64

+ Description string

+ Hash []byte

+ ID string

+ ModifyIndex uint64

+ Name string

+ Policies []*ACLRolePolicyLink

+ type ACLRolePolicyLink struct

+ Name string

+ type ACLRolesByIDRequest struct

+ ACLRoleIDs []string

+ type ACLRolesByIDResponse struct

+ ACLRoles map[string]*ACLRole

+ type ACLRolesDeleteByIDRequest struct

+ ACLRoleIDs []string

+ type ACLRolesDeleteByIDResponse struct

+ type ACLRolesListRequest struct

+ type ACLRolesListResponse struct

+ ACLRoles []*ACLRoleListStub

+ type ACLRolesUpsertRequest struct

+ ACLRoles []*ACLRole

+ AllowMissingPolicies bool

+ type ACLRolesUpsertResponse struct

+ ACLRoles []*ACLRole

type ACLToken

+ ExpirationTTL time.Duration

+ ExpirationTime *time.Time

+ Roles []*ACLTokenRoleLink

+ func (a *ACLToken) Canonicalize()

+ func (a *ACLToken) HasExpirationTime() bool

+ func (a *ACLToken) IsExpired(t time.Time) bool

type ACLTokenListStub

+ ExpirationTime *time.Time

+ Roles []*ACLTokenRoleLink

+ type ACLTokenRoleLink struct

+ ID string

+ Name string

+ type AllocInfo struct

+ AllocID string

+ Group string

+ JobID string

+ Namespace string

+ Task string

type Allocation

+ SignedIdentities map[string]string

+ func (a *Allocation) ToIdentityClaims(job *Job) *IdentityClaims

+ func (a *Allocation) ToTaskIdentityClaims(job *Job, taskName string) *IdentityClaims

+ type CheckID string

+ func NomadCheckID(allocID, group string, c *ServiceCheck) CheckID

+ type CheckMode string

+ const Healthiness

+ const Readiness

+ func GetCheckMode(c *ServiceCheck) CheckMode

+ type CheckQueryResult struct

+ Check string

+ Group string

+ ID CheckID

+ Mode CheckMode

+ Output string

+ Service string

+ Status CheckStatus

+ StatusCode int

+ Task string

+ Timestamp int64

+ func (r *CheckQueryResult) String() string

+ type CheckStatus string

+ const CheckFailure

+ const CheckPending

+ const CheckSuccess

type Context

+ const Variables

+ type EncryptionAlgorithm string

+ const EncryptionAlgorithmAES256GCM

+ type IdentityClaims struct

+ AllocationID string

+ JobID string

+ Namespace string

+ TaskName string

+ type JobACL struct

+ Group string

+ JobID string

+ Namespace string

+ Task string

+ type KeyEncryptionKeyWrapper struct

+ EncryptedDataEncryptionKey []byte

+ KeyEncryptionKey []byte

+ Meta *RootKeyMeta

+ type KeyringDeleteRootKeyRequest struct

+ KeyID string

+ type KeyringDeleteRootKeyResponse struct

+ type KeyringGetRootKeyRequest struct

+ KeyID string

+ type KeyringGetRootKeyResponse struct

+ Key *RootKey

+ type KeyringListRootKeyMetaRequest struct

+ type KeyringListRootKeyMetaResponse struct

+ Keys []*RootKeyMeta

+ type KeyringRotateRootKeyRequest struct

+ Algorithm EncryptionAlgorithm

+ Full bool

+ type KeyringRotateRootKeyResponse struct

+ Key *RootKeyMeta

+ type KeyringUpdateRootKeyMetaRequest struct

+ Rekey bool

+ RootKeyMeta *RootKeyMeta

+ type KeyringUpdateRootKeyMetaResponse struct

+ type KeyringUpdateRootKeyRequest struct

+ Rekey bool

+ RootKey *RootKey

+ type KeyringUpdateRootKeyResponse struct

type MessageType

+ const ACLRolesDeleteByIDRequestType

+ const ACLRolesUpsertRequestType

+ const RootKeyMetaDeleteRequestType

+ const RootKeyMetaUpsertRequestType

+ const VarApplyStateRequestType

+ type NetworkStatus interface

+ NetworkStatus func() *AllocNetworkStatus

+ type OperatorHealthReply struct

+ FailureTolerance int

+ Healthy bool

+ Servers []ServerHealth

+ type RaftStats struct

+ LastContact string

+ LastIndex uint64

+ LastTerm uint64

+ func (s *RaftStats) ToAutopilotServerStats() *autopilot.ServerStats

+ type RootKey struct

+ Key []byte

+ Meta *RootKeyMeta

+ func NewRootKey(algorithm EncryptionAlgorithm) (*RootKey, error)

+ type RootKeyMeta struct

+ Algorithm EncryptionAlgorithm

+ CreateIndex uint64

+ CreateTime int64

+ KeyID string

+ ModifyIndex uint64

+ State RootKeyState

+ func NewRootKeyMeta() *RootKeyMeta

+ func (rkm *RootKeyMeta) Active() bool

+ func (rkm *RootKeyMeta) Copy() *RootKeyMeta

+ func (rkm *RootKeyMeta) Deprecated() bool

+ func (rkm *RootKeyMeta) Rekeying() bool

+ func (rkm *RootKeyMeta) SetActive()

+ func (rkm *RootKeyMeta) SetDeprecated()

+ func (rkm *RootKeyMeta) SetInactive()

+ func (rkm *RootKeyMeta) SetRekeying()

+ func (rkm *RootKeyMeta) Stub() *RootKeyMetaStub

+ func (rkm *RootKeyMeta) Validate() error

+ type RootKeyMetaStub struct

+ Algorithm EncryptionAlgorithm

+ CreateTime int64

+ KeyID string

+ State RootKeyState

+ type RootKeyState string

+ type ServerHealth struct

+ Address string

+ Healthy bool

+ ID string

+ LastContact time.Duration

+ LastIndex uint64

+ LastTerm uint64

+ Leader bool

+ Name string

+ SerfStatus serf.MemberStatus

+ StableSince time.Time

+ Version string

+ Voter bool

type Service

+ TaggedAddresses map[string]string

type ServiceCheck

+ func (sc *ServiceCheck) IsReadiness() bool

type TaskGroup

+ func (tg *TaskGroup) NomadServices() []*Service

+ type VarApplyStateRequest struct

+ Op VarOp

+ Var *VariableEncrypted

+ func (r *VarApplyStateRequest) ConflictResponse(raftIndex uint64, cv *VariableEncrypted) *VarApplyStateResponse

+ func (r *VarApplyStateRequest) ErrorResponse(raftIndex uint64, err error) *VarApplyStateResponse

+ func (r *VarApplyStateRequest) SuccessResponse(raftIndex uint64, meta *VariableMetadata) *VarApplyStateResponse

+ type VarApplyStateResponse struct

+ Conflict *VariableEncrypted

+ Error error

+ Op VarOp

+ Result VarOpResult

+ WrittenSVMeta *VariableMetadata

+ func (r *VarApplyStateResponse) IsConflict() bool

+ func (r *VarApplyStateResponse) IsError() bool

+ func (r *VarApplyStateResponse) IsOk() bool

+ type VarOp string

+ const VarOpCAS

+ const VarOpDelete

+ const VarOpDeleteCAS

+ const VarOpSet

+ type VarOpResult string

+ const VarOpResultConflict

+ const VarOpResultError

+ const VarOpResultOk

+ const VarOpResultRedacted

+ type VariableData struct

+ Data []byte

+ KeyID string

+ func (d1 VariableData) Equals(d2 VariableData) bool

+ func (sv VariableData) Copy() VariableData

+ type VariableDecrypted struct

+ Items VariableItems

+ func (sv *VariableDecrypted) Canonicalize()

+ func (sv VariableDecrypted) Copy() VariableDecrypted

+ func (v VariableDecrypted) Validate() error

+ func (v1 VariableDecrypted) Equals(v2 VariableDecrypted) bool

+ type VariableEncrypted struct

+ func (sv VariableEncrypted) Copy() VariableEncrypted

+ func (v1 VariableEncrypted) Equals(v2 VariableEncrypted) bool

+ type VariableItems map[string]string

+ func (i1 VariableItems) Equals(i2 VariableItems) bool

+ func (sv VariableItems) Copy() VariableItems

+ func (svi VariableItems) Size() uint64

+ type VariableMetadata struct

+ CreateIndex uint64

+ CreateTime int64

+ ModifyIndex uint64

+ ModifyTime int64

+ Namespace string

+ Path string

+ func (sv *VariableMetadata) Copy() *VariableMetadata

+ func (sv VariableMetadata) Equals(sv2 VariableMetadata) bool

+ func (sv VariableMetadata) GetCreateIndex() uint64

+ func (sv VariableMetadata) GetID() string

+ func (sv VariableMetadata) GetNamespace() string

+ type VariablesApplyRequest struct

+ Op VarOp

+ Var *VariableDecrypted

+ type VariablesApplyResponse struct

+ Conflict *VariableDecrypted

+ Error error

+ Input *VariableDecrypted

+ Op VarOp

+ Output *VariableDecrypted

+ Result VarOpResult

+ func (r *VariablesApplyResponse) IsConflict() bool

+ func (r *VariablesApplyResponse) IsError() bool

+ func (r *VariablesApplyResponse) IsOk() bool

+ func (r *VariablesApplyResponse) IsRedacted() bool

+ type VariablesListRequest struct

+ type VariablesListResponse struct

+ Data []*VariableMetadata

+ type VariablesQuota struct

+ CreateIndex uint64

+ ModifyIndex uint64

+ Namespace string

+ Size int64

+ func (svq *VariablesQuota) Copy() *VariablesQuota

+ type VariablesReadRequest struct

+ Path string

+ type VariablesReadResponse struct

+ Data *VariableDecrypted

Sep 27, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Sep 14, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Aug 18, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

May 19, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

May 3, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type Deployment

+ func (d *Deployment) GetNamespace() string

Apr 4, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Mar 21, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Mar 10, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type Bitmap

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

+ func (b Bitmap) String() string

Mar 1, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const DeploymentStatusInitializing

type JobRegisterRequest

+ Deployment *Deployment

type Node

+ LastAllocUpdateIndex uint64

+ LastMissedHeartbeatIndex uint64

+ func (n *Node) UnresponsiveStatus() bool

Feb 14, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Feb 15, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Nov 21, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type Allocation

+ func (a *Allocation) NeedsToReconnect() bool

Oct 26, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Oct 4, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type Job

+ func (j *Job) UsesDeployments() bool

Aug 31, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type ChangeScript

+ func (cs *ChangeScript) Copy() *ChangeScript

+ func (cs *ChangeScript) Validate() error

Aug 25, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const TaskHookMessage

+ const TemplateChangeModeScript

type AllocRestartRequest

+ AllTasks bool

+ type ChangeScript struct

+ Args []string

+ Command string

+ FailOnError bool

+ Timeout time.Duration

type Task

+ func (t *Task) IsMain() bool

+ func (t *Task) IsPoststart() bool

+ func (t *Task) IsPoststop() bool

+ func (t *Task) IsPrestart() bool

type Template

+ ChangeScript *ChangeScript

Aug 5, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type TaskCSIPluginConfig

+ StagePublishBaseDir string

type Template

+ Gid int

+ Uid int

Jul 13, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const EvalDeleteRPCMethod

+ const NodeEventSubsystemScheduler

+ var ErrMalformedChooseParameter = errors.New(errMalformedChooseParameter)

+ var MaxUUIDsPerWriteRequest = (1024 * 256) / 36

type ACLTokenBootstrapRequest

+ BootstrapSecret string

type ApplyPlanResultsRequest

+ IneligibleNodes []string

+ UpdatedAt int64

type ConsulConnect

+ func (c *ConsulConnect) IsCustomizedTLS() bool

type ConsulGatewayTLSConfig

+ CipherSuites []string

+ TLSMaxVersion string

+ TLSMinVersion string

type EvalDeleteRequest

+ EvalIDs []string

+ type EvalDeleteResponse struct

+ type EvalReapRequest struct

+ Allocs []string

+ Evals []string

+ UserInitiated bool

type Evaluation

+ func (e *Evaluation) GetNamespace() string

type PlanResult

+ IneligibleNodes []string

+ RejectedNodes []string

type SchedulerConfiguration

+ PauseEvalBroker bool

type ServiceRegistration

+ func (s *ServiceRegistration) HashWith(key string) string

type ServiceRegistrationByNameRequest

+ Choose string

May 19, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

May 11, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const AllocClientStatusUnknown

+ const AllocServiceRegistrationsRPCMethod

+ const EvalTriggerMaxDisconnectTimeout

+ const EvalTriggerReconnect

+ const JobServiceRegistrationsRPCMethod

+ const NodeStatusDisconnected

+ const ServiceProviderConsul

+ const ServiceProviderNomad

+ const ServiceRegistrationDeleteByIDRPCMethod

+ const ServiceRegistrationGetServiceRPCMethod

+ const ServiceRegistrationListRPCMethod

+ const ServiceRegistrationUpsertRPCMethod

+ const TaskClientReconnected

+ const TopicService

+ const TypeServiceDeregistration

+ const TypeServiceRegistration

+ var ErrIncompatibleFiltering = errors.New(errIncompatibleFiltering)

+ func DecodeVaultSecretData(s *vapi.Secret, out interface{}) error

type ACLToken

+ func (a *ACLToken) GetCreateIndex() uint64

+ func (a *ACLToken) GetID() string

type AllocMetric

+ func (a *AllocMetric) MaxNormScore() *NodeScoreMeta

+ type AllocServiceRegistrationsRequest struct

+ AllocID string

+ type AllocServiceRegistrationsResponse struct

+ Services []*ServiceRegistration

type Allocation

+ func (a *Allocation) DisconnectTimeout(now time.Time) time.Time

+ func (a *Allocation) Expired(now time.Time) bool

+ func (a *Allocation) GetCreateIndex() uint64

+ func (a *Allocation) GetID() string

+ func (a *Allocation) GetNamespace() string

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

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

+ func (a *Allocation) Reconnected() (bool, bool)

+ func (a *Allocation) ServiceProviderNamespace() string

+ func (a *Allocation) SupportsDisconnectedClients(serverSupportsDisconnectedClients bool) bool

type CSIMountOptions

+ func (o *CSIMountOptions) Equal(p *CSIMountOptions) bool

type CSITopology

+ func (t *CSITopology) MatchFound(o []*CSITopology) bool

+ type CSITopologyRequest struct

+ Preferred []*CSITopology

+ Required []*CSITopology

+ func (tr *CSITopologyRequest) Equal(o *CSITopologyRequest) bool

type CSIVolume

+ RequestedTopologies *CSITopologyRequest

+ func (v *CSIVolume) GetCreateIndex() uint64

+ func (v *CSIVolume) GetID() string

+ func (v *CSIVolume) GetNamespace() string

+ func (v *CSIVolume) Merge(other *CSIVolume) error

type CSIVolumeDeleteRequest

+ Secrets CSISecrets

type Deployment

+ func (d *Deployment) GetCreateIndex() uint64

type EvalSpecificRequest

+ IncludeRelated bool

type Evaluation

+ RelatedEvals []*EvaluationStub

+ func (e *Evaluation) GetCreateIndex() uint64

+ func (e *Evaluation) RelatedIDs() []string

+ func (e *Evaluation) Stub() *EvaluationStub

+ type EvaluationStub struct

+ BlockedEval string

+ CreateIndex uint64

+ CreateTime int64

+ DeploymentID string

+ ID string

+ JobID string

+ ModifyIndex uint64

+ ModifyTime int64

+ Namespace string

+ NextEval string

+ NodeID string

+ PreviousEval string

+ Priority int

+ Status string

+ StatusDescription string

+ TriggeredBy string

+ Type string

+ WaitUntil time.Time

type Job

+ func (j *Job) GetCreateIndex() uint64

+ func (j *Job) GetID() string

+ func (j *Job) GetNamespace() string

+ func (j *Job) IsPlugin() bool

+ func (j *Job) RequiredConsulServiceDiscovery() map[string]bool

+ func (j *Job) RequiredNativeServiceDiscovery() map[string]bool

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

+ type JobServiceRegistrationsRequest struct

+ JobID string

+ type JobServiceRegistrationsResponse struct

+ Services []*ServiceRegistration

type MessageType

+ const ServiceRegistrationDeleteByIDRequestType

+ const ServiceRegistrationDeleteByNodeIDRequestType

+ const ServiceRegistrationUpsertRequestType

type Namespace

+ Capabilities *NamespaceCapabilities

+ Meta map[string]string

+ type NamespaceCapabilities struct

+ DisabledTaskDrivers []string

+ EnabledTaskDrivers []string

type Node

+ CgroupParent string

+ func (n *Node) GetID() string

type NodeListStub

+ Attributes map[string]string

type NodeStubFields

+ OS bool

type Plan

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

type QueryOptions

+ Filter string

+ Reverse bool

type Service

+ Address string

+ Provider string

+ type ServiceRegistration struct

+ Address string

+ AllocID string

+ CreateIndex uint64

+ Datacenter string

+ ID string

+ JobID string

+ ModifyIndex uint64

+ Namespace string

+ NodeID string

+ Port int

+ ServiceName string

+ Tags []string

+ func (s *ServiceRegistration) Copy() *ServiceRegistration

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

+ func (s *ServiceRegistration) GetID() string

+ func (s *ServiceRegistration) GetNamespace() string

+ func (s *ServiceRegistration) Validate() error

+ type ServiceRegistrationByNameRequest struct

+ ServiceName string

+ type ServiceRegistrationByNameResponse struct

+ Services []*ServiceRegistration

+ type ServiceRegistrationDeleteByIDRequest struct

+ ID string

+ type ServiceRegistrationDeleteByIDResponse struct

+ type ServiceRegistrationDeleteByNodeIDRequest struct

+ NodeID string

+ type ServiceRegistrationDeleteByNodeIDResponse struct

+ type ServiceRegistrationListRequest struct

+ type ServiceRegistrationListResponse struct

+ Services []*ServiceRegistrationListStub

+ type ServiceRegistrationListStub struct

+ Namespace string

+ Services []*ServiceRegistrationStub

+ type ServiceRegistrationStreamEvent struct

+ Service *ServiceRegistration

+ type ServiceRegistrationStub struct

+ ServiceName string

+ Tags []string

+ type ServiceRegistrationUpsertRequest struct

+ Services []*ServiceRegistration

+ type ServiceRegistrationUpsertResponse struct

type TaskGroup

+ MaxClientDisconnect *time.Duration

type TaskGroupSummary

+ Unknown int

+ type VaultTokenData struct

+ CreationTTL int

+ NamespacePath string

+ Policies []string

+ Renewable bool

+ Role string

+ TTL int

+ func (d VaultTokenData) Root() bool

+ type VaultTokenRoleData struct

+ AllowedEntityAliases []string

+ AllowedPolicies []string

+ DisallowedPolicies []string

+ ExplicitMaxTtl int

+ Name string

+ Orphan bool

+ Period int

+ Renewable bool

+ TokenExplicitMaxTtl int

+ TokenPeriod int

May 2, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Apr 7, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Feb 14, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Feb 15, 2023 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Nov 21, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Oct 26, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Oct 4, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type AutopilotConfig

+ func (a *AutopilotConfig) Copy() *AutopilotConfig

type CSIVolListStub

+ ControllerRequired bool

+ ResourceExhausted time.Time

type NodeUpdateResponse

+ SchedulingEligibility string

type SchedulerConfiguration

+ func (s *SchedulerConfiguration) Copy() *SchedulerConfiguration

type SearchConfig

+ func (s *SearchConfig) Copy() *SearchConfig

Aug 31, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Aug 25, 2022 GO-2024-2669GO-2024-2670GO-2024-2671

  GO-2024-2669: API token secret ID leak to Sentinel in github.com/hashicorp/nomad

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Aug 5, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jul 13, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type ConsulUpstream

+ DestinationNamespace string

May 19, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

May 10, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Feb 10, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jan 31, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jan 19, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ var ErrJobRegistrationDisabled = errors.New(errJobRegistrationDisabled)

+ func IsErrNoSuchFileOrDirectory(err error) bool

type AllocStopRequest

+ NoShutdownDelay bool

type Allocation

+ func (a *Allocation) RescheduleInfo() (int, int)

type Deployment

+ EvalPriority int

type DesiredTransition

+ NoShutdownDelay *bool

+ func (d *DesiredTransition) ShouldIgnoreShutdownDelay() bool

type EvalListRequest

+ FilterEvalStatus string

+ FilterJobID string

+ func (req *EvalListRequest) ShouldBeFiltered(e *Evaluation) bool

type Evaluation

+ func (e *Evaluation) GetID() string

type JobDeregisterRequest

+ EvalPriority int

+ NoShutdownDelay bool

type JobRegisterRequest

+ EvalPriority int

type QueryMeta

+ NextToken string

type SchedulerConfiguration

+ RejectJobRegistration bool

type Template

+ Wait *WaitConfig

+ type WaitConfig struct

+ Max *time.Duration

+ Min *time.Duration

+ func (wc *WaitConfig) Copy() *WaitConfig

+ func (wc *WaitConfig) Equals(o *WaitConfig) bool

+ func (wc *WaitConfig) Validate() error

Dec 10, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Nov 24, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Nov 19, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Nov 15, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const DefaultMaxDynamicPort

+ const DefaultMinDynamicPort

+ const JobTypeSysBatch

+ const MaxValidPort

+ func SplitTerminalAllocs(allocs []*Allocation) ([]*Allocation, TerminalByNodeByName)

type ClientHostNetworkConfig

+ func (p *ClientHostNetworkConfig) Copy() *ClientHostNetworkConfig

+ type DiffableWithID interface

+ DiffID func() string

type Node

+ HostNetworks map[string]*ClientHostNetworkConfig

type PreemptionConfig

+ SysBatchSchedulerEnabled bool

type TaskArtifact

+ func (ta *TaskArtifact) DiffID() string

type Template

+ func (t *Template) DiffID() string

+ type TerminalByNodeByName map[string]map[string]*Allocation

+ func (a TerminalByNodeByName) Get(nodeID, name string) (*Allocation, bool)

+ func (a TerminalByNodeByName) Set(allocation *Allocation)

Nov 9, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Oct 14, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Aug 31, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Aug 25, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Aug 5, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type OneTimeTokenExpireRequest

+ Timestamp time.Time

Jul 13, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type NetworkIndex

+ GroupNetworks []*NodeNetworkResource

+ HostNetworks map[string][]NodeNetworkAddress

+ MaxDynamicPort int

+ MinDynamicPort int

+ TaskNetworks []*NetworkResource

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

type NodeResources

+ MaxDynamicPort int

+ MinDynamicPort int

type TaskCSIPluginConfig

+ HealthTimeout time.Duration

May 19, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

May 10, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ var ErrCSIVolumeMaxClaims = errors.New("volume max claims reached")

+ var ErrCSIVolumeUnschedulable = errors.New("volume is currently unschedulable")

+ func AllocSubset(allocs []*Allocation, subset []*Allocation) bool

type CSIVolume

+ func (v *CSIVolume) HasFreeReadClaims() bool

+ func (v *CSIVolume) HasFreeWriteClaims() bool

Feb 10, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jan 31, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jan 19, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Dec 10, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Nov 19, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Nov 15, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Oct 5, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Sep 20, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type NetworkResource

+ Hostname string

Aug 26, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type CSISnapshotListRequest

+ Secrets CSISecrets

Jul 29, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type Job

+ DispatchIdempotencyToken string

type WriteRequest

+ IdempotencyToken string

Jun 22, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jun 9, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const ConnectMeshPrefix

type ConsulConnect

+ func (c *ConsulConnect) IsMesh() bool

type ConsulGateway

+ Mesh *ConsulMeshConfigEntry

+ type ConsulMeshConfigEntry struct

+ func (e *ConsulMeshConfigEntry) Copy() *ConsulMeshConfigEntry

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

+ func (e *ConsulMeshConfigEntry) Validate() error

+ type ConsulMeshGateway struct

+ Mode string

+ func (c *ConsulMeshGateway) Copy() *ConsulMeshGateway

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

+ func (c *ConsulMeshGateway) Validate() error

type ConsulUpstream

+ MeshGateway *ConsulMeshGateway

type Plan

+ func (p *Plan) GoString() string

type TaskKind

+ func (k TaskKind) IsConnectMesh() bool

May 17, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const CoreJobOneTimeTokenGC

+ const OnUpdateIgnore

+ const OnUpdateIgnoreWarn

+ const OnUpdateRequireHealthy

+ var JsonHandleWithExtensions = NomadJsonEncodingExtensions(&codec.JsonHandle{ ... })

+ func AllocSuffix(name string) string

+ func NomadJsonEncodingExtensions(h *codec.JsonHandle) *codec.JsonHandle

type AllocMetric

+ ResourcesExhausted map[string]*Resources

+ func (a *AllocMetric) ExhaustResources(tg *TaskGroup)

type AllocatedCpuResources

+ ReservedCores []uint16

type AllocatedMemoryResources

+ MemoryMaxMB int64

type Allocation

+ func (a *Allocation) ConsulNamespace() string

+ type CSIControllerCapability byte

+ const CSIControllerSupportsAttachDetach

+ const CSIControllerSupportsClone

+ const CSIControllerSupportsCondition

+ const CSIControllerSupportsCreateDelete

+ const CSIControllerSupportsCreateDeleteSnapshot

+ const CSIControllerSupportsExpand

+ const CSIControllerSupportsGet

+ const CSIControllerSupportsGetCapacity

+ const CSIControllerSupportsListSnapshots

+ const CSIControllerSupportsListVolumes

+ const CSIControllerSupportsListVolumesAttachedNodes

+ const CSIControllerSupportsReadOnlyAttach

type CSIControllerInfo

+ SupportsClone bool

+ SupportsCondition bool

+ SupportsCreateDelete bool

+ SupportsCreateDeleteSnapshot bool

+ SupportsExpand bool

+ SupportsGet bool

+ SupportsGetCapacity bool

+ SupportsListSnapshots bool

+ type CSINodeCapability byte

+ const CSINodeSupportsCondition

+ const CSINodeSupportsExpand

+ const CSINodeSupportsStageVolume

+ const CSINodeSupportsStats

type CSINodeInfo

+ SupportsCondition bool

+ SupportsExpand bool

+ SupportsStats bool

type CSIPlugin

+ func (p *CSIPlugin) HasControllerCapability(cap CSIControllerCapability) bool

+ func (p *CSIPlugin) HasNodeCapability(cap CSINodeCapability) bool

+ type CSISnapshot struct

+ CreateTime int64

+ ExternalSourceVolumeID string

+ ID string

+ IsReady bool

+ Name string

+ Parameters map[string]string

+ PluginID string

+ Secrets CSISecrets

+ SizeBytes int64

+ SourceVolumeID string

+ type CSISnapshotCreateRequest struct

+ Snapshots []*CSISnapshot

+ type CSISnapshotCreateResponse struct

+ Snapshots []*CSISnapshot

+ type CSISnapshotDeleteRequest struct

+ Snapshots []*CSISnapshot

+ type CSISnapshotDeleteResponse struct

+ type CSISnapshotListRequest struct

+ PluginID string

+ type CSISnapshotListResponse struct

+ NextToken string

+ Snapshots []*CSISnapshot

type CSIVolume

+ Capacity int64

+ CloneID string

+ RequestedCapabilities []*CSIVolumeCapability

+ RequestedCapacityMax int64

+ RequestedCapacityMin int64

+ SnapshotID string

+ type CSIVolumeCapability struct

+ AccessMode CSIVolumeAccessMode

+ AttachmentMode CSIVolumeAttachmentMode

type CSIVolumeClaim

+ AccessMode CSIVolumeAccessMode

+ AttachmentMode CSIVolumeAttachmentMode

type CSIVolumeClaimRequest

+ AccessMode CSIVolumeAccessMode

+ AttachmentMode CSIVolumeAttachmentMode

+ type CSIVolumeCreateRequest struct

+ Volumes []*CSIVolume

+ type CSIVolumeCreateResponse struct

+ Volumes []*CSIVolume

+ type CSIVolumeDeleteRequest struct

+ VolumeIDs []string

+ type CSIVolumeDeleteResponse struct

+ type CSIVolumeExternalListRequest struct

+ PluginID string

+ type CSIVolumeExternalListResponse struct

+ NextToken string

+ Volumes []*CSIVolumeExternalStub

+ type CSIVolumeExternalStub struct

+ CapacityBytes int64

+ CloneID string

+ ExternalID string

+ IsAbnormal bool

+ PublishedExternalNodeIDs []string

+ SnapshotID string

+ Status string

+ VolumeContext map[string]string

+ type Consul struct

+ Namespace string

+ func (c *Consul) Copy() *Consul

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

+ func (c *Consul) GetNamespace() string

+ func (c *Consul) Validate() error

type ConsulSidecarService

+ DisableDefaultTCPCheck bool

type ConsulUpstream

+ LocalBindAddress string

+ type ConsulUsage struct

+ KV bool

+ Kinds []TaskKind

+ Services []string

+ func (cu *ConsulUsage) Used() bool

type Context

+ const Classes

+ const Commands

+ const Groups

+ const Images

+ const Services

+ const Tasks

+ type DrainMetadata struct

+ AccessorID string

+ Meta map[string]string

+ StartedAt time.Time

+ Status DrainStatus

+ UpdatedAt time.Time

+ func (m *DrainMetadata) Copy() *DrainMetadata

+ type DrainStatus string

+ const DrainStatusCanceled

+ const DrainStatusComplete

+ const DrainStatusDraining

+ type FuzzyMatch struct

+ ID string

+ Scope []string

+ type FuzzySearchRequest struct

+ Context Context

+ Text string

+ type FuzzySearchResponse struct

+ Matches map[Context][]FuzzyMatch

+ Truncations map[Context]bool

type Job

+ ConsulNamespace string

+ func (j *Job) ConsulUsages() map[string]*ConsulUsage

type MessageType

+ const OneTimeTokenDeleteRequestType

+ const OneTimeTokenExpireRequestType

+ const OneTimeTokenUpsertRequestType

type Node

+ LastDrain *DrainMetadata

+ func (n *Node) Sanitize() *Node

type NodeCpuResources

+ ReservableCpuCores []uint16

+ TotalCpuCores uint16

+ func (n *NodeCpuResources) SharesPerCore() int64

type NodeListStub

+ LastDrain *DrainMetadata

type NodeReservedCpuResources

+ ReservedCpuCores []uint16

type NodeUpdateDrainRequest

+ Meta map[string]string

+ type OneTimeToken struct

+ AccessorID string

+ CreateIndex uint64

+ ExpiresAt time.Time

+ ModifyIndex uint64

+ OneTimeSecretID string

+ type OneTimeTokenDeleteRequest struct

+ AccessorIDs []string

+ type OneTimeTokenExchangeRequest struct

+ OneTimeSecretID string

+ type OneTimeTokenExchangeResponse struct

+ Token *ACLToken

+ type OneTimeTokenExpireRequest struct

+ type OneTimeTokenUpsertRequest struct

+ type OneTimeTokenUpsertResponse struct

+ OneTimeToken *OneTimeToken

type QueryOptions

+ NextToken string

+ PerPage int32

type Resources

+ Cores int

+ MemoryMaxMB int

type SIToken

+ ConsulNamespace string

type SITokenAccessor

+ ConsulNamespace string

type SchedulerConfiguration

+ MemoryOversubscriptionEnabled bool

+ type SearchConfig struct

+ FuzzyEnabled bool

+ LimitQuery int

+ LimitResults int

+ MinTermLength int

type Service

+ Namespace string

+ OnUpdate string

type ServiceCheck

+ Body string

+ OnUpdate string

type TaskGroup

+ Consul *Consul

+ type TaskHandle struct

+ DriverState []byte

+ Version int

+ func (h *TaskHandle) Copy() *TaskHandle

type TaskState

+ TaskHandle *TaskHandle

type VolumeRequest

+ AccessMode CSIVolumeAccessMode

+ AttachmentMode CSIVolumeAttachmentMode

+ PerAlloc bool

+ func (v *VolumeRequest) Validate(canaries int) error

May 12, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

May 3, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Feb 10, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jan 31, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jan 18, 2022 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type NetworkIndex

+ func (idx *NetworkIndex) Copy() *NetworkIndex

type NodeCpuResources

+ func (n NodeCpuResources) Copy() NodeCpuResources

type NodeNetworkResource

+ func (n *NodeNetworkResource) Copy() *NodeNetworkResource

Dec 10, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Nov 19, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Nov 15, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Oct 5, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Sep 20, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Aug 26, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jul 29, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jun 22, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jun 9, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

May 17, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type Allocation

+ func (a *Allocation) JobNamespacedID() NamespacedID

May 12, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Feb 23, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const ConnectTerminatingPrefix

+ type ConsulConfigEntries struct

+ Ingress map[string]*ConsulIngressConfigEntry

+ Terminating map[string]*ConsulTerminatingConfigEntry

type ConsulConnect

+ func (c *ConsulConnect) IsIngress() bool

+ func (c *ConsulConnect) IsTerminating() bool

type ConsulGateway

+ Terminating *ConsulTerminatingConfigEntry

+ func (g *ConsulGateway) Prefix() string

type ConsulGatewayProxy

+ EnvoyDNSDiscoveryType string

+ type ConsulLinkedService struct

+ CAFile string

+ CertFile string

+ KeyFile string

+ Name string

+ SNI string

+ func (s *ConsulLinkedService) Copy() *ConsulLinkedService

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

+ func (s *ConsulLinkedService) Validate() error

+ type ConsulTerminatingConfigEntry struct

+ Services []*ConsulLinkedService

+ func (e *ConsulTerminatingConfigEntry) Copy() *ConsulTerminatingConfigEntry

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

+ func (e *ConsulTerminatingConfigEntry) Validate() error

type Context

+ const ScalingPolicies

type JobScaleRequest

+ func (r *JobScaleRequest) Validate() error

type TaskKind

+ func (k TaskKind) IsConnectTerminating() bool

Jan 28, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jan 13, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Dec 16, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type ACLToken

+ func (a *ACLToken) Copy() *ACLToken

type ACLTokenEvent

+ func NewACLTokenEvent(token *ACLToken) *ACLTokenEvent

+ func (a *ACLTokenEvent) SecretID() string

Dec 8, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const AddressModeAlloc

+ const DefaultBlockingRPCQueryTime

+ const EnvoyImageFormat

+ const EnvoyVersionVar

+ const MaxBlockingRPCQueryTime

+ const MsgTypeTestSetup

+ const ScalingPolicyTypeHorizontal

+ const ScalingTargetTask

+ const TaskLifecycleHookPoststop

+ const TopicACLPolicy

+ const TopicACLToken

+ const TopicAll

+ const TopicAllocation

+ const TopicDeployment

+ const TopicEvaluation

+ const TopicJob

+ const TopicNode

+ const TypeACLPolicyDeleted

+ const TypeACLPolicyUpserted

+ const TypeACLTokenDeleted

+ const TypeACLTokenUpserted

+ const TypeAllocationCreated

+ const TypeAllocationUpdateDesiredStatus

+ const TypeAllocationUpdated

+ const TypeDeploymentAllocHealth

+ const TypeDeploymentPromotion

+ const TypeDeploymentUpdate

+ const TypeEvalUpdated

+ const TypeJobBatchDeregistered

+ const TypeJobDeregistered

+ const TypeJobRegistered

+ const TypeNodeDeregistration

+ const TypeNodeDrain

+ const TypeNodeEligibilityUpdate

+ const TypeNodeEvent

+ const TypeNodeRegistration

+ const TypePlanResult

+ type ACLPolicyEvent struct

+ ACLPolicy *ACLPolicy

+ type ACLTokenEvent struct

+ ACLToken *ACLToken

type AllocListRequest

+ Fields *AllocStubFields

type AllocListStub

+ AllocatedResources *AllocatedResources

+ type AllocNetworkStatus struct

+ Address string

+ DNS *DNSConfig

+ InterfaceName string

+ func (a *AllocNetworkStatus) Copy() *AllocNetworkStatus

+ type AllocStubFields struct

+ Resources bool

+ TaskStates bool

+ func NewAllocStubFields() *AllocStubFields

type AllocatedResources

+ func (a *AllocatedResources) Canonicalize()

type Allocation

+ NetworkStatus *AllocNetworkStatus

+ func (a *Allocation) MigrateStrategy() *MigrateStrategy

+ type AllocationEvent struct

+ Allocation *Allocation

type CSIVolumeClaimMode

+ const CSIVolumeClaimGC

type CSIVolumeClaimState

+ const CSIVolumeClaimStateUnpublishing

type ConsulUpstream

+ Datacenter string

type Context

+ const Recommendations

type DNSConfig

+ func (d *DNSConfig) Copy() *DNSConfig

+ type DeploymentEvent struct

+ Deployment *Deployment

+ type EvaluationEvent struct

+ Evaluation *Evaluation

+ type Event struct

+ FilterKeys []string

+ Index uint64

+ Key string

+ Namespace string

+ Payload interface{}

+ Topic Topic

+ Type string

+ type EventJson struct

+ Data []byte

+ func (j *EventJson) Copy() *EventJson

+ type EventStreamRequest struct

+ Index int

+ Topics map[Topic][]string

+ type EventStreamWrapper struct

+ Error *RpcError

+ Event *EventJson

+ type Events struct

+ Events []Event

+ Index uint64

type Job

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

+ type JobEvent struct

+ Job *Job

type JobNamespacedDescriptions

+ func (j JobNamespacedDescriptions) Copy() JobNamespacedDescriptions

type LogConfig

+ func (l *LogConfig) Equals(o *LogConfig) bool

type MessageType

+ const BatchEventSinkUpdateProgressType

+ const EventSinkDeleteRequestType

+ const EventSinkUpsertRequestType

+ const NamespaceDeleteRequestType

+ const NamespaceUpsertRequestType

+ type Namespace struct

+ CreateIndex uint64

+ Description string

+ Hash []byte

+ ModifyIndex uint64

+ Name string

+ Quota string

+ func (n *Namespace) Copy() *Namespace

+ func (n *Namespace) SetHash() []byte

+ func (n *Namespace) Validate() error

+ type NamespaceDeleteRequest struct

+ Namespaces []string

+ type NamespaceListRequest struct

+ type NamespaceListResponse struct

+ Namespaces []*Namespace

+ type NamespaceSetRequest struct

+ Namespaces []string

+ type NamespaceSetResponse struct

+ Namespaces map[string]*Namespace

+ type NamespaceSpecificRequest struct

+ Name string

+ type NamespaceUpsertRequest struct

+ Namespaces []*Namespace

type NodeListRequest

+ Fields *NodeStubFields

type NodeListStub

+ NodeResources *NodeResources

+ ReservedResources *NodeReservedResources

+ type NodeStreamEvent struct

+ Node *Node

+ type NodeStubFields struct

+ Resources bool

type QueryOptions

+ func (q QueryOptions) SetTimeToBlock(t time.Duration)

+ func (q QueryOptions) TimeToBlock() time.Duration

type RPCInfo

+ SetTimeToBlock func(t time.Duration)

+ TimeToBlock func() time.Duration

+ type RpcError struct

+ Code *int64

+ Message string

+ func NewRpcError(err error, code *int64) *RpcError

+ func (r *RpcError) Error() string

type ScalingPolicy

+ Type string

+ func (p *ScalingPolicy) Canonicalize()

+ func (p *ScalingPolicy) Copy() *ScalingPolicy

+ func (p *ScalingPolicy) JobKey() string

+ func (p *ScalingPolicy) TargetTask(job *Job, tg *TaskGroup, task *Task) *ScalingPolicy

+ func (p *ScalingPolicy) Validate() error

type ScalingPolicyListRequest

+ Job string

+ Type string

type ScalingPolicyListStub

+ Type string

type SidecarTask

+ func (t *SidecarTask) Equals(o *SidecarTask) bool

+ type SingleNamespaceResponse struct

+ Namespace *Namespace

type Task

+ ScalingPolicies []*ScalingPolicy

+ func (t *Task) UsesConnectSidecar() bool

type TaskArtifact

+ GetterHeaders map[string]string

+ type Topic string

type WriteRequest

+ func (w WriteRequest) SetTimeToBlock(_ time.Duration)

+ func (w WriteRequest) TimeToBlock() time.Duration

Dec 3, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Nov 12, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Oct 26, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

May 12, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Mar 18, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jan 28, 2021 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Nov 19, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Nov 10, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Oct 22, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Oct 21, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Sep 17, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Sep 9, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const ConnectIngressPrefix

+ const TaskLifecycleHookPoststart

type AllocatedSharedResources

+ func (a *AllocatedSharedResources) Canonicalize()

type CSIPlugin

+ ControllerJobs JobDescriptions

+ ControllersExpected int

+ NodeJobs JobDescriptions

+ NodesExpected int

+ func (p *CSIPlugin) AddJob(job *Job, summary *JobSummary)

+ func (p *CSIPlugin) DeleteJob(job *Job, summary *JobSummary)

+ func (p *CSIPlugin) UpdateExpectedWithJob(job *Job, summary *JobSummary, terminal bool)

type ConsulConnect

+ Gateway *ConsulGateway

+ func (c *ConsulConnect) IsGateway() bool

+ type ConsulGateway struct

+ Ingress *ConsulIngressConfigEntry

+ Proxy *ConsulGatewayProxy

+ func (g *ConsulGateway) Copy() *ConsulGateway

+ func (g *ConsulGateway) Equals(o *ConsulGateway) bool

+ func (g *ConsulGateway) Validate() error

+ type ConsulGatewayBindAddress struct

+ Address string

+ Port int

+ func (a *ConsulGatewayBindAddress) Copy() *ConsulGatewayBindAddress

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

+ func (a *ConsulGatewayBindAddress) Validate() error

+ type ConsulGatewayProxy struct

+ Config map[string]interface{}

+ ConnectTimeout *time.Duration

+ EnvoyGatewayBindAddresses map[string]*ConsulGatewayBindAddress

+ EnvoyGatewayBindTaggedAddresses bool

+ EnvoyGatewayNoDefaultBind bool

+ func (p *ConsulGatewayProxy) Copy() *ConsulGatewayProxy

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

+ func (p *ConsulGatewayProxy) Validate() error

+ type ConsulGatewayTLSConfig struct

+ Enabled bool

+ func (c *ConsulGatewayTLSConfig) Copy() *ConsulGatewayTLSConfig

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

+ type ConsulIngressConfigEntry struct

+ Listeners []*ConsulIngressListener

+ TLS *ConsulGatewayTLSConfig

+ func (e *ConsulIngressConfigEntry) Copy() *ConsulIngressConfigEntry

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

+ func (e *ConsulIngressConfigEntry) Validate() error

+ type ConsulIngressListener struct

+ Port int

+ Protocol string

+ Services []*ConsulIngressService

+ func (l *ConsulIngressListener) Copy() *ConsulIngressListener

+ func (l *ConsulIngressListener) Equals(o *ConsulIngressListener) bool

+ func (l *ConsulIngressListener) Validate() error

+ type ConsulIngressService struct

+ Hosts []string

+ Name string

+ func (s *ConsulIngressService) Copy() *ConsulIngressService

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

+ func (s *ConsulIngressService) Validate(isHTTP bool) error

type Job

+ func (j *Job) ConfigEntries() map[string]*ConsulIngressConfigEntry

type JobDeregisterRequest

+ Global bool

+ type JobDescription struct

+ Expected int

+ ID string

+ Namespace string

+ type JobDescriptions map[string]JobNamespacedDescriptions

+ func (j JobDescriptions) Add(job *Job, expected int)

+ func (j JobDescriptions) Count() int

+ func (j JobDescriptions) Delete(job *Job)

+ type JobNamespacedDescriptions map[string]JobDescription

type TaskGroup

+ func (tg *TaskGroup) UsesConnectGateway() bool

type TaskKind

+ func (k TaskKind) IsAnyConnectGateway() bool

+ func (k TaskKind) IsConnectIngress() bool

Sep 3, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Aug 13, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Aug 12, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ var ErrCSIClientRPCIgnorable = errors.New("CSI client error (ignorable)")

+ var ErrCSIClientRPCRetryable = errors.New("CSI client error (retryable)")

+ var ErrUnknownNode = errors.New(ErrUnknownNodePrefix)

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

type CSIVolumeClaim

+ ExternalNodeID string

type CSIVolumeClaimRequest

+ ExternalNodeID string

+ type CSIVolumeUnpublishRequest struct

+ Claim *CSIVolumeClaim

+ VolumeID string

+ type CSIVolumeUnpublishResponse struct

type Job

+ VaultNamespace string

type JobScaleStatus

+ Namespace string

type ServiceCheck

+ FailuresBeforeCritical int

+ SuccessBeforePassing int

type Vault

+ Namespace string

Jul 23, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

type JobDeregisterRequest

+ Eval *Evaluation

type JobRegisterRequest

+ Eval *Evaluation

Jul 8, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Changes in this version

+ const AllNamespacesSentinel

+ const DeploymentStatusBlocked

+ const DeploymentStatusDescriptionBlocked

+ const DeploymentStatusDescriptionFailedByPeer

+ const DeploymentStatusDescriptionPendingForPeer

+ const DeploymentStatusDescriptionUnblocking

+ const DeploymentStatusPending

+ const DeploymentStatusUnblocking

+ const TaskMainDead

+ var ErrDeploymentRunningNoUnblock = errors.New(errDeploymentRunningNoUnblock)

+ var ErrDeploymentTerminalNoCancel = errors.New(errDeploymentTerminalNoCancel)

+ var ErrDeploymentTerminalNoFail = errors.New(errDeploymentTerminalNoFail)

+ var ErrDeploymentTerminalNoPause = errors.New(errDeploymentTerminalNoPause)

+ var ErrDeploymentTerminalNoPromote = errors.New(errDeploymentTerminalNoPromote)

+ var ErrDeploymentTerminalNoResume = errors.New(errDeploymentTerminalNoResume)

+ var ErrDeploymentTerminalNoRun = errors.New(errDeploymentTerminalNoRun)

+ var ErrDeploymentTerminalNoSetHealth = errors.New(errDeploymentTerminalNoSetHealth)

+ var ErrDeploymentTerminalNoUnblock = errors.New(errDeploymentTerminalNoUnblock)

+ func NodeNetworksEquals(n1, n2 []*NodeNetworkResource) bool

+ type AllocatedPortMapping struct

+ HostIP string

+ Label string

+ To int

+ Value int

+ type AllocatedPorts []AllocatedPortMapping

+ func (p AllocatedPorts) Get(label string) (AllocatedPortMapping, bool)

type AllocatedSharedResources

+ Ports AllocatedPorts

type CSIVolumeDeregisterRequest

+ Force bool

+ type ClientHostNetworkConfig struct

+ CIDR string

+ Interface string

+ Name string

+ ReservedPorts string

type ConsulConnect

+ func (c *ConsulConnect) IsNative() bool

+ type DNSConfig struct

+ Options []string

+ Searches []string

+ Servers []string

+ func (c *DNSConfig) Diff(other *DNSConfig, contextual bool) *ObjectDiff

type Deployment

+ IsMultiregion bool

+ type DeploymentCancelRequest struct

+ DeploymentID string

+ type DeploymentRunRequest struct

+ DeploymentID string

+ type DeploymentUnblockRequest struct

+ DeploymentID string

+ type HostDataRequest struct

+ NodeID string

+ ServerID string

+ type HostDataResponse struct

+ AgentID string

+ HostData *host.HostData

type Job

+ Multiregion *Multiregion

+ NomadTokenID string

+ func (j *Job) IsMultiregion() bool

+ func (j *Job) IsMultiregionStarter() bool

type JobListStub

+ Multiregion *Multiregion

+ Namespace string

type JobRegisterRequest

+ PreserveCounts bool

+ type Multiregion struct

+ Regions []*MultiregionRegion

+ Strategy *MultiregionStrategy

+ func (m *Multiregion) Canonicalize()

+ func (m *Multiregion) Copy() *Multiregion

+ func (m *Multiregion) Diff(m2 *Multiregion) bool

+ func (m *Multiregion) Validate(jobType string) error

+ type MultiregionRegion struct

+ Count int

+ Datacenters []string

+ Meta map[string]string

+ Name string

+ type MultiregionStrategy struct

+ MaxParallel int

+ OnFailure string

type NetworkIndex

+ AvailAddresses map[string][]NodeNetworkAddress

+ NodeNetworks []*NodeNetworkResource

+ func (idx *NetworkIndex) AddReservedPorts(ports AllocatedPorts) (collide bool)

+ func (idx *NetworkIndex) AddReservedPortsForIP(ports string, ip string) (collide bool)

+ func (idx *NetworkIndex) AssignPorts(ask *NetworkResource) (AllocatedPorts, error)

type NetworkResource

+ DNS *DNSConfig

+ func AllocatedPortsToNetworkResouce(ask *NetworkResource, ports AllocatedPorts, node *NodeResources) *NetworkResource

+ func (nr *NetworkResource) Hash() uint32

+ type NodeNetworkAF string

+ const NodeNetworkAF_IPv4

+ const NodeNetworkAF_IPv6

+ type NodeNetworkAddress struct

+ Address string

+ Alias string

+ Family NodeNetworkAF

+ Gateway string

+ ReservedPorts string

+ type NodeNetworkResource struct

+ Addresses []NodeNetworkAddress

+ Device string

+ MacAddress string

+ Mode string

+ Speed int

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

+ func (n *NodeNetworkResource) HasAlias(alias string) bool

type NodeResources

+ NodeNetworks []*NodeNetworkResource

type NodeUpdateResponse

+ Features uint64

type Port

+ HostNetwork string

type ScalingEvent

+ PreviousCount int64

type Service

+ TaskName string

+ type SnapshotRestoreRequest struct

+ type SnapshotRestoreResponse struct

+ ErrorCode int

+ ErrorMsg string

+ type SnapshotSaveRequest struct

+ type SnapshotSaveResponse struct

+ ErrorCode int

+ ErrorMsg string

+ SnapshotChecksum string

Jul 7, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jun 26, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jun 22, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Nov 19, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Nov 11, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Oct 23, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Oct 21, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Aug 7, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Jun 5, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

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

May 14, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

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

Apr 22, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

Apr 8, 2020 GO-2024-2670GO-2024-2671

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

  GO-2024-2671: CSI plugin names disclosure in github.com/hashicorp/nomad

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

Apr 7, 2020 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Apr 1, 2020 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Mar 25, 2020 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Nov 19, 2020 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Nov 11, 2020 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Oct 23, 2020 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Oct 21, 2020 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Mar 24, 2020 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Feb 19, 2020 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

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

Feb 12, 2020 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Jan 29, 2020 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Dec 4, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

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

Nov 22, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Nov 4, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Oct 22, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

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)

Oct 10, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Jul 9, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Sep 6, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Dec 4, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Oct 7, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Changes in this version

+ var ErrMissingAllocID = errors.New(errMissingAllocID)

Aug 21, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Changes in this version

type Evaluation

+ CreateTime int64

+ ModifyTime int64

+ func (e *Evaluation) UpdateModifyTime()

Jul 30, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

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

Jul 23, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Jun 12, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Changes in this version

type BatchNodeUpdateDrainRequest

+ UpdatedAt int64

type NodeUpdateDrainRequest

+ UpdatedAt int64

type NodeUpdateEligibilityRequest

+ UpdatedAt int64

type NodeUpdateStatusRequest

+ UpdatedAt int64

Jun 5, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

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

May 23, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Apr 29, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Apr 23, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Apr 9, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

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()

Apr 3, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Mar 22, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Feb 26, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Jan 30, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Jan 30, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Jan 11, 2019 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Changes in this version

type NamespacedID

+ func NewNamespacedID(id, ns string) NamespacedID

Dec 10, 2018 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Sep 26, 2018 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Changes in this version

+ const EvalTriggerQueuedAllocs

Sep 13, 2018 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Jun 11, 2018 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

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

Jun 1, 2018 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Apr 27, 2018 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Apr 26, 2018 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

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)

Apr 17, 2018 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Changes in this version

type DriverInfo

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

Apr 12, 2018 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

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)

Mar 30, 2018 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Dec 20, 2017 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

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()

Dec 12, 2017 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

Nov 1, 2017 GO-2024-2670

  GO-2024-2670: ACL security vulnerability in github.com/hashicorp/nomad

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

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)

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

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

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

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

Dec 21, 2016

Changes in this version

+ const TaskDriverMessage

type JobSpecificRequest

+ AllAllocs bool

type TaskEvent

+ DriverMessage string

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

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

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

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

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

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

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

Dec 18, 2015

Changes in this version

type Allocation

+ Services map[string]string

+ func (a *Allocation) PopulateServiceIDs()

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)

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)

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

Oct 5, 2015

Changes in this version

type Task

+ Env map[string]string

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