api

Jun 11, 2018

Changes in this version

type AllocDeploymentStatus

+ Canary bool

+ Timestamp time.Time

type Deployment

+ JobSpecModifyIndex uint64

type DeploymentState

+ ProgressDeadline time.Duration

+ RequireProgressBy time.Time

type DesiredTransition

+ Reschedule *bool

+ type EvalOptions struct

+ ForceReschedule bool

type Job

+ Dispatched bool

+ type JobEvaluateRequest struct

+ EvalOptions EvalOptions

+ JobID string

type Jobs

+ func (j *Jobs) EvaluateWithOpts(jobID string, opts EvalOptions, q *WriteOptions) (string, *WriteMeta, error)

type NodeListStub

+ Drivers map[string]*DriverInfo

type Service

+ CanaryTags []string

type ServiceCheck

+ GRPCService string

+ GRPCUseTLS bool

type UpdateStrategy

+ ProgressDeadline *time.Duration

Apr 26, 2018

Changes in this version

type Jobs

+ func (j *Jobs) ParseHCL(jobHCL string, canonicalize bool) (*Job, error)

+ type JobsParseRequest struct

+ Canonicalize bool

+ JobHCL string

Apr 12, 2018

Changes in this version

+ const NodeEventSubsystemCluster

+ const NodeEventSubsystemDrain

+ const NodeEventSubsystemDriver

+ const NodeEventSubsystemHeartbeat

+ var ClientConnTimeout = 1 * time.Second

type Allocation

+ DesiredTransition DesiredTransition

+ FollowupEvalID string

+ NextAllocation string

+ RescheduleTracker *RescheduleTracker

+ func (a Allocation) RescheduleInfo(t time.Time) (int, int)

type AllocationListStub

+ FollowupEvalID string

+ RescheduleTracker *RescheduleTracker

+ type AutopilotConfiguration struct

+ CleanupDeadServers bool

+ CreateIndex uint64

+ DisableUpgradeMigration bool

+ EnableCustomUpgrades bool

+ EnableRedundancyZones bool

+ LastContactThreshold time.Duration

+ MaxTrailingLogs uint64

+ ModifyIndex uint64

+ ServerStabilizationTime time.Duration

+ func (u *AutopilotConfiguration) MarshalJSON() ([]byte, error)

+ func (u *AutopilotConfiguration) UnmarshalJSON(data []byte) error

type Client

+ func (c *Client) GetNodeClientWithTimeout(nodeID string, timeout time.Duration, q *QueryOptions) (*Client, error)

type Config

+ func (c *Config) SetTimeout(t time.Duration) error

+ type DesiredTransition struct

+ Migrate *bool

+ func (d DesiredTransition) ShouldMigrate() bool

+ type DrainSpec struct

+ Deadline time.Duration

+ IgnoreSystemJobs bool

+ type DrainStrategy struct

+ ForceDeadline 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 Evaluation

+ WaitUntil time.Time

type Job

+ Migrate *MigrateStrategy

+ Reschedule *ReschedulePolicy

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

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

+ DrainStrategy *DrainStrategy

+ Drivers map[string]*DriverInfo

+ Events []*NodeEvent

+ SchedulingEligibility string

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

+ Address string

+ SchedulingEligibility string

+ type NodeUpdateDrainRequest struct

+ DrainSpec *DrainSpec

+ MarkEligible bool

+ NodeID string

+ type NodeUpdateEligibilityRequest struct

+ Eligibility string

+ NodeID string

type Nodes

+ func (n *Nodes) GcAlloc(allocID string, q *QueryOptions) error

+ func (n *Nodes) MonitorDrain(ctx context.Context, nodeID string, index uint64, ignoreSys bool) <-chan *MonitorMessage

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

type Operator

+ 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) RaftRemovePeerByID(id string, q *WriteOptions) error

+ type OperatorHealthReply struct

+ FailureTolerance int

+ Healthy bool

+ Servers []ServerHealth

type RaftServer

+ RaftProtocol string

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

+ Migrate *MigrateStrategy

+ ReschedulePolicy *ReschedulePolicy

Dec 20, 2017

Changes in this version

type Allocation

+ ModifyTime int64

type AllocationListStub

+ ModifyTime int64

type Resources

+ func DefaultResources() *Resources

type ServiceCheck

+ AddressMode string

type Task

+ KillSignal string

type TaskEvent

+ Details map[string]string

+ DisplayMessage string

Nov 1, 2017

Changes in this version

+ const DefaultNamespace

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

type Agent

+ func (a *Agent) Health() (*AgentHealthResponse, error)

+ type AgentHealth struct

+ Message string

+ Ok bool

+ type AgentHealthResponse struct

+ Client *AgentHealth

+ Server *AgentHealth

type Allocation

+ Namespace string

type AllocationMetric

+ QuotaExhausted []string

+ 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

+ func (c *Client) ACLPolicies() *ACLPolicies

+ func (c *Client) ACLTokens() *ACLTokens

+ func (c *Client) Address() string

+ func (c *Client) Namespaces() *Namespaces

+ func (c *Client) Quotas() *Quotas

+ func (c *Client) SentinelPolicies() *SentinelPolicies

+ func (c *Client) SetNamespace(namespace string)

+ func (c *Client) SetSecretID(secretID string)

type Config

+ Namespace string

+ SecretID string

type Deployment

+ Namespace string

type Evaluation

+ Namespace string

+ QuotaLimitReached string

type Job

+ Namespace *string

type JobPlanRequest

+ PolicyOverride bool

type JobRegisterRequest

+ PolicyOverride bool

type JobSummary

+ Namespace string

type Jobs

+ func (j *Jobs) PlanOpts(job *Job, opts *PlanOptions, q *WriteOptions) (*JobPlanResponse, *WriteMeta, error)

+ func (j *Jobs) RegisterOpts(job *Job, opts *RegisterOptions, q *WriteOptions) (*JobRegisterResponse, *WriteMeta, error)

+ type Namespace struct

+ CreateIndex uint64

+ Description string

+ ModifyIndex uint64

+ Name string

+ Quota 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 PlanOptions struct

+ Diff bool

+ PolicyOverride bool

type QueryOptions

+ AuthToken string

+ Namespace string

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

+ PolicyOverride bool

+ type RegisterOptions struct

+ EnforceIndex bool

+ ModifyIndex uint64

+ PolicyOverride 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 Service

+ CheckRestart *CheckRestart

type ServiceCheck

+ CheckRestart *CheckRestart

type UpdateStrategy

+ func DefaultUpdateStrategy() *UpdateStrategy

type WriteOptions

+ AuthToken string

+ Namespace string

type WriteRequest

+ Namespace string

+ SecretID string

Sep 11, 2017

Changes in this version

type UpdateStrategy

+ func (u *UpdateStrategy) Empty() bool

Aug 28, 2017

Changes in this version

+ const TaskGenericMessage

type Client

+ func (c *Client) GetNodeClient(nodeID string, q *QueryOptions) (*Client, error)

+ func (c *Client) Search() *Search

type Config

+ func (c *Config) ClientConfig(region, address string, tlsEnabled bool) *Config

type NodeListStub

+ Version string

+ type Search struct

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

+ Header map[string][]string

+ Method string

type System

+ func (s *System) ReconcileSummaries() error

type TLSConfig

+ func (t *TLSConfig) Copy() *TLSConfig

type Task

+ ShutdownDelay time.Duration

type TaskEvent

+ GenericSource string

type Template

+ VaultGrace *time.Duration

Jul 26, 2017

Changes in this version

+ const TaskBuildingTaskDir

+ type AllocDeploymentStatus struct

+ Healthy *bool

+ ModifyIndex uint64

type Allocation

+ DeploymentID string

+ DeploymentStatus *AllocDeploymentStatus

type AllocationListStub

+ DeploymentStatus *AllocDeploymentStatus

+ JobVersion uint64

type Client

+ func (c *Client) Deployments() *Deployments

+ 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

+ 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

+ Promoted bool

+ UnhealthyAllocs int

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

type DesiredUpdates

+ Canary uint64

type Evaluation

+ DeploymentID string

type Job

+ Stable *bool

+ Stop *bool

+ SubmitTime *int64

+ Version *uint64

+ type JobDeregisterResponse struct

+ EvalCreateIndex uint64

+ EvalID string

+ JobModifyIndex uint64

type JobListStub

+ ParameterizedJob bool

+ Periodic bool

+ Stop bool

+ SubmitTime int64

type JobPlanResponse

+ Warnings string

+ type JobRegisterResponse struct

+ EvalCreateIndex uint64

+ EvalID string

+ JobModifyIndex uint64

+ Warnings string

+ type JobRevertRequest struct

+ EnforcePriorVersion *uint64

+ JobID string

+ JobVersion uint64

+ type JobStabilityRequest struct

+ JobID string

+ JobVersion uint64

+ Stable bool

+ type JobStabilityResponse struct

+ JobModifyIndex uint64

type JobValidateResponse

+ Warnings string

+ type JobVersionsResponse struct

+ Diffs []*JobDiff

+ Versions []*Job

type Jobs

+ func (j *Jobs) Deployments(jobID string, q *QueryOptions) ([]*Deployment, *QueryMeta, error)

+ func (j *Jobs) LatestDeployment(jobID string, q *QueryOptions) (*Deployment, *QueryMeta, error)

+ func (j *Jobs) Revert(jobID string, version uint64, enforcePriorVersion *uint64, q *WriteOptions) (*JobRegisterResponse, *WriteMeta, error)

+ func (j *Jobs) Stable(jobID string, version uint64, stable bool, q *WriteOptions) (*JobStabilityResponse, *WriteMeta, error)

+ func (j *Jobs) Versions(jobID string, diffs bool, q *QueryOptions) ([]*Job, []*JobDiff, *QueryMeta, error)

type NetworkResource

+ Device string

type Service

+ AddressMode string

type ServiceCheck

+ TLSSkipVerify bool

+ type SingleDeploymentResponse struct

+ Deployment *Deployment

type TaskArtifact

+ GetterMode *string

type TaskGroup

+ Update *UpdateStrategy

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

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

+ func (u *UpdateStrategy) Merge(o *UpdateStrategy)

Apr 1, 2017

Changes in this version

type TaskState

+ FinishedAt time.Time

+ StartedAt time.Time

Mar 14, 2017

Changes in this version

+ const PeriodicSpecCron

+ const TaskLeaderDead

+ const TaskSetup

+ type AgentSelf struct

+ Config map[string]interface{}

+ Member AgentMember

+ Stats map[string]map[string]string

type Client

+ func (c *Client) Operator() *Operator

type EphemeralDisk

+ func DefaultEphemeralDisk() *EphemeralDisk

+ func (e *EphemeralDisk) Canonicalize()

type Evaluation

+ AnnotatePlan bool

+ ClassEligibility map[string]bool

+ EscapedComputedClass bool

+ SnapshotIndex uint64

type Job

+ func MockJob() *Job

+ func MockPeriodicJob() *Job

+ func (j *Job) Canonicalize()

+ func (j *Job) IsParameterized() bool

+ func (j *Job) IsPeriodic() bool

+ type JobRegisterRequest struct

+ EnforceIndex bool

+ Job *Job

+ JobModifyIndex uint64

+ type JobValidateRequest struct

+ Job *Job

+ type JobValidateResponse struct

+ DriverConfigValidated bool

+ Error string

+ ValidationErrors []string

type Jobs

+ func (j *Jobs) Validate(job *Job, q *WriteOptions) (*JobValidateResponse, *WriteMeta, error)

type LogConfig

+ func DefaultLogConfig() *LogConfig

+ func (l *LogConfig) Canonicalize()

type NetworkResource

+ func (n *NetworkResource) Canonicalize()

+ type Operator struct

+ func (op *Operator) RaftGetConfiguration(q *QueryOptions) (*RaftConfiguration, error)

+ func (op *Operator) RaftRemovePeerByAddress(address string, q *WriteOptions) error

type PeriodicConfig

+ TimeZone *string

+ func (p *PeriodicConfig) Canonicalize()

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

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

+ type RaftConfiguration struct

+ Index uint64

+ Servers []*RaftServer

+ type RaftServer struct

+ Address string

+ ID string

+ Leader bool

+ Node string

+ Voter bool

type Resources

+ func MinResources() *Resources

+ func (r *Resources) Canonicalize()

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

type RestartPolicy

+ func (r *RestartPolicy) Merge(rp *RestartPolicy)

type ServerMembers

+ ServerDC string

+ ServerRegion string

type Service

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

type Task

+ Leader bool

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

type TaskArtifact

+ func (a *TaskArtifact) Canonicalize()

type TaskGroup

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

type Template

+ LeftDelim *string

+ Perms *string

+ RightDelim *string

+ func (tmpl *Template) Canonicalize()

type Vault

+ func (v *Vault) Canonicalize()

+ type WriteRequest struct

+ Region string

Jan 30, 2017

Changes in this version

type Allocation

+ AllocModifyIndex uint64

type Allocations

+ func (a *Allocations) GC(alloc *Allocation, q *QueryOptions) error

+ type DispatchPayloadConfig struct

+ File string

type Evaluation

+ QueuedAllocations map[string]int

type Job

+ ParameterizedJob *ParameterizedJobConfig

+ Payload []byte

+ type JobChildrenSummary struct

+ Dead int64

+ Pending int64

+ Running int64

+ func (jc *JobChildrenSummary) Sum() int

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

+ func (j *Jobs) Dispatch(jobID string, meta map[string]string, payload []byte, q *WriteOptions) (*JobDispatchResponse, *WriteMeta, error)

type Nodes

+ func (n *Nodes) GC(nodeID string, q *QueryOptions) error

+ type ParameterizedJobConfig struct

+ MetaOptional []string

+ MetaRequired []string

+ Payload string

type Task

+ DispatchPayload *DispatchPayloadConfig

Dec 21, 2016

Changes in this version

+ const TaskDriverMessage

type TaskEvent

+ DriverMessage string

Nov 16, 2016

Changes in this version

+ const TaskRestartSignal

+ const TaskSetupFailure

+ const TaskSiblingFailed

+ const TaskSignaling

+ const TaskVaultRenewalFailed

+ var NodeDownErr = fmt.Errorf("node down")

type Agent

+ func (a *Agent) InstallKey(key string) (*KeyringResponse, error)

+ func (a *Agent) ListKeys() (*KeyringResponse, error)

+ func (a *Agent) RemoveKey(key string) (*KeyringResponse, error)

+ func (a *Agent) UseKey(key string) (*KeyringResponse, error)

type Allocation

+ PreviousAllocation string

type Config

+ TLSConfig *TLSConfig

+ func (c *Config) ConfigureTLS() error

+ func (c *Config) CopyConfig(address string, tlsEnabled bool) *Config

+ type EphemeralDisk struct

+ Migrate bool

+ SizeMB int

+ Sticky bool

type Job

+ ParentID string

+ VaultToken string

+ type KeyringRequest struct

+ Key string

+ type KeyringResponse struct

+ Keys map[string]int

+ Messages map[string]string

+ NumNodes int

type Node

+ TLSEnabled bool

type Raw

+ func (raw *Raw) Response(endpoint string, q *QueryOptions) (io.ReadCloser, error)

+ type ServerMembers struct

+ DC string

+ Members []*AgentMember

+ Region string

+ ServerName string

type ServiceCheck

+ InitialStatus string

+ type TLSConfig struct

+ CACert string

+ CAPath string

+ ClientCert string

+ ClientKey string

+ Insecure bool

+ TLSServerName string

type Task

+ Templates []*Template

+ Vault *Vault

type TaskEvent

+ DiskLimit int64

+ DiskSize int64

+ FailedSibling string

+ FailsTask bool

+ KillReason string

+ SetupError string

+ TaskSignal string

+ TaskSignalReason string

+ VaultError string

type TaskGroup

+ EphemeralDisk *EphemeralDisk

+ func (g *TaskGroup) RequireDisk(disk *EphemeralDisk) *TaskGroup

type TaskState

+ Failed bool

+ type Template struct

+ ChangeMode string

+ ChangeSignal string

+ DestPath string

+ EmbeddedTmpl string

+ SourcePath string

+ Splay time.Duration

+ type Vault struct

+ ChangeMode string

+ ChangeSignal string

+ Env bool

+ Policies []string

Aug 17, 2016

Changes in this version

+ const OriginEnd

+ const OriginStart

+ const TaskKilling

type AllocFS

+ func (a *AllocFS) Logs(alloc *Allocation, follow bool, task, logType, origin string, offset int64, ...) (<-chan *StreamFrame, error)

+ func (a *AllocFS) Stream(alloc *Allocation, path, origin string, offset int64, cancel <-chan struct{}, ...) (<-chan *StreamFrame, error)

type Config

+ HttpAuth *HttpBasicAuth

+ type FrameReader struct

+ func NewFrameReader(frames <-chan *StreamFrame, 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 HttpBasicAuth struct

+ Password string

+ Username string

type JobListStub

+ JobSummary *JobSummary

+ type JobSummary struct

+ CreateIndex uint64

+ JobID string

+ ModifyIndex uint64

+ Summary map[string]TaskGroupSummary

type Jobs

+ func (j *Jobs) Summary(jobID string, q *QueryOptions) (*JobSummary, *QueryMeta, error)

type Node

+ StatusUpdatedAt int64

type QueryOptions

+ Params map[string]string

type ServiceCheck

+ PortLabel string

+ type StreamFrame struct

+ Data []byte

+ File string

+ FileEvent string

+ Offset int64

+ func (s *StreamFrame) IsHeartbeat() bool

type TaskEvent

+ KillTimeout time.Duration

+ type TaskGroupSummary struct

+ Complete int

+ Failed int

+ Lost int

+ Queued int

+ Running int

+ Starting int

Jun 28, 2016

Changes in this version

+ const RegisterEnforceIndexErrPrefix

+ type AllocResourceUsage struct

+ ResourceUsage *ResourceUsage

+ Tasks map[string]*TaskResourceUsage

+ Timestamp int64

type Allocations

+ func (a *Allocations) Stats(alloc *Allocation, q *QueryOptions) (*AllocResourceUsage, error)

type Client

+ func (c *Client) SetRegion(region string)

+ type CpuStats struct

+ Measured []string

+ Percent float64

+ SystemMode float64

+ ThrottledPeriods uint64

+ ThrottledTime uint64

+ TotalTicks float64

+ UserMode float64

+ type DesiredUpdates struct

+ DestructiveUpdate uint64

+ Ignore uint64

+ InPlaceUpdate uint64

+ Migrate uint64

+ Place uint64

+ Stop uint64

type Evaluation

+ BlockedEval string

+ FailedTGAllocs map[string]*AllocationMetric

+ type FieldDiff struct

+ Annotations []string

+ Name string

+ New string

+ Old string

+ Type string

+ type HostCPUStats struct

+ CPU string

+ Idle float64

+ System float64

+ User float64

+ 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 HostStats struct

+ CPU []*HostCPUStats

+ CPUTicksConsumed float64

+ DiskStats []*HostDiskStats

+ Memory *HostMemoryStats

+ Uptime uint64

type Job

+ JobModifyIndex uint64

+ type JobDiff struct

+ Fields []*FieldDiff

+ ID string

+ Objects []*ObjectDiff

+ TaskGroups []*TaskGroupDiff

+ Type string

type JobListStub

+ JobModifyIndex uint64

+ type JobPlanRequest struct

+ Diff bool

+ Job *Job

+ type JobPlanResponse struct

+ Annotations *PlanAnnotations

+ CreatedEvals []*Evaluation

+ Diff *JobDiff

+ FailedTGAllocs map[string]*AllocationMetric

+ JobModifyIndex uint64

+ NextPeriodicLaunch time.Time

type Jobs

+ func (j *Jobs) EnforceRegister(job *Job, modifyIndex uint64, q *WriteOptions) (string, *WriteMeta, error)

+ func (j *Jobs) Plan(job *Job, diff bool, q *WriteOptions) (*JobPlanResponse, *WriteMeta, error)

+ type MemoryStats struct

+ Cache uint64

+ KernelMaxUsage uint64

+ KernelUsage uint64

+ MaxUsage uint64

+ Measured []string

+ RSS uint64

+ Swap uint64

type Nodes

+ func (n *Nodes) Stats(nodeID string, q *QueryOptions) (*HostStats, error)

+ type ObjectDiff struct

+ Fields []*FieldDiff

+ Name string

+ Objects []*ObjectDiff

+ Type string

+ type PlanAnnotations struct

+ DesiredTGUpdates map[string]*DesiredUpdates

type RegisterJobRequest

+ EnforceIndex bool

+ JobModifyIndex uint64

+ type ResourceUsage struct

+ CpuStats *CpuStats

+ MemoryStats *MemoryStats

+ type TaskDiff struct

+ Annotations []string

+ Fields []*FieldDiff

+ Name string

+ Objects []*ObjectDiff

+ Type string

+ type TaskGroupDiff struct

+ Fields []*FieldDiff

+ Name string

+ Objects []*ObjectDiff

+ Tasks []*TaskDiff

+ Type string

+ Updates map[string]uint64

+ type TaskResourceUsage struct

+ Pids map[string]*ResourceUsage

+ ResourceUsage *ResourceUsage

+ Timestamp int64

Apr 22, 2016

Changes in this version

+ const TaskFailedValidation

type AllocFS

+ func (a *AllocFS) Cat(alloc *Allocation, path string, q *QueryOptions) (io.Reader, *QueryMeta, error)

+ type RegisterJobRequest struct

+ Job *Job

type ServiceCheck

+ Args []string

+ Command string

type Status

+ func (s *Status) RegionLeader(region string) (string, error)

type Task

+ User string

type TaskArtifact

+ RelativeDest string

type TaskEvent

+ RestartReason string

+ ValidationError string

Mar 16, 2016

Changes in this version

+ const TaskArtifactDownloadFailed

+ const TaskDownloadingArtifacts

+ const TaskNotRestarting

+ const TaskReceived

+ const TaskRestarting

type NetworkResource

+ IP string

type Task

+ Artifacts []*TaskArtifact

+ type TaskArtifact struct

+ GetterOptions map[string]string

+ GetterSource string

type TaskEvent

+ DownloadError string

+ StartDelay int64

Feb 25, 2016

Changes in this version

+ type AllocFS struct

+ func (a *AllocFS) List(alloc *Allocation, path string, q *QueryOptions) ([]*AllocFileInfo, *QueryMeta, error)

+ func (a *AllocFS) ReadAt(alloc *Allocation, path string, offset int64, limit int64, q *QueryOptions) (io.Reader, *QueryMeta, error)

+ func (a *AllocFS) Stat(alloc *Allocation, path string, q *QueryOptions) (*AllocFileInfo, *QueryMeta, error)

+ type AllocFileInfo struct

+ FileMode string

+ IsDir bool

+ ModTime time.Time

+ Name string

+ Size int64

type Allocation

+ CreateTime int64

type AllocationListStub

+ CreateTime int64

type AllocationMetric

+ NodesAvailable map[string]int

type Allocations

+ func (a *Allocations) PrefixList(prefix string) ([]*AllocationListStub, *QueryMeta, error)

type Client

+ func (c *Client) AllocFS() *AllocFS

+ func (c *Client) System() *System

type Evaluations

+ func (e *Evaluations) PrefixList(prefix string) ([]*Evaluation, *QueryMeta, error)

type Job

+ Periodic *PeriodicConfig

+ func (j *Job) AddPeriodicConfig(cfg *PeriodicConfig) *Job

type JobListStub

+ ParentID string

type Jobs

+ func (j *Jobs) PeriodicForce(jobID string, q *WriteOptions) (string, *WriteMeta, error)

+ func (j *Jobs) PrefixList(prefix string) ([]*JobListStub, *QueryMeta, error)

+ type LogConfig struct

+ MaxFileSizeMB int

+ MaxFiles int

type Node

+ HTTPAddr string

type Nodes

+ func (n *Nodes) PrefixList(prefix string) ([]*NodeListStub, *QueryMeta, error)

+ type PeriodicConfig struct

+ Enabled bool

+ ProhibitOverlap bool

+ Spec string

+ SpecType string

type QueryOptions

+ Prefix string

type RestartPolicy

+ Mode string

+ type System struct

+ func (s *System) GarbageCollect() error

type Task

+ KillTimeout time.Duration

+ LogConfig *LogConfig

+ func (t *Task) SetLogConfig(l *LogConfig) *Task

Dec 18, 2015

Changes in this version

type Allocation

+ Services map[string]string

Dec 11, 2015

Changes in this version

type Node

+ Meta map[string]string

Nov 28, 2015

Changes in this version

type Client

+ func (c *Client) Regions() *Regions

+ type Regions struct

+ func (r *Regions) List() ([]string, error)

Nov 19, 2015

Changes in this version

+ const TaskDriverFailure

+ const TaskKilled

+ const TaskStarted

+ const TaskTerminated

+ type AgentMembersNameSort []*AgentMember

+ func (a AgentMembersNameSort) Len() int

+ func (a AgentMembersNameSort) Less(i, j int) bool

+ func (a AgentMembersNameSort) Swap(i, j int)

type Allocation

+ TaskStates map[string]*TaskState

type AllocationListStub

+ TaskStates map[string]*TaskState

+ type AllocationSort []*Allocation

+ func (a AllocationSort) Len() int

+ func (a AllocationSort) Less(i, j int) bool

+ func (a AllocationSort) Swap(i, j int)

type Constraint

+ func NewConstraint(left, operand, right string) *Constraint

type Job

+ Update *UpdateStrategy

+ type Port struct

+ Label string

+ Value int

+ type RestartPolicy struct

+ Attempts int

+ Delay time.Duration

+ Interval time.Duration

+ func NewRestartPolicy() *RestartPolicy

+ type Service struct

+ Checks []ServiceCheck

+ Id string

+ Name string

+ PortLabel string

+ Tags []string

+ type ServiceCheck struct

+ Id string

+ Interval time.Duration

+ Name string

+ Path string

+ Protocol string

+ Script string

+ Timeout time.Duration

+ Type string

type Task

+ Services []Service

+ type TaskEvent struct

+ DriverError string

+ ExitCode int

+ KillError string

+ Message string

+ Signal int

+ Time int64

+ Type string

type TaskGroup

+ RestartPolicy *RestartPolicy

+ type TaskState struct

+ Events []*TaskEvent

+ State string

+ type UpdateStrategy struct

+ MaxParallel int

+ Stagger time.Duration

Oct 5, 2015

Changes in this version

type Task

+ Env map[string]string

Sep 28, 2015

Changes in this version

+ const JobTypeBatch

+ const JobTypeService

+ type Agent struct

+ func (a *Agent) Datacenter() (string, error)

+ func (a *Agent) ForceLeave(node string) error

+ func (a *Agent) Join(addrs ...string) (int, error)

+ func (a *Agent) Members() ([]*AgentMember, error)

+ func (a *Agent) NodeName() (string, error)

+ func (a *Agent) Region() (string, error)

+ func (a *Agent) Self() (map[string]map[string]interface{}, error)

+ func (a *Agent) Servers() ([]string, error)

+ func (a *Agent) SetServers(addrs []string) error

+ 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 AllocIndexSort []*AllocationListStub

+ func (a AllocIndexSort) Len() int

+ func (a AllocIndexSort) Less(i, j int) bool

+ func (a AllocIndexSort) Swap(i, j int)

+ type Allocation struct

+ ClientDescription string

+ ClientStatus string

+ CreateIndex uint64

+ DesiredDescription string

+ DesiredStatus string

+ EvalID string

+ ID string

+ Job *Job

+ JobID string

+ Metrics *AllocationMetric

+ ModifyIndex uint64

+ Name string

+ NodeID string

+ Resources *Resources

+ TaskGroup string

+ TaskResources map[string]*Resources

+ type AllocationListStub 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 AllocationMetric 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

+ type Allocations struct

+ func (a *Allocations) Info(allocID string, q *QueryOptions) (*Allocation, *QueryMeta, error)

+ func (a *Allocations) List(q *QueryOptions) ([]*AllocationListStub, *QueryMeta, error)

+ type Client struct

+ func NewClient(config *Config) (*Client, error)

+ func (c *Client) Agent() *Agent

+ func (c *Client) Allocations() *Allocations

+ func (c *Client) Evaluations() *Evaluations

+ func (c *Client) Jobs() *Jobs

+ func (c *Client) Nodes() *Nodes

+ func (c *Client) Raw() *Raw

+ func (c *Client) Status() *Status

+ type Config struct

+ Address string

+ HttpClient *http.Client

+ Region string

+ WaitTime time.Duration

+ func DefaultConfig() *Config

+ type Constraint struct

+ Hard bool

+ LTarget string

+ Operand string

+ RTarget string

+ Weight int

+ func HardConstraint(left, operand, right string) *Constraint

+ func SoftConstraint(left, operand, right string, weight int) *Constraint

+ type EvalIndexSort []*Evaluation

+ func (e EvalIndexSort) Len() int

+ func (e EvalIndexSort) Less(i, j int) bool

+ func (e EvalIndexSort) Swap(i, j int)

+ 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

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

+ 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

+ func NewBatchJob(id, name, region string, pri int) *Job

+ func NewServiceJob(id, name, region string, pri int) *Job

+ func (j *Job) AddDatacenter(dc string) *Job

+ func (j *Job) AddTaskGroup(grp *TaskGroup) *Job

+ func (j *Job) Constrain(c *Constraint) *Job

+ func (j *Job) SetMeta(key, val string) *Job

+ 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

+ ID string

+ ModifyIndex uint64

+ Name string

+ Priority int

+ Status string

+ StatusDescription string

+ Type string

+ type Jobs struct

+ func (j *Jobs) Allocations(jobID string, q *QueryOptions) ([]*AllocationListStub, *QueryMeta, error)

+ func (j *Jobs) Deregister(jobID string, 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) List(q *QueryOptions) ([]*JobListStub, *QueryMeta, error)

+ func (j *Jobs) Register(job *Job, q *WriteOptions) (string, *WriteMeta, error)

+ type NetworkResource struct

+ CIDR string

+ DynamicPorts []string

+ MBits int

+ Public bool

+ ReservedPorts []int

+ type Node struct

+ Attributes map[string]string

+ CreateIndex uint64

+ Datacenter string

+ Drain bool

+ ID string

+ Links map[string]string

+ ModifyIndex uint64

+ Name string

+ NodeClass string

+ Reserved *Resources

+ Resources *Resources

+ Status string

+ StatusDescription string

+ 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

+ CreateIndex uint64

+ Datacenter string

+ Drain bool

+ ID string

+ ModifyIndex uint64

+ Name string

+ NodeClass string

+ Status string

+ StatusDescription string

+ type Nodes struct

+ func (n *Nodes) Allocations(nodeID string, q *QueryOptions) ([]*AllocationListStub, *QueryMeta, error)

+ func (n *Nodes) ForceEvaluate(nodeID string, q *WriteOptions) (string, *WriteMeta, error)

+ func (n *Nodes) Info(nodeID string, q *QueryOptions) (*Node, *QueryMeta, error)

+ func (n *Nodes) List(q *QueryOptions) ([]*NodeListStub, *QueryMeta, error)

+ func (n *Nodes) ToggleDrain(nodeID string, drain bool, q *WriteOptions) (*WriteMeta, error)

+ type QueryMeta struct

+ KnownLeader bool

+ LastContact time.Duration

+ LastIndex uint64

+ RequestTime time.Duration

+ type QueryOptions struct

+ AllowStale bool

+ Region string

+ WaitIndex uint64

+ WaitTime time.Duration

+ 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) Write(endpoint string, in, out interface{}, q *WriteOptions) (*WriteMeta, error)

+ type Resources struct

+ CPU int

+ DiskMB int

+ IOPS int

+ MemoryMB int

+ Networks []*NetworkResource

+ type Status struct

+ func (s *Status) Leader() (string, error)

+ func (s *Status) Peers() ([]string, error)

+ type Task struct

+ Config map[string]string

+ Constraints []*Constraint

+ Driver string

+ Meta map[string]string

+ Name string

+ Resources *Resources

+ func NewTask(name, driver string) *Task

+ func (t *Task) Constrain(c *Constraint) *Task

+ func (t *Task) Require(r *Resources) *Task

+ func (t *Task) SetConfig(key, val string) *Task

+ func (t *Task) SetMeta(key, val string) *Task

+ type TaskGroup struct

+ Constraints []*Constraint

+ Count int

+ Meta map[string]string

+ Name string

+ Tasks []*Task

+ func NewTaskGroup(name string, count int) *TaskGroup

+ func (g *TaskGroup) AddTask(t *Task) *TaskGroup

+ func (g *TaskGroup) Constrain(c *Constraint) *TaskGroup

+ func (g *TaskGroup) SetMeta(key, val string) *TaskGroup

+ type WriteMeta struct

+ LastIndex uint64

+ RequestTime time.Duration

+ type WriteOptions struct

+ Region string