state

May 28, 2020

Changes in this version

+ func CreateTestCSIPlugin(s *StateStore, id string) func()

+ type ScalingPolicyTargetFieldIndex struct

+ Field string

+ func (s *ScalingPolicyTargetFieldIndex) FromArgs(args ...interface{}) ([]byte, error)

+ func (s *ScalingPolicyTargetFieldIndex) FromObject(obj interface{}) (bool, []byte, error)

+ func (s *ScalingPolicyTargetFieldIndex) PrefixFromArgs(args ...interface{}) ([]byte, error)

+ type SliceIterator struct

+ func NewSliceIterator() *SliceIterator

+ func (i *SliceIterator) Add(datum interface{})

+ func (i *SliceIterator) Next() interface{}

+ func (i *SliceIterator) WatchCh() <-chan struct{}

type StateRestore

+ func (r *StateRestore) CSIPluginRestore(plugin *structs.CSIPlugin) error

+ func (r *StateRestore) CSIVolumeRestore(volume *structs.CSIVolume) error

+ func (r *StateRestore) ScalingEventsRestore(jobEvents *structs.JobScalingEvents) error

+ func (r *StateRestore) ScalingPolicyRestore(scalingPolicy *structs.ScalingPolicy) error

type StateStore

+ func (s *StateStore) CSIPluginByID(ws memdb.WatchSet, id string) (*structs.CSIPlugin, error)

+ func (s *StateStore) CSIPluginDenormalize(ws memdb.WatchSet, plug *structs.CSIPlugin) (*structs.CSIPlugin, error)

+ func (s *StateStore) CSIPlugins(ws memdb.WatchSet) (memdb.ResultIterator, error)

+ func (s *StateStore) CSIPluginsByIDPrefix(ws memdb.WatchSet, pluginID string) (memdb.ResultIterator, error)

+ func (s *StateStore) CSIVolumeByID(ws memdb.WatchSet, namespace, id string) (*structs.CSIVolume, error)

+ func (s *StateStore) CSIVolumeClaim(index uint64, namespace, id string, claim *structs.CSIVolumeClaim) error

+ func (s *StateStore) CSIVolumeDenormalize(ws memdb.WatchSet, vol *structs.CSIVolume) (*structs.CSIVolume, error)

+ func (s *StateStore) CSIVolumeDenormalizePlugins(ws memdb.WatchSet, vol *structs.CSIVolume) (*structs.CSIVolume, error)

+ func (s *StateStore) CSIVolumeDeregister(index uint64, namespace string, ids []string) error

+ func (s *StateStore) CSIVolumeRegister(index uint64, volumes []*structs.CSIVolume) error

+ func (s *StateStore) CSIVolumes(ws memdb.WatchSet) (memdb.ResultIterator, error)

+ func (s *StateStore) CSIVolumesByIDPrefix(ws memdb.WatchSet, namespace, volumeID string) (memdb.ResultIterator, error)

+ func (s *StateStore) CSIVolumesByNamespace(ws memdb.WatchSet, namespace string) (memdb.ResultIterator, error)

+ func (s *StateStore) CSIVolumesByNodeID(ws memdb.WatchSet, nodeID string) (memdb.ResultIterator, error)

+ func (s *StateStore) CSIVolumesByPluginID(ws memdb.WatchSet, namespace, pluginID string) (memdb.ResultIterator, error)

+ func (s *StateStore) DeleteCSIPlugin(index uint64, id string) error

+ func (s *StateStore) DeleteScalingPolicies(index uint64, ids []string) error

+ func (s *StateStore) DeleteScalingPoliciesTxn(index uint64, ids []string, txn *memdb.Txn) error

+ func (s *StateStore) NodesByToken(ws memdb.WatchSet, token string) (memdb.ResultIterator, error)

+ func (s *StateStore) ScalingEvents(ws memdb.WatchSet) (memdb.ResultIterator, error)

+ func (s *StateStore) ScalingEventsByJob(ws memdb.WatchSet, namespace, jobID string) (map[string][]*structs.ScalingEvent, uint64, error)

+ func (s *StateStore) ScalingPolicies(ws memdb.WatchSet) (memdb.ResultIterator, error)

+ func (s *StateStore) ScalingPoliciesByJob(ws memdb.WatchSet, namespace, jobID string) (memdb.ResultIterator, error)

+ func (s *StateStore) ScalingPoliciesByJobTxn(ws memdb.WatchSet, namespace, jobID string, txn *memdb.Txn) (memdb.ResultIterator, error)

+ func (s *StateStore) ScalingPoliciesByNamespace(ws memdb.WatchSet, namespace string) (memdb.ResultIterator, error)

+ func (s *StateStore) ScalingPolicyByID(ws memdb.WatchSet, id string) (*structs.ScalingPolicy, error)

+ func (s *StateStore) ScalingPolicyByTarget(ws memdb.WatchSet, target map[string]string) (*structs.ScalingPolicy, error)

+ func (s *StateStore) UpsertCSIPlugin(index uint64, plug *structs.CSIPlugin) error

+ func (s *StateStore) UpsertScalingEvent(index uint64, req *structs.ScalingEventRequest) error

+ func (s *StateStore) UpsertScalingPolicies(index uint64, scalingPolicies []*structs.ScalingPolicy) error

+ func (s *StateStore) UpsertScalingPoliciesTxn(index uint64, scalingPolicies []*structs.ScalingPolicy, txn *memdb.Txn) error

Apr 1, 2020

Changes in this version

type StateRestore

+ func (r *StateRestore) ClusterMetadataRestore(meta *structs.ClusterMetadata) error

+ func (r *StateRestore) SITokenAccessorRestore(accessor *structs.SITokenAccessor) error

type StateStore

+ func (s *StateStore) ClusterMetadata() (*structs.ClusterMetadata, error)

+ func (s *StateStore) ClusterSetMetadata(index uint64, meta *structs.ClusterMetadata) error

+ func (s *StateStore) DeleteSITokenAccessors(index uint64, accessors []*structs.SITokenAccessor) error

+ func (s *StateStore) SITokenAccessor(ws memdb.WatchSet, accessorID string) (*structs.SITokenAccessor, error)

+ func (s *StateStore) SITokenAccessors(ws memdb.WatchSet) (memdb.ResultIterator, error)

+ func (s *StateStore) SITokenAccessorsByAlloc(ws memdb.WatchSet, allocID string) ([]*structs.SITokenAccessor, error)

+ func (s *StateStore) SITokenAccessorsByNode(ws memdb.WatchSet, nodeID string) ([]*structs.SITokenAccessor, error)

+ func (s *StateStore) SnapshotMinIndex(ctx context.Context, index uint64) (*StateSnapshot, error)

+ func (s *StateStore) UpsertSITokenAccessors(index uint64, accessors []*structs.SITokenAccessor) error

Jun 5, 2019

Changes in this version

type StateSnapshot

+ func (s *StateSnapshot) DenormalizeAllocationDiffSlice(allocDiffs []*structs.AllocationDiff, planJob *structs.Job) ([]*structs.Allocation, error)

+ func (s *StateSnapshot) DenormalizeAllocationSlice(allocs []*structs.Allocation, job *structs.Job) ([]*structs.Allocation, error)

+ func (s *StateSnapshot) DenormalizeAllocationsMap(nodeAllocations map[string][]*structs.Allocation, job *structs.Job) error

type StateStore

+ func (s *StateStore) SnapshotAfter(ctx context.Context, index uint64) (*StateSnapshot, error)

Apr 9, 2019

Changes in this version

type StateRestore

+ func (r *StateRestore) SchedulerConfigRestore(schedConfig *structs.SchedulerConfiguration) error

type StateStore

+ func (s *StateStore) SchedulerCASConfig(idx, cidx uint64, config *structs.SchedulerConfiguration) (bool, error)

+ func (s *StateStore) SchedulerConfig() (uint64, *structs.SchedulerConfiguration, error)

+ func (s *StateStore) SchedulerSetConfig(idx uint64, config *structs.SchedulerConfiguration) error

type StateStoreConfig

+ Logger log.Logger

Jan 11, 2019

Changes in this version

type StateStore

+ func (s *StateStore) DeleteJobTxn(index uint64, namespace, jobID string, txn Txn) error

+ func (s *StateStore) DeletePeriodicLaunchTxn(index uint64, namespace, jobID string, txn Txn) error

+ func (s *StateStore) JobByIDTxn(ws memdb.WatchSet, namespace, id string, txn Txn) (*structs.Job, error)

+ func (s *StateStore) UpsertEvalsTxn(index uint64, evals []*structs.Evaluation, txn Txn) error

+ func (s *StateStore) UpsertJobTxn(index uint64, job *structs.Job, txn Txn) error

+ func (s *StateStore) WithWriteTransaction(fn func(Txn) error) error

+ type Txn = *memdb.Txn

Jun 11, 2018

Changes in this version

+ const NodeRegisterEventRegistered

+ const NodeRegisterEventReregistered

Apr 12, 2018

Changes in this version

type StateStore

+ func (s *StateStore) AutopilotCASConfig(idx, cidx uint64, config *structs.AutopilotConfig) (bool, error)

+ func (s *StateStore) AutopilotConfig() (uint64, *structs.AutopilotConfig, error)

+ func (s *StateStore) AutopilotSetConfig(idx uint64, config *structs.AutopilotConfig) error

+ func (s *StateStore) BatchUpdateNodeDrain(index uint64, updates map[string]*structs.DrainUpdate) error

+ func (s *StateStore) UpdateAllocsDesiredTransitions(index uint64, allocs map[string]*structs.DesiredTransition, ...) error

+ func (s *StateStore) UpdateNodeEligibility(index uint64, nodeID string, eligibility string) error

+ func (s *StateStore) UpsertNodeEvents(index uint64, nodeEvents map[string][]*structs.NodeEvent) error

Nov 1, 2017

Changes in this version

+ func RegisterSchemaFactories(factories ...SchemaFactory)

+ func TestInitState(t testing.T, state *StateStore)

+ type QueryFn func(memdb.WatchSet, *StateStore) (resp interface{}, index uint64, err error)

+ type SchemaFactories []SchemaFactory

+ func GetFactories() SchemaFactories

+ type SchemaFactory func() *memdb.TableSchema

type StateRestore

+ func (r *StateRestore) ACLPolicyRestore(policy *structs.ACLPolicy) error

+ func (r *StateRestore) ACLTokenRestore(token *structs.ACLToken) error

type StateStore

+ func TestStateStore(t testing.T) *StateStore

+ func (s *StateStore) ACLPolicies(ws memdb.WatchSet) (memdb.ResultIterator, error)

+ func (s *StateStore) ACLPolicyByName(ws memdb.WatchSet, name string) (*structs.ACLPolicy, error)

+ func (s *StateStore) ACLPolicyByNamePrefix(ws memdb.WatchSet, prefix string) (memdb.ResultIterator, error)

+ func (s *StateStore) ACLTokenByAccessorID(ws memdb.WatchSet, id string) (*structs.ACLToken, error)

+ func (s *StateStore) ACLTokenByAccessorIDPrefix(ws memdb.WatchSet, prefix string) (memdb.ResultIterator, error)

+ func (s *StateStore) ACLTokenBySecretID(ws memdb.WatchSet, secretID string) (*structs.ACLToken, error)

+ func (s *StateStore) ACLTokens(ws memdb.WatchSet) (memdb.ResultIterator, error)

+ func (s *StateStore) ACLTokensByGlobal(ws memdb.WatchSet, globalVal bool) (memdb.ResultIterator, error)

+ func (s *StateStore) AllocsByNamespace(ws memdb.WatchSet, namespace string) (memdb.ResultIterator, error)

+ func (s *StateStore) BlockingQuery(query QueryFn, minIndex uint64, ctx context.Context) (resp interface{}, index uint64, err error)

+ func (s *StateStore) BootstrapACLTokens(index, resetIndex uint64, token *structs.ACLToken) error

+ func (s *StateStore) CanBootstrapACLToken() (bool, uint64, error)

+ func (s *StateStore) Config() *StateStoreConfig

+ func (s *StateStore) DeleteACLPolicies(index uint64, names []string) error

+ func (s *StateStore) DeleteACLTokens(index uint64, ids []string) error

+ func (s *StateStore) DeploymentsByNamespace(ws memdb.WatchSet, namespace string) (memdb.ResultIterator, error)

+ func (s *StateStore) EvalsByNamespace(ws memdb.WatchSet, namespace string) (memdb.ResultIterator, error)

+ func (s *StateStore) JobsByNamespace(ws memdb.WatchSet, namespace string) (memdb.ResultIterator, error)

+ func (s *StateStore) NodeBySecretID(ws memdb.WatchSet, secretID string) (*structs.Node, error)

+ func (s *StateStore) UpsertACLPolicies(index uint64, policies []*structs.ACLPolicy) error

+ func (s *StateStore) UpsertACLTokens(index uint64, tokens []*structs.ACLToken) error

+ type StateStoreConfig struct

+ LogOutput io.Writer

+ Region string

Jul 26, 2017

Changes in this version

type StateRestore

+ func (r *StateRestore) DeploymentRestore(deployment *structs.Deployment) error

+ func (r *StateRestore) JobVersionRestore(version *structs.Job) error

type StateStore

+ func (s *StateStore) AllocsByDeployment(ws memdb.WatchSet, deploymentID string) ([]*structs.Allocation, error)

+ func (s *StateStore) DeleteDeployment(index uint64, deploymentIDs []string) error

+ func (s *StateStore) DeploymentByID(ws memdb.WatchSet, deploymentID string) (*structs.Deployment, error)

+ func (s *StateStore) Deployments(ws memdb.WatchSet) (memdb.ResultIterator, error)

+ func (s *StateStore) DeploymentsByIDPrefix(ws memdb.WatchSet, deploymentID string) (memdb.ResultIterator, error)

+ func (s *StateStore) DeploymentsByJobID(ws memdb.WatchSet, jobID string) ([]*structs.Deployment, error)

+ func (s *StateStore) JobByIDAndVersion(ws memdb.WatchSet, id string, version uint64) (*structs.Job, error)

+ func (s *StateStore) JobVersions(ws memdb.WatchSet) (memdb.ResultIterator, error)

+ func (s *StateStore) JobVersionsByID(ws memdb.WatchSet, id string) ([]*structs.Job, error)

+ func (s *StateStore) LatestDeploymentByJobID(ws memdb.WatchSet, jobID string) (*structs.Deployment, error)

+ func (s *StateStore) UpdateDeploymentAllocHealth(index uint64, req *structs.ApplyDeploymentAllocHealthRequest) error

+ func (s *StateStore) UpdateDeploymentPromotion(index uint64, req *structs.ApplyDeploymentPromoteRequest) error

+ func (s *StateStore) UpdateDeploymentStatus(index uint64, req *structs.DeploymentStatusUpdateRequest) error

+ func (s *StateStore) UpdateJobStability(index uint64, jobID string, jobVersion uint64, stable bool) error

+ func (s *StateStore) UpsertDeployment(index uint64, deployment *structs.Deployment) error

+ func (s *StateStore) UpsertPlanResults(index uint64, results *structs.ApplyPlanResultsRequest) error

Mar 14, 2017

Changes in this version

type StateStore

+ func (s *StateStore) Abandon()

+ func (s *StateStore) AbandonCh() <-chan struct{}

Nov 16, 2016

Changes in this version

type StateRestore

+ func (r *StateRestore) VaultAccessorRestore(accessor *structs.VaultAccessor) error

type StateStore

+ func (s *StateStore) DeleteVaultAccessors(index uint64, accessors []*structs.VaultAccessor) error

+ func (s *StateStore) UpsertVaultAccessor(index uint64, accessors []*structs.VaultAccessor) error

+ func (s *StateStore) VaultAccessor(accessor string) (*structs.VaultAccessor, error)

+ func (s *StateStore) VaultAccessors() (memdb.ResultIterator, error)

+ func (s *StateStore) VaultAccessorsByAlloc(allocID string) ([]*structs.VaultAccessor, error)

+ func (s *StateStore) VaultAccessorsByNode(nodeID string) ([]*structs.VaultAccessor, error)

Aug 17, 2016

Changes in this version

type StateRestore

+ func (r *StateRestore) JobSummaryRestore(jobSummary *structs.JobSummary) error

type StateStore

+ func (s *StateStore) DeleteJobSummary(index uint64, id string) error

+ func (s *StateStore) JobSummaries() (memdb.ResultIterator, error)

+ func (s *StateStore) JobSummaryByID(jobID string) (*structs.JobSummary, error)

+ func (s *StateStore) JobSummaryByPrefix(id string) (memdb.ResultIterator, error)

+ func (s *StateStore) ReconcileJobSummaries(index uint64) error

+ func (s *StateStore) RemoveIndex(name string) error

+ func (s *StateStore) UpsertJobSummary(index uint64, jobSummary *structs.JobSummary) error

Jun 28, 2016

Changes in this version

type StateStore

+ func (s *StateStore) LatestIndex() (uint64, error)

Feb 25, 2016

Changes in this version

type StateRestore

+ func (r *StateRestore) PeriodicLaunchRestore(launch *structs.PeriodicLaunch) error

type StateStore

+ func (s *StateStore) AllocsByIDPrefix(id string) (memdb.ResultIterator, error)

+ func (s *StateStore) AllocsByNodeTerminal(node string, terminal bool) ([]*structs.Allocation, error)

+ func (s *StateStore) DeletePeriodicLaunch(index uint64, jobID string) error

+ func (s *StateStore) EvalsByIDPrefix(id string) (memdb.ResultIterator, error)

+ func (s *StateStore) JobsByGC(gc bool) (memdb.ResultIterator, error)

+ func (s *StateStore) JobsByIDPrefix(id string) (memdb.ResultIterator, error)

+ func (s *StateStore) JobsByPeriodic(periodic bool) (memdb.ResultIterator, error)

+ func (s *StateStore) NodesByIDPrefix(nodeID string) (memdb.ResultIterator, error)

+ func (s *StateStore) PeriodicLaunchByID(id string) (*structs.PeriodicLaunch, error)

+ func (s *StateStore) PeriodicLaunches() (memdb.ResultIterator, error)

+ func (s *StateStore) UpdateAllocsFromClient(index uint64, allocs []*structs.Allocation) error

+ func (s *StateStore) UpsertPeriodicLaunch(index uint64, launch *structs.PeriodicLaunch) error

Nov 19, 2015

Changes in this version

type StateStore

+ func (s *StateStore) JobsByScheduler(schedulerType string) (memdb.ResultIterator, error)

+ func (s *StateStore) StopWatch(items watch.Items, notify chan struct{})

+ func (s *StateStore) Watch(items watch.Items, notify chan struct{})

Sep 28, 2015

Changes in this version

+ type IndexEntry struct

+ Key string

+ Value uint64

+ type NotifyGroup struct

+ func (n *NotifyGroup) Clear(ch chan struct{})

+ func (n *NotifyGroup) Empty() bool

+ func (n *NotifyGroup) Notify()

+ func (n *NotifyGroup) Wait(ch chan struct{})

+ func (n *NotifyGroup) WaitCh() chan struct{}

+ type StateRestore struct

+ func (r *StateRestore) AllocRestore(alloc *structs.Allocation) error

+ func (r *StateRestore) EvalRestore(eval *structs.Evaluation) error

+ func (r *StateRestore) IndexRestore(idx *IndexEntry) error

+ func (r *StateRestore) JobRestore(job *structs.Job) error

+ func (r *StateRestore) NodeRestore(node *structs.Node) error

+ func (s *StateRestore) Abort()

+ func (s *StateRestore) Commit()

+ type StateSnapshot struct

+ type StateStore struct

+ func NewStateStore(logOutput io.Writer) (*StateStore, error)

+ func (s *StateStore) AllocByID(id string) (*structs.Allocation, error)

+ func (s *StateStore) Allocs() (memdb.ResultIterator, error)

+ func (s *StateStore) AllocsByEval(evalID string) ([]*structs.Allocation, error)

+ func (s *StateStore) AllocsByJob(jobID string) ([]*structs.Allocation, error)

+ func (s *StateStore) AllocsByNode(node string) ([]*structs.Allocation, error)

+ func (s *StateStore) DeleteEval(index uint64, evals []string, allocs []string) error

+ func (s *StateStore) DeleteJob(index uint64, jobID string) error

+ func (s *StateStore) DeleteNode(index uint64, nodeID string) error

+ func (s *StateStore) EvalByID(id string) (*structs.Evaluation, error)

+ func (s *StateStore) Evals() (memdb.ResultIterator, error)

+ func (s *StateStore) EvalsByJob(jobID string) ([]*structs.Evaluation, error)

+ func (s *StateStore) Index(name string) (uint64, error)

+ func (s *StateStore) Indexes() (memdb.ResultIterator, error)

+ func (s *StateStore) JobByID(id string) (*structs.Job, error)

+ func (s *StateStore) Jobs() (memdb.ResultIterator, error)

+ func (s *StateStore) NodeByID(nodeID string) (*structs.Node, error)

+ func (s *StateStore) Nodes() (memdb.ResultIterator, error)

+ func (s *StateStore) Restore() (*StateRestore, error)

+ func (s *StateStore) Snapshot() (*StateSnapshot, error)

+ func (s *StateStore) StopWatchAllocs(node string, notify chan struct{})

+ func (s *StateStore) UpdateAllocFromClient(index uint64, alloc *structs.Allocation) error

+ func (s *StateStore) UpdateNodeDrain(index uint64, nodeID string, drain bool) error

+ func (s *StateStore) UpdateNodeStatus(index uint64, nodeID, status string) error

+ func (s *StateStore) UpsertAllocs(index uint64, allocs []*structs.Allocation) error

+ func (s *StateStore) UpsertEvals(index uint64, evals []*structs.Evaluation) error

+ func (s *StateStore) UpsertJob(index uint64, job *structs.Job) error

+ func (s *StateStore) UpsertNode(index uint64, node *structs.Node) error

+ func (s *StateStore) WatchAllocs(node string, notify chan struct{})