Versions in this module Expand all Collapse all v1 v1.2.7 Mar 15, 2022 Changes in this version + const AllNamespacesNamespace + const AllocClientStatusComplete + const AllocClientStatusFailed + const AllocClientStatusLost + const AllocClientStatusPending + const AllocClientStatusRunning + const AllocDesiredStatusEvict + const AllocDesiredStatusRun + const AllocDesiredStatusStop + const ConstraintAttributeIsNotSet + const ConstraintAttributeIsSet + const ConstraintDistinctHosts + const ConstraintDistinctProperty + const ConstraintRegex + const ConstraintSemver + const ConstraintSetContains + const ConstraintSetContainsAll + const ConstraintSetContainsAny + const ConstraintVersion + const DefaultNamespace + const DrainStatusCanceled + const DrainStatusComplete + const DrainStatusDraining + const GlobalRegion + const JobTypeBatch + const JobTypeService + const JobTypeSystem + const NodeEventSubsystemCluster + const NodeEventSubsystemDrain + const NodeEventSubsystemDriver + const NodeEventSubsystemHeartbeat + const NodeSchedulingEligible + const NodeSchedulingIneligible + const NodeStatusDown + const NodeStatusInit + const NodeStatusReady + const OnUpdateIgnore + const OnUpdateIgnoreWarn + const OnUpdateRequireHealthy + const OriginEnd + const OriginStart + const PeriodicSpecCron + const RegisterEnforceIndexErrPrefix + const RestartPolicyModeDelay + const RestartPolicyModeFail + const ScalingPolicyTypeHorizontal + const TaskArtifactDownloadFailed + const TaskBuildingTaskDir + const TaskDownloadingArtifacts + const TaskDriverFailure + const TaskDriverMessage + const TaskFailedValidation + const TaskKilled + const TaskKilling + const TaskLeaderDead + const TaskLifecycleHookPoststart + const TaskLifecycleHookPoststop + const TaskLifecycleHookPrestart + const TaskNotRestarting + const TaskReceived + const TaskRestartSignal + const TaskRestarting + const TaskSetup + const TaskSetupFailure + const TaskSiblingFailed + const TaskSignaling + const TaskStarted + const TaskTerminated + const VolumeMountPropagationBidirectional + const VolumeMountPropagationHostToTask + const VolumeMountPropagationPrivate + var ClientConnTimeout = 1 * time.Second + var NodeDownErr = fmt.Errorf("node down") + func ConfigureTLS(httpClient *http.Client, tlsConfig *TLSConfig) error + type ACLPolicies struct + func (a *ACLPolicies) Delete(policyName string, q *WriteOptions) (*WriteMeta, error) + func (a *ACLPolicies) Info(policyName string, q *QueryOptions) (*ACLPolicy, *QueryMeta, error) + func (a *ACLPolicies) List(q *QueryOptions) ([]*ACLPolicyListStub, *QueryMeta, error) + func (a *ACLPolicies) Upsert(policy *ACLPolicy, q *WriteOptions) (*WriteMeta, error) + type ACLPolicy struct + CreateIndex uint64 + Description string + ModifyIndex uint64 + Name string + Rules string + type ACLPolicyListStub struct + CreateIndex uint64 + Description string + ModifyIndex uint64 + Name string + type ACLToken struct + AccessorID string + CreateIndex uint64 + CreateTime time.Time + Global bool + ModifyIndex uint64 + Name string + Policies []string + SecretID string + Type string + type ACLTokenListStub struct + AccessorID string + CreateIndex uint64 + CreateTime time.Time + Global bool + ModifyIndex uint64 + Name string + Policies []string + Type string + type ACLTokens struct + func (a *ACLTokens) Bootstrap(q *WriteOptions) (*ACLToken, *WriteMeta, error) + func (a *ACLTokens) Create(token *ACLToken, q *WriteOptions) (*ACLToken, *WriteMeta, error) + func (a *ACLTokens) Delete(accessorID string, q *WriteOptions) (*WriteMeta, error) + func (a *ACLTokens) ExchangeOneTimeToken(secret string, q *WriteOptions) (*ACLToken, *WriteMeta, error) + func (a *ACLTokens) Info(accessorID string, q *QueryOptions) (*ACLToken, *QueryMeta, error) + func (a *ACLTokens) List(q *QueryOptions) ([]*ACLTokenListStub, *QueryMeta, error) + func (a *ACLTokens) Self(q *QueryOptions) (*ACLToken, *QueryMeta, error) + func (a *ACLTokens) Update(token *ACLToken, q *WriteOptions) (*ACLToken, *WriteMeta, error) + func (a *ACLTokens) UpsertOneTimeToken(q *WriteOptions) (*OneTimeToken, *WriteMeta, error) + type Affinity struct + LTarget string + Operand string + RTarget string + Weight *int8 + func NewAffinity(lTarget string, operand string, rTarget string, weight int8) *Affinity + func (a *Affinity) Canonicalize() + type Agent struct + func (a *Agent) CPUProfile(opts PprofOptions, q *QueryOptions) ([]byte, error) + func (a *Agent) Datacenter() (string, error) + func (a *Agent) ForceLeave(node string) error + func (a *Agent) GetSchedulerWorkerConfig(q *QueryOptions) (*SchedulerWorkerPoolArgs, error) + func (a *Agent) GetSchedulerWorkersInfo(q *QueryOptions) (*AgentSchedulerWorkersInfo, error) + func (a *Agent) Health() (*AgentHealthResponse, error) + func (a *Agent) Host(serverID, nodeID string, q *QueryOptions) (*HostDataResponse, error) + func (a *Agent) InstallKey(key string) (*KeyringResponse, error) + func (a *Agent) Join(addrs ...string) (int, error) + func (a *Agent) ListKeys() (*KeyringResponse, error) + func (a *Agent) Lookup(profile string, opts PprofOptions, q *QueryOptions) ([]byte, error) + func (a *Agent) Members() (*ServerMembers, error) + func (a *Agent) MembersOpts(opts *QueryOptions) (*ServerMembers, error) + func (a *Agent) Monitor(stopCh <-chan struct{}, q *QueryOptions) (<-chan *StreamFrame, <-chan error) + func (a *Agent) NodeName() (string, error) + func (a *Agent) Region() (string, error) + func (a *Agent) RemoveKey(key string) (*KeyringResponse, error) + func (a *Agent) Self() (*AgentSelf, error) + func (a *Agent) Servers() ([]string, error) + func (a *Agent) SetSchedulerWorkerConfig(args SchedulerWorkerPoolArgs, q *WriteOptions) (*SchedulerWorkerPoolArgs, error) + func (a *Agent) SetServers(addrs []string) error + func (a *Agent) Trace(opts PprofOptions, q *QueryOptions) ([]byte, error) + func (a *Agent) UseKey(key string) (*KeyringResponse, error) + type AgentHealth struct + Message string + Ok bool + type AgentHealthResponse struct + Client *AgentHealth + Server *AgentHealth + type AgentMember struct + Addr string + DelegateCur uint8 + DelegateMax uint8 + DelegateMin uint8 + Name string + Port uint16 + ProtocolCur uint8 + ProtocolMax uint8 + ProtocolMin uint8 + Status string + Tags map[string]string + type AgentMembersNameSort []*AgentMember + func (a AgentMembersNameSort) Len() int + func (a AgentMembersNameSort) Less(i, j int) bool + func (a AgentMembersNameSort) Swap(i, j int) + type AgentSchedulerWorkerConfigRequest struct + EnabledSchedulers []string + NumSchedulers int + type AgentSchedulerWorkerConfigResponse struct + EnabledSchedulers []string + NumSchedulers int + ServerID string + type AgentSchedulerWorkerInfo struct + EnabledSchedulers []string + ID string + Started string + Status string + WorkloadStatus string + type AgentSchedulerWorkersInfo struct + Schedulers []AgentSchedulerWorkerInfo + ServerID string + type AgentSelf struct + Config map[string]interface{} + Member AgentMember + Stats map[string]map[string]string + type AggregateSample struct + Count int + LastUpdated time.Time + Max float64 + Min float64 + Rate float64 + Sum float64 + SumSq float64 + type AllocDeploymentStatus struct + Canary bool + Healthy *bool + ModifyIndex uint64 + Timestamp time.Time + type AllocFS struct + func (a *AllocFS) Cat(alloc *Allocation, path string, q *QueryOptions) (io.ReadCloser, error) + func (a *AllocFS) List(alloc *Allocation, path string, q *QueryOptions) ([]*AllocFileInfo, *QueryMeta, error) + func (a *AllocFS) Logs(alloc *Allocation, follow bool, task, logType, origin string, offset int64, ...) (<-chan *StreamFrame, <-chan error) + func (a *AllocFS) ReadAt(alloc *Allocation, path string, offset int64, limit int64, q *QueryOptions) (io.ReadCloser, error) + func (a *AllocFS) Stat(alloc *Allocation, path string, q *QueryOptions) (*AllocFileInfo, *QueryMeta, error) + func (a *AllocFS) Stream(alloc *Allocation, path, origin string, offset int64, cancel <-chan struct{}, ...) (<-chan *StreamFrame, <-chan error) + type AllocFileInfo struct + ContentType string + FileMode string + IsDir bool + ModTime time.Time + Name string + Size int64 + type AllocIndexSort []*AllocationListStub + func (a AllocIndexSort) Len() int + func (a AllocIndexSort) Less(i, j int) bool + func (a AllocIndexSort) Swap(i, j int) + type AllocResourceUsage struct + ResourceUsage *ResourceUsage + Tasks map[string]*TaskResourceUsage + Timestamp int64 + type AllocSignalRequest struct + Signal string + Task string + type AllocStopResponse struct + EvalID string + type AllocatedCpuResources struct + CpuShares int64 + type AllocatedDeviceResource struct + DeviceIDs []string + Name string + Type string + Vendor string + type AllocatedMemoryResources struct + MemoryMB int64 + MemoryMaxMB int64 + type AllocatedResources struct + Shared AllocatedSharedResources + Tasks map[string]*AllocatedTaskResources + type AllocatedSharedResources struct + DiskMB int64 + Networks []*NetworkResource + Ports []PortMapping + type AllocatedTaskResources struct + Cpu AllocatedCpuResources + Devices []*AllocatedDeviceResource + Memory AllocatedMemoryResources + Networks []*NetworkResource + type Allocation struct + AllocModifyIndex uint64 + AllocatedResources *AllocatedResources + ClientDescription string + ClientStatus string + CreateIndex uint64 + CreateTime int64 + DeploymentID string + DeploymentStatus *AllocDeploymentStatus + DesiredDescription string + DesiredStatus string + DesiredTransition DesiredTransition + EvalID string + FollowupEvalID string + ID string + Job *Job + JobID string + Metrics *AllocationMetric + ModifyIndex uint64 + ModifyTime int64 + Name string + Namespace string + NextAllocation string + NodeID string + NodeName string + PreemptedAllocations []string + PreemptedByAllocation string + PreviousAllocation string + RescheduleTracker *RescheduleTracker + Resources *Resources + Services map[string]string + TaskGroup string + TaskResources map[string]*Resources + TaskStates map[string]*TaskState + func (a *Allocation) ClientTerminalStatus() bool + func (a *Allocation) ServerTerminalStatus() bool + func (a *Allocation) Stub() *AllocationListStub + func (a Allocation) GetTaskGroup() *TaskGroup + func (a Allocation) RescheduleInfo(t time.Time) (int, int) + type AllocationListStub struct + AllocatedResources *AllocatedResources + ClientDescription string + ClientStatus string + CreateIndex uint64 + CreateTime int64 + DeploymentStatus *AllocDeploymentStatus + DesiredDescription string + DesiredStatus string + EvalID string + FollowupEvalID string + ID string + JobID string + JobType string + JobVersion uint64 + ModifyIndex uint64 + ModifyTime int64 + Name string + Namespace string + NodeID string + NodeName string + PreemptedAllocations []string + PreemptedByAllocation string + RescheduleTracker *RescheduleTracker + TaskGroup string + TaskStates map[string]*TaskState + type AllocationMetric struct + AllocationTime time.Duration + ClassExhausted map[string]int + ClassFiltered map[string]int + CoalescedFailures int + ConstraintFiltered map[string]int + DimensionExhausted map[string]int + NodesAvailable map[string]int + NodesEvaluated int + NodesExhausted int + NodesFiltered int + QuotaExhausted []string + ResourcesExhausted map[string]*Resources + ScoreMetaData []*NodeScoreMeta + Scores map[string]float64 + type AllocationRestartRequest struct + TaskName string + type AllocationSort []*Allocation + func (a AllocationSort) Len() int + func (a AllocationSort) Less(i, j int) bool + func (a AllocationSort) Swap(i, j int) + type Allocations struct + func (a *Allocations) Exec(ctx context.Context, alloc *Allocation, task string, tty bool, ...) (exitCode int, err error) + func (a *Allocations) GC(alloc *Allocation, q *QueryOptions) error + func (a *Allocations) Info(allocID string, q *QueryOptions) (*Allocation, *QueryMeta, error) + func (a *Allocations) List(q *QueryOptions) ([]*AllocationListStub, *QueryMeta, error) + func (a *Allocations) PrefixList(prefix string) ([]*AllocationListStub, *QueryMeta, error) + func (a *Allocations) Restart(alloc *Allocation, taskName string, q *QueryOptions) error + func (a *Allocations) Signal(alloc *Allocation, q *QueryOptions, task, signal string) error + func (a *Allocations) Stats(alloc *Allocation, q *QueryOptions) (*AllocResourceUsage, error) + func (a *Allocations) Stop(alloc *Allocation, q *QueryOptions) (*AllocStopResponse, error) + type ApplyLicenseOptions struct + Force bool + type Attribute struct + BoolVal *bool + FloatVal *float64 + IntVal *int64 + StringVal *string + Unit string + func (a Attribute) String() string + type AutopilotConfiguration struct + CleanupDeadServers bool + CreateIndex uint64 + DisableUpgradeMigration bool + EnableCustomUpgrades bool + EnableRedundancyZones bool + LastContactThreshold time.Duration + MaxTrailingLogs uint64 + MinQuorum uint + ModifyIndex uint64 + ServerStabilizationTime time.Duration + func (u *AutopilotConfiguration) MarshalJSON() ([]byte, error) + func (u *AutopilotConfiguration) UnmarshalJSON(data []byte) error + type CSIControllerInfo struct + SupportsAttachDetach bool + SupportsClone bool + SupportsCondition bool + SupportsCreateDelete bool + SupportsCreateDeleteSnapshot bool + SupportsExpand bool + SupportsGet bool + SupportsGetCapacity bool + SupportsListSnapshots bool + SupportsListVolumes bool + SupportsListVolumesAttachedNodes bool + SupportsReadOnlyAttach bool + type CSIInfo struct + AllocID string + ControllerInfo *CSIControllerInfo + HealthDescription string + Healthy bool + NodeInfo *CSINodeInfo + PluginID string + RequiresControllerPlugin bool + RequiresTopologies bool + UpdateTime time.Time + type CSIMountOptions struct + ExtraKeysHCL []string + FSType string + MountFlags []string + type CSINodeInfo struct + AccessibleTopology *CSITopology + ID string + MaxVolumes int64 + RequiresNodeStageVolume bool + SupportsCondition bool + SupportsExpand bool + SupportsStats bool + type CSIPlugin struct + Allocations []*AllocationListStub + ControllerRequired bool + Controllers map[string]*CSIInfo + ControllersExpected int + ControllersHealthy int + CreateIndex uint64 + ID string + ModifyIndex uint64 + Nodes map[string]*CSIInfo + NodesExpected int + NodesHealthy int + Provider string + Version string + type CSIPluginIndexSort []*CSIPluginListStub + func (v CSIPluginIndexSort) Len() int + func (v CSIPluginIndexSort) Less(i, j int) bool + func (v CSIPluginIndexSort) Swap(i, j int) + 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 CSIPlugins struct + func (v *CSIPlugins) Info(id string, q *QueryOptions) (*CSIPlugin, *QueryMeta, error) + func (v *CSIPlugins) List(q *QueryOptions) ([]*CSIPluginListStub, *QueryMeta, error) + type CSISecrets map[string]string + 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 CSISnapshotListRequest struct + PluginID string + Secrets CSISecrets + type CSISnapshotListResponse struct + NextToken string + Snapshots []*CSISnapshot + type CSISnapshotSort []*CSISnapshot + func (v CSISnapshotSort) Len() int + func (v CSISnapshotSort) Less(i, j int) bool + func (v CSISnapshotSort) Swap(i, j int) + type CSITopology struct + Segments map[string]string + type CSITopologyRequest struct + Preferred []*CSITopology + Required []*CSITopology + type CSIVolume struct + AccessMode CSIVolumeAccessMode + Allocations []*AllocationListStub + AttachmentMode CSIVolumeAttachmentMode + Capacity int64 + CloneID string + Context map[string]string + ControllerRequired bool + ControllersExpected int + ControllersHealthy int + CreateIndex uint64 + ExternalID string + ExtraKeysHCL []string + ID string + ModifyIndex uint64 + MountOptions *CSIMountOptions + Name string + Namespace string + NodesExpected int + NodesHealthy int + Parameters map[string]string + PluginID string + Provider string + ProviderVersion string + ReadAllocs map[string]*Allocation + RequestedCapabilities []*CSIVolumeCapability + RequestedCapacityMax int64 + RequestedCapacityMin int64 + RequestedTopologies *CSITopologyRequest + ResourceExhausted time.Time + Schedulable bool + Secrets CSISecrets + SnapshotID string + Topologies []*CSITopology + WriteAllocs map[string]*Allocation + 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 CSIVolumeCapability struct + AccessMode CSIVolumeAccessMode + AttachmentMode CSIVolumeAttachmentMode + type CSIVolumeCreateRequest struct + Volumes []*CSIVolume + type CSIVolumeCreateResponse struct + Volumes []*CSIVolume + type CSIVolumeDeregisterRequest struct + VolumeIDs []string + type CSIVolumeExternalStub struct + CapacityBytes int64 + CloneID string + ExternalID string + IsAbnormal bool + PublishedExternalNodeIDs []string + SnapshotID string + Status string + VolumeContext map[string]string + type CSIVolumeExternalStubSort []*CSIVolumeExternalStub + func (v CSIVolumeExternalStubSort) Len() int + func (v CSIVolumeExternalStubSort) Less(i, j int) bool + func (v CSIVolumeExternalStubSort) Swap(i, j int) + type CSIVolumeIndexSort []*CSIVolumeListStub + func (v CSIVolumeIndexSort) Len() int + func (v CSIVolumeIndexSort) Less(i, j int) bool + func (v CSIVolumeIndexSort) Swap(i, j int) + type CSIVolumeListExternalResponse struct + NextToken string + Volumes []*CSIVolumeExternalStub + type CSIVolumeListStub struct + AccessMode CSIVolumeAccessMode + AttachmentMode CSIVolumeAttachmentMode + ControllerRequired bool + ControllersExpected int + ControllersHealthy int + CreateIndex uint64 + ExternalID string + ID string + ModifyIndex uint64 + Name string + Namespace string + NodesExpected int + NodesHealthy int + PluginID string + Provider string + ResourceExhausted time.Time + Schedulable bool + Topologies []*CSITopology + type CSIVolumeRegisterRequest struct + Volumes []*CSIVolume + type CSIVolumes struct + func (v *CSIVolumes) Create(vol *CSIVolume, w *WriteOptions) ([]*CSIVolume, *WriteMeta, error) + func (v *CSIVolumes) CreateSnapshot(snap *CSISnapshot, w *WriteOptions) (*CSISnapshotCreateResponse, *WriteMeta, error) + func (v *CSIVolumes) Delete(externalVolID string, w *WriteOptions) error + func (v *CSIVolumes) DeleteSnapshot(snap *CSISnapshot, w *WriteOptions) error + func (v *CSIVolumes) Deregister(id string, force bool, w *WriteOptions) error + func (v *CSIVolumes) Detach(volID, nodeID string, w *WriteOptions) error + func (v *CSIVolumes) Info(id string, q *QueryOptions) (*CSIVolume, *QueryMeta, error) + func (v *CSIVolumes) List(q *QueryOptions) ([]*CSIVolumeListStub, *QueryMeta, error) + func (v *CSIVolumes) ListExternal(pluginID string, q *QueryOptions) (*CSIVolumeListExternalResponse, *QueryMeta, error) + func (v *CSIVolumes) ListSnapshots(pluginID string, secrets string, q *QueryOptions) (*CSISnapshotListResponse, *QueryMeta, error) + func (v *CSIVolumes) ListSnapshotsOpts(req *CSISnapshotListRequest) (*CSISnapshotListResponse, *QueryMeta, error) + func (v *CSIVolumes) PluginList(pluginID string) ([]*CSIVolumeListStub, *QueryMeta, error) + func (v *CSIVolumes) Register(vol *CSIVolume, w *WriteOptions) (*WriteMeta, error) + type CheckRestart struct + Grace *time.Duration + IgnoreWarnings bool + Limit int + func (c *CheckRestart) Canonicalize() + func (c *CheckRestart) Copy() *CheckRestart + func (c *CheckRestart) Merge(o *CheckRestart) *CheckRestart + type Client struct + func NewClient(config *Config) (*Client, error) + func (c *Client) ACLPolicies() *ACLPolicies + func (c *Client) ACLTokens() *ACLTokens + func (c *Client) Address() string + func (c *Client) Agent() *Agent + func (c *Client) AllocFS() *AllocFS + func (c *Client) Allocations() *Allocations + func (c *Client) CSIPlugins() *CSIPlugins + func (c *Client) CSIVolumes() *CSIVolumes + func (c *Client) Deployments() *Deployments + func (c *Client) Evaluations() *Evaluations + func (c *Client) EventStream() *EventStream + func (c *Client) GetNodeClient(nodeID string, q *QueryOptions) (*Client, error) + func (c *Client) GetNodeClientWithTimeout(nodeID string, timeout time.Duration, q *QueryOptions) (*Client, error) + func (c *Client) Jobs() *Jobs + func (c *Client) Namespaces() *Namespaces + func (c *Client) Nodes() *Nodes + func (c *Client) Operator() *Operator + func (c *Client) Quotas() *Quotas + func (c *Client) Raw() *Raw + func (c *Client) Recommendations() *Recommendations + func (c *Client) Regions() *Regions + func (c *Client) Scaling() *Scaling + func (c *Client) Search() *Search + func (c *Client) SentinelPolicies() *SentinelPolicies + func (c *Client) SetNamespace(namespace string) + func (c *Client) SetRegion(region string) + func (c *Client) SetSecretID(secretID string) + func (c *Client) Status() *Status + func (c *Client) System() *System + type Config struct + Address string + Headers http.Header + HttpAuth *HttpBasicAuth + HttpClient *http.Client + Namespace string + Region string + SecretID string + TLSConfig *TLSConfig + WaitTime time.Duration + func DefaultConfig() *Config + func (c *Config) ClientConfig(region, address string, tlsEnabled bool) *Config + type Constraint struct + LTarget string + Operand string + RTarget string + func NewConstraint(left, operand, right string) *Constraint + type Consul struct + Namespace string + func (c *Consul) Canonicalize() + func (c *Consul) Copy() *Consul + func (c *Consul) MergeNamespace(namespace *string) + type ConsulConnect struct + Gateway *ConsulGateway + Native bool + SidecarService *ConsulSidecarService + SidecarTask *SidecarTask + func (cc *ConsulConnect) Canonicalize() + type ConsulExposeConfig struct + Path []*ConsulExposePath + func (cec *ConsulExposeConfig) Canonicalize() + type ConsulExposePath struct + ListenerPort string + LocalPathPort int + Path string + Protocol string + type ConsulGateway struct + Ingress *ConsulIngressConfigEntry + Mesh *ConsulMeshConfigEntry + Proxy *ConsulGatewayProxy + Terminating *ConsulTerminatingConfigEntry + func (g *ConsulGateway) Canonicalize() + func (g *ConsulGateway) Copy() *ConsulGateway + type ConsulGatewayBindAddress struct + Address string + Name string + Port int + type ConsulGatewayProxy struct + Config map[string]interface{} + ConnectTimeout *time.Duration + EnvoyDNSDiscoveryType string + EnvoyGatewayBindAddresses map[string]*ConsulGatewayBindAddress + EnvoyGatewayBindTaggedAddresses bool + EnvoyGatewayNoDefaultBind bool + func (p *ConsulGatewayProxy) Canonicalize() + func (p *ConsulGatewayProxy) Copy() *ConsulGatewayProxy + type ConsulGatewayTLSConfig struct + Enabled bool + func (tc *ConsulGatewayTLSConfig) Canonicalize() + func (tc *ConsulGatewayTLSConfig) Copy() *ConsulGatewayTLSConfig + type ConsulIngressConfigEntry struct + Listeners []*ConsulIngressListener + TLS *ConsulGatewayTLSConfig + func (e *ConsulIngressConfigEntry) Canonicalize() + func (e *ConsulIngressConfigEntry) Copy() *ConsulIngressConfigEntry + type ConsulIngressListener struct + Port int + Protocol string + Services []*ConsulIngressService + func (l *ConsulIngressListener) Canonicalize() + func (l *ConsulIngressListener) Copy() *ConsulIngressListener + type ConsulIngressService struct + Hosts []string + Name string + func (s *ConsulIngressService) Canonicalize() + func (s *ConsulIngressService) Copy() *ConsulIngressService + type ConsulLinkedService struct + CAFile string + CertFile string + KeyFile string + Name string + SNI string + func (s *ConsulLinkedService) Canonicalize() + func (s *ConsulLinkedService) Copy() *ConsulLinkedService + type ConsulMeshConfigEntry struct + func (e *ConsulMeshConfigEntry) Canonicalize() + func (e *ConsulMeshConfigEntry) Copy() *ConsulMeshConfigEntry + type ConsulMeshGateway struct + Mode string + func (c *ConsulMeshGateway) Canonicalize() + func (c *ConsulMeshGateway) Copy() *ConsulMeshGateway + type ConsulProxy struct + Config map[string]interface{} + ExposeConfig *ConsulExposeConfig + LocalServiceAddress string + LocalServicePort int + Upstreams []*ConsulUpstream + func (cp *ConsulProxy) Canonicalize() + type ConsulSidecarService struct + DisableDefaultTCPCheck bool + Port string + Proxy *ConsulProxy + Tags []string + func (css *ConsulSidecarService) Canonicalize() + type ConsulTerminatingConfigEntry struct + Services []*ConsulLinkedService + func (e *ConsulTerminatingConfigEntry) Canonicalize() + func (e *ConsulTerminatingConfigEntry) Copy() *ConsulTerminatingConfigEntry + type ConsulUpstream struct + Datacenter string + DestinationName string + LocalBindAddress string + LocalBindPort int + MeshGateway *ConsulMeshGateway + func (cu *ConsulUpstream) Canonicalize() + func (cu *ConsulUpstream) Copy() *ConsulUpstream + type CpuStats struct + Measured []string + Percent float64 + SystemMode float64 + ThrottledPeriods uint64 + ThrottledTime uint64 + TotalTicks float64 + UserMode float64 + type DNSConfig struct + Options []string + Searches []string + Servers []string + type Deployment struct + CreateIndex uint64 + ID string + IsMultiregion bool + JobCreateIndex uint64 + JobID string + JobModifyIndex uint64 + JobSpecModifyIndex uint64 + JobVersion uint64 + ModifyIndex uint64 + Namespace string + Status string + StatusDescription string + TaskGroups map[string]*DeploymentState + type DeploymentAllocHealthRequest struct + DeploymentID string + HealthyAllocationIDs []string + UnhealthyAllocationIDs []string + type DeploymentFailRequest struct + DeploymentID string + type DeploymentIndexSort []*Deployment + func (d DeploymentIndexSort) Len() int + func (d DeploymentIndexSort) Less(i, j int) bool + func (d DeploymentIndexSort) Swap(i, j int) + 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 + ProgressDeadline time.Duration + Promoted bool + RequireProgressBy time.Time + UnhealthyAllocs int + type DeploymentUnblockRequest struct + DeploymentID string + type DeploymentUpdateResponse struct + DeploymentModifyIndex uint64 + EvalCreateIndex uint64 + EvalID string + RevertedJobVersion *uint64 + type Deployments struct + func (d *Deployments) Allocations(deploymentID string, q *QueryOptions) ([]*AllocationListStub, *QueryMeta, error) + func (d *Deployments) Fail(deploymentID string, q *WriteOptions) (*DeploymentUpdateResponse, *WriteMeta, error) + func (d *Deployments) Info(deploymentID string, q *QueryOptions) (*Deployment, *QueryMeta, error) + func (d *Deployments) List(q *QueryOptions) ([]*Deployment, *QueryMeta, error) + func (d *Deployments) Pause(deploymentID string, pause bool, q *WriteOptions) (*DeploymentUpdateResponse, *WriteMeta, error) + func (d *Deployments) PrefixList(prefix string) ([]*Deployment, *QueryMeta, error) + func (d *Deployments) PromoteAll(deploymentID string, q *WriteOptions) (*DeploymentUpdateResponse, *WriteMeta, error) + func (d *Deployments) PromoteGroups(deploymentID string, groups []string, q *WriteOptions) (*DeploymentUpdateResponse, *WriteMeta, error) + func (d *Deployments) SetAllocHealth(deploymentID string, healthy, unhealthy []string, q *WriteOptions) (*DeploymentUpdateResponse, *WriteMeta, error) + func (d *Deployments) Unblock(deploymentID string, q *WriteOptions) (*DeploymentUpdateResponse, *WriteMeta, error) + type DeregisterOptions struct + EvalPriority int + Global bool + NoShutdownDelay bool + Purge bool + type DesiredTransition struct + Migrate *bool + Reschedule *bool + func (d DesiredTransition) ShouldMigrate() bool + type DesiredUpdates struct + Canary uint64 + DestructiveUpdate uint64 + Ignore uint64 + InPlaceUpdate uint64 + Migrate uint64 + Place uint64 + Preemptions uint64 + Stop uint64 + type DeviceGroupStats struct + InstanceStats map[string]*DeviceStats + Name string + Type string + Vendor string + type DeviceStats struct + Stats *StatObject + Summary *StatValue + Timestamp time.Time + type DiskUsage struct + DiskMB int64 + UsedMB int64 + type DispatchPayloadConfig struct + File string + type DrainMetadata struct + AccessorID string + Meta map[string]string + StartedAt time.Time + Status DrainStatus + UpdatedAt time.Time + type DrainOptions struct + DrainSpec *DrainSpec + MarkEligible bool + Meta map[string]string + type DrainSpec struct + Deadline time.Duration + IgnoreSystemJobs bool + type DrainStatus string + type DrainStrategy struct + ForceDeadline time.Time + StartedAt time.Time + func (d *DrainStrategy) Equal(o *DrainStrategy) bool + func (d *DrainStrategy) String() string + type DriverInfo struct + Attributes map[string]string + Detected bool + HealthDescription string + Healthy bool + UpdateTime time.Time + type EphemeralDisk struct + Migrate *bool + SizeMB *int + Sticky *bool + func DefaultEphemeralDisk() *EphemeralDisk + func (e *EphemeralDisk) Canonicalize() + type EvalIndexSort []*Evaluation + func (e EvalIndexSort) Len() int + func (e EvalIndexSort) Less(i, j int) bool + func (e EvalIndexSort) Swap(i, j int) + type EvalOptions struct + ForceReschedule bool + type Evaluation struct + AnnotatePlan bool + BlockedEval string + ClassEligibility map[string]bool + CreateIndex uint64 + CreateTime int64 + DeploymentID string + EscapedComputedClass bool + FailedTGAllocs map[string]*AllocationMetric + ID string + JobID string + JobModifyIndex uint64 + ModifyIndex uint64 + ModifyTime int64 + Namespace string + NextEval string + NodeID string + NodeModifyIndex uint64 + PreviousEval string + Priority int + QueuedAllocations map[string]int + QuotaLimitReached string + SnapshotIndex uint64 + Status string + StatusDescription string + TriggeredBy string + Type string + Wait time.Duration + WaitUntil time.Time + type Evaluations struct + func (e *Evaluations) Allocations(evalID string, q *QueryOptions) ([]*AllocationListStub, *QueryMeta, error) + func (e *Evaluations) Info(evalID string, q *QueryOptions) (*Evaluation, *QueryMeta, error) + func (e *Evaluations) List(q *QueryOptions) ([]*Evaluation, *QueryMeta, error) + func (e *Evaluations) PrefixList(prefix string) ([]*Evaluation, *QueryMeta, error) + type Event struct + FilterKeys []string + Index uint64 + Key string + Payload map[string]interface{} + Topic Topic + Type string + func (e *Event) Allocation() (*Allocation, error) + func (e *Event) Deployment() (*Deployment, error) + func (e *Event) Evaluation() (*Evaluation, error) + func (e *Event) Job() (*Job, error) + func (e *Event) Node() (*Node, error) + type EventStream struct + func (e *EventStream) Stream(ctx context.Context, topics map[Topic][]string, index uint64, q *QueryOptions) (<-chan *Events, error) + type Events struct + Err error + Events []Event + Index uint64 + func (e *Events) IsHeartbeat() bool + type ExecStreamingExitResult struct + ExitCode int + type ExecStreamingIOOperation struct + Close bool + Data []byte + type ExecStreamingInput struct + Stdin *ExecStreamingIOOperation + TTYSize *TerminalSize + type ExecStreamingOutput struct + Exited bool + Result *ExecStreamingExitResult + Stderr *ExecStreamingIOOperation + Stdout *ExecStreamingIOOperation + type FieldDiff struct + Annotations []string + Name string + New string + Old string + Type string + type FrameReader struct + func NewFrameReader(frames <-chan *StreamFrame, errCh <-chan error, cancelCh chan struct{}) *FrameReader + func (f *FrameReader) Close() error + func (f *FrameReader) Offset() int + func (f *FrameReader) Read(p []byte) (n int, err error) + func (f *FrameReader) SetUnblockTime(d time.Duration) + type FuzzyMatch struct + ID string + Scope []string + type FuzzySearchRequest struct + Context contexts.Context + Text string + type FuzzySearchResponse struct + Matches map[contexts.Context][]FuzzyMatch + Truncations map[contexts.Context]bool + type GaugeValue struct + DisplayLabels map[string]string + Hash string + Labels []Label + Name string + Value float32 + type GenericResponse struct + type HostCPUStats struct + CPU string + Idle float64 + System float64 + User float64 + type HostData struct + Disk map[string]DiskUsage + Environment map[string]string + Hosts string + Network []map[string]string + OS string + ResolvConf string + type HostDataResponse struct + AgentID string + HostData *HostData + type HostDiskStats struct + Available uint64 + Device string + InodesUsedPercent float64 + Mountpoint string + Size uint64 + Used uint64 + UsedPercent float64 + type HostMemoryStats struct + Available uint64 + Free uint64 + Total uint64 + Used uint64 + type HostNetworkInfo struct + CIDR string + Interface string + Name string + ReservedPorts string + type HostStats struct + CPU []*HostCPUStats + CPUTicksConsumed float64 + DeviceStats []*DeviceGroupStats + DiskStats []*HostDiskStats + Memory *HostMemoryStats + Uptime uint64 + type HostVolumeInfo struct + Path string + ReadOnly bool + type HttpBasicAuth struct + Password string + Username string + type Job struct + Affinities []*Affinity + AllAtOnce *bool + Constraints []*Constraint + ConsulNamespace *string + ConsulToken *string + CreateIndex *uint64 + Datacenters []string + DispatchIdempotencyToken *string + Dispatched bool + ID *string + JobModifyIndex *uint64 + Meta map[string]string + Migrate *MigrateStrategy + ModifyIndex *uint64 + Multiregion *Multiregion + Name *string + Namespace *string + NomadTokenID *string + ParameterizedJob *ParameterizedJobConfig + ParentID *string + Payload []byte + Periodic *PeriodicConfig + Priority *int + Region *string + Reschedule *ReschedulePolicy + Spreads []*Spread + Stable *bool + Status *string + StatusDescription *string + Stop *bool + SubmitTime *int64 + TaskGroups []*TaskGroup + Type *string + Update *UpdateStrategy + VaultNamespace *string + VaultToken *string + Version *uint64 + func NewBatchJob(id, name, region string, pri int) *Job + func NewServiceJob(id, name, region string, pri int) *Job + func NewSystemJob(id, name, region string, pri int) *Job + func (j *Job) AddAffinity(a *Affinity) *Job + func (j *Job) AddDatacenter(dc string) *Job + func (j *Job) AddPeriodicConfig(cfg *PeriodicConfig) *Job + func (j *Job) AddSpread(s *Spread) *Job + func (j *Job) AddTaskGroup(grp *TaskGroup) *Job + func (j *Job) Canonicalize() + func (j *Job) Constrain(c *Constraint) *Job + func (j *Job) IsMultiregion() bool + func (j *Job) IsParameterized() bool + func (j *Job) IsPeriodic() bool + func (j *Job) LookupTaskGroup(name string) *TaskGroup + func (j *Job) SetMeta(key, val string) *Job + type JobChildrenSummary struct + Dead int64 + Pending int64 + Running int64 + func (jc *JobChildrenSummary) Sum() int + type JobDeregisterResponse struct + EvalCreateIndex uint64 + EvalID string + JobModifyIndex uint64 + type JobDiff struct + Fields []*FieldDiff + ID string + Objects []*ObjectDiff + TaskGroups []*TaskGroupDiff + Type string + type JobDispatchRequest struct + JobID string + Meta map[string]string + Payload []byte + type JobDispatchResponse struct + DispatchedJobID string + EvalCreateIndex uint64 + EvalID string + JobCreateIndex uint64 + type JobEvaluateRequest struct + EvalOptions EvalOptions + JobID string + type JobIDSort []*JobListStub + func (j JobIDSort) Len() int + func (j JobIDSort) Less(a, b int) bool + func (j JobIDSort) Swap(a, b int) + type JobListStub struct + CreateIndex uint64 + Datacenters []string + ID string + JobModifyIndex uint64 + JobSummary *JobSummary + ModifyIndex uint64 + Name string + Namespace string + ParameterizedJob bool + ParentID string + Periodic bool + Priority int + Status string + StatusDescription string + Stop bool + SubmitTime int64 + Type string + type JobPlanRequest struct + Diff bool + Job *Job + PolicyOverride bool + type JobPlanResponse struct + Annotations *PlanAnnotations + CreatedEvals []*Evaluation + Diff *JobDiff + FailedTGAllocs map[string]*AllocationMetric + JobModifyIndex uint64 + NextPeriodicLaunch time.Time + Warnings string + type JobRegisterRequest struct + EnforceIndex bool + EvalPriority int + Job *Job + JobModifyIndex uint64 + PolicyOverride bool + PreserveCounts bool + type JobRegisterResponse struct + EvalCreateIndex uint64 + EvalID string + JobModifyIndex uint64 + Warnings string + type JobRevertRequest struct + ConsulToken string + EnforcePriorVersion *uint64 + JobID string + JobVersion uint64 + VaultToken string + type JobScaleStatusResponse struct + JobCreateIndex uint64 + JobID string + JobModifyIndex uint64 + JobStopped bool + Namespace string + TaskGroups map[string]TaskGroupScaleStatus + type JobStabilityRequest struct + JobID string + JobVersion uint64 + Stable bool + type JobStabilityResponse struct + JobModifyIndex uint64 + type JobSummary struct + Children *JobChildrenSummary + CreateIndex uint64 + JobID string + ModifyIndex uint64 + Namespace string + Summary map[string]TaskGroupSummary + type JobValidateRequest struct + Job *Job + type JobValidateResponse struct + DriverConfigValidated bool + Error string + ValidationErrors []string + Warnings string + type JobVersionsResponse struct + Diffs []*JobDiff + Versions []*Job + type Jobs struct + func (j *Jobs) Allocations(jobID string, allAllocs bool, q *QueryOptions) ([]*AllocationListStub, *QueryMeta, error) + func (j *Jobs) Deployments(jobID string, all bool, q *QueryOptions) ([]*Deployment, *QueryMeta, error) + func (j *Jobs) Deregister(jobID string, purge bool, q *WriteOptions) (string, *WriteMeta, error) + func (j *Jobs) DeregisterOpts(jobID string, opts *DeregisterOptions, q *WriteOptions) (string, *WriteMeta, error) + func (j *Jobs) Dispatch(jobID string, meta map[string]string, payload []byte, q *WriteOptions) (*JobDispatchResponse, *WriteMeta, error) + func (j *Jobs) EnforceRegister(job *Job, modifyIndex uint64, q *WriteOptions) (*JobRegisterResponse, *WriteMeta, error) + func (j *Jobs) EvaluateWithOpts(jobID string, opts EvalOptions, q *WriteOptions) (string, *WriteMeta, error) + func (j *Jobs) Evaluations(jobID string, q *QueryOptions) ([]*Evaluation, *QueryMeta, error) + func (j *Jobs) ForceEvaluate(jobID string, q *WriteOptions) (string, *WriteMeta, error) + func (j *Jobs) Info(jobID string, q *QueryOptions) (*Job, *QueryMeta, error) + func (j *Jobs) LatestDeployment(jobID string, q *QueryOptions) (*Deployment, *QueryMeta, error) + func (j *Jobs) List(q *QueryOptions) ([]*JobListStub, *QueryMeta, error) + func (j *Jobs) ParseHCL(jobHCL string, canonicalize bool) (*Job, error) + func (j *Jobs) PeriodicForce(jobID string, q *WriteOptions) (string, *WriteMeta, error) + func (j *Jobs) Plan(job *Job, diff bool, q *WriteOptions) (*JobPlanResponse, *WriteMeta, error) + func (j *Jobs) PlanOpts(job *Job, opts *PlanOptions, q *WriteOptions) (*JobPlanResponse, *WriteMeta, error) + func (j *Jobs) PrefixList(prefix string) ([]*JobListStub, *QueryMeta, error) + func (j *Jobs) Register(job *Job, q *WriteOptions) (*JobRegisterResponse, *WriteMeta, error) + func (j *Jobs) RegisterOpts(job *Job, opts *RegisterOptions, q *WriteOptions) (*JobRegisterResponse, *WriteMeta, error) + func (j *Jobs) Revert(jobID string, version uint64, enforcePriorVersion *uint64, q *WriteOptions, ...) (*JobRegisterResponse, *WriteMeta, error) + func (j *Jobs) Scale(jobID, group string, count *int, message string, error bool, ...) (*JobRegisterResponse, *WriteMeta, error) + func (j *Jobs) ScaleStatus(jobID string, q *QueryOptions) (*JobScaleStatusResponse, *QueryMeta, error) + func (j *Jobs) Stable(jobID string, version uint64, stable bool, q *WriteOptions) (*JobStabilityResponse, *WriteMeta, error) + func (j *Jobs) Summary(jobID string, q *QueryOptions) (*JobSummary, *QueryMeta, error) + func (j *Jobs) Validate(job *Job, q *WriteOptions) (*JobValidateResponse, *WriteMeta, error) + func (j *Jobs) Versions(jobID string, diffs bool, q *QueryOptions) ([]*Job, []*JobDiff, *QueryMeta, error) + type JobsParseRequest struct + Canonicalize bool + HCLv1 bool + JobHCL string + type KeyringRequest struct + Key string + type KeyringResponse struct + Keys map[string]int + Messages map[string]string + NumNodes int + type Label struct + Name string + Value string + type License struct + CustomerID string + ExpirationTime time.Time + Features []string + Flags map[string]interface{} + InstallationID string + IssueTime time.Time + LicenseID string + Modules []string + Product string + StartTime time.Time + TerminationTime time.Time + type LicenseReply struct + ConfigOutdated bool + License *License + type LogConfig struct + MaxFileSizeMB *int + MaxFiles *int + func DefaultLogConfig() *LogConfig + func (l *LogConfig) Canonicalize() + type MemoryStats struct + Cache uint64 + KernelMaxUsage uint64 + KernelUsage uint64 + MaxUsage uint64 + Measured []string + RSS uint64 + Swap uint64 + Usage uint64 + type MetricsSummary struct + Counters []SampledValue + Gauges []GaugeValue + Points []PointValue + Samples []SampledValue + Timestamp string + type MigrateStrategy struct + HealthCheck *string + HealthyDeadline *time.Duration + MaxParallel *int + MinHealthyTime *time.Duration + func DefaultMigrateStrategy() *MigrateStrategy + func (m *MigrateStrategy) Canonicalize() + func (m *MigrateStrategy) Copy() *MigrateStrategy + func (m *MigrateStrategy) Merge(o *MigrateStrategy) + type MonitorMessage struct + Level MonitorMsgLevel + Message string + func Messagef(lvl MonitorMsgLevel, msg string, args ...interface{}) *MonitorMessage + func (m *MonitorMessage) String() string + type MonitorMsgLevel int + const MonitorMsgLevelError + const MonitorMsgLevelInfo + const MonitorMsgLevelNormal + const MonitorMsgLevelWarn + type Multiregion struct + Regions []*MultiregionRegion + Strategy *MultiregionStrategy + func (m *Multiregion) Canonicalize() + func (m *Multiregion) Copy() *Multiregion + type MultiregionRegion struct + Count *int + Datacenters []string + Meta map[string]string + Name string + type MultiregionStrategy struct + MaxParallel *int + OnFailure *string + type Namespace struct + Capabilities *NamespaceCapabilities + CreateIndex uint64 + Description string + Meta map[string]string + ModifyIndex uint64 + Name string + Quota string + type NamespaceCapabilities struct + DisabledTaskDrivers []string + EnabledTaskDrivers []string + type NamespaceIndexSort []*Namespace + func (n NamespaceIndexSort) Len() int + func (n NamespaceIndexSort) Less(i, j int) bool + func (n NamespaceIndexSort) Swap(i, j int) + type Namespaces struct + func (n *Namespaces) Delete(namespace string, q *WriteOptions) (*WriteMeta, error) + func (n *Namespaces) Info(name string, q *QueryOptions) (*Namespace, *QueryMeta, error) + func (n *Namespaces) List(q *QueryOptions) ([]*Namespace, *QueryMeta, error) + func (n *Namespaces) PrefixList(prefix string, q *QueryOptions) ([]*Namespace, *QueryMeta, error) + func (n *Namespaces) Register(namespace *Namespace, q *WriteOptions) (*WriteMeta, error) + type NetworkResource struct + CIDR string + DNS *DNSConfig + Device string + DynamicPorts []Port + Hostname string + IP string + MBits *int + Mode string + ReservedPorts []Port + func (n *NetworkResource) Canonicalize() + func (n *NetworkResource) HasPorts() bool + func (n *NetworkResource) Megabits() int + type Node struct + Attributes map[string]string + CSIControllerPlugins map[string]*CSIInfo + CSINodePlugins map[string]*CSIInfo + CreateIndex uint64 + Datacenter string + Drain bool + DrainStrategy *DrainStrategy + Drivers map[string]*DriverInfo + Events []*NodeEvent + HTTPAddr string + HostNetworks map[string]*HostNetworkInfo + HostVolumes map[string]*HostVolumeInfo + ID string + LastDrain *DrainMetadata + Links map[string]string + Meta map[string]string + ModifyIndex uint64 + Name string + NodeClass string + NodeResources *NodeResources + Reserved *Resources + ReservedResources *NodeReservedResources + Resources *Resources + SchedulingEligibility string + Status string + StatusDescription string + StatusUpdatedAt int64 + TLSEnabled bool + type NodeCpuResources struct + CpuShares int64 + ReservableCpuCores []uint16 + TotalCpuCores uint16 + type NodeDevice struct + HealthDescription string + Healthy bool + ID string + Locality *NodeDeviceLocality + type NodeDeviceLocality struct + PciBusID string + type NodeDeviceResource struct + Attributes map[string]*Attribute + Instances []*NodeDevice + Name string + Type string + Vendor string + func (r NodeDeviceResource) ID() string + type NodeDiskResources struct + DiskMB int64 + type NodeDrainUpdateResponse struct + EvalCreateIndex uint64 + EvalIDs []string + NodeModifyIndex uint64 + type NodeEligibilityUpdateResponse struct + EvalCreateIndex uint64 + EvalIDs []string + NodeModifyIndex uint64 + type NodeEvent struct + CreateIndex uint64 + Details map[string]string + Message string + Subsystem string + Timestamp time.Time + type NodeIndexSort []*NodeListStub + func (n NodeIndexSort) Len() int + func (n NodeIndexSort) Less(i, j int) bool + func (n NodeIndexSort) Swap(i, j int) + type NodeListStub struct + Address string + CreateIndex uint64 + Datacenter string + Drain bool + Drivers map[string]*DriverInfo + ID string + LastDrain *DrainMetadata + ModifyIndex uint64 + Name string + NodeClass string + NodeResources *NodeResources + ReservedResources *NodeReservedResources + SchedulingEligibility string + Status string + StatusDescription string + Version string + type NodeMemoryResources struct + MemoryMB int64 + type NodePurgeResponse struct + EvalCreateIndex uint64 + EvalIDs []string + NodeModifyIndex uint64 + type NodeReservedCpuResources struct + CpuShares uint64 + type NodeReservedDiskResources struct + DiskMB uint64 + type NodeReservedMemoryResources struct + MemoryMB uint64 + type NodeReservedNetworkResources struct + ReservedHostPorts string + type NodeReservedResources struct + Cpu NodeReservedCpuResources + Disk NodeReservedDiskResources + Memory NodeReservedMemoryResources + Networks NodeReservedNetworkResources + type NodeResources struct + Cpu NodeCpuResources + Devices []*NodeDeviceResource + Disk NodeDiskResources + MaxDynamicPort int + Memory NodeMemoryResources + MinDynamicPort int + Networks []*NetworkResource + type NodeScoreMeta struct + NodeID string + NormScore float64 + Scores map[string]float64 + type NodeUpdateDrainRequest struct + DrainSpec *DrainSpec + MarkEligible bool + Meta map[string]string + NodeID string + type NodeUpdateEligibilityRequest struct + Eligibility string + NodeID string + type Nodes struct + func (n *Nodes) Allocations(nodeID string, q *QueryOptions) ([]*Allocation, *QueryMeta, error) + func (n *Nodes) CSIVolumes(nodeID string, q *QueryOptions) ([]*CSIVolumeListStub, error) + func (n *Nodes) ForceEvaluate(nodeID string, q *WriteOptions) (string, *WriteMeta, error) + func (n *Nodes) GC(nodeID string, q *QueryOptions) error + func (n *Nodes) GcAlloc(allocID string, q *QueryOptions) error + func (n *Nodes) Info(nodeID string, q *QueryOptions) (*Node, *QueryMeta, error) + func (n *Nodes) List(q *QueryOptions) ([]*NodeListStub, *QueryMeta, error) + func (n *Nodes) MonitorDrain(ctx context.Context, nodeID string, index uint64, ignoreSys bool) <-chan *MonitorMessage + func (n *Nodes) PrefixList(prefix string) ([]*NodeListStub, *QueryMeta, error) + func (n *Nodes) PrefixListOpts(prefix string, opts *QueryOptions) ([]*NodeListStub, *QueryMeta, error) + func (n *Nodes) Purge(nodeID string, q *QueryOptions) (*NodePurgeResponse, *QueryMeta, error) + func (n *Nodes) Stats(nodeID string, q *QueryOptions) (*HostStats, error) + func (n *Nodes) ToggleEligibility(nodeID string, eligible bool, q *WriteOptions) (*NodeEligibilityUpdateResponse, error) + func (n *Nodes) UpdateDrain(nodeID string, spec *DrainSpec, markEligible bool, q *WriteOptions) (*NodeDrainUpdateResponse, error) + func (n *Nodes) UpdateDrainOpts(nodeID string, opts *DrainOptions, q *WriteOptions) (*NodeDrainUpdateResponse, error) + type ObjectDiff struct + Fields []*FieldDiff + Name string + Objects []*ObjectDiff + Type string + type OneTimeToken struct + AccessorID string + CreateIndex uint64 + ExpiresAt time.Time + ModifyIndex uint64 + OneTimeSecretID string + type OneTimeTokenExchangeRequest struct + OneTimeSecretID string + type OneTimeTokenExchangeResponse struct + Token *ACLToken + type OneTimeTokenUpsertResponse struct + OneTimeToken *OneTimeToken + type Operator struct + func (op *Operator) ApplyLicense(license string, opts *ApplyLicenseOptions, q *WriteOptions) (*WriteMeta, error) + func (op *Operator) AutopilotCASConfiguration(conf *AutopilotConfiguration, q *WriteOptions) (bool, *WriteMeta, error) + func (op *Operator) AutopilotGetConfiguration(q *QueryOptions) (*AutopilotConfiguration, *QueryMeta, error) + func (op *Operator) AutopilotServerHealth(q *QueryOptions) (*OperatorHealthReply, *QueryMeta, error) + func (op *Operator) AutopilotSetConfiguration(conf *AutopilotConfiguration, q *WriteOptions) (*WriteMeta, error) + func (op *Operator) LicenseGet(q *QueryOptions) (*LicenseReply, *QueryMeta, error) + func (op *Operator) LicensePut(license string, q *WriteOptions) (*WriteMeta, error) + func (op *Operator) Metrics(q *QueryOptions) ([]byte, error) + func (op *Operator) MetricsSummary(q *QueryOptions) (*MetricsSummary, *QueryMeta, error) + func (op *Operator) RaftGetConfiguration(q *QueryOptions) (*RaftConfiguration, error) + func (op *Operator) RaftRemovePeerByAddress(address string, q *WriteOptions) error + func (op *Operator) RaftRemovePeerByID(id string, q *WriteOptions) error + func (op *Operator) SchedulerCASConfiguration(conf *SchedulerConfiguration, q *WriteOptions) (*SchedulerSetConfigurationResponse, *WriteMeta, error) + func (op *Operator) SchedulerGetConfiguration(q *QueryOptions) (*SchedulerConfigurationResponse, *QueryMeta, error) + func (op *Operator) SchedulerSetConfiguration(conf *SchedulerConfiguration, q *WriteOptions) (*SchedulerSetConfigurationResponse, *WriteMeta, error) + func (op *Operator) Snapshot(q *QueryOptions) (io.ReadCloser, error) + func (op *Operator) SnapshotRestore(in io.Reader, q *WriteOptions) (*WriteMeta, error) + type OperatorHealthReply struct + FailureTolerance int + Healthy bool + Servers []ServerHealth + type ParameterizedJobConfig struct + MetaOptional []string + MetaRequired []string + Payload string + type PeriodicConfig struct + Enabled *bool + ProhibitOverlap *bool + Spec *string + SpecType *string + TimeZone *string + func (p *PeriodicConfig) Canonicalize() + func (p *PeriodicConfig) GetLocation() (*time.Location, error) + func (p *PeriodicConfig) Next(fromTime time.Time) (time.Time, error) + type PlanAnnotations struct + DesiredTGUpdates map[string]*DesiredUpdates + PreemptedAllocs []*AllocationListStub + type PlanOptions struct + Diff bool + PolicyOverride bool + type PointValue struct + Name string + Points []float32 + type Port struct + HostNetwork string + Label string + To int + Value int + type PortMapping struct + HostIP string + Label string + To int + Value int + type PprofOptions struct + Debug int + GC int + NodeID string + Seconds int + ServerID string + type PreemptionConfig struct + BatchSchedulerEnabled bool + ServiceSchedulerEnabled bool + SysBatchSchedulerEnabled bool + SystemSchedulerEnabled bool + type QueryMeta struct + KnownLeader bool + LastContact time.Duration + LastIndex uint64 + NextToken string + RequestTime time.Duration + type QueryOptions struct + AllowStale bool + AuthToken string + Filter string + Headers map[string]string + Namespace string + NextToken string + Params map[string]string + PerPage int32 + Prefix string + Region string + Reverse bool + WaitIndex uint64 + WaitTime time.Duration + func (o *QueryOptions) Context() context.Context + func (o *QueryOptions) WithContext(ctx context.Context) *QueryOptions + func (q *QueryOptions) SetHeadersFromCSISecrets(secrets CSISecrets) + type QuotaLimit struct + Hash []byte + Region string + RegionLimit *Resources + type QuotaLimitSort []*QuotaLimit + func (q QuotaLimitSort) Len() int + func (q QuotaLimitSort) Less(i, j int) bool + func (q QuotaLimitSort) Swap(i, j int) + type QuotaSpec struct + CreateIndex uint64 + Description string + Limits []*QuotaLimit + ModifyIndex uint64 + Name string + type QuotaSpecIndexSort []*QuotaSpec + func (q QuotaSpecIndexSort) Len() int + func (q QuotaSpecIndexSort) Less(i, j int) bool + func (q QuotaSpecIndexSort) Swap(i, j int) + type QuotaUsage struct + CreateIndex uint64 + ModifyIndex uint64 + Name string + Used map[string]*QuotaLimit + type QuotaUsageIndexSort []*QuotaUsage + func (q QuotaUsageIndexSort) Len() int + func (q QuotaUsageIndexSort) Less(i, j int) bool + func (q QuotaUsageIndexSort) Swap(i, j int) + type Quotas struct + func (q *Quotas) Delete(quota string, qo *WriteOptions) (*WriteMeta, error) + func (q *Quotas) Info(name string, qo *QueryOptions) (*QuotaSpec, *QueryMeta, error) + func (q *Quotas) List(qo *QueryOptions) ([]*QuotaSpec, *QueryMeta, error) + func (q *Quotas) ListUsage(qo *QueryOptions) ([]*QuotaUsage, *QueryMeta, error) + func (q *Quotas) PrefixList(prefix string, qo *QueryOptions) ([]*QuotaSpec, *QueryMeta, error) + func (q *Quotas) PrefixListUsage(prefix string, qo *QueryOptions) ([]*QuotaUsage, *QueryMeta, error) + func (q *Quotas) Register(spec *QuotaSpec, qo *WriteOptions) (*WriteMeta, error) + func (q *Quotas) Usage(name string, qo *QueryOptions) (*QuotaUsage, *QueryMeta, error) + type RaftConfiguration struct + Index uint64 + Servers []*RaftServer + type RaftServer struct + Address string + ID string + Leader bool + Node string + RaftProtocol string + Voter bool + type Raw struct + func (raw *Raw) Delete(endpoint string, out interface{}, q *WriteOptions) (*WriteMeta, error) + func (raw *Raw) Query(endpoint string, out interface{}, q *QueryOptions) (*QueryMeta, error) + func (raw *Raw) Response(endpoint string, q *QueryOptions) (io.ReadCloser, error) + func (raw *Raw) Write(endpoint string, in, out interface{}, q *WriteOptions) (*WriteMeta, error) + type Recommendation struct + CreateIndex uint64 + Current int + EnforceVersion bool + Group string + ID string + JobID string + JobVersion uint64 + Meta map[string]interface{} + ModifyIndex uint64 + Namespace string + Region string + Resource string + Stats map[string]float64 + SubmitTime int64 + Task string + Value int + type RecommendationApplyRequest struct + Apply []string + Dismiss []string + PolicyOverride bool + type RecommendationApplyResponse struct + Errors []*SingleRecommendationApplyError + UpdatedJobs []*SingleRecommendationApplyResult + type Recommendations struct + func (r *Recommendations) Apply(ids []string, policyOverride bool) (*RecommendationApplyResponse, *WriteMeta, error) + func (r *Recommendations) Delete(ids []string, q *WriteOptions) (*WriteMeta, error) + func (r *Recommendations) Info(id string, q *QueryOptions) (*Recommendation, *QueryMeta, error) + func (r *Recommendations) List(q *QueryOptions) ([]*Recommendation, *QueryMeta, error) + func (r *Recommendations) Upsert(rec *Recommendation, q *WriteOptions) (*Recommendation, *WriteMeta, error) + type Regions struct + func (r *Regions) List() ([]string, error) + type RegisterOptions struct + EnforceIndex bool + EvalPriority int + ModifyIndex uint64 + PolicyOverride bool + PreserveCounts bool + type RequestedDevice struct + Affinities []*Affinity + Constraints []*Constraint + Count *uint64 + Name string + func (d *RequestedDevice) Canonicalize() + type RescheduleEvent struct + PrevAllocID string + PrevNodeID string + RescheduleTime int64 + type ReschedulePolicy struct + Attempts *int + Delay *time.Duration + DelayFunction *string + Interval *time.Duration + MaxDelay *time.Duration + Unlimited *bool + func NewDefaultReschedulePolicy(jobType string) *ReschedulePolicy + func (p *ReschedulePolicy) String() string + func (r *ReschedulePolicy) Canonicalize(jobType string) + func (r *ReschedulePolicy) Copy() *ReschedulePolicy + func (r *ReschedulePolicy) Merge(rp *ReschedulePolicy) + type RescheduleTracker struct + Events []*RescheduleEvent + type ResourceUsage struct + CpuStats *CpuStats + DeviceStats []*DeviceGroupStats + MemoryStats *MemoryStats + type Resources struct + CPU *int + Cores *int + Devices []*RequestedDevice + DiskMB *int + IOPS *int + MemoryMB *int + MemoryMaxMB *int + Networks []*NetworkResource + func DefaultResources() *Resources + func MinResources() *Resources + func (r *Resources) Canonicalize() + func (r *Resources) Merge(other *Resources) + type RestartPolicy struct + Attempts *int + Delay *time.Duration + Interval *time.Duration + Mode *string + func (r *RestartPolicy) Merge(rp *RestartPolicy) + type SampledValue struct + DisplayLabels map[string]string + Hash string + Labels []Label + Mean float64 + Name string + Stddev float64 + type Scaling struct + func (s *Scaling) GetPolicy(id string, q *QueryOptions) (*ScalingPolicy, *QueryMeta, error) + func (s *Scaling) ListPolicies(q *QueryOptions) ([]*ScalingPolicyListStub, *QueryMeta, error) + type ScalingEvent struct + Count *int64 + CreateIndex uint64 + Error bool + EvalID *string + Message string + Meta map[string]interface{} + PreviousCount int64 + Time uint64 + type ScalingPolicy struct + CreateIndex uint64 + Enabled *bool + ID string + Max *int64 + Min *int64 + ModifyIndex uint64 + Namespace string + Policy map[string]interface{} + Target map[string]string + Type string + func (p *ScalingPolicy) Canonicalize(taskGroupCount int) + type ScalingPolicyListStub struct + CreateIndex uint64 + Enabled bool + ID string + ModifyIndex uint64 + Target map[string]string + Type string + type ScalingRequest struct + Count *int64 + Error bool + Message string + Meta map[string]interface{} + PolicyOverride bool + Target map[string]string + type SchedulerAlgorithm string + const SchedulerAlgorithmBinpack + const SchedulerAlgorithmSpread + type SchedulerConfiguration struct + CreateIndex uint64 + MemoryOversubscriptionEnabled bool + ModifyIndex uint64 + PreemptionConfig PreemptionConfig + RejectJobRegistration bool + SchedulerAlgorithm SchedulerAlgorithm + type SchedulerConfigurationResponse struct + SchedulerConfig *SchedulerConfiguration + type SchedulerSetConfigurationResponse struct + Updated bool + type SchedulerWorkerPoolArgs struct + EnabledSchedulers []string + NumSchedulers int + type Search struct + func (s *Search) FuzzySearch(text string, context contexts.Context, q *QueryOptions) (*FuzzySearchResponse, *QueryMeta, error) + func (s *Search) PrefixSearch(prefix string, context contexts.Context, q *QueryOptions) (*SearchResponse, *QueryMeta, error) + type SearchRequest struct + Context contexts.Context + Prefix string + type SearchResponse struct + Matches map[contexts.Context][]string + Truncations map[contexts.Context]bool + type SentinelPolicies struct + func (a *SentinelPolicies) Delete(policyName string, q *WriteOptions) (*WriteMeta, error) + func (a *SentinelPolicies) Info(policyName string, q *QueryOptions) (*SentinelPolicy, *QueryMeta, error) + func (a *SentinelPolicies) List(q *QueryOptions) ([]*SentinelPolicyListStub, *QueryMeta, error) + func (a *SentinelPolicies) Upsert(policy *SentinelPolicy, q *WriteOptions) (*WriteMeta, error) + type SentinelPolicy struct + CreateIndex uint64 + Description string + EnforcementLevel string + ModifyIndex uint64 + Name string + Policy string + Scope string + type SentinelPolicyListStub struct + CreateIndex uint64 + Description string + EnforcementLevel string + ModifyIndex uint64 + Name string + Scope string + type ServerHealth struct + Address string + Healthy bool + ID string + LastContact time.Duration + LastIndex uint64 + LastTerm uint64 + Leader bool + Name string + SerfStatus string + StableSince time.Time + Version string + Voter bool + func (u *ServerHealth) MarshalJSON() ([]byte, error) + func (u *ServerHealth) UnmarshalJSON(data []byte) error + type ServerMembers struct + Members []*AgentMember + ServerDC string + ServerName string + ServerRegion string + type Service struct + AddressMode string + CanaryMeta map[string]string + CanaryTags []string + CheckRestart *CheckRestart + Checks []ServiceCheck + Connect *ConsulConnect + EnableTagOverride bool + Id string + Meta map[string]string + Name string + OnUpdate string + PortLabel string + Tags []string + TaskName string + func (s *Service) Canonicalize(t *Task, tg *TaskGroup, job *Job) + type ServiceCheck struct + AddressMode string + Args []string + Body string + CheckRestart *CheckRestart + Command string + Expose bool + FailuresBeforeCritical int + GRPCService string + GRPCUseTLS bool + Header map[string][]string + Id string + InitialStatus string + Interval time.Duration + Method string + Name string + OnUpdate string + Path string + PortLabel string + Protocol string + SuccessBeforePassing int + TLSSkipVerify bool + TaskName string + Timeout time.Duration + Type string + 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 (st *SidecarTask) Canonicalize() + type SingleDeploymentResponse struct + Deployment *Deployment + type SingleRecommendationApplyError struct + Error string + JobID string + Namespace string + Recommendations []string + type SingleRecommendationApplyResult struct + EvalCreateIndex uint64 + EvalID string + JobID string + JobModifyIndex uint64 + Namespace string + Recommendations []string + Warnings string + type Spread struct + Attribute string + SpreadTarget []*SpreadTarget + Weight *int8 + func NewSpread(attribute string, weight int8, spreadTargets []*SpreadTarget) *Spread + func (s *Spread) Canonicalize() + type SpreadTarget struct + Percent uint8 + Value string + func NewSpreadTarget(value string, percent uint8) *SpreadTarget + type StatObject struct + Attributes map[string]*StatValue + Nested map[string]*StatObject + type StatValue struct + BoolVal *bool + Desc string + FloatDenominatorVal *float64 + FloatNumeratorVal *float64 + IntDenominatorVal *int64 + IntNumeratorVal *int64 + StringVal *string + Unit string + func (v *StatValue) String() string + type Status struct + func (s *Status) Leader() (string, error) + func (s *Status) Peers() ([]string, error) + func (s *Status) RegionLeader(region string) (string, error) + type StreamFrame struct + Data []byte + File string + FileEvent string + Offset int64 + func (s *StreamFrame) IsHeartbeat() bool + type System struct + func (s *System) GarbageCollect() error + func (s *System) ReconcileSummaries() error + type TLSConfig struct + CACert string + CACertPEM []byte + CAPath string + ClientCert string + ClientCertPEM []byte + ClientKey string + ClientKeyPEM []byte + Insecure bool + TLSServerName string + func (t *TLSConfig) Copy() *TLSConfig + type Task struct + Affinities []*Affinity + Artifacts []*TaskArtifact + CSIPluginConfig *TaskCSIPluginConfig + Config map[string]interface{} + Constraints []*Constraint + DispatchPayload *DispatchPayloadConfig + Driver string + Env map[string]string + KillSignal string + KillTimeout *time.Duration + Kind string + Leader bool + Lifecycle *TaskLifecycle + LogConfig *LogConfig + Meta map[string]string + Name string + Resources *Resources + RestartPolicy *RestartPolicy + ScalingPolicies []*ScalingPolicy + Services []*Service + ShutdownDelay time.Duration + Templates []*Template + User string + Vault *Vault + VolumeMounts []*VolumeMount + func NewTask(name, driver string) *Task + func (t *Task) AddAffinity(a *Affinity) *Task + func (t *Task) Canonicalize(tg *TaskGroup, job *Job) + func (t *Task) Constrain(c *Constraint) *Task + func (t *Task) Require(r *Resources) *Task + func (t *Task) SetConfig(key string, val interface{}) *Task + func (t *Task) SetLogConfig(l *LogConfig) *Task + func (t *Task) SetMeta(key, val string) *Task + type TaskArtifact struct + GetterHeaders map[string]string + GetterMode *string + GetterOptions map[string]string + GetterSource *string + RelativeDest *string + func (a *TaskArtifact) Canonicalize() + type TaskCSIPluginConfig struct + ID string + MountDir string + Type CSIPluginType + func (t *TaskCSIPluginConfig) Canonicalize() + type TaskDiff struct + Annotations []string + Fields []*FieldDiff + Name string + Objects []*ObjectDiff + Type string + type TaskEvent struct + Details map[string]string + DiskLimit int64 + DiskSize int64 + DisplayMessage string + DownloadError string + DriverError string + DriverMessage string + ExitCode int + FailedSibling string + FailsTask bool + GenericSource string + KillError string + KillReason string + KillTimeout time.Duration + Message string + RestartReason string + SetupError string + Signal int + StartDelay int64 + TaskSignal string + TaskSignalReason string + Time int64 + Type string + ValidationError string + VaultError string + type TaskGroup struct + Affinities []*Affinity + Constraints []*Constraint + Consul *Consul + Count *int + EphemeralDisk *EphemeralDisk + Meta map[string]string + Migrate *MigrateStrategy + Name *string + Networks []*NetworkResource + ReschedulePolicy *ReschedulePolicy + RestartPolicy *RestartPolicy + Scaling *ScalingPolicy + Services []*Service + ShutdownDelay *time.Duration + Spreads []*Spread + StopAfterClientDisconnect *time.Duration + Tasks []*Task + Update *UpdateStrategy + Volumes map[string]*VolumeRequest + func NewTaskGroup(name string, count int) *TaskGroup + func (g *TaskGroup) AddAffinity(a *Affinity) *TaskGroup + func (g *TaskGroup) AddSpread(s *Spread) *TaskGroup + func (g *TaskGroup) AddTask(t *Task) *TaskGroup + func (g *TaskGroup) Canonicalize(job *Job) + func (g *TaskGroup) Constrain(c *Constraint) *TaskGroup + func (g *TaskGroup) RequireDisk(disk *EphemeralDisk) *TaskGroup + func (g *TaskGroup) SetMeta(key, val string) *TaskGroup + type TaskGroupDiff struct + Fields []*FieldDiff + Name string + Objects []*ObjectDiff + Tasks []*TaskDiff + Type string + Updates map[string]uint64 + type TaskGroupScaleStatus struct + Desired int + Events []ScalingEvent + Healthy int + Placed int + Running int + Unhealthy int + type TaskGroupSummary struct + Complete int + Failed int + Lost int + Queued int + Running int + Starting int + type TaskHandle struct + DriverState []byte + Version int + type TaskLifecycle struct + Hook string + Sidecar bool + func (l *TaskLifecycle) Empty() bool + type TaskResourceUsage struct + Pids map[string]*ResourceUsage + ResourceUsage *ResourceUsage + Timestamp int64 + type TaskState struct + Events []*TaskEvent + Failed bool + FinishedAt time.Time + LastRestart time.Time + Restarts uint64 + StartedAt time.Time + State string + TaskHandle *TaskHandle + type Template struct + ChangeMode *string + ChangeSignal *string + DestPath *string + EmbeddedTmpl *string + Envvars *bool + LeftDelim *string + Perms *string + RightDelim *string + SourcePath *string + Splay *time.Duration + VaultGrace *time.Duration + Wait *WaitConfig + func (tmpl *Template) Canonicalize() + type TerminalSize struct + Height int + Width int + type Topic string + const TopicAll + const TopicAllocation + const TopicDeployment + const TopicEvaluation + const TopicJob + const TopicNode + type UpdateStrategy struct + AutoPromote *bool + AutoRevert *bool + Canary *int + HealthCheck *string + HealthyDeadline *time.Duration + MaxParallel *int + MinHealthyTime *time.Duration + ProgressDeadline *time.Duration + Stagger *time.Duration + func DefaultUpdateStrategy() *UpdateStrategy + func (u *UpdateStrategy) Canonicalize() + func (u *UpdateStrategy) Copy() *UpdateStrategy + func (u *UpdateStrategy) Empty() bool + func (u *UpdateStrategy) Merge(o *UpdateStrategy) + type Vault struct + ChangeMode *string + ChangeSignal *string + Env *bool + Namespace *string + Policies []string + func (v *Vault) Canonicalize() + type VolumeMount struct + Destination *string + PropagationMode *string + ReadOnly *bool + Volume *string + func (vm *VolumeMount) Canonicalize() + type VolumeRequest struct + AccessMode string + AttachmentMode string + ExtraKeysHCL []string + MountOptions *CSIMountOptions + Name string + PerAlloc bool + ReadOnly bool + Source string + Type string + type WaitConfig struct + Max *time.Duration + Min *time.Duration + func (wc *WaitConfig) Copy() *WaitConfig + type WriteMeta struct + LastIndex uint64 + RequestTime time.Duration + type WriteOptions struct + AuthToken string + Headers map[string]string + IdempotencyToken string + Namespace string + Region string + func (o *WriteOptions) Context() context.Context + func (o *WriteOptions) WithContext(ctx context.Context) *WriteOptions + func (w *WriteOptions) SetHeadersFromCSISecrets(secrets CSISecrets) + type WriteRequest struct + Namespace string + Region string + SecretID string Other modules containing this package github.com/tsaarni/nomad
Go to main page