statemanager

Documentation

Overview

Package statemanager implements simple constructs for saving and restoring state from disk. It provides the interface for a StateManager which can read/write arbitrary json data from/to disk.

Index

• Constants
• type NoopStateManager
  • func (nsm *NoopStateManager) ForceSave() error
  • func (nsm *NoopStateManager) Load() error
  • func (nsm *NoopStateManager) Save() error
• type Option
  • func AddSaveable(name string, saveable Saveable) Option
• type Saveable
• type Saver
• type StateManager
  • func NewNoopStateManager() StateManager
  • func NewStateManager(cfg *config.Config, options ...Option) (StateManager, error)

Constants

const (
	// ECSDataVersion is the current version of saved data. Any backwards or
	// forwards incompatible changes to the data-format should increment this number
	// and retain the ability to read old data versions.
	// Version changes:
	// 1) initial
	// 2)
	//   a) Add 'ACSSeqNum' top level field (backwards compatible; technically
	//      forwards compatible but could cause resource constraint violations)
	//   b) remove 'DEAD', 'UNKNOWN' state from ever being marshalled (backward and
	//      forward compatible)
	// 3) Add 'Protocol' field to 'portMappings' and 'KnownPortBindings'
	// 4) Add 'DockerConfig' struct
	// 5) Add 'ImageStates' struct as part of ImageManager
	// 6)
	//   a) Refactor 'Internal' field in 'apicontainer.Container' to 'Type' enum
	//   b) Add 'ContainerResourcesProvisioned' as a new 'ContainerStatus' enum
	//   c) Add 'SteadyStateStatus' field to 'Container' struct
	//   d) Add 'ENIAttachments' struct
	//   e) Deprecate 'SteadyStateDependencies' in favor of 'TransitionDependencySet'
	// 7)
	//   a) Add 'MetadataUpdated' field to 'apicontainer.Container'
	//   b) Add 'DomainNameServers' and 'DomainNameSearchList' in `api.ENI`
	// 8)
	//   a) Add 'UseExecutionRole' in `api.ECRAuthData`
	//   b) Add `executionCredentialsID` in `apitask.Task`
	//   c) Add 'LogsAuthStrategy' field to 'apicontainer.Container'
	//   d) Added task cgroup related fields ('CPU', 'Memory', 'MemoryCPULimitsEnabled') to 'apitask.Task'
	// 9) Add 'ipToTask' map to state file
	// 10) Add 'healthCheckType' field in 'apicontainer.Container'
	// 11)
	//  a) Add 'PrivateDNSName' field to 'api.ENI'
	//  b)Remove `AppliedStatus` field form 'apicontainer.Container'
	// 12) Deprecate 'TransitionDependencySet' and add new 'TransitionDependenciesMap' in 'apicontainer.Container'
	// 13) Add 'resources' field to 'api.task.task'
	ECSDataVersion = 13
)

Types

type NoopStateManager

type NoopStateManager struct{}

NoopStateManager is a state manager that succeeds for all reads/writes without even trying; it allows disabling of state serialization by being a drop-in replacement so no other code need be concerned with it.

func (*NoopStateManager) ForceSave

func (nsm *NoopStateManager) ForceSave() error

ForceSave does nothing, successfully

func (*NoopStateManager) Load

func (nsm *NoopStateManager) Load() error

Load does nothing, successfully

func (*NoopStateManager) Save

func (nsm *NoopStateManager) Save() error

Save does nothing, successfully

type Option

type Option func(StateManager)

Option functions are functions that may be used as part of constructing a new StateManager

func AddSaveable

func AddSaveable(name string, saveable Saveable) Option

AddSaveable is an option that adds a given saveable as one that should be saved under the given name. The name must be the same across uses of the statemanager (e.g. program invocations) for it to be serialized and deserialized correctly.

type Saveable

type Saveable interface{}

Saveable types should be able to be json serializable and deserializable Properly, this should have json.Marshaler/json.Unmarshaler here, but string and so on can be marshaled/unmarshaled sanely but don't fit those interfaces.

type Saver

type Saver interface {
	Save() error
	ForceSave() error
}

Saver is a type that can be saved

type StateManager

type StateManager interface {
	Saver
	Load() error
}

A StateManager can load and save state from disk. Load is not expected to return an error if there is no state to load.

func NewNoopStateManager

func NewNoopStateManager() StateManager

NewNoopStateManager constructs a state manager

func NewStateManager

func NewStateManager(cfg *config.Config, options ...Option) (StateManager, error)

NewStateManager constructs a new StateManager which saves data at the location specified in cfg and operates under the given options. The returned StateManager will not save more often than every 10 seconds and will not reliably return errors with Save, but will log them appropriately.