state

package
v0.0.0-...-f19ae85 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 12, 2015 License: AGPL-3.0 Imports: 43 Imported by: 0

Documentation

Overview

Package state enables reading, observing, and changing the state stored in MongoDB of a whole environment managed by juju.

Index

Constants

View Source
const (
	ItemAdded = iota
	ItemModified
	ItemDeleted
)
View Source
const (
	CleanupAge = time.Hour * 24
)

Variables

View Source
var ErrCannotEnterScope = stderrors.New("cannot enter scope: unit or relation is not alive")

ErrCannotEnterScope indicates that a relation unit failed to enter its scope due to either the unit or the relation not being Alive.

View Source
var ErrCannotEnterScopeYet = stderrors.New("cannot enter scope yet: non-alive subordinate unit has not been removed")

ErrCannotEnterScopeYet indicates that a relation unit failed to enter its scope due to a required and pre-existing subordinate unit that is not Alive. Once that subordinate has been removed, a new one can be created.

View Source
var ErrCharmRevisionAlreadyModified = fmt.Errorf("charm revision already modified")

ErrCharmRevisionAlreadyModified is returned when a pending or placeholder charm is no longer pending or a placeholder, signaling the charm is available in state with its full information.

View Source
var ErrDead = fmt.Errorf("not found or dead")
View Source
var ErrStateClosed = fmt.Errorf("state has been closed")

ErrStateClosed is returned from watchers if their underlying state connection has been closed.

View Source
var ErrStopped = stderrors.New("watcher was stopped")
View Source
var ErrSubordinateConstraints = stderrors.New("constraints do not apply to subordinate services")
View Source
var ErrUnitHasStorageInstances = stderrors.New("unit has storage instances")

ErrUnitHasStorageInstances is a standard error to indicate that a Unit cannot complete an operation to end its life because it still has storage instances.

View Source
var ErrUnitHasSubordinates = stderrors.New("unit has subordinates")

ErrUnitHasSubordinates is a standard error to indicate that a Unit cannot complete an operation to end its life because it still has subordinate services

View Source
var NewUUID = func() (utils.UUID, error) { return utils.NewUUID() }

NewUUID wraps the utils.NewUUID() call, and exposes it as a var to facilitate patching.

View Source
var UpgradeInProgressError = errors.New("an upgrade is already in progress or the last upgrade did not complete")

Functions

func AddAvailabilityZoneToInstanceData

func AddAvailabilityZoneToInstanceData(st *State, azFunc func(*State, instance.Id) (string, error)) error

AddAvailabilityZoneToInstanceData sets the AvailZone field on instanceData docs that don't have it already.

func AddCharmStoragePaths

func AddCharmStoragePaths(st *State, storagePaths map[*charm.URL]string) error

AddCharmStoragePaths adds storagepath fields to the specified charms.

func AddEnvUUIDToAnnotations

func AddEnvUUIDToAnnotations(st *State) error

AddEnvUUIDToAnnotations prepends the environment UUID to the ID of all annotation docs and adds new "env-uuid" field.

func AddEnvUUIDToCharms

func AddEnvUUIDToCharms(st *State) error

AddEnvUUIDToCharms prepends the environment UUID to the ID of all charm docs and adds new "env-uuid" field.

func AddEnvUUIDToCleanups

func AddEnvUUIDToCleanups(st *State) error

AddEnvUUIDToCleanups prepends the environment UUID to the ID of all cleanup docs and adds new "env-uuid" field.

func AddEnvUUIDToConstraints

func AddEnvUUIDToConstraints(st *State) error

AddEnvUUIDToConstraints prepends the environment UUID to the ID of all constraints docs and adds new "env-uuid" field.

func AddEnvUUIDToContainerRefs

func AddEnvUUIDToContainerRefs(st *State) error

AddEnvUUIDToContainerRefs prepends the environment UUID to the ID of all containerRef docs and adds new "env-uuid" field.

func AddEnvUUIDToInstanceData

func AddEnvUUIDToInstanceData(st *State) error

AddEnvUUIDToInstanceData prepends the environment UUID to the ID of all instanceData docs and adds new "env-uuid" field.

func AddEnvUUIDToMachines

func AddEnvUUIDToMachines(st *State) error

AddEnvUUIDToMachines prepends the environment UUID to the ID of all machine docs and adds new "env-uuid" field.

func AddEnvUUIDToMeterStatus

func AddEnvUUIDToMeterStatus(st *State) error

AddEnvUUIDToMeterStatus prepends the environment UUID to the ID of all meterStatus docs and adds new "env-uuid" field and "id" fields.

func AddEnvUUIDToMinUnits

func AddEnvUUIDToMinUnits(st *State) error

AddEnvUUIDToMinUnits prepends the environment UUID to the ID of all minUnits docs and adds new "env-uuid" field.

func AddEnvUUIDToNetworkInterfaces

func AddEnvUUIDToNetworkInterfaces(st *State) error

AddEnvUUIDToNetworkInterfaces prepends adds a new "env-uuid" field to all networkInterfaces docs.

func AddEnvUUIDToNetworks

func AddEnvUUIDToNetworks(st *State) error

AddEnvUUIDToNetworks prepends the environment UUID to the ID of all network docs and adds new "env-uuid" field.

func AddEnvUUIDToOpenPorts

func AddEnvUUIDToOpenPorts(st *State) error

AddEnvUUIDToOpenPorts prepends the environment UUID to the ID of all openPorts docs and adds new "env-uuid" field.

func AddEnvUUIDToReboots

func AddEnvUUIDToReboots(st *State) error

AddEnvUUIDToReboots prepends the environment UUID to the ID of all reboot docs and adds new "env-uuid" field.

func AddEnvUUIDToRelationScopes

func AddEnvUUIDToRelationScopes(st *State) error

AddEnvUUIDToRelationScopes prepends the environment UUID to the ID of all relationscopes docs and adds new "env-uuid" field and "key" fields.

func AddEnvUUIDToRelations

func AddEnvUUIDToRelations(st *State) error

AddEnvUUIDToRelations prepends the environment UUID to the ID of all relations docs and adds new "env-uuid" and "key" fields.

func AddEnvUUIDToRequestedNetworks

func AddEnvUUIDToRequestedNetworks(st *State) error

AddEnvUUIDToRequestedNetworks prepends the environment UUID to the ID of all requestedNetworks docs and adds new "env-uuid" field.

func AddEnvUUIDToSequences

func AddEnvUUIDToSequences(st *State) error

AddEnvUUIDToSequences prepends the environment UUID to the ID of all sequence docs and adds new "env-uuid" field.

func AddEnvUUIDToServices

func AddEnvUUIDToServices(st *State) error

AddEnvUUIDToServices prepends the environment UUID to the ID of all service docs and adds new "env-uuid" field.

func AddEnvUUIDToSettings

func AddEnvUUIDToSettings(st *State) error

AddEnvUUIDToSettings prepends the environment UUID to the ID of all settings docs and adds new "env-uuid" field.

func AddEnvUUIDToSettingsRefs

func AddEnvUUIDToSettingsRefs(st *State) error

AddEnvUUIDToSettingsRefs prepends the environment UUID to the ID of all settingRef docs and adds new "env-uuid" field.

func AddEnvUUIDToStatuses

func AddEnvUUIDToStatuses(st *State) error

AddEnvUUIDToStatuses prepends the environment UUID to the ID of all Statuses docs and adds new "env-uuid" field.

func AddEnvUUIDToUnits

func AddEnvUUIDToUnits(st *State) error

AddEnvUUIDToUnits prepends the environment UUID to the ID of all unit docs and adds new "env-uuid" field.

func AddEnvironmentUUIDToStateServerDoc

func AddEnvironmentUUIDToStateServerDoc(st *State) error

AddEnvironmentUUIDToStateServerDoc adds environment uuid to state server doc.

func AddStateUsersAsEnvironUsers

func AddStateUsersAsEnvironUsers(st *State) error

AddStateUsersAsEnvironUsers loops through all users stored in state and adds them as environment users with a local provider.

func ContainerTypeFromId

func ContainerTypeFromId(machineId string) instance.ContainerType

ContainerTypeFromId returns the container type if machineId is a container id, or "" if machineId is not for a container.

func CreateUnitMeterStatus

func CreateUnitMeterStatus(st *State) error

CreateUnitMeterStatus creates documents in the meter status collection for all existing units.

func DropOldIndexesv123

func DropOldIndexesv123(st *State) error

DropOldIndexesv123 drops old mongo indexes.

func FixMinUnitsEnvUUID

func FixMinUnitsEnvUUID(st *State) error

FixMinUnitsEnvUUID sets the env-uuid field on documents in the minUnits collection where the field is blank. This is needed because a code change was missed with the env UUID migration was done for this collection (in 1.21).

func FixSequenceFields

func FixSequenceFields(st *State) error

FixSequenceFields sets the env-uuid and name fields on documents in the sequence collection where these fields are blank. This is needed because code changes were missed with the env UUID migration was done for this collection (in 1.21).

func IsCharmAlreadyUploadedError

func IsCharmAlreadyUploadedError(err interface{}) bool

IsCharmAlreadyUploadedError returns if the given error is ErrCharmAlreadyUploaded.

func IsHasAssignedUnitsError

func IsHasAssignedUnitsError(err error) bool

func IsHasContainersError

func IsHasContainersError(err error) bool

func IsNotAssigned

func IsNotAssigned(err error) bool

IsNotAssigned verifies that err is an instance of NotAssignedError

func IsUpgradeInProgressError

func IsUpgradeInProgressError(err error) bool

IsUpgradeInProgressError returns true if the error given is UpgradeInProgressError.

func IsVersionInconsistentError

func IsVersionInconsistentError(e interface{}) bool

IsVersionInconsistentError returns if the given error is versionInconsistentError.

func LeadershipSettingsDocId

func LeadershipSettingsDocId(serviceId string) string

func MigrateJobManageNetworking

func MigrateJobManageNetworking(st *State) error

migrateJobManageNetworking adds the job JobManageNetworking to all machines except for:

- machines in a MAAS environment, - machines in a Joyent environment, - machines in a manual environment, - bootstrap node (host machine) in a local environment, and - manually provisioned machines.

func MigrateMachineInstanceIdToInstanceData

func MigrateMachineInstanceIdToInstanceData(st *State) error

MigrateMachineInstanceIdToInstanceData migrates the deprecated "instanceid" machine field into "instanceid" in the instanceData doc.

func MigrateUnitPortsToOpenedPorts

func MigrateUnitPortsToOpenedPorts(st *State) error

MigrateUnitPortsToOpenedPorts loops through all units stored in state and migrates any ports into the openedPorts collection.

func MigrateUserLastConnectionToLastLogin

func MigrateUserLastConnectionToLastLogin(st *State) error

func NestingLevel

func NestingLevel(machineId string) int

NestingLevel returns how many levels of nesting exist for a machine id.

func ParentId

func ParentId(machineId string) string

ParentId returns the id of the host machine if machineId a container id, or "" if machineId is not for a container.

func ServiceInstances

func ServiceInstances(st *State, service string) ([]instance.Id, error)

ServiceInstances returns the instance IDs of provisioned machines that are assigned units of the specified service.

func SetOwnerAndServerUUIDForEnvironment

func SetOwnerAndServerUUIDForEnvironment(st *State) error

SetOwnerAndServerUUIDForEnvironment adds the environment uuid as the server uuid as well (it is the initial environment, so all good), and the owner to "admin@local", again all good as all existing environments have a user called "admin".

func SetSystemIdentity

func SetSystemIdentity(st *State, identity string) error

SetSystemIdentity sets the system identity value in the database if and only iff it is empty.

func TopParentId

func TopParentId(machineId string) string

TopParentId returns the id of the top level host machine for a container id.

Types

type Action

type Action struct {
	// contains filtered or unexported fields
}

Action represents an instruction to do some "action" and is expected to match an action definition in a charm.

func (*Action) ActionTag

func (a *Action) ActionTag() names.ActionTag

ActionTag returns an ActionTag constructed from this action's Prefix and Sequence.

func (*Action) Begin

func (a *Action) Begin() (*Action, error)

Begin marks an action as running, and logs the time it was started. It asserts that the action is currently pending.

func (*Action) Completed

func (a *Action) Completed() time.Time

Completed returns the completion time of the Action.

func (*Action) Enqueued

func (a *Action) Enqueued() time.Time

Enqueued returns the time the action was added to state as a pending Action.

func (*Action) Finish

func (a *Action) Finish(results ActionResults) (*Action, error)

Finish removes action from the pending queue and captures the output and end state of the action.

func (*Action) Id

func (a *Action) Id() string

Id returns the local id of the Action.

func (*Action) Name

func (a *Action) Name() string

Name returns the name of the action, as defined in the charm.

func (*Action) Parameters

func (a *Action) Parameters() map[string]interface{}

Parameters will contain a structure representing arguments or parameters to an action, and is expected to be validated by the Unit using the Charm definition of the Action.

func (*Action) Receiver

func (a *Action) Receiver() string

Receiver returns the Name of the ActionReceiver for which this action is enqueued. Usually this is a Unit Name().

func (*Action) Results

func (a *Action) Results() (map[string]interface{}, string)

Results returns the structured output of the action and any error.

func (*Action) Started

func (a *Action) Started() time.Time

Started returns the time that the Action execution began.

func (*Action) Status

func (a *Action) Status() ActionStatus

Status returns the final state of the action.

func (*Action) Tag

func (a *Action) Tag() names.Tag

Tag implements the Entity interface and returns a names.Tag that is a names.ActionTag.

func (*Action) ValidateTag

func (a *Action) ValidateTag() bool

ValidateTag should be called before calls to Tag() or ActionTag(). It verifies that the Action can produce a valid Tag.

type ActionReceiver

type ActionReceiver interface {
	Entity

	// AddAction queues an action with the given name and payload for this
	// ActionReceiver.
	AddAction(name string, payload map[string]interface{}) (*Action, error)

	// CancelAction removes a pending Action from the queue for this
	// ActionReceiver and marks it as cancelled.
	CancelAction(action *Action) (*Action, error)

	// WatchActionNotifications returns a StringsWatcher that will notify
	// on changes to the queued actions for this ActionReceiver.
	WatchActionNotifications() StringsWatcher

	// Actions returns the list of Actions queued and completed for this
	// ActionReceiver.
	Actions() ([]*Action, error)

	// CompletedActions returns the list of Actions completed for this
	// ActionReceiver.
	CompletedActions() ([]*Action, error)

	// PendingActions returns the list of Actions queued for this
	// ActionReceiver.
	PendingActions() ([]*Action, error)

	// RunningActions returns the list of Actions currently running for
	// this ActionReceiver.
	RunningActions() ([]*Action, error)
}

ActionReceiver describes Entities that can have Actions queued for them, and that can get ActionRelated information about those actions. TODO(jcw4) consider implementing separate Actor classes for this interface; for example UnitActor that implements this interface, and takes a Unit and performs all these actions.

type ActionResults

type ActionResults struct {
	Status  ActionStatus           `json:"status"`
	Results map[string]interface{} `json:"results"`
	Message string                 `json:"message"`
}

ActionResults is a data transfer object that holds the key Action output and results information.

type ActionSpecsByName

type ActionSpecsByName map[string]charm.ActionSpec

ActionSpecsByName is a map of action names to their respective ActionSpec.

type ActionStatus

type ActionStatus string

ActionStatus represents the possible end states for an action.

const (
	// ActionFailed signifies that the action did not complete successfully.
	ActionFailed ActionStatus = "failed"

	// ActionCompleted indicates that the action ran to completion as intended.
	ActionCompleted ActionStatus = "completed"

	// ActionCancelled means that the Action was cancelled before being run.
	ActionCancelled ActionStatus = "cancelled"

	// ActionPending is the default status when an Action is first queued.
	ActionPending ActionStatus = "pending"

	// ActionRunning indicates that the Action is currently running.
	ActionRunning ActionStatus = "running"
)

type ActionsWatcher

type ActionsWatcher interface {
	Entity
	WatchActionNotifications() StringsWatcher
}

ActionsWatcher defines the methods an entity exposes to watch Actions queued up for itself

type AddressState

type AddressState string

AddressState represents the states an IP address can be in. They are created in an unknown state and then either become allocated or unavailable if allocation fails.

const (
	// AddressStateUnknown is the initial state an IP address is created with
	AddressStateUnknown AddressState = ""

	// AddressStateAllocated means that the IP address has successfully
	// been allocated by the provider and is now in use.
	AddressStateAllocated AddressState = "allocated"

	// AddressStateUnavailable means that allocating the address with the
	// provider failed. We shouldn't use this address, nor should we
	// attempt to allocate it again in the future.
	AddressStateUnvailable AddressState = "unavailable"
)

type AgentEntity

AgentEntity represents an entity that can have an agent responsible for it.

type AgentLiving

type AgentLiving interface {
	Living
	EnsureDead() error
	Remove() error
}

AgentLiving describes state entities with a lifecycle and an agent that manages it.

type AgentTooler

type AgentTooler interface {
	AgentTools() (*tools.Tools, error)
	SetAgentVersion(version.Binary) error
}

AgentTooler is implemented by entities that have associated agent tools.

type AssignmentPolicy

type AssignmentPolicy string

AssignmentPolicy controls what machine a unit will be assigned to.

const (
	// AssignLocal indicates that all service units should be assigned
	// to machine 0.
	AssignLocal AssignmentPolicy = "local"

	// AssignClean indicates that every service unit should be assigned
	// to a machine which never previously has hosted any units, and that
	// new machines should be launched if required.
	AssignClean AssignmentPolicy = "clean"

	// AssignCleanEmpty indicates that every service unit should be assigned
	// to a machine which never previously has hosted any units, and which is not
	// currently hosting any containers, and that new machines should be launched if required.
	AssignCleanEmpty AssignmentPolicy = "clean-empty"

	// AssignNew indicates that every service unit should be assigned to a new
	// dedicated machine.  A new machine will be launched for each new unit.
	AssignNew AssignmentPolicy = "new"
)

type Authenticator

type Authenticator interface {
	Refresh() error
	SetPassword(pass string) error
	PasswordValid(pass string) bool
}

Authenticator represents entites capable of handling password authentication.

type Backing

type Backing interface {

	// GetAll retrieves information about all information
	// known to the Backing and stashes it in the Store.
	GetAll(all *multiwatcherStore) error

	// Changed informs the backing about a change received
	// from a watcher channel.  The backing is responsible for
	// updating the Store to reflect the change.
	Changed(all *multiwatcherStore, change watcher.Change) error

	// Watch watches for any changes and sends them
	// on the given channel.
	Watch(in chan<- watcher.Change)

	// Unwatch stops watching for changes on the
	// given channel.
	Unwatch(in chan<- watcher.Change)
}

Backing is the interface required by the storeManager to access the underlying state.

type BlockDevice

type BlockDevice interface {
	// Tag returns the tag for the block device.
	Tag() names.Tag

	// Name returns the unique name of the block device.
	Name() string

	// StorageInstance returns the ID of the storage instance that this
	// block device is assigned to, if any, and a boolean indicating whether
	// it is assigned to a store.
	//
	// A block device can be assigned to at most one store. It is possible
	// for multiple block devices to be assigned to the same store, e.g.
	// multi-attach volumes.
	StorageInstance() (string, bool)

	// Machine returns the ID of the machine the block device is attached to.
	Machine() string

	// Attached returns true if the block device is known to be attached to
	// its associated machine.
	Attached() bool

	// Info returns the block device's BlockDeviceInfo, or a NotProvisioned
	// error if the block device has not yet been provisioned.
	Info() (BlockDeviceInfo, error)

	// Params returns the parameters for provisioning the block device,
	// if it has not already been provisioned. Params returns true if the
	// returned parameters are usable for provisioning, otherwise false.
	Params() (BlockDeviceParams, bool)
}

BlockDevice represents the state of a block device in the environment.

type BlockDeviceInfo

type BlockDeviceInfo struct {
	DeviceName     string `bson:"devicename,omitempty"`
	Label          string `bson:"label,omitempty"`
	UUID           string `bson:"uuid,omitempty"`
	Serial         string `bson:"serial,omitempty"`
	Size           uint64 `bson:"size"`
	FilesystemType string `bson:"fstype"`
	InUse          bool   `bson:"inuse"`
}

BlockDeviceInfo describes information about a block device.

type BlockDeviceParams

type BlockDeviceParams struct {
	Size uint64 `bson:"size"`
	// contains filtered or unexported fields
}

BlockDeviceParams records parameters for provisioning a new block device.

type Charm

type Charm struct {
	// contains filtered or unexported fields
}

Charm represents the state of a charm in the environment.

func (*Charm) Actions

func (c *Charm) Actions() *charm.Actions

Actions returns the actions definition of the charm.

func (*Charm) BundleSha256

func (c *Charm) BundleSha256() string

BundleSha256 returns the SHA256 digest of the charm bundle bytes.

func (*Charm) BundleURL

func (c *Charm) BundleURL() *url.URL

BundleURL returns the url to the charm bundle in the provider storage.

DEPRECATED: this is only to be used for migrating charm archives to environment storage.

func (*Charm) Config

func (c *Charm) Config() *charm.Config

Config returns the configuration of the charm.

func (*Charm) IsPlaceholder

func (c *Charm) IsPlaceholder() bool

IsPlaceholder returns whether the charm record is just a placeholder rather than representing a deployed charm.

func (*Charm) IsUploaded

func (c *Charm) IsUploaded() bool

IsUploaded returns whether the charm has been uploaded to the environment storage.

func (*Charm) Meta

func (c *Charm) Meta() *charm.Meta

Meta returns the metadata of the charm.

func (*Charm) Metrics

func (c *Charm) Metrics() *charm.Metrics

Metrics returns the metrics declared for the charm.

func (*Charm) Revision

func (c *Charm) Revision() int

Revision returns the monotonically increasing charm revision number.

func (*Charm) StoragePath

func (c *Charm) StoragePath() string

StoragePath returns the storage path of the charm bundle.

func (*Charm) String

func (c *Charm) String() string

func (*Charm) Tag

func (c *Charm) Tag() names.Tag

Tag returns a tag identifying the charm. Implementing state.GlobalEntity interface.

func (*Charm) URL

func (c *Charm) URL() *charm.URL

URL returns the URL that identifies the charm.

type ConfigValidator

type ConfigValidator interface {
	Validate(cfg, old *config.Config) (valid *config.Config, err error)
}

ConfigValidator is a policy interface that is provided to State to check validity of new configuration attributes before applying them to state.

type DeployerConnectionValues

type DeployerConnectionValues struct {
	StateAddresses []string
	APIAddresses   []string
}

type Endpoint

type Endpoint struct {
	ServiceName string
	charm.Relation
}

Endpoint represents one endpoint of a relation.

func (Endpoint) CanRelateTo

func (ep Endpoint) CanRelateTo(other Endpoint) bool

CanRelateTo returns whether a relation may be established between e and other.

func (Endpoint) String

func (ep Endpoint) String() string

String returns the unique identifier of the relation endpoint.

type EnsureDeader

type EnsureDeader interface {
	EnsureDead() error
}

EnsureDeader with an EnsureDead method.

type Entity

type Entity interface {
	Tag() names.Tag
}

Entity represents any entity that can be returned by State.FindEntity. All entities have a tag.

type EntityFinder

type EntityFinder interface {
	FindEntity(tag names.Tag) (Entity, error)
}

EntityFinder is implemented by *State. See State.FindEntity for documentation on the method.

type EnvironAccessor

type EnvironAccessor interface {
	WatchForEnvironConfigChanges() NotifyWatcher
	EnvironConfig() (*config.Config, error)
}

EnvironAccessor defines the methods needed to watch for environment config changes, and read the environment config.

type EnvironCapability

type EnvironCapability interface {
	// SupportedArchitectures returns the image architectures which can
	// be hosted by this environment.
	SupportedArchitectures() ([]string, error)

	// SupportsUnitAssignment returns an error which, if non-nil, indicates
	// that the environment does not support unit placement. If the environment
	// does not support unit placement, then machines may not be created
	// without units, and units cannot be placed explcitly.
	SupportsUnitPlacement() error
}

EnvironCapability implements access to metadata about the capabilities of an environment.

type EnvironConfigWatcher

type EnvironConfigWatcher struct {
	// contains filtered or unexported fields
}

EnvironConfigWatcher observes changes to the environment configuration.

func (*EnvironConfigWatcher) Changes

func (w *EnvironConfigWatcher) Changes() <-chan *config.Config

Changes returns a channel that will receive the new environment configuration when a change is detected. Note that multiple changes may be observed as a single event in the channel.

func (*EnvironConfigWatcher) Err

func (w *EnvironConfigWatcher) Err() error

Err returns any error encountered while running or shutting down, or tomb.ErrStillAlive if the watcher is still running.

func (*EnvironConfigWatcher) Kill

func (w *EnvironConfigWatcher) Kill()

Kill kills the watcher without waiting for it to shut down.

func (*EnvironConfigWatcher) Stop

func (w *EnvironConfigWatcher) Stop() error

Stop stops the watcher, and returns any error encountered while running or shutting down.

func (*EnvironConfigWatcher) Wait

func (w *EnvironConfigWatcher) Wait() error

Wait waits for the watcher to die and returns any error encountered when it was running.

type EnvironMachinesWatcher

type EnvironMachinesWatcher interface {
	WatchEnvironMachines() StringsWatcher
}

EnvironMachinesWatcher defines a single method - WatchEnvironMachines.

type Environment

type Environment struct {
	// contains filtered or unexported fields
}

Environment represents the state of an environment.

func (*Environment) Config

func (e *Environment) Config() (*config.Config, error)

Config returns the config for the environment.

func (*Environment) Destroy

func (e *Environment) Destroy() error

Destroy sets the environment's lifecycle to Dying, preventing addition of services or machines to state.

func (*Environment) EnvironTag

func (e *Environment) EnvironTag() names.EnvironTag

EnvironTag is the concrete environ tag for this environment.

func (*Environment) Life

func (e *Environment) Life() Life

Life returns whether the environment is Alive, Dying or Dead.

func (*Environment) Name

func (e *Environment) Name() string

Name returns the human friendly name of the environment.

func (*Environment) Owner

func (e *Environment) Owner() names.UserTag

Owner returns tag representing the owner of the environment. The owner is the user that created the environment.

func (*Environment) Refresh

func (e *Environment) Refresh() error

func (*Environment) ServerTag

func (e *Environment) ServerTag() names.EnvironTag

ServerTag is the environ tag for the server that the environment is running within.

func (*Environment) Tag

func (e *Environment) Tag() names.Tag

Tag returns a name identifying the environment. The returned name will be different from other Tag values returned by any other entities from the same state.

func (*Environment) UUID

func (e *Environment) UUID() string

UUID returns the universally unique identifier of the environment.

func (*Environment) Watch

func (e *Environment) Watch() NotifyWatcher

Watch returns a watcher for observing changes to an environment.

type EnvironmentUser

type EnvironmentUser struct {
	// contains filtered or unexported fields
}

EnvironmentUser represents a user access to an environment whereas the user could represent a remote user or a user across multiple environments the environment user always represents a single user for a single environment. There should be no more than one EnvironmentUser per user

func (*EnvironmentUser) CreatedBy

func (e *EnvironmentUser) CreatedBy() string

CreatedBy returns the user who created the environment user.

func (*EnvironmentUser) DateCreated

func (e *EnvironmentUser) DateCreated() time.Time

DateCreated returns the date the environment user.

func (*EnvironmentUser) DisplayName

func (e *EnvironmentUser) DisplayName() string

DisplayName returns the display name of the environment user.

func (*EnvironmentUser) EnvironmentTag

func (e *EnvironmentUser) EnvironmentTag() names.EnvironTag

EnvironmentTag returns the environment tag of the environment user.

func (*EnvironmentUser) ID

func (e *EnvironmentUser) ID() string

ID returns the ID of the environment user.

func (*EnvironmentUser) LastConnection

func (e *EnvironmentUser) LastConnection() *time.Time

LastConnection returns the last connection time of the environment user.

func (*EnvironmentUser) UpdateLastConnection

func (e *EnvironmentUser) UpdateLastConnection() error

UpdateLastConnection updates the last connection time of the environment user.

func (*EnvironmentUser) UserName

func (e *EnvironmentUser) UserName() string

UserName returns the user name of the environment user.

func (*EnvironmentUser) UserTag

func (e *EnvironmentUser) UserTag() names.UserTag

UserTag returns the tag for the environment user.

type ErrCharmAlreadyUploaded

type ErrCharmAlreadyUploaded struct {
	// contains filtered or unexported fields
}

ErrCharmAlreadyUploaded is returned by UpdateUploadedCharm() when the given charm is already uploaded and marked as not pending in state.

func (*ErrCharmAlreadyUploaded) Error

func (e *ErrCharmAlreadyUploaded) Error() string

type GlobalEntity

type GlobalEntity interface {
	Tag() names.Tag
	// contains filtered or unexported methods
}

GlobalEntity specifies entity.

type HasAssignedUnitsError

type HasAssignedUnitsError struct {
	MachineId string
	UnitNames []string
}

func (*HasAssignedUnitsError) Error

func (e *HasAssignedUnitsError) Error() string

type HasContainersError

type HasContainersError struct {
	MachineId    string
	ContainerIds []string
}

func (*HasContainersError) Error

func (e *HasContainersError) Error() string

type IPAddress

type IPAddress struct {
	// contains filtered or unexported fields
}

IPAddress represents the state of an IP address.

func (*IPAddress) Address

func (i *IPAddress) Address() network.Address

Address returns the network.Address represent the IP address

func (*IPAddress) AllocateTo

func (i *IPAddress) AllocateTo(machineId string, interfaceId string) (err error)

AllocateTo sets the machine ID and interface ID of the IP address. It will fail if the state is not AddressStateUnknown.

func (*IPAddress) InterfaceId

func (i *IPAddress) InterfaceId() string

InterfaceId returns the ID of the network interface the IP address is associated with. If the address is not associated with a netowrk interface this returns "".

func (*IPAddress) MachineId

func (i *IPAddress) MachineId() string

MachineId returns the ID of the machine the IP address is associated with. If the address is not associated with a machine this returns "".

func (*IPAddress) Remove

func (i *IPAddress) Remove() (err error)

Remove removes a no-longer need IP address.

func (*IPAddress) Scope

func (i *IPAddress) Scope() network.Scope

Scope returns the scope of the IP address. If the scope is not set this returns "".

func (*IPAddress) SetState

func (i *IPAddress) SetState(newState AddressState) (err error)

SetState sets the State of an IPAddress. Valid state transitions are Unknown to Allocated or Unavailable. Any other transition will fail.

func (*IPAddress) State

func (i *IPAddress) State() AddressState

State returns the state of an IP address.

func (*IPAddress) SubnetId

func (i *IPAddress) SubnetId() string

SubnetId returns the ID of the subnet the IP address is associated with. If the address is not associated with a subnet this returns "".

func (*IPAddress) Type

func (i *IPAddress) Type() network.AddressType

Type returns the type of the IP address. The IP address will have a type of IPv4, IPv6 or hostname.

func (*IPAddress) Value

func (i *IPAddress) Value() string

Value returns the IP address.

type InstanceDistributor

type InstanceDistributor interface {
	// DistributeInstance takes a set of clean, empty
	// instances, and a distribution group, and returns
	// the subset of candidates which the policy will
	// allow entry into the distribution group.
	//
	// The AssignClean and AssignCleanEmpty unit
	// assignment policies will attempt to assign a
	// unit to each of the resulting instances until
	// one is successful. If no instances can be assigned
	// to (e.g. because of concurrent deployments), then
	// a new machine will be allocated.
	DistributeInstances(candidates, distributionGroup []instance.Id) ([]instance.Id, error)
}

InstanceDistributor is a policy interface that is provided to State to perform distribution of units across instances for high availability.

type InstanceIdGetter

type InstanceIdGetter interface {
	InstanceId() (instance.Id, error)
}

InstanceIdGetter defines a single method - InstanceId.

type ItemChange

type ItemChange struct {
	Type     int
	Key      string
	OldValue interface{}
	NewValue interface{}
}

ItemChange represents the change of an item in a settings.

func (*ItemChange) String

func (ic *ItemChange) String() string

String returns the item change in a readable format.

type LeadershipSettingsWatcher

type LeadershipSettingsWatcher struct {
	// contains filtered or unexported fields
}

LeadershipSettingsWatcher provides a type that can watch settings for a provided key.

func NewLeadershipSettingsWatcher

func NewLeadershipSettingsWatcher(state *State, key string) *LeadershipSettingsWatcher

NewLeadershipSettingsWatcher returns a new LeadershipSettingsWatcher.

func (LeadershipSettingsWatcher) Changes

func (w LeadershipSettingsWatcher) Changes() <-chan *Settings

Changes returns a channel that will receive the new settings. Multiple changes may be observed as a single event in the channel.

type LeasePersistor

type LeasePersistor struct {
	// contains filtered or unexported fields
}

LeasePersistor represents logic which can persist lease tokens to a data store.

func NewLeasePersistor

func NewLeasePersistor(
	collectionName string,
	runTransaction func([]txn.Op) error,
	getCollection func(string) (_ stateCollection, closer func()),
) *LeasePersistor

NewLeasePersistor returns a new LeasePersistor. It should be passed functions it can use to run transactions and get collections.

func (*LeasePersistor) PersistedTokens

func (p *LeasePersistor) PersistedTokens() (tokens []lease.Token, _ error)

PersistedTokens retrieves all tokens currently persisted.

func (*LeasePersistor) RemoveToken

func (p *LeasePersistor) RemoveToken(id string) error

RemoveToken removes the lease token with the given ID from the data store.

func (*LeasePersistor) WriteToken

func (p *LeasePersistor) WriteToken(id string, tok lease.Token) error

WriteToken writes the given token to the data store with the given ID.

type Life

type Life int8

Life represents the lifecycle state of the entities Relation, Unit, Service and Machine.

const (
	Alive Life = iota
	Dying
	Dead
)

func (Life) String

func (l Life) String() string

type Lifer

type Lifer interface {
	Life() Life
}

Lifer represents an entity with a life.

type Living

type Living interface {
	Life() Life
	Destroy() error
	Refresh() error
}

Living describes state entities with a lifecycle.

type Machine

type Machine struct {
	presence.Presencer
	// contains filtered or unexported fields
}

Machine represents the state of a machine.

func (*Machine) AddNetworkInterface

func (m *Machine) AddNetworkInterface(args NetworkInterfaceInfo) (iface *NetworkInterface, err error)

AddNetworkInterface creates a new network interface with the given args for this machine. The machine must be alive and not yet provisioned, and there must be no other interface with the same MAC address on the same network, or the same name on that machine for this to succeed. If a network interface already exists, the returned error satisfies errors.IsAlreadyExists.

func (*Machine) Addresses

func (m *Machine) Addresses() (addresses []network.Address)

Addresses returns any hostnames and ips associated with a machine, determined both by the machine itself, and by asking the provider.

The addresses returned by the provider shadow any of the addresses that the machine reported with the same address value. Provider-reported addresses always come before machine-reported addresses. Duplicates are removed.

func (*Machine) AgentPresence

func (m *Machine) AgentPresence() (bool, error)

AgentPresence returns whether the respective remote agent is alive.

func (*Machine) AgentTools

func (m *Machine) AgentTools() (*tools.Tools, error)

AgentTools returns the tools that the agent is currently running. It returns an error that satisfies errors.IsNotFound if the tools have not yet been set.

func (*Machine) AllPorts

func (m *Machine) AllPorts() ([]*Ports, error)

AllPorts returns all opened ports for this machine (on all networks).

func (*Machine) AvailabilityZone

func (m *Machine) AvailabilityZone() (string, error)

AvailabilityZone returns the provier-specific instance availability zone in which the machine was provisioned.

func (*Machine) BlockDevices

func (m *Machine) BlockDevices() ([]BlockDevice, error)

BlockDevices gets the aggregated list of block devices associated with the machine, including unprovisioned ones.

func (*Machine) CheckProvisioned

func (m *Machine) CheckProvisioned(nonce string) bool

CheckProvisioned returns true if the machine was provisioned with the given nonce.

func (*Machine) Clean

func (m *Machine) Clean() bool

Clean returns true if the machine does not have any deployed units or containers.

func (*Machine) Constraints

func (m *Machine) Constraints() (constraints.Value, error)

Constraints returns the exact constraints that should apply when provisioning an instance for the machine.

func (*Machine) ContainerType

func (m *Machine) ContainerType() instance.ContainerType

ContainerType returns the type of container hosting this machine.

func (*Machine) Containers

func (m *Machine) Containers() ([]string, error)

Containers returns the container ids belonging to a parent machine. TODO(wallyworld): move this method to a service

func (*Machine) Destroy

func (m *Machine) Destroy() error

Destroy sets the machine lifecycle to Dying if it is Alive. It does nothing otherwise. Destroy will fail if the machine has principal units assigned, or if the machine has JobManageEnviron. If the machine has assigned units, Destroy will return a HasAssignedUnitsError.

func (*Machine) EnsureDead

func (m *Machine) EnsureDead() error

EnsureDead sets the machine lifecycle to Dead if it is Alive or Dying. It does nothing otherwise. EnsureDead will fail if the machine has principal units assigned, or if the machine has JobManageEnviron. If the machine has assigned units, EnsureDead will return a HasAssignedUnitsError.

func (*Machine) ForceDestroy

func (m *Machine) ForceDestroy() error

ForceDestroy queues the machine for complete removal, including the destruction of all units and containers on the machine.

func (*Machine) GetRebootFlag

func (m *Machine) GetRebootFlag() (bool, error)

GetRebootFlag returns the reboot flag for this machine.

func (*Machine) HardwareCharacteristics

func (m *Machine) HardwareCharacteristics() (*instance.HardwareCharacteristics, error)

TODO(wallyworld): move this method to a service.

func (*Machine) HasVote

func (m *Machine) HasVote() bool

HasVote reports whether that machine is currently a voting member of the replica set.

func (*Machine) Id

func (m *Machine) Id() string

Id returns the machine id.

func (*Machine) InstanceId

func (m *Machine) InstanceId() (instance.Id, error)

InstanceId returns the provider specific instance id for this machine, or a NotProvisionedError, if not set.

func (*Machine) InstanceStatus

func (m *Machine) InstanceStatus() (string, error)

InstanceStatus returns the provider specific instance status for this machine, or a NotProvisionedError if instance is not yet provisioned.

func (*Machine) IsContainer

func (m *Machine) IsContainer() bool

IsContainer returns true if the machine is a container.

func (*Machine) IsManager

func (m *Machine) IsManager() bool

IsManager returns true if the machine has JobManageEnviron.

func (*Machine) IsManual

func (m *Machine) IsManual() (bool, error)

IsManual returns true if the machine was manually provisioned.

func (*Machine) Jobs

func (m *Machine) Jobs() []MachineJob

Jobs returns the responsibilities that must be fulfilled by m's agent.

func (*Machine) Life

func (m *Machine) Life() Life

Life returns whether the machine is Alive, Dying or Dead.

func (*Machine) MachineAddresses

func (m *Machine) MachineAddresses() (addresses []network.Address)

MachineAddresses returns any hostnames and ips associated with a machine, determined by asking the machine itself.

func (*Machine) MachineTag

func (m *Machine) MachineTag() names.MachineTag

MachineTag returns the more specific MachineTag type as opposed to the more generic Tag type.

func (*Machine) NetworkInterfaces

func (m *Machine) NetworkInterfaces() ([]*NetworkInterface, error)

NetworkInterfaces returns the list of configured network interfaces of the machine.

func (*Machine) Networks

func (m *Machine) Networks() ([]*Network, error)

Networks returns the list of configured networks on the machine. The configured and requested networks on a machine must match.

func (*Machine) OpenedPorts

func (m *Machine) OpenedPorts(networkName string) (*Ports, error)

OpenedPorts returns this machine ports document for the given network.

func (*Machine) ParentId

func (m *Machine) ParentId() (string, bool)

ParentId returns the Id of the host machine if this machine is a container.

func (*Machine) PasswordValid

func (m *Machine) PasswordValid(password string) bool

PasswordValid returns whether the given password is valid for the given machine.

func (*Machine) Placement

func (m *Machine) Placement() string

Placement returns the machine's Placement structure that should be used when provisioning an instance for the machine.

func (*Machine) Refresh

func (m *Machine) Refresh() error

Refresh refreshes the contents of the machine from the underlying state. It returns an error that satisfies errors.IsNotFound if the machine has been removed.

func (*Machine) Remove

func (m *Machine) Remove() (err error)

Remove removes the machine from state. It will fail if the machine is not Dead.

func (*Machine) RequestedNetworks

func (m *Machine) RequestedNetworks() ([]string, error)

RequestedNetworks returns the list of network names the machine should be on. Unlike networks specified with constraints, these networks are required to be present on the machine.

func (*Machine) Series

func (m *Machine) Series() string

Series returns the operating system series running on the machine.

func (*Machine) SetAddresses

func (m *Machine) SetAddresses(addresses ...network.Address) (err error)

SetAddresses records any addresses related to the machine, sourced by asking the provider.

func (*Machine) SetAgentPresence

func (m *Machine) SetAgentPresence() (*presence.Pinger, error)

SetAgentPresence signals that the agent for machine m is alive. It returns the started pinger.

func (*Machine) SetAgentVersion

func (m *Machine) SetAgentVersion(v version.Binary) (err error)

SetAgentVersion sets the version of juju that the agent is currently running.

func (*Machine) SetConstraints

func (m *Machine) SetConstraints(cons constraints.Value) (err error)

SetConstraints sets the exact constraints to apply when provisioning an instance for the machine. It will fail if the machine is Dead, or if it is already provisioned.

func (*Machine) SetHasVote

func (m *Machine) SetHasVote(hasVote bool) error

SetHasVote sets whether the machine is currently a voting member of the replica set. It should only be called from the worker that maintains the replica set.

func (*Machine) SetInstanceInfo

func (m *Machine) SetInstanceInfo(
	id instance.Id, nonce string, characteristics *instance.HardwareCharacteristics,
	networks []NetworkInfo, interfaces []NetworkInterfaceInfo,
	blockDevices map[string]BlockDeviceInfo) error

SetInstanceInfo is used to provision a machine and in one steps set it's instance id, nonce, hardware characteristics, add networks and network interfaces as needed.

TODO(dimitern) Do all the operations described in a single transaction, rather than using separate calls. Alternatively, we can add all the things to create/set in a document in some collection and have a worker that takes care of the actual work. Merge SetProvisioned() in here or drop it at that point.

func (*Machine) SetInstanceStatus

func (m *Machine) SetInstanceStatus(status string) (err error)

SetInstanceStatus sets the provider specific instance status for a machine.

func (*Machine) SetMachineAddresses

func (m *Machine) SetMachineAddresses(addresses ...network.Address) (err error)

SetMachineAddresses records any addresses related to the machine, sourced by asking the machine.

func (*Machine) SetMachineBlockDevices

func (m *Machine) SetMachineBlockDevices(info ...BlockDeviceInfo) error

SetMachineBlockDevices sets the block devices visible on the machine.

func (*Machine) SetMongoPassword

func (m *Machine) SetMongoPassword(password string) error

SetMongoPassword sets the password the agent responsible for the machine should use to communicate with the state servers. Previous passwords are invalidated.

func (*Machine) SetPassword

func (m *Machine) SetPassword(password string) error

SetPassword sets the password for the machine's agent.

func (*Machine) SetProvisioned

func (m *Machine) SetProvisioned(id instance.Id, nonce string, characteristics *instance.HardwareCharacteristics) (err error)

SetProvisioned sets the provider specific machine id, nonce and also metadata for this machine. Once set, the instance id cannot be changed.

When provisioning an instance, a nonce should be created and passed when starting it, before adding the machine to the state. This means that if the provisioner crashes (or its connection to the state is lost) after starting the instance, we can be sure that only a single instance will be able to act for that machine.

func (*Machine) SetRebootFlag

func (m *Machine) SetRebootFlag(flag bool) error

SetRebootFlag sets the reboot flag of a machine to a boolean value. It will also do a lazy create of a reboot document if needed; i.e. If a document does not exist yet for this machine, it will create it.

func (*Machine) SetStatus

func (m *Machine) SetStatus(status Status, info string, data map[string]interface{}) error

SetStatus sets the status of the machine.

func (*Machine) SetSupportedContainers

func (m *Machine) SetSupportedContainers(containers []instance.ContainerType) (err error)

SetSupportedContainers sets the list of containers supported by this machine.

func (*Machine) ShouldRebootOrShutdown

func (m *Machine) ShouldRebootOrShutdown() (RebootAction, error)

ShouldRebootOrShutdown check if the current node should reboot or shutdown If we are a container, and our parent needs to reboot, this should return: ShouldShutdown

func (*Machine) Status

func (m *Machine) Status() (status Status, info string, data map[string]interface{}, err error)

Status returns the status of the machine.

func (*Machine) String

func (m *Machine) String() string

String returns a unique description of this machine.

func (*Machine) SupportedContainers

func (m *Machine) SupportedContainers() ([]instance.ContainerType, bool)

SupportedContainers returns any containers this machine is capable of hosting, and a bool indicating if the supported containers have been determined or not.

func (*Machine) SupportsNoContainers

func (m *Machine) SupportsNoContainers() (err error)

SupportsNoContainers records the fact that this machine doesn't support any containers.

func (*Machine) Tag

func (m *Machine) Tag() names.Tag

Tag returns a tag identifying the machine. The String method provides a string representation that is safe to use as a file name. The returned name will be different from other Tag values returned by any other entities from the same state.

func (*Machine) Units

func (m *Machine) Units() (units []*Unit, err error)

Units returns all the units that have been assigned to the machine.

func (*Machine) WaitAgentPresence

func (m *Machine) WaitAgentPresence(timeout time.Duration) (err error)

WaitAgentPresence blocks until the respective agent is alive.

func (*Machine) WantsVote

func (m *Machine) WantsVote() bool

WantsVote reports whether the machine is a state server that wants to take part in peer voting.

func (*Machine) Watch

func (m *Machine) Watch() NotifyWatcher

Watch returns a watcher for observing changes to a machine.

func (*Machine) WatchAddresses

func (m *Machine) WatchAddresses() NotifyWatcher

WatchAddresses returns a new NotifyWatcher watching m's addresses.

func (*Machine) WatchAllContainers

func (m *Machine) WatchAllContainers() StringsWatcher

WatchAllContainers returns a StringsWatcher that notifies of changes to the lifecycles of all containers on a machine.

func (*Machine) WatchBlockDevices

func (m *Machine) WatchBlockDevices() StringsWatcher

WatchBlockDevices returns a new StringsWatcher watching for block devices associated with m.

func (*Machine) WatchContainers

func (m *Machine) WatchContainers(ctype instance.ContainerType) StringsWatcher

WatchContainers returns a StringsWatcher that notifies of changes to the lifecycles of containers of the specified type on a machine.

func (*Machine) WatchForRebootEvent

func (m *Machine) WatchForRebootEvent() (NotifyWatcher, error)

WatchForRebootEvent returns a notify watcher that will trigger an event when the reboot flag is set on our machine agent, our parent machine agent or grandparent machine agent

func (*Machine) WatchHardwareCharacteristics

func (m *Machine) WatchHardwareCharacteristics() NotifyWatcher

WatchHardwareCharacteristics returns a watcher for observing changes to a machine's hardware characteristics.

func (*Machine) WatchInterfaces

func (m *Machine) WatchInterfaces() NotifyWatcher

WatchInterfaces returns a new NotifyWatcher watching m's network interfaces.

func (*Machine) WatchPrincipalUnits

func (m *Machine) WatchPrincipalUnits() StringsWatcher

WatchPrincipalUnits returns a StringsWatcher tracking the machine's principal units.

func (*Machine) WatchUnits

func (m *Machine) WatchUnits() StringsWatcher

WatchUnits returns a new StringsWatcher watching m's units.

type MachineJob

type MachineJob int

MachineJob values define responsibilities that machines may be expected to fulfil.

const (
	JobHostUnits MachineJob
	JobManageEnviron
	JobManageNetworking

	// Deprecated in 1.18.
	JobManageStateDeprecated
)

func AllJobs

func AllJobs() []MachineJob

AllJobs returns all supported machine jobs.

func (MachineJob) String

func (job MachineJob) String() string

func (MachineJob) ToParams

func (job MachineJob) ToParams() multiwatcher.MachineJob

ToParams returns the job as multiwatcher.MachineJob.

type MachineTemplate

type MachineTemplate struct {
	// Series is the series to be associated with the new machine.
	Series string

	// Constraints are the constraints to be used when finding
	// an instance for the machine.
	Constraints constraints.Value

	// Jobs holds the jobs to run on the machine's instance.
	// A machine must have at least one job to do.
	// JobManageEnviron can only be part of the jobs
	// when the first (bootstrap) machine is added.
	Jobs []MachineJob

	// NoVote holds whether a machine running
	// a state server should abstain from peer voting.
	// It is ignored if Jobs does not contain JobManageEnviron.
	NoVote bool

	// Addresses holds the addresses to be associated with the
	// new machine.
	Addresses []network.Address

	// InstanceId holds the instance id to associate with the machine.
	// If this is empty, the provisioner will try to provision the machine.
	// If this is non-empty, the HardwareCharacteristics and Nonce
	// fields must be set appropriately.
	InstanceId instance.Id

	// HardwareCharacteristics holds the h/w characteristics to
	// be associated with the machine.
	HardwareCharacteristics instance.HardwareCharacteristics

	// RequestedNetworks holds a list of network names the machine
	// should be part of.
	RequestedNetworks []string

	// BlockDevices holds the parameters for block devices that should be
	// created and attached to the machine.
	BlockDevices []BlockDeviceParams

	// Nonce holds a unique value that can be used to check
	// if a new instance was really started for this machine.
	// See Machine.SetProvisioned. This must be set if InstanceId is set.
	Nonce string

	// Dirty signifies whether the new machine will be treated
	// as unclean for unit-assignment purposes.
	Dirty bool

	// Placement holds the placement directive that will be associated
	// with the machine.
	Placement string
	// contains filtered or unexported fields
}

MachineTemplate holds attributes that are to be associated with a newly created machine.

type MeterStatusCode

type MeterStatusCode string

MeterStatusCode represents the meter status code of a unit.

const (
	MeterNotSet       MeterStatusCode = "NOT SET"
	MeterNotAvailable MeterStatusCode = "NOT AVAILABLE"
	MeterGreen        MeterStatusCode = "GREEN"
	MeterAmber        MeterStatusCode = "AMBER"
	MeterRed          MeterStatusCode = "RED"
)

type Metric

type Metric struct {
	Key   string    `bson:"key"`
	Value string    `bson:"value"`
	Time  time.Time `bson:"time"`
}

Metric represents a single Metric.

type MetricBatch

type MetricBatch struct {
	// contains filtered or unexported fields
}

MetricBatch represents a batch of metrics reported from a unit. These will be received from the unit in batches. The main contents of the metric (key, value) is defined by the charm author and sent from the unit via a call to add-metric

func (*MetricBatch) CharmURL

func (m *MetricBatch) CharmURL() string

CharmURL returns the charm url for the charm this metric was generated in.

func (*MetricBatch) Created

func (m *MetricBatch) Created() time.Time

Created returns the time this metric batch was created.

func (*MetricBatch) Credentials

func (m *MetricBatch) Credentials() []byte

Credentials returns any credentials associated with the metric batch.

func (*MetricBatch) EnvUUID

func (m *MetricBatch) EnvUUID() string

EnvUUID returns the environment UUID this metric applies to.

func (*MetricBatch) MarshalJSON

func (m *MetricBatch) MarshalJSON() ([]byte, error)

MarshalJSON defines how the MetricBatch type should be converted to json.

func (*MetricBatch) Metrics

func (m *MetricBatch) Metrics() []Metric

Metrics returns the metrics in this batch.

func (*MetricBatch) Sent

func (m *MetricBatch) Sent() bool

Sent returns a flag to tell us if this metric has been sent to the metric collection service

func (*MetricBatch) SetSent

func (m *MetricBatch) SetSent() error

SetSent sets the sent flag to true

func (*MetricBatch) UUID

func (m *MetricBatch) UUID() string

UUID returns to uuid of the metric.

func (*MetricBatch) Unit

func (m *MetricBatch) Unit() string

Unit returns the name of the unit this metric was generated in.

type Multiwatcher

type Multiwatcher struct {
	// contains filtered or unexported fields
}

Multiwatcher watches any changes to the state.

func NewMultiwatcher

func NewMultiwatcher(all *storeManager) *Multiwatcher

NewMultiwatcher creates a new watcher that can observe changes to an underlying store manager.

func (*Multiwatcher) Next

func (w *Multiwatcher) Next() ([]multiwatcher.Delta, error)

Next retrieves all changes that have happened since the last time it was called, blocking until there are some changes available.

func (*Multiwatcher) Stop

func (w *Multiwatcher) Stop() error

Stop stops the watcher.

type Network

type Network struct {
	// contains filtered or unexported fields
}

Network represents the state of a network.

func (*Network) CIDR

func (n *Network) CIDR() string

CIDR returns the network CIDR (e.g. 192.168.50.0/24).

func (*Network) GoString

func (n *Network) GoString() string

GoString implements fmt.GoStringer.

func (*Network) Interfaces

func (n *Network) Interfaces() ([]*NetworkInterface, error)

Interfaces returns all network interfaces on the network.

func (*Network) IsVLAN

func (n *Network) IsVLAN() bool

IsVLAN returns whether the network is a VLAN (has tag > 0) or a normal network.

func (*Network) Name

func (n *Network) Name() string

Name returns the network name.

func (*Network) ProviderId

func (n *Network) ProviderId() network.Id

ProviderId returns the provider-specific id of the network.

func (*Network) Tag

func (n *Network) Tag() names.Tag

Tag returns the network tag.

func (*Network) VLANTag

func (n *Network) VLANTag() int

VLANTag returns the network VLAN tag. It's a number between 1 and 4094 for VLANs and 0 if the network is not a VLAN.

type NetworkInfo

type NetworkInfo struct {
	// Name is juju-internal name of the network.
	Name string

	// ProviderId is a provider-specific network id.
	ProviderId network.Id

	// CIDR of the network, in 123.45.67.89/24 format.
	CIDR string

	// VLANTag needs to be between 1 and 4094 for VLANs and 0 for
	// normal networks. It's defined by IEEE 802.1Q standard.
	VLANTag int
}

NetworkInfo describes a single network.

type NetworkInterface

type NetworkInterface struct {
	// contains filtered or unexported fields
}

NetworkInterface represents the state of a machine network interface.

func (*NetworkInterface) Disable

func (ni *NetworkInterface) Disable() (err error)

Disable changes the state of the network interface to disabled. In case of a physical interface that has dependent virtual interfaces (e.g. VLANs), those will be disabled along with their parent interface. If the interface is already disabled, nothing happens and no error is returned.

func (*NetworkInterface) Enable

func (ni *NetworkInterface) Enable() (err error)

Enable changes the state of the network interface to enabled. If the interface is already enabled, nothing happens and no error is returned.

func (*NetworkInterface) GoString

func (ni *NetworkInterface) GoString() string

GoString implements fmt.GoStringer.

func (*NetworkInterface) Id

func (ni *NetworkInterface) Id() string

Id returns the internal juju-specific id of the interface.

func (*NetworkInterface) InterfaceName

func (ni *NetworkInterface) InterfaceName() string

InterfaceName returns the name of the interface.

func (*NetworkInterface) IsDisabled

func (ni *NetworkInterface) IsDisabled() bool

IsDisabled returns whether the interface is disabled.

func (*NetworkInterface) IsPhysical

func (ni *NetworkInterface) IsPhysical() bool

IsPhysical returns whether the interface represents a physical device.

func (*NetworkInterface) IsVirtual

func (ni *NetworkInterface) IsVirtual() bool

IsVirtual returns whether the interface represents a virtual device.

func (*NetworkInterface) MACAddress

func (ni *NetworkInterface) MACAddress() string

MACAddress returns the MAC address of the interface.

func (*NetworkInterface) MachineId

func (ni *NetworkInterface) MachineId() string

MachineId returns the machine id of the interface.

func (*NetworkInterface) MachineTag

func (ni *NetworkInterface) MachineTag() names.MachineTag

MachineTag returns the machine tag of the interface.

func (*NetworkInterface) NetworkName

func (ni *NetworkInterface) NetworkName() string

NetworkName returns the network name of the interface.

func (*NetworkInterface) NetworkTag

func (ni *NetworkInterface) NetworkTag() names.NetworkTag

NetworkTag returns the network tag of the interface.

func (*NetworkInterface) RawInterfaceName

func (ni *NetworkInterface) RawInterfaceName() string

RawInterfaceName return the name of the raw interface.

func (*NetworkInterface) Refresh

func (ni *NetworkInterface) Refresh() error

Refresh refreshes the contents of the network interface from the underlying state. It returns an error that satisfies errors.IsNotFound if the machine has been removed.

func (*NetworkInterface) Remove

func (ni *NetworkInterface) Remove() (err error)

Remove removes the network interface from state.

type NetworkInterfaceInfo

type NetworkInterfaceInfo struct {
	// MACAddress is the network interface's hardware MAC address
	// (e.g. "aa:bb:cc:dd:ee:ff").
	MACAddress string

	// InterfaceName is the OS-specific network device name (e.g.
	// "eth0", or "eth1.42" for a VLAN virtual interface, or
	// "eth1:suffix" for a network alias).
	InterfaceName string

	// NetworkName is this interface's network name.
	NetworkName string

	// IsVirtual is true when the interface is a virtual device, as
	// opposed to a physical device (e.g. a VLAN or a network alias).
	IsVirtual bool

	// Disabled returns whether the interface is disabled.
	Disabled bool
}

NetworkInterfaceInfo describes a single network interface available on an instance.

type NotAssignedError

type NotAssignedError struct{ Unit *Unit }

NotAssignedError indicates that a unit is not assigned to a machine (and, in the case of subordinate units, that the unit's principal is not assigned).

func (*NotAssignedError) Error

func (e *NotAssignedError) Error() string

type NotifyWatcher

type NotifyWatcher interface {
	Watcher
	Changes() <-chan struct{}
}

NotifyWatcher generates signals when something changes, but it does not return any content for those changes

type NotifyWatcherFactory

type NotifyWatcherFactory interface {
	Watch() NotifyWatcher
}

NotifyWatcherFactory represents an entity that can be watched.

type Policy

type Policy interface {
	// Prechecker takes a *config.Config and returns a Prechecker or an error.
	Prechecker(*config.Config) (Prechecker, error)

	// ConfigValidator takes a provider type name and returns a ConfigValidator
	// or an error.
	ConfigValidator(providerType string) (ConfigValidator, error)

	// EnvironCapability takes a *config.Config and returns an EnvironCapability
	// or an error.
	EnvironCapability(*config.Config) (EnvironCapability, error)

	// ConstraintsValidator takes a *config.Config and returns a
	// constraints.Validator or an error.
	ConstraintsValidator(*config.Config) (constraints.Validator, error)

	// InstanceDistributor takes a *config.Config and returns an
	// InstanceDistributor or an error.
	InstanceDistributor(*config.Config) (InstanceDistributor, error)
}

Policy is an interface provided to State that may be consulted by State to validate or modify the behaviour of certain operations.

If a Policy implementation does not implement one of the methods, it must return an error that satisfies errors.IsNotImplemented, and will thus be ignored. Any other error will cause an error in the use of the policy.

type PortRange

type PortRange struct {
	UnitName string
	FromPort int
	ToPort   int
	Protocol string
}

PortRange represents a single range of ports opened by one unit.

func NewPortRange

func NewPortRange(unitName string, fromPort, toPort int, protocol string) (PortRange, error)

NewPortRange create a new port range and validate it.

func PortRangeFromNetworkPortRange

func PortRangeFromNetworkPortRange(unitName string, portRange network.PortRange) (PortRange, error)

PortRangeFromNetworkPortRange constructs a state.PortRange from the given unitName and network.PortRange.

func (PortRange) CheckConflicts

func (prA PortRange) CheckConflicts(prB PortRange) error

CheckConflicts determines if the two port ranges conflict.

func (PortRange) Length

func (a PortRange) Length() int

Length returns the number of ports in the range. If the range is not valid, it returns 0.

func (PortRange) SanitizeBounds

func (a PortRange) SanitizeBounds() PortRange

Sanitize returns a copy of the port range, which is guaranteed to have FromPort >= ToPort and both FromPort and ToPort fit into the valid range from 1 to 65535, inclusive.

func (PortRange) String

func (p PortRange) String() string

Strings returns the port range as a string.

func (PortRange) Validate

func (p PortRange) Validate() error

Validate checks if the port range is valid.

type Ports

type Ports struct {
	// contains filtered or unexported fields
}

Ports represents the state of ports on a machine.

func (*Ports) AllPortRanges

func (p *Ports) AllPortRanges() map[network.PortRange]string

AllPortRanges returns a map with network.PortRange as keys and unit names as values.

func (*Ports) ClosePorts

func (p *Ports) ClosePorts(portRange PortRange) (err error)

ClosePorts removes the specified port range from the list of ports maintained by this document.

func (*Ports) GlobalKey

func (p *Ports) GlobalKey() string

Id returns the id of the ports document.

func (*Ports) NetworkName

func (p *Ports) NetworkName() string

NetworkName returns the network name associated with this ports document.

func (*Ports) OpenPorts

func (p *Ports) OpenPorts(portRange PortRange) (err error)

OpenPorts adds the specified port range to the list of ports maintained by this document.

func (*Ports) PortsForUnit

func (p *Ports) PortsForUnit(unit string) []PortRange

PortsForUnit returns the ports associated with specified unit that are maintained on this document (i.e. are open on this unit's assigned machine).

func (*Ports) Refresh

func (p *Ports) Refresh() error

Refresh refreshes the port document from state.

func (*Ports) Remove

func (p *Ports) Remove() error

Remove removes the ports document from state.

func (*Ports) String

func (p *Ports) String() string

String returns p as a user-readable string.

type Prechecker

type Prechecker interface {
	// PrecheckInstance performs a preflight check on the specified
	// series and constraints, ensuring that they are possibly valid for
	// creating an instance in this environment.
	//
	// PrecheckInstance is best effort, and not guaranteed to eliminate
	// all invalid parameters. If PrecheckInstance returns nil, it is not
	// guaranteed that the constraints are valid; if a non-nil error is
	// returned, then the constraints are definitely invalid.
	PrecheckInstance(series string, cons constraints.Value, placement string) error
}

Prechecker is a policy interface that is provided to State to perform pre-flight checking of instance creation.

type RebootAction

type RebootAction string

RebootAction defines the action a machine should take when a hook needs to reboot

const (
	// ShouldDoNothing instructs a machine agent that no action
	// is required on its part
	ShouldDoNothing RebootAction = "noop"
	// ShouldReboot instructs a machine to reboot
	// this happens when a hook running on a machine, requests
	// a reboot
	ShouldReboot RebootAction = "reboot"
	// ShouldShutdown instructs a machine to shut down. This usually
	// happens when running inside a container, and a hook on the parent
	// machine requests a reboot
	ShouldShutdown RebootAction = "shutdown"
)

type RebootActionGetter

type RebootActionGetter interface {
	ShouldRebootOrShutdown() (RebootAction, error)
}

type RebootFlagSetter

type RebootFlagSetter interface {
	SetRebootFlag(flag bool) error
}

type Relation

type Relation struct {
	// contains filtered or unexported fields
}

Relation represents a relation between one or two service endpoints.

func (*Relation) Destroy

func (r *Relation) Destroy() (err error)

Destroy ensures that the relation will be removed at some point; if no units are currently in scope, it will be removed immediately.

func (*Relation) Endpoint

func (r *Relation) Endpoint(serviceName string) (Endpoint, error)

Endpoint returns the endpoint of the relation for the named service. If the service is not part of the relation, an error will be returned.

func (*Relation) Endpoints

func (r *Relation) Endpoints() []Endpoint

Endpoints returns the endpoints for the relation.

func (*Relation) Id

func (r *Relation) Id() int

Id returns the integer internal relation key. This is exposed because the unit agent needs to expose a value derived from this (as JUJU_RELATION_ID) to allow relation hooks to differentiate between relations with different services.

func (*Relation) Life

func (r *Relation) Life() Life

Life returns the relation's current life state.

func (*Relation) Refresh

func (r *Relation) Refresh() error

Refresh refreshes the contents of the relation from the underlying state. It returns an error that satisfies errors.IsNotFound if the relation has been removed.

func (*Relation) RelatedEndpoints

func (r *Relation) RelatedEndpoints(serviceName string) ([]Endpoint, error)

RelatedEndpoints returns the endpoints of the relation r with which units of the named service will establish relations. If the service is not part of the relation r, an error will be returned.

func (*Relation) String

func (r *Relation) String() string

func (*Relation) Tag

func (r *Relation) Tag() names.Tag

Tag returns a name identifying the relation.

func (*Relation) Unit

func (r *Relation) Unit(u *Unit) (*RelationUnit, error)

Unit returns a RelationUnit for the supplied unit.

type RelationScopeChange

type RelationScopeChange struct {
	Entered []string
	Left    []string
}

RelationScopeChange contains information about units that have entered or left a particular scope.

type RelationScopeWatcher

type RelationScopeWatcher struct {
	// contains filtered or unexported fields
}

RelationScopeWatcher observes changes to the set of units in a particular relation scope.

func (*RelationScopeWatcher) Changes

func (w *RelationScopeWatcher) Changes() <-chan *RelationScopeChange

Changes returns a channel that will receive changes when units enter and leave a relation scope. The Entered field in the first event on the channel holds the initial state.

func (*RelationScopeWatcher) Err

func (w *RelationScopeWatcher) Err() error

Err returns any error encountered while running or shutting down, or tomb.ErrStillAlive if the watcher is still running.

func (*RelationScopeWatcher) Kill

func (w *RelationScopeWatcher) Kill()

Kill kills the watcher without waiting for it to shut down.

func (*RelationScopeWatcher) Stop

func (w *RelationScopeWatcher) Stop() error

Stop stops the watcher, and returns any error encountered while running or shutting down.

func (*RelationScopeWatcher) Wait

func (w *RelationScopeWatcher) Wait() error

Wait waits for the watcher to die and returns any error encountered when it was running.

type RelationUnit

type RelationUnit struct {
	// contains filtered or unexported fields
}

RelationUnit holds information about a single unit in a relation, and allows clients to conveniently access unit-specific functionality.

func (*RelationUnit) Endpoint

func (ru *RelationUnit) Endpoint() Endpoint

Endpoint returns the relation endpoint that defines the unit's participation in the relation.

func (*RelationUnit) EnterScope

func (ru *RelationUnit) EnterScope(settings map[string]interface{}) error

EnterScope ensures that the unit has entered its scope in the relation. When the unit has already entered its relation scope, EnterScope will report success but make no changes to state.

Otherwise, assuming both the relation and the unit are alive, it will enter scope and create or overwrite the unit's settings in the relation according to the supplied map.

If the unit is a principal and the relation has container scope, EnterScope will also create the required subordinate unit, if it does not already exist; this is because there's no point having a principal in scope if there is no corresponding subordinate to join it.

Once a unit has entered a scope, it stays in scope without further intervention; the relation will not be able to become Dead until all units have departed its scopes.

func (*RelationUnit) InScope

func (ru *RelationUnit) InScope() (bool, error)

InScope returns whether the relation unit has entered scope and not left it.

func (*RelationUnit) Joined

func (ru *RelationUnit) Joined() (bool, error)

Joined returns whether the relation unit has entered scope and neither left it nor prepared to leave it.

func (*RelationUnit) LeaveScope

func (ru *RelationUnit) LeaveScope() error

LeaveScope signals that the unit has left its scope in the relation. After the unit has left its relation scope, it is no longer a member of the relation; if the relation is dying when its last member unit leaves, it is removed immediately. It is not an error to leave a scope that the unit is not, or never was, a member of.

func (*RelationUnit) PrepareLeaveScope

func (ru *RelationUnit) PrepareLeaveScope() error

PrepareLeaveScope causes the unit to be reported as departed by watchers, but does not *actually* leave the scope, to avoid triggering relation cleanup.

func (*RelationUnit) PrivateAddress

func (ru *RelationUnit) PrivateAddress() (string, bool)

PrivateAddress returns the private address of the unit and whether it is valid.

func (*RelationUnit) ReadSettings

func (ru *RelationUnit) ReadSettings(uname string) (m map[string]interface{}, err error)

ReadSettings returns a map holding the settings of the unit with the supplied name within this relation. An error will be returned if the relation no longer exists, or if the unit's service is not part of the relation, or the settings are invalid; but mere non-existence of the unit is not grounds for an error, because the unit settings are guaranteed to persist for the lifetime of the relation, regardless of the lifetime of the unit.

func (*RelationUnit) Relation

func (ru *RelationUnit) Relation() *Relation

Relation returns the relation associated with the unit.

func (*RelationUnit) Settings

func (ru *RelationUnit) Settings() (*Settings, error)

Settings returns a Settings which allows access to the unit's settings within the relation.

func (*RelationUnit) Watch

func (ru *RelationUnit) Watch() RelationUnitsWatcher

Watch returns a watcher that notifies of changes to conterpart units in the relation.

func (*RelationUnit) WatchScope

func (ru *RelationUnit) WatchScope() *RelationScopeWatcher

WatchScope returns a watcher which notifies of counterpart units entering and leaving the unit's scope.

type RelationUnitsWatcher

type RelationUnitsWatcher interface {
	Watcher
	Changes() <-chan multiwatcher.RelationUnitsChange
}

RelationUnitsWatcher generates signals when units enter or leave the scope of a RelationUnit, and changes to the settings of those units known to have entered.

type Remover

type Remover interface {
	Remove() error
}

Remover represents entities with a Remove method.

type ResolvedMode

type ResolvedMode string

ResolvedMode describes the way state transition errors are resolved.

const (
	ResolvedNone       ResolvedMode = ""
	ResolvedRetryHooks ResolvedMode = "retry-hooks"
	ResolvedNoHooks    ResolvedMode = "no-hooks"
)

These are available ResolvedMode values.

type RestoreInfo

type RestoreInfo struct {
	// contains filtered or unexported fields
}

RestoreInfo its used to syncronize Restore and machine agent

func (*RestoreInfo) SetStatus

func (info *RestoreInfo) SetStatus(status RestoreStatus) error

SetStatus sets the status of the current restore. Checks are made to ensure that status changes are performed in the correct order.

func (*RestoreInfo) Status

func (info *RestoreInfo) Status() RestoreStatus

Status returns the current Restore doc status

type RestoreStatus

type RestoreStatus string

RestoreStatus is the type of the statuses

const (

	// UnknownRestoreStatus is the initial status for restoreInfoDoc
	UnknownRestoreStatus RestoreStatus = "UNKNOWN"
	// RestorePending is a status to signal that a restore is about to start
	// any change done in this status will be lost
	RestorePending RestoreStatus = "PENDING"
	// RestoreInProgress indicates that a Restore is in progress.
	RestoreInProgress RestoreStatus = "RESTORING"
	// RestoreFinished it is set by restore upon a succesful run
	RestoreFinished RestoreStatus = "RESTORED"
	RestoreChecked  RestoreStatus = "CHECKED"
)

type Service

type Service struct {
	// contains filtered or unexported fields
}

Service represents the state of a service.

func (*Service) AddUnit

func (s *Service) AddUnit() (unit *Unit, err error)

AddUnit adds a new principal unit to the service.

func (*Service) AllUnits

func (s *Service) AllUnits() (units []*Unit, err error)

AllUnits returns all units of the service.

func (*Service) Charm

func (s *Service) Charm() (ch *Charm, force bool, err error)

Charm returns the service's charm and whether units should upgrade to that charm even if they are in an error state.

func (*Service) CharmURL

func (s *Service) CharmURL() (curl *charm.URL, force bool)

CharmURL returns the service's charm URL, and whether units should upgrade to the charm with that URL even if they are in an error state.

func (*Service) ClearExposed

func (s *Service) ClearExposed() error

ClearExposed removes the exposed flag from the service. See SetExposed and IsExposed.

func (*Service) ConfigSettings

func (s *Service) ConfigSettings() (charm.Settings, error)

ConfigSettings returns the raw user configuration for the service's charm. Unset values are omitted.

func (*Service) Constraints

func (s *Service) Constraints() (constraints.Value, error)

Constraints returns the current service constraints.

func (*Service) Destroy

func (s *Service) Destroy() (err error)

Destroy ensures that the service and all its relations will be removed at some point; if the service has no units, and no relation involving the service has any units in scope, they are all removed immediately.

func (*Service) Endpoint

func (s *Service) Endpoint(relationName string) (Endpoint, error)

Endpoint returns the relation endpoint with the supplied name, if it exists.

func (*Service) Endpoints

func (s *Service) Endpoints() (eps []Endpoint, err error)

Endpoints returns the service's currently available relation endpoints.

func (*Service) EnsureMinUnits

func (s *Service) EnsureMinUnits() (err error)

EnsureMinUnits adds new units if the service's MinUnits value is greater than the number of alive units.

func (*Service) GetOwnerTag

func (s *Service) GetOwnerTag() string

SCHEMACHANGE TODO(mattyw) remove when schema upgrades are possible

func (*Service) IsExposed

func (s *Service) IsExposed() bool

IsExposed returns whether this service is exposed. The explicitly open ports (with open-port) for exposed services may be accessed from machines outside of the local deployment network. See SetExposed and ClearExposed.

func (*Service) IsPrincipal

func (s *Service) IsPrincipal() bool

IsPrincipal returns whether units of the service can have subordinate units.

func (*Service) Life

func (s *Service) Life() Life

Life returns whether the service is Alive, Dying or Dead.

func (*Service) MetricCredentials

func (s *Service) MetricCredentials() []byte

MetricCredentials returns any metric credentials associated with this service.

func (*Service) MinUnits

func (s *Service) MinUnits() int

MinUnits returns the minimum units count for the service.

func (*Service) Name

func (s *Service) Name() string

Name returns the service name.

func (*Service) Networks

func (s *Service) Networks() ([]string, error)

Networks returns the networks a service is associated with. Unlike networks specified with constraints, these networks are required to be present on machines hosting this service's units.

func (*Service) Refresh

func (s *Service) Refresh() error

Refresh refreshes the contents of the Service from the underlying state. It returns an error that satisfies errors.IsNotFound if the service has been removed.

func (*Service) Relations

func (s *Service) Relations() (relations []*Relation, err error)

Relations returns a Relation for every relation the service is in.

func (*Service) SetCharm

func (s *Service) SetCharm(ch *Charm, force bool) error

SetCharm changes the charm for the service. New units will be started with this charm, and existing units will be upgraded to use it. If force is true, units will be upgraded even if they are in an error state.

func (*Service) SetConstraints

func (s *Service) SetConstraints(cons constraints.Value) (err error)

SetConstraints replaces the current service constraints.

func (*Service) SetExposed

func (s *Service) SetExposed() error

SetExposed marks the service as exposed. See ClearExposed and IsExposed.

func (*Service) SetMetricCredentials

func (s *Service) SetMetricCredentials(b []byte) error

SetMetricCredentials updates the metric credentials associated with this service.

func (*Service) SetMinUnits

func (s *Service) SetMinUnits(minUnits int) (err error)

SetMinUnits changes the number of minimum units required by the service.

func (*Service) StorageConstraints

func (s *Service) StorageConstraints() (map[string]StorageConstraints, error)

func (*Service) String

func (s *Service) String() string

String returns the service name.

func (*Service) Tag

func (s *Service) Tag() names.Tag

Tag returns a name identifying the service. The returned name will be different from other Tag values returned by any other entities from the same state.

func (*Service) UpdateConfigSettings

func (s *Service) UpdateConfigSettings(changes charm.Settings) error

UpdateConfigSettings changes a service's charm config settings. Values set to nil will be deleted; unknown and invalid values will return an error.

func (*Service) Watch

func (s *Service) Watch() NotifyWatcher

Watch returns a watcher for observing changes to a service.

func (*Service) WatchRelations

func (s *Service) WatchRelations() StringsWatcher

WatchRelations returns a StringsWatcher that notifies of changes to the lifecycles of relations involving s.

func (*Service) WatchUnits

func (s *Service) WatchUnits() StringsWatcher

WatchUnits returns a StringsWatcher that notifies of changes to the lifecycles of units of s.

type Settings

type Settings struct {
	// contains filtered or unexported fields
}

A Settings manages changes to settings as a delta in memory and merges them back in the database when explicitly requested.

func (*Settings) Delete

func (c *Settings) Delete(key string)

Delete removes key.

func (*Settings) Get

func (c *Settings) Get(key string) (value interface{}, found bool)

Get returns the value of key and whether it was found.

func (*Settings) Keys

func (c *Settings) Keys() []string

Keys returns the current keys in alphabetical order.

func (*Settings) Map

func (c *Settings) Map() map[string]interface{}

Map returns all keys and values of the node.

func (*Settings) Read

func (c *Settings) Read() error

Read (re)reads the node data into c.

func (*Settings) Set

func (c *Settings) Set(key string, value interface{})

Set sets key to value

func (*Settings) Update

func (c *Settings) Update(kv map[string]interface{})

Update sets multiple key/value pairs.

func (*Settings) Write

func (c *Settings) Write() ([]ItemChange, error)

Write writes changes made to c back onto its node. Changes are written as a delta applied on top of the latest version of the node, to prevent overwriting unrelated changes made to the node since it was last read.

type State

type State struct {
	// TODO(katco-): As state gets broken up, remove this.
	*LeasePersistor
	// contains filtered or unexported fields
}

State represents the state of an environment managed by juju.

func Initialize

func Initialize(owner names.UserTag, info *mongo.MongoInfo, cfg *config.Config, opts mongo.DialOpts, policy Policy) (rst *State, err error)

Initialize sets up an initial empty state and returns it. This needs to be performed only once for the initial state server environment. It returns unauthorizedError if access is unauthorized.

func Open

func Open(info *mongo.MongoInfo, opts mongo.DialOpts, policy Policy) (*State, error)

Open connects to the server described by the given info, waits for it to be initialized, and returns a new State representing the environment connected to.

A policy may be provided, which will be used to validate and modify behaviour of certain operations in state. A nil policy may be provided.

Open returns unauthorizedError if access is unauthorized.

func (*State) APIAddressesFromMachines

func (st *State) APIAddressesFromMachines() ([]string, error)

APIAddressesFromMachines returns the list of cloud-internal addresses that can be used to connect to the state API server. This method will be deprecated when API addresses are stored independently in their own document.

func (*State) APIHostPorts

func (st *State) APIHostPorts() ([][]network.HostPort, error)

APIHostPorts returns the API addresses as set by SetAPIHostPorts.

func (*State) AbortCurrentUpgrade

func (st *State) AbortCurrentUpgrade() error

AbortCurrentUpgrade archives any current UpgradeInfo and sets its status to UpgradeAborted. Nothing happens if there's no current UpgradeInfo.

func (*State) Action

func (st *State) Action(id string) (*Action, error)

Action returns an Action by Id, which is a UUID.

func (*State) ActionByTag

func (st *State) ActionByTag(tag names.ActionTag) (*Action, error)

ActionByTag returns an Action given an ActionTag.

func (*State) AddCharm

func (st *State) AddCharm(ch charm.Charm, curl *charm.URL, storagePath, bundleSha256 string) (stch *Charm, err error)

AddCharm adds the ch charm with curl to the state. On success the newly added charm state is returned.

func (*State) AddEnvironmentUser

func (st *State) AddEnvironmentUser(user, createdBy names.UserTag) (*EnvironmentUser, error)

AddEnvironmentUser adds a new user to the database.

func (*State) AddIPAddress

func (st *State) AddIPAddress(addr network.Address, subnetid string) (ipaddress *IPAddress, err error)

AddIPAddress creates and returns a new IP address

func (*State) AddMachine

func (st *State) AddMachine(series string, jobs ...MachineJob) (*Machine, error)

AddMachine adds a machine with the given series and jobs. It is deprecated and around for testing purposes only.

func (*State) AddMachineInsideMachine

func (st *State) AddMachineInsideMachine(template MachineTemplate, parentId string, containerType instance.ContainerType) (*Machine, error)

AddMachineInsideMachine adds a machine inside a container of the given type on the existing machine with id=parentId.

func (*State) AddMachineInsideNewMachine

func (st *State) AddMachineInsideNewMachine(template, parentTemplate MachineTemplate, containerType instance.ContainerType) (*Machine, error)

AddMachineInsideNewMachine creates a new machine within a container of the given type inside another new machine. The two given templates specify the form of the child and parent respectively.

func (*State) AddMachines

func (st *State) AddMachines(templates ...MachineTemplate) (_ []*Machine, err error)

AddMachines adds new machines configured according to the given templates.

func (*State) AddNetwork

func (st *State) AddNetwork(args NetworkInfo) (n *Network, err error)

AddNetwork creates a new network with the given params. If a network with the same name or provider id already exists in state, an error satisfying errors.IsAlreadyExists is returned.

func (*State) AddOneMachine

func (st *State) AddOneMachine(template MachineTemplate) (*Machine, error)

AddOneMachine machine adds a new machine configured according to the given template.

func (*State) AddRelation

func (st *State) AddRelation(eps ...Endpoint) (r *Relation, err error)

AddRelation creates a new relation with the given endpoints.

func (*State) AddService

func (st *State) AddService(
	name, owner string, ch *Charm, networks []string, storage map[string]StorageConstraints,
) (service *Service, err error)

AddService creates a new service, running the supplied charm, with the supplied name (which must be unique). If the charm defines peer relations, they will be created automatically.

func (*State) AddStoreCharmPlaceholder

func (st *State) AddStoreCharmPlaceholder(curl *charm.URL) (err error)

AddStoreCharmPlaceholder creates a charm document in state for the given charm URL which must reference a charm from the store. The charm document is marked as a placeholder which means that if the charm is to be deployed, it will need to first be uploaded to env storage.

func (*State) AddSubnet

func (st *State) AddSubnet(args SubnetInfo) (subnet *Subnet, err error)

AddSubnet creates and returns a new subnet

func (*State) AddUser

func (st *State) AddUser(name, displayName, password, creator string) (*User, error)

AddUser adds a user to the database.

func (*State) Addresses

func (st *State) Addresses() ([]string, error)

Addresses returns the list of cloud-internal addresses that can be used to connect to the state.

func (*State) AllCharms

func (st *State) AllCharms() ([]*Charm, error)

AllCharms returns all charms in state.

func (*State) AllMachines

func (st *State) AllMachines() (machines []*Machine, err error)

AllMachines returns all machines in the environment ordered by id.

func (*State) AllNetworks

func (st *State) AllNetworks() (networks []*Network, err error)

AllNetworks returns all known networks in the environment.

func (*State) AllRelations

func (st *State) AllRelations() (relations []*Relation, err error)

AllRelations returns all relations in the environment ordered by id.

func (*State) AllServices

func (st *State) AllServices() (services []*Service, err error)

AllServices returns all deployed services in the environment.

func (*State) AllUsers

func (st *State) AllUsers(includeDeactivated bool) ([]*User, error)

User returns the state User for the given name,

func (*State) Annotation

func (st *State) Annotation(entity GlobalEntity, key string) (string, error)

Annotation returns the annotation value corresponding to the given key. If the requested annotation is not found, an empty string is returned.

func (*State) Annotations

func (st *State) Annotations(entity GlobalEntity) (map[string]string, error)

Annotations returns all the annotations corresponding to an entity.

func (*State) AssignUnit

func (st *State) AssignUnit(u *Unit, policy AssignmentPolicy) (err error)

AssignUnit places the unit on a machine. Depending on the policy, and the state of the environment, this may lead to new instances being launched within the environment.

func (*State) BlockDevice

func (st *State) BlockDevice(diskName string) (BlockDevice, error)

BlockDevice returns the BlockDevice with the specified name.

func (*State) CACert

func (st *State) CACert() string

CACert returns the certificate used to validate the state connection.

func (*State) Charm

func (st *State) Charm(curl *charm.URL) (*Charm, error)

Charm returns the charm with the given URL. Charms pending upload to storage and placeholders are never returned.

func (*State) Cleanup

func (st *State) Cleanup() error

Cleanup removes all documents that were previously marked for removal, if any such exist. It should be called periodically by at least one element of the system.

func (*State) CleanupOldMetrics

func (st *State) CleanupOldMetrics() error

CleanupOldMetrics looks for metrics that are 24 hours old (or older) and have been sent. Any metrics it finds are deleted.

func (*State) ClearUpgradeInfo

func (st *State) ClearUpgradeInfo() error

ClearUpgradeInfo clears information about an upgrade in progress. It returns an error if no upgrade is current.

func (*State) Close

func (st *State) Close() (err error)

func (*State) CountofSentMetrics

func (st *State) CountofSentMetrics() (int, error)

CountofSentMetrics returns the number of metrics that have been sent to the collection service and have not been removed by the cleanup worker.

func (*State) CountofUnsentMetrics

func (st *State) CountofUnsentMetrics() (int, error)

CountofUnsentMetrics returns the number of metrics that haven't been sent to the collection service.

func (*State) DeployerConnectionInfo

func (st *State) DeployerConnectionInfo() (*DeployerConnectionValues, error)

DeployerConnectionInfo returns the address information necessary for the deployer. The function does the expensive operations (getting stuff from mongo) just once.

func (*State) EndpointsRelation

func (st *State) EndpointsRelation(endpoints ...Endpoint) (*Relation, error)

EndpointsRelation returns the existing relation with the given endpoints.

func (*State) EnqueueAction

func (st *State) EnqueueAction(receiver names.Tag, actionName string, payload map[string]interface{}) (*Action, error)

EnqueueAction

func (*State) EnsureAvailability

func (st *State) EnsureAvailability(
	numStateServers int, cons constraints.Value, series string, placement []string,
) (StateServersChanges, error)

EnsureAvailability adds state server machines as necessary to make the number of live state servers equal to numStateServers. The given constraints and series will be attached to any new machines. If placement is not empty, any new machines which may be required are started according to the specified placement directives until the placement list is exhausted; thereafter any new machines are started according to the constraints and series.

func (*State) EnsureRestoreInfo

func (st *State) EnsureRestoreInfo() (*RestoreInfo, error)

EnsureRestoreInfo returns the current info doc, if it does not exists it creates it with UnknownRestoreStatus status

func (*State) EnsureUpgradeInfo

func (st *State) EnsureUpgradeInfo(machineId string, previousVersion, targetVersion version.Number) (*UpgradeInfo, error)

EnsureUpgradeInfo returns an UpgradeInfo describing a current upgrade between the supplied versions. If a matching upgrade is in progress, that upgrade is returned; if there's a mismatch, an error is returned. The supplied machine id must correspond to a current state server.

func (*State) EnvironConfig

func (st *State) EnvironConfig() (*config.Config, error)

func (*State) EnvironConstraints

func (st *State) EnvironConstraints() (constraints.Value, error)

EnvironConstraints returns the current environment constraints.

func (*State) EnvironTag

func (st *State) EnvironTag() names.EnvironTag

EnvironTag() returns the environment tag for the environment controlled by this state instance.

func (*State) EnvironUUID

func (st *State) EnvironUUID() string

EnvironUUID returns the environment UUID for the environment controlled by this state instance.

func (*State) Environment

func (st *State) Environment() (*Environment, error)

Environment returns the environment entity.

func (*State) EnvironmentUser

func (st *State) EnvironmentUser(user names.UserTag) (*EnvironmentUser, error)

EnvironmentUser returns the environment user.

func (*State) EnvironmentsForUser

func (st *State) EnvironmentsForUser(user names.UserTag) ([]*Environment, error)

EnvironmentsForUser returns a list of enviroments that the user is able to access.

func (*State) FindActionTagsByPrefix

func (st *State) FindActionTagsByPrefix(prefix string) []names.ActionTag

FindActionTagsByPrefix finds Actions with ids that share the supplied prefix, and returns a list of corresponding ActionTags.

func (*State) FindEntity

func (st *State) FindEntity(tag names.Tag) (Entity, error)

FindEntity returns the entity with the given tag.

The returned value can be of type *Machine, *Unit, *User, *Service, *Environment, or *Action, depending on the tag.

func (*State) ForEnviron

func (st *State) ForEnviron(env names.EnvironTag) (*State, error)

ForEnviron returns a connection to mongo for the specified environment. The connection uses the same credentails and policy as the existing connection.

func (*State) GetEnvironment

func (st *State) GetEnvironment(tag names.EnvironTag) (*Environment, error)

GetEnvironment looks for the environment identified by the uuid passed in.

func (*State) IPAddress

func (st *State) IPAddress(value string) (*IPAddress, error)

IPAddress returns an existing IP address from the state.

func (*State) ImageStorage

func (st *State) ImageStorage() imagestorage.Storage

ImageStorage returns a new imagestorage.Storage that stores image metadata.

func (*State) InferEndpoints

func (st *State) InferEndpoints(names ...string) ([]Endpoint, error)

InferEndpoints returns the endpoints corresponding to the supplied names. There must be 1 or 2 supplied names, of the form <service>[:<relation>]. If the supplied names uniquely specify a possible relation, or if they uniquely specify a possible relation once all implicit relations have been filtered, the endpoints corresponding to that relation will be returned.

func (*State) IsUpgrading

func (st *State) IsUpgrading() (bool, error)

IsUpgrading returns true if an upgrade is currently in progress.

func (*State) KeyRelation

func (st *State) KeyRelation(key string) (*Relation, error)

KeyRelation returns the existing relation with the given key (which can be derived unambiguously from the relation's endpoints).

func (*State) LatestPlaceholderCharm

func (st *State) LatestPlaceholderCharm(curl *charm.URL) (*Charm, error)

LatestPlaceholderCharm returns the latest charm described by the given URL but which is not yet deployed.

func (*State) Machine

func (st *State) Machine(id string) (*Machine, error)

Machine returns the machine with the given id.

func (*State) MetricBatch

func (st *State) MetricBatch(id string) (*MetricBatch, error)

MetricBatch returns the metric batch with the given id.

func (*State) MetricBatches

func (st *State) MetricBatches() ([]MetricBatch, error)

MetricBatches returns all metric batches currently stored in state. TODO (tasdomas): this method is currently only used in the uniter worker test -

it needs to be modified to restrict the scope of the values it
returns if it is to be used outside of tests.

func (*State) MetricsToSend

func (st *State) MetricsToSend(batchSize int) ([]*MetricBatch, error)

MetricsToSend returns batchSize metrics that need to be sent to the collector

func (*State) MongoConnectionInfo

func (st *State) MongoConnectionInfo() *mongo.MongoInfo

MongoConnectionInfo returns information for connecting to mongo

func (*State) MongoSession

func (st *State) MongoSession() *mgo.Session

MongoSession returns the underlying mongodb session used by the state. It is exposed so that external code can maintain the mongo replica set and should not otherwise be used.

func (*State) NeedsCleanup

func (st *State) NeedsCleanup() (bool, error)

NeedsCleanup returns true if documents previously marked for removal exist.

func (*State) Network

func (st *State) Network(name string) (*Network, error)

Network returns the network with the given name.

func (*State) NewEnvironment

func (st *State) NewEnvironment(cfg *config.Config, owner names.UserTag) (_ *Environment, _ *State, err error)

NewEnvironment creates a new environment with its own UUID and prepares it for use. Environment and State instances for the new environment are returned.

The state server environment's UUID is attached to the new environment's document. Having the server UUIDs stored with each environment document means that we have a way to represent external environments, perhaps for future use around cross environment relations.

func (*State) Ping

func (st *State) Ping() error

Ping probes the state's database connection to ensure that it is still alive.

func (*State) PrepareLocalCharmUpload

func (st *State) PrepareLocalCharmUpload(curl *charm.URL) (chosenUrl *charm.URL, err error)

PrepareLocalCharmUpload must be called before a local charm is uploaded to the provider storage in order to create a charm document in state. It returns the chosen unique charm URL reserved in state for the charm.

The url's schema must be "local" and it must include a revision.

func (*State) PrepareStoreCharmUpload

func (st *State) PrepareStoreCharmUpload(curl *charm.URL) (*Charm, error)

PrepareStoreCharmUpload must be called before a charm store charm is uploaded to the provider storage in order to create a charm document in state. If a charm with the same URL is already in state, it will be returned as a *state.Charm (is can be still pending or already uploaded). Otherwise, a new charm document is added in state with just the given charm URL and PendingUpload=true, which is then returned as a *state.Charm.

The url's schema must be "cs" and it must include a revision.

func (*State) ReadLeadershipSettings

func (st *State) ReadLeadershipSettings(serviceId string) (*Settings, error)

func (*State) ReadSettings

func (st *State) ReadSettings(key string) (*Settings, error)

ReadSettings returns the settings for the given key.

func (*State) Relation

func (st *State) Relation(id int) (*Relation, error)

Relation returns the existing relation with the given id.

func (*State) RemoveEnvironmentUser

func (st *State) RemoveEnvironmentUser(user names.UserTag) error

RemoveEnvironmentUser adds a new user to the database.

func (*State) ResumeTransactions

func (st *State) ResumeTransactions() error

ResumeTransactions resumes all pending transactions.

func (*State) Service

func (st *State) Service(name string) (service *Service, err error)

Service returns a service state by name.

func (*State) SetAPIHostPorts

func (st *State) SetAPIHostPorts(hps [][]network.HostPort) error

SetAPIHostPorts sets the addresses of the API server instances. Each server is represented by one element in the top level slice.

func (*State) SetAdminMongoPassword

func (st *State) SetAdminMongoPassword(password string) error

SetAdminMongoPassword sets the administrative password to access the state. If the password is non-empty, all subsequent attempts to access the state must be authorized; otherwise no authorization is required.

func (*State) SetAnnotations

func (st *State) SetAnnotations(entity GlobalEntity, annotations map[string]string) (err error)

SetAnnotations adds key/value pairs to annotations in MongoDB.

func (*State) SetEnvironAgentVersion

func (st *State) SetEnvironAgentVersion(newVersion version.Number) (err error)

SetEnvironAgentVersion changes the agent version for the environment to the given version, only if the environment is in a stable state (all agents are running the current version).

func (*State) SetEnvironConstraints

func (st *State) SetEnvironConstraints(cons constraints.Value) error

SetEnvironConstraints replaces the current environment constraints.

func (*State) SetMetricBatchesSent

func (st *State) SetMetricBatchesSent(batchUUIDs []string) error

SetMetricBatchesSent sets sent on each MetricBatch corresponding to the uuids provided.

func (*State) SetStateServingInfo

func (st *State) SetStateServingInfo(info StateServingInfo) error

SetStateServingInfo stores information needed for running a state server

func (*State) StartSync

func (st *State) StartSync()

StartSync forces watchers to resynchronize their state with the database immediately. This will happen periodically automatically.

func (*State) StateServerEnvironment

func (st *State) StateServerEnvironment() (*Environment, error)

StateServerEnvironment returns the environment that was bootstrapped. This is the only environment that can have state server machines. The owner of this environment is also considered "special", in that they are the only user that is able to create other users (until we have more fine grained permissions), and they cannot be disabled.

func (*State) StateServerInfo

func (st *State) StateServerInfo() (*StateServerInfo, error)

StateServerInfo returns information about the currently configured state server machines.

func (*State) StateServingInfo

func (st *State) StateServingInfo() (StateServingInfo, error)

StateServingInfo returns information for running a state server machine

func (*State) StorageInstance

func (st *State) StorageInstance(id string) (StorageInstance, error)

StorageInstance returns the StorageInstance with the specified ID.

func (*State) Subnet

func (st *State) Subnet(cidr string) (*Subnet, error)

func (*State) ToolsStorage

func (st *State) ToolsStorage() (toolstorage.StorageCloser, error)

ToolsStorage returns a new toolstorage.StorageCloser that stores tools metadata in the "juju" database” "toolsmetadata" collection.

TODO(axw) remove this, add a constructor function in toolstorage.

func (*State) Unit

func (st *State) Unit(name string) (*Unit, error)

Unit returns a unit by name.

func (*State) UpdateEnvironConfig

func (st *State) UpdateEnvironConfig(updateAttrs map[string]interface{}, removeAttrs []string, additionalValidation ValidateConfigFunc) error

UpdateEnvironConfig adds, updates or removes attributes in the current configuration of the environment with the provided updateAttrs and removeAttrs.

func (*State) UpdateUploadedCharm

func (st *State) UpdateUploadedCharm(ch charm.Charm, curl *charm.URL, storagePath, bundleSha256 string) (*Charm, error)

UpdateUploadedCharm marks the given charm URL as uploaded and updates the rest of its data, returning it as *state.Charm.

func (*State) User

func (st *State) User(tag names.UserTag) (*User, error)

User returns the state User for the given name,

func (*State) Watch

func (st *State) Watch() *Multiwatcher

func (*State) WatchAPIHostPorts

func (st *State) WatchAPIHostPorts() NotifyWatcher

WatchAPIHostPorts returns a NotifyWatcher that notifies when the set of API addresses changes.

func (*State) WatchActionResults

func (st *State) WatchActionResults() StringsWatcher

WatchActionResults starts and returns a StringsWatcher that notifies on new ActionResults being added.

func (*State) WatchActionResultsFilteredBy

func (st *State) WatchActionResultsFilteredBy(receivers ...ActionReceiver) StringsWatcher

WatchActionResultsFilteredBy starts and returns a StringsWatcher that notifies on new ActionResults being added for the ActionRecevers being watched.

func (*State) WatchCleanups

func (st *State) WatchCleanups() NotifyWatcher

WatchCleanups starts and returns a CleanupWatcher.

func (*State) WatchEnvironConfig

func (st *State) WatchEnvironConfig() *EnvironConfigWatcher

WatchEnvironConfig returns a watcher for observing changes to the environment configuration.

func (*State) WatchEnvironMachines

func (st *State) WatchEnvironMachines() StringsWatcher

WatchEnvironMachines returns a StringsWatcher that notifies of changes to the lifecycles of the machines (but not containers) in the environment.

func (*State) WatchEnvironments

func (st *State) WatchEnvironments() StringsWatcher

WatchEnvironments returns a StringsWatcher that notifies of changes to the lifecycles of all environments.

func (*State) WatchForEnvironConfigChanges

func (st *State) WatchForEnvironConfigChanges() NotifyWatcher

WatchForEnvironConfigChanges returns a NotifyWatcher waiting for the Environ Config to change. This differs from WatchEnvironConfig in that the watcher is a NotifyWatcher that does not give content during Changes()

func (*State) WatchLeadershipSettings

func (st *State) WatchLeadershipSettings(serviceId string) *LeadershipSettingsWatcher

WatchLeadershipSettings returns a LeadershipSettingsWatcher for watching -- wait for it -- leadership settings.

func (*State) WatchMinUnits

func (st *State) WatchMinUnits() StringsWatcher

WatchMinUnits returns a StringsWatcher for the minUnits collection

func (*State) WatchOpenedPorts

func (st *State) WatchOpenedPorts() StringsWatcher

WatchOpenedPorts starts and returns a StringsWatcher notifying of changes to the openedPorts collection. Reported changes have the following format: "<machine-id>:<network-name>", i.e. "0:juju-public".

func (*State) WatchRestoreInfoChanges

func (st *State) WatchRestoreInfoChanges() NotifyWatcher

WatchRestoreInfoChanges returns a NotifyWatcher that will inform when the restore status changes.

func (*State) WatchServices

func (st *State) WatchServices() StringsWatcher

WatchServices returns a StringsWatcher that notifies of changes to the lifecycles of the services in the environment.

func (*State) WatchStateServerInfo

func (st *State) WatchStateServerInfo() NotifyWatcher

WatchStateServerInfo returns a NotifyWatcher for the stateServers collection

func (*State) WatchUpgradeInfo

func (st *State) WatchUpgradeInfo() NotifyWatcher

WatchUpgradeInfo returns a watcher for observing changes to upgrade synchronisation state.

type StateServerInfo

type StateServerInfo struct {
	// EnvironmentTag identifies the initial environment. Only the initial
	// environment is able to have machines that manage state. The initial
	// environment is the environment that is created when bootstrapping.
	EnvironmentTag names.EnvironTag

	// MachineIds holds the ids of all machines configured
	// to run a state server. It includes all the machine
	// ids in VotingMachineIds.
	MachineIds []string

	// VotingMachineIds holds the ids of all machines
	// configured to run a state server and to have a vote
	// in peer election.
	VotingMachineIds []string
}

StateServerInfo holds information about currently configured state server machines.

type StateServersChanges

type StateServersChanges struct {
	Added      []string
	Removed    []string
	Maintained []string
	Promoted   []string
	Demoted    []string
}

Change in state servers after the ensure availability txn has committed.

type StateServingInfo

type StateServingInfo struct {
	APIPort      int
	StatePort    int
	Cert         string
	PrivateKey   string
	CAPrivateKey string
	// this will be passed as the KeyFile argument to MongoDB
	SharedSecret   string
	SystemIdentity string
}

StateServingInfo holds information needed by a state server. This type is a copy of the type of the same name from the api/params package. It is replicated here to avoid the state pacakge depending on api/params.

type StateSettings

type StateSettings struct {
	// contains filtered or unexported fields
}

StateSettings is used to expose various settings APIs outside of the state package.

func NewStateSettings

func NewStateSettings(st *State) *StateSettings

NewStateSettings creates a StateSettings from state.

func (*StateSettings) CreateSettings

func (s *StateSettings) CreateSettings(key string, settings map[string]interface{}) error

CreateSettings exposes createSettings on state for use outside the state package.

func (*StateSettings) ListSettings

func (s *StateSettings) ListSettings(keyPrefix string) (map[string]map[string]interface{}, error)

ListSettings exposes listSettings on state for use outside the state package.

func (*StateSettings) ReadSettings

func (s *StateSettings) ReadSettings(key string) (map[string]interface{}, error)

ReadSettings exposes readSettings on state for use outside the state package.

func (*StateSettings) RemoveSettings

func (s *StateSettings) RemoveSettings(key string) error

RemoveSettings exposes removeSettings on state for use outside the state package.

type Status

type Status string

Status represents the status of an entity. It could be a service, unit, machine or its agent.

const (

	// The entity requires human intervention in order to operate
	// correctly.
	StatusError Status = "error"

	// The entity is actively participating in the environment.
	// For unit agents, this is a state we preserve for backwards
	// compatibility with scripts during the life of Juju 1.x.
	// In Juju 2.x, the agent-state will remain “active” and scripts
	// will watch the unit-state instead for signals of service readiness.
	StatusStarted Status = "started"
)
const (

	// The machine is not yet participating in the environment.
	StatusPending Status = "pending"

	// The machine's agent will perform no further action, other than
	// to set the unit to Dead at a suitable moment.
	StatusStopped Status = "stopped"

	// The machine ought to be signalling activity, but it cannot be
	// detected.
	StatusDown Status = "down"
)
const (

	// The machine on which a unit is to be hosted is still being
	// spun up in the cloud.
	StatusAllocating Status = "allocating"

	// The unit agent is downloading the charm and running the install hook.
	StatusInstalling Status = "installing"

	// The agent is actively participating in the environment.
	StatusActive Status = "active"

	// The unit is being destroyed; the agent will soon mark the unit as “dead”.
	// In Juju 2.x this will describe the state of the agent rather than a unit.
	StatusStopping Status = "stopping"

	// The unit agent has failed in some way,eg the agent ought to be signalling
	// activity, but it cannot be detected. It might also be that the unit agent
	// detected an unrecoverable condition and managed to tell the Juju server about it.
	StatusFailed Status = "failed"
)
const (

	// The unit is installed and has no problems but is busy getting itself
	// ready to provide services.
	StatusBusy Status = "busy"

	// The unit is unable to offer services because it needs another
	// service to be up.
	StatusWaiting Status = "waiting"

	// The unit needs manual intervention to get back to the Running state.
	StatusBlocked Status = "blocked"

	// The unit believes it is correctly offering all the services it has
	// been asked to offer.
	StatusRunning Status = "running"
)

func (Status) Matches

func (status Status) Matches(candidate Status) bool

Matches returns true if the candidate matches status, taking into account that the candidate may be a legacy status value which has been deprecated.

func (Status) ValidAgentStatus

func (status Status) ValidAgentStatus() bool

ValidAgentStatus returns true if status has a known value for an agent. This is used by the status command to filter out unknown status values.

type StatusGetter

type StatusGetter interface {
	Status() (status Status, info string, data map[string]interface{}, err error)
}

type StatusSetter

type StatusSetter interface {
	SetStatus(status Status, info string, data map[string]interface{}) error
}

type StorageConstraints

type StorageConstraints struct {
	// Pool is the name of the storage pool from which to provision the
	// storage instances.
	Pool string `bson:"pool"`

	// Size is the required size of the storage instances, in MiB.
	Size uint64 `bson:"size"`

	// Count is the required number of storage instances.
	Count uint64 `bson:"count"`
}

StorageConstraints contains the user-specified constraints for provisioning storage instances for a service unit.

type StorageInstance

type StorageInstance interface {
	// Tag returns the tag for the storage instance.
	Tag() names.Tag

	// Id returns the unique ID of the storage instance.
	Id() string

	// Kind returns the storage instance kind.
	Kind() StorageKind

	// Owner returns the tag of the service or unit that owns this storage
	// instance.
	Owner() names.Tag

	// StorageName returns the name of the storage, as defined in the charm
	// storage metadata. This does not uniquely identify storage instances,
	// but identifies the group that the instances belong to.
	StorageName() string

	// BlockDevices returns the names of the block devices assigned to this
	// storage instance.
	BlockDeviceNames() []string

	// Info returns the storage instance's StorageInstanceInfo, or a
	// NotProvisioned error if the storage instance has not yet been
	// provisioned.
	Info() (StorageInstanceInfo, error)

	// Params returns the parameters for provisioning the storage instance,
	// if it has not already been provisioned. Params returns true if the
	// returned parameters are usable for provisioning, otherwise false.
	Params() (StorageInstanceParams, bool)

	// Remove removes the storage instance and any remaining references to
	// it. If the storage instance no longer exists, the call is a no-op.
	Remove() error
}

StorageInstance represents the state of a unit or service-wide storage instance in the environment.

type StorageInstanceInfo

type StorageInstanceInfo struct {
	// Location is the location of the storage
	// instance, e.g. the mount point.
	Location string `bson:"location"`
}

StorageInfo describes information about the storage instance.

type StorageInstanceParams

type StorageInstanceParams struct {
	Size     uint64 `bson:"size"`
	Location string `bson:"location,omitempty"`
	ReadOnly bool   `bson:"read-only"`
}

StorageInstanceParams records parameters for provisioning a new storage instance.

type StorageKind

type StorageKind int

StorageKind defines the type of a store: whether it is a block device or a filesystem.

const (
	StorageKindUnknown StorageKind = iota
	StorageKindBlock
	StorageKindFilesystem
)

type StringsWatcher

type StringsWatcher interface {
	Watcher
	Changes() <-chan []string
}

StringsWatcher generates signals when something changes, returning the changes as a list of strings.

type Subnet

type Subnet struct {
	// contains filtered or unexported fields
}

func (*Subnet) AllocatableIPHigh

func (s *Subnet) AllocatableIPHigh() string

AllocatableIPHigh returns the hightest allocatable IP address in the subnet.

func (*Subnet) AllocatableIPLow

func (s *Subnet) AllocatableIPLow() string

AllocatableIPLow returns the lowest allocatable IP address in the subnet

func (*Subnet) AvailabilityZone

func (s *Subnet) AvailabilityZone() string

AvailabilityZone returns the availability zone of the subnet. If the subnet is not associated with an availability zone it will be the empty string.

func (*Subnet) CIDR

func (s *Subnet) CIDR() string

CIDR returns the subnet CIDR (e.g. 192.168.50.0/24).

func (*Subnet) EnsureDead

func (s *Subnet) EnsureDead() (err error)

EnsureDead sets the Life of the subnet to Dead

func (*Subnet) ID

func (s *Subnet) ID() string

ID returns the unique id for the subnet, for other entities to reference it

func (*Subnet) Life

func (s *Subnet) Life() Life

Life returns whether the subnet is Alive, Dying or Dead.

func (*Subnet) PickNewAddress

func (s *Subnet) PickNewAddress() (*IPAddress, error)

PickNewAddress returns a new IPAddress that isn't in use for the subnet. The address starts with AddressStateUnknown, for later allocation.

func (*Subnet) ProviderId

func (s *Subnet) ProviderId() string

ProviderId returns the provider-specific id of the subnet.

func (*Subnet) Refresh

func (s *Subnet) Refresh() error

Refresh refreshes the contents of the Subnet from the underlying state. It an error that satisfies errors.IsNotFound if the Subnet has been removed.

func (*Subnet) Remove

func (s *Subnet) Remove() (err error)

Remove removes a dead subnet. If the subnet is not dead it returns an error. It also removes any IP addresses associated with the subnet.

func (*Subnet) VLANTag

func (s *Subnet) VLANTag() int

VLANTag returns the subnet VLAN tag. It's a number between 1 and 4094 for VLANs and 0 if the network is not a VLAN.

func (*Subnet) Validate

func (s *Subnet) Validate() error

Validate validates the subnet, checking the CIDR, VLANTag and AllocatableIPHigh and Low, if present.

type SubnetInfo

type SubnetInfo struct {
	// ProviderId is a provider-specific network id. This may be empty.
	ProviderId string

	// CIDR of the network, in 123.45.67.89/24 format.
	CIDR string

	// VLANTag needs to be between 1 and 4094 for VLANs and 0 for normal
	// networks. It's defined by IEEE 802.1Q standard.
	VLANTag int

	// AllocatableIPHigh and Low describe the allocatable portion of the
	// subnet. The remainder, if any, is reserved by the provider.
	// Either both of these must be set or neither, if they're empty it
	// means that none of the subnet is allocatable. If present they must
	// be valid IP addresses within the subnet CIDR.
	AllocatableIPHigh string
	AllocatableIPLow  string

	// AvailabilityZone describes which availability zone this subnet is in. It can
	// be empty if the provider does not support availability zones.
	AvailabilityZone string
}

SubnetInfo describes a single subnet.

type Unit

type Unit struct {
	presence.Presencer
	// contains filtered or unexported fields
}

Unit represents the state of a service unit.

func (*Unit) ActionSpecs

func (u *Unit) ActionSpecs() (ActionSpecsByName, error)

ActionSpecs gets the ActionSpec map for the Unit's charm.

func (*Unit) Actions

func (u *Unit) Actions() ([]*Action, error)

Actions returns a list of actions pending or completed for this unit.

func (*Unit) AddAction

func (u *Unit) AddAction(name string, payload map[string]interface{}) (*Action, error)

AddAction adds a new Action of type name and using arguments payload to this Unit, and returns its ID.

func (*Unit) AddMetrics

func (u *Unit) AddMetrics(created time.Time, metrics []Metric) (*MetricBatch, error)

AddMetric adds a new batch of metrics to the database. A UUID for the metric will be generated and the new MetricBatch will be returned

func (*Unit) AgentPresence

func (u *Unit) AgentPresence() (bool, error)

AgentPresence returns whether the respective remote agent is alive.

func (*Unit) AgentTools

func (u *Unit) AgentTools() (*tools.Tools, error)

AgentTools returns the tools that the agent is currently running. It an error that satisfies errors.IsNotFound if the tools have not yet been set.

func (*Unit) AssignToCleanEmptyMachine

func (u *Unit) AssignToCleanEmptyMachine() (m *Machine, err error)

AssignToCleanEmptyMachine assigns u to a machine which is marked as clean and is also not hosting any containers. A machine is clean if it has never had any principal units assigned to it. If there are no clean machines besides any machine(s) running JobHostEnviron, an error is returned. This method does not take constraints into consideration when choosing a machine (lp:1161919).

func (*Unit) AssignToCleanMachine

func (u *Unit) AssignToCleanMachine() (m *Machine, err error)

AssignToCleanMachine assigns u to a machine which is marked as clean. A machine is clean if it has never had any principal units assigned to it. If there are no clean machines besides any machine(s) running JobHostEnviron, an error is returned. This method does not take constraints into consideration when choosing a machine (lp:1161919).

func (*Unit) AssignToMachine

func (u *Unit) AssignToMachine(m *Machine) (err error)

AssignToMachine assigns this unit to a given machine.

func (*Unit) AssignToNewMachine

func (u *Unit) AssignToNewMachine() (err error)

AssignToNewMachine assigns the unit to a new machine, with constraints determined according to the service and environment constraints at the time of unit creation.

func (*Unit) AssignToNewMachineOrContainer

func (u *Unit) AssignToNewMachineOrContainer() (err error)

AssignToNewMachineOrContainer assigns the unit to a new machine, with constraints determined according to the service and environment constraints at the time of unit creation. If a container is required, a clean, empty machine instance is required on which to create the container. An existing clean, empty instance is first searched for, and if not found, a new one is created.

func (*Unit) AssignedMachineId

func (u *Unit) AssignedMachineId() (id string, err error)

AssignedMachineId returns the id of the assigned machine.

func (*Unit) AvailabilityZone

func (u *Unit) AvailabilityZone() (string, error)

AvailabilityZone returns the name of the availability zone into which the unit's machine instance was provisioned.

func (*Unit) CancelAction

func (u *Unit) CancelAction(action *Action) (*Action, error)

CancelAction removes a pending Action from the queue for this ActionReceiver and marks it as cancelled.

func (*Unit) CharmURL

func (u *Unit) CharmURL() (*charm.URL, bool)

CharmURL returns the charm URL this unit is currently using.

func (*Unit) ClearResolved

func (u *Unit) ClearResolved() error

ClearResolved removes any resolved setting on the unit.

func (*Unit) ClosePort

func (u *Unit) ClosePort(protocol string, number int) error

ClosePort closes the given port and protocol for the unit.

func (*Unit) ClosePorts

func (u *Unit) ClosePorts(protocol string, fromPort, toPort int) (err error)

ClosePorts closes the given port range and protocol for the unit.

func (*Unit) CompletedActions

func (u *Unit) CompletedActions() ([]*Action, error)

CompletedActions returns a list of actions that have finished for this unit.

func (*Unit) ConfigSettings

func (u *Unit) ConfigSettings() (charm.Settings, error)

ConfigSettings returns the complete set of service charm config settings available to the unit. Unset values will be replaced with the default value for the associated option, and may thus be nil when no default is specified.

func (*Unit) Constraints

func (u *Unit) Constraints() (*constraints.Value, error)

Constraints returns the unit's deployment constraints.

func (*Unit) DeployerTag

func (u *Unit) DeployerTag() (names.Tag, bool)

DeployerTag returns the tag of the agent responsible for deploying the unit. If no such entity can be determined, false is returned.

func (*Unit) Destroy

func (u *Unit) Destroy() (err error)

Destroy, when called on a Alive unit, advances its lifecycle as far as possible; it otherwise has no effect. In most situations, the unit's life is just set to Dying; but if a principal unit that is not assigned to a provisioned machine is Destroyed, it will be removed from state directly.

func (*Unit) EnsureDead

func (u *Unit) EnsureDead() (err error)

EnsureDead sets the unit lifecycle to Dead if it is Alive or Dying. It does nothing otherwise. If the unit has subordinates, it will return ErrUnitHasSubordinates; otherwise, if it has storage instances, it will return ErrUnitHasStorageInstances.

func (*Unit) GetMeterStatus

func (u *Unit) GetMeterStatus() (code, info string, err error)

GetMeterStatus returns the meter status for the unit.

func (*Unit) IsPrincipal

func (u *Unit) IsPrincipal() bool

IsPrincipal returns whether the unit is deployed in its own container, and can therefore have subordinate services deployed alongside it.

func (*Unit) Life

func (u *Unit) Life() Life

Life returns whether the unit is Alive, Dying or Dead.

func (*Unit) Name

func (u *Unit) Name() string

Name returns the unit name.

func (*Unit) OpenPort

func (u *Unit) OpenPort(protocol string, number int) error

OpenPort opens the given port and protocol for the unit.

func (*Unit) OpenPorts

func (u *Unit) OpenPorts(protocol string, fromPort, toPort int) (err error)

OpenPorts opens the given port range and protocol for the unit, if it does not conflict with another already opened range on the unit's assigned machine.

func (*Unit) OpenedPorts

func (u *Unit) OpenedPorts() ([]network.PortRange, error)

OpenedPorts returns a slice containing the open port ranges of the unit.

func (*Unit) PasswordValid

func (u *Unit) PasswordValid(password string) bool

PasswordValid returns whether the given password is valid for the given unit.

func (*Unit) PendingActions

func (u *Unit) PendingActions() ([]*Action, error)

PendingActions returns a list of actions pending for this unit.

func (*Unit) PrincipalName

func (u *Unit) PrincipalName() (string, bool)

PrincipalName returns the name of the unit's principal. If the unit is not a subordinate, false is returned.

func (*Unit) PrivateAddress

func (u *Unit) PrivateAddress() (string, bool)

PrivateAddress returns the private address of the unit and whether it is valid.

func (*Unit) PublicAddress

func (u *Unit) PublicAddress() (string, bool)

PublicAddress returns the public address of the unit and whether it is valid.

func (*Unit) Refresh

func (u *Unit) Refresh() error

Refresh refreshes the contents of the Unit from the underlying state. It an error that satisfies errors.IsNotFound if the unit has been removed.

func (*Unit) RelationsInScope

func (u *Unit) RelationsInScope() ([]*Relation, error)

RelationsInScope returns the relations for which the unit has entered scope and not left it.

func (*Unit) RelationsJoined

func (u *Unit) RelationsJoined() ([]*Relation, error)

RelationsJoined returns the relations for which the unit has entered scope and neither left it nor prepared to leave it

func (*Unit) Remove

func (u *Unit) Remove() (err error)

Remove removes the unit from state, and may remove its service as well, if the service is Dying and no other references to it exist. It will fail if the unit is not Dead.

func (*Unit) Resolve

func (u *Unit) Resolve(retryHooks bool) error

Resolve marks the unit as having had any previous state transition problems resolved, and informs the unit that it may attempt to reestablish normal workflow. The retryHooks parameter informs whether to attempt to reexecute previous failed hooks or to continue as if they had succeeded before.

func (*Unit) Resolved

func (u *Unit) Resolved() ResolvedMode

Resolved returns the resolved mode for the unit.

func (*Unit) RunningActions

func (u *Unit) RunningActions() ([]*Action, error)

RunningActions returns a list of actions running on this unit.

func (*Unit) Series

func (u *Unit) Series() string

Series returns the deployed charm's series.

func (*Unit) Service

func (u *Unit) Service() (*Service, error)

Service returns the service.

func (*Unit) ServiceName

func (u *Unit) ServiceName() string

ServiceName returns the service name.

func (*Unit) SetAgentPresence

func (u *Unit) SetAgentPresence() (*presence.Pinger, error)

SetAgentPresence signals that the agent for unit u is alive. It returns the started pinger.

func (*Unit) SetAgentVersion

func (u *Unit) SetAgentVersion(v version.Binary) (err error)

SetAgentVersion sets the version of juju that the agent is currently running.

func (*Unit) SetCharmURL

func (u *Unit) SetCharmURL(curl *charm.URL) error

SetCharmURL marks the unit as currently using the supplied charm URL. An error will be returned if the unit is dead, or the charm URL not known.

func (*Unit) SetMeterStatus

func (u *Unit) SetMeterStatus(codeRaw, info string) error

SetMeterStatus sets the meter status for the unit.

func (*Unit) SetPassword

func (u *Unit) SetPassword(password string) error

SetPassword sets the password for the machine's agent.

func (*Unit) SetResolved

func (u *Unit) SetResolved(mode ResolvedMode) (err error)

SetResolved marks the unit as having had any previous state transition problems resolved, and informs the unit that it may attempt to reestablish normal workflow. The resolved mode parameter informs whether to attempt to reexecute previous failed hooks or to continue as if they had succeeded before.

func (*Unit) SetStatus

func (u *Unit) SetStatus(status Status, info string, data map[string]interface{}) error

SetStatus sets the status of the unit agent. The optional values allow to pass additional helpful status data.

func (*Unit) Status

func (u *Unit) Status() (status Status, info string, data map[string]interface{}, err error)

Status returns the status of the unit.

func (*Unit) StorageConstraints

func (u *Unit) StorageConstraints() (map[string]StorageConstraints, error)

StorageConstraints returns the unit's storage constraints.

func (*Unit) StorageInstanceIds

func (u *Unit) StorageInstanceIds() []string

StorageInstanceIds returns the IDs of any storage instances owned by the unit.

func (*Unit) StorageInstances

func (u *Unit) StorageInstances() ([]StorageInstance, error)

StorageInstances returns the storage instances owned by this unit.

func (*Unit) String

func (u *Unit) String() string

String returns the unit as string.

func (*Unit) SubordinateNames

func (u *Unit) SubordinateNames() []string

SubordinateNames returns the names of any subordinate units.

func (*Unit) Tag

func (u *Unit) Tag() names.Tag

Tag returns a name identifying the unit. The returned name will be different from other Tag values returned by any other entities from the same state.

func (*Unit) UnassignFromMachine

func (u *Unit) UnassignFromMachine() (err error)

UnassignFromMachine removes the assignment between this unit and the machine it's assigned to.

func (*Unit) UnitTag

func (u *Unit) UnitTag() names.UnitTag

UnitTag returns a names.UnitTag representing this Unit, unless the unit Name is invalid, in which case it will panic

func (*Unit) WaitAgentPresence

func (u *Unit) WaitAgentPresence(timeout time.Duration) (err error)

WaitAgentPresence blocks until the respective agent is alive.

func (*Unit) Watch

func (u *Unit) Watch() NotifyWatcher

Watch returns a watcher for observing changes to a unit.

func (*Unit) WatchActionNotifications

func (u *Unit) WatchActionNotifications() StringsWatcher

WatchActionNotifications starts and returns a StringsWatcher that notifies when actions with Id prefixes matching this Unit are added

func (*Unit) WatchConfigSettings

func (u *Unit) WatchConfigSettings() (NotifyWatcher, error)

WatchConfigSettings returns a watcher for observing changes to the unit's service configuration settings. The unit must have a charm URL set before this method is called, and the returned watcher will be valid only while the unit's charm URL is not changed. TODO(fwereade): this could be much smarter; if it were, uniter.Filter could be somewhat simpler.

func (*Unit) WatchMeterStatus

func (u *Unit) WatchMeterStatus() NotifyWatcher

WatchMeterStatus returns a watcher observing the changes to the unit's meter status.

func (*Unit) WatchSubordinateUnits

func (u *Unit) WatchSubordinateUnits() StringsWatcher

WatchSubordinateUnits returns a StringsWatcher tracking the unit's subordinate units.

type UnitsWatcher

type UnitsWatcher interface {
	Entity
	WatchUnits() StringsWatcher
}

UnitsWatcher defines the methods needed to retrieve an entity (a machine or a service) and watch its units.

type UpgradeInfo

type UpgradeInfo struct {
	// contains filtered or unexported fields
}

UpgradeInfo is used to synchronise state server upgrades.

func (*UpgradeInfo) Abort

func (info *UpgradeInfo) Abort() error

Abort marks the current upgrade as aborted. It should be called if the upgrade can't be completed for some reason.

func (*UpgradeInfo) AllProvisionedStateServersReady

func (info *UpgradeInfo) AllProvisionedStateServersReady() (bool, error)

AllProvisionedStateServersReady returns true if and only if all state servers that have been started by the provisioner have called EnsureUpgradeInfo with matching versions.

When this returns true the master state state server can begin it's own upgrade.

func (*UpgradeInfo) PreviousVersion

func (info *UpgradeInfo) PreviousVersion() version.Number

PreviousVersion returns the version being upgraded from.

func (*UpgradeInfo) Refresh

func (info *UpgradeInfo) Refresh() error

Refresh updates the contents of the UpgradeInfo from underlying state.

func (*UpgradeInfo) SetStateServerDone

func (info *UpgradeInfo) SetStateServerDone(machineId string) error

SetStateServerDone marks the supplied state machineId as having completed its upgrades. When SetStateServerDone is called by the last provisioned state server, the current upgrade info document will be archived with a status of UpgradeComplete.

func (*UpgradeInfo) SetStatus

func (info *UpgradeInfo) SetStatus(status UpgradeStatus) error

SetStatus sets the status of the current upgrade. Checks are made to ensure that status changes are performed in the correct order.

func (*UpgradeInfo) Started

func (info *UpgradeInfo) Started() time.Time

Started returns the time at which the upgrade was started.

func (*UpgradeInfo) StateServersDone

func (info *UpgradeInfo) StateServersDone() []string

StateServersDone returns the machine ids for state servers that have completed their upgrades.

func (*UpgradeInfo) StateServersReady

func (info *UpgradeInfo) StateServersReady() []string

StateServersReady returns the machine ids for state servers that have signalled that they are ready for upgrade.

func (*UpgradeInfo) Status

func (info *UpgradeInfo) Status() UpgradeStatus

Status returns the status of the upgrade.

func (*UpgradeInfo) TargetVersion

func (info *UpgradeInfo) TargetVersion() version.Number

TargetVersion returns the version being upgraded to.

func (*UpgradeInfo) Watch

func (info *UpgradeInfo) Watch() NotifyWatcher

Watcher returns a watcher for the state underlying the current UpgradeInfo instance. This is provided purely for convenience.

type UpgradeStatus

type UpgradeStatus string

UpgradeStatus describes the states an upgrade operation may be in.

const (
	// UpgradePending indicates that an upgrade is queued but not yet started.
	UpgradePending UpgradeStatus = "pending"

	// UpgradeRunning indicates that the master state server has started
	// running upgrade logic, and other state servers are waiting for it.
	UpgradeRunning UpgradeStatus = "running"

	// UpgradeFinishing indicates that the master state server has finished
	// running upgrade logic, and other state servers are catching up.
	UpgradeFinishing UpgradeStatus = "finishing"

	// UpgradeComplete indicates that all state servers have finished running
	// upgrade logic.
	UpgradeComplete UpgradeStatus = "complete"

	// UpgradeAborted indicates that the upgrade wasn't completed due
	// to some problem.
	UpgradeAborted UpgradeStatus = "aborted"
)

type User

type User struct {
	// contains filtered or unexported fields
}

User represents a local user in the database.

func (*User) CreatedBy

func (u *User) CreatedBy() string

CreatedBy returns the name of the User that created this User.

func (*User) DateCreated

func (u *User) DateCreated() time.Time

DateCreated returns when this User was created in UTC.

func (*User) Disable

func (u *User) Disable() error

Disable deactivates the user. Disabled identities cannot log in.

func (*User) DisplayName

func (u *User) DisplayName() string

DisplayName returns the display name of the User.

func (*User) Enable

func (u *User) Enable() error

Enable reactivates the user, setting disabled to false.

func (*User) IsDisabled

func (u *User) IsDisabled() bool

IsDisabled returns whether the user is currently enabled.

func (*User) LastLogin

func (u *User) LastLogin() *time.Time

LastLogin returns when this User last connected through the API in UTC. The resulting time will be nil if the user has never logged in. In the normal case, the LastLogin is the last time that the user connected through the API server.

func (*User) Name

func (u *User) Name() string

Name returns the User name.

func (*User) PasswordValid

func (u *User) PasswordValid(password string) bool

PasswordValid returns whether the given password is valid for the User.

func (*User) Refresh

func (u *User) Refresh() error

Refresh refreshes information about the User from the state.

func (*User) SetPassword

func (u *User) SetPassword(password string) error

SetPassword sets the password associated with the User.

func (*User) SetPasswordHash

func (u *User) SetPasswordHash(pwHash string, pwSalt string) error

SetPasswordHash stores the hash and the salt of the password.

func (*User) String

func (u *User) String() string

String returns "<name>@local" where <name> is the Name of the user.

func (*User) Tag

func (u *User) Tag() names.Tag

Tag returns the Tag for the User.

func (*User) UpdateLastLogin

func (u *User) UpdateLastLogin() error

UpdateLastLogin sets the LastLogin time of the user to be now (to the nearest second).

func (*User) UserTag

func (u *User) UserTag() names.UserTag

UserTag returns the Tag for the User.

type ValidateConfigFunc

type ValidateConfigFunc func(updateAttrs map[string]interface{}, removeAttrs []string, oldConfig *config.Config) error

type Watcher

type Watcher interface {
	// Kill asks the watcher to stop without waiting for it do so.
	Kill()
	// Wait waits for the watcher to die and returns any
	// error encountered when it was running.
	Wait() error
	// Stop kills the watcher, then waits for it to die.
	Stop() error
	// Err returns any error encountered while the watcher
	// has been running.
	Err() error
}

Watcher is implemented by all watchers; the actual changes channel is returned by a watcher-specific Changes method.

Directories

Path Synopsis
Package backups contains all the stand-alone backup-related functionality for juju state.
Package backups contains all the stand-alone backup-related functionality for juju state.
The presence package implements an interface for observing liveness of arbitrary keys (agents, processes, etc) on top of MongoDB.
The presence package implements an interface for observing liveness of arbitrary keys (agents, processes, etc) on top of MongoDB.
The watcher package provides an interface for observing changes to arbitrary MongoDB documents that are maintained via the mgo/txn transaction package.
The watcher package provides an interface for observing changes to arbitrary MongoDB documents that are maintained via the mgo/txn transaction package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL