storageprovisioner

package
v0.0.0-...-b0bff92 Latest Latest
Warning

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

 Go to latest Published: Dec 7, 2021 License: AGPL-3.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewStateBackends 

func NewStateBackends(st *state.State) (Backend, StorageBackend, error)

NewStateBackends creates a Backend from the given *state.State.

Types

type Backend 

type Backend interface {
	state.EntityFinder
	state.ModelAccessor

	ControllerConfig() (controller.Config, error)
	MachineInstanceId(names.MachineTag) (instance.Id, error)
	ModelTag() names.ModelTag
	WatchMachine(names.MachineTag) (state.NotifyWatcher, error)
	WatchApplications() state.StringsWatcher
}

type StorageBackend 

type StorageBackend interface {
	BlockDevices(names.MachineTag) ([]state.BlockDeviceInfo, error)

	WatchBlockDevices(names.MachineTag) state.NotifyWatcher
	WatchModelFilesystems() state.StringsWatcher
	WatchModelFilesystemAttachments() state.StringsWatcher
	WatchMachineFilesystems(names.MachineTag) state.StringsWatcher
	WatchUnitFilesystems(tag names.ApplicationTag) state.StringsWatcher
	WatchMachineFilesystemAttachments(names.MachineTag) state.StringsWatcher
	WatchUnitFilesystemAttachments(tag names.ApplicationTag) state.StringsWatcher
	WatchModelVolumes() state.StringsWatcher
	WatchModelVolumeAttachments() state.StringsWatcher
	WatchMachineVolumes(names.MachineTag) state.StringsWatcher
	WatchMachineVolumeAttachments(names.MachineTag) state.StringsWatcher
	WatchUnitVolumeAttachments(tag names.ApplicationTag) state.StringsWatcher
	WatchVolumeAttachment(names.Tag, names.VolumeTag) state.NotifyWatcher
	WatchMachineAttachmentsPlans(names.MachineTag) state.StringsWatcher

	StorageInstance(names.StorageTag) (state.StorageInstance, error)
	AllStorageInstances() ([]state.StorageInstance, error)
	StorageInstanceVolume(names.StorageTag) (state.Volume, error)
	StorageInstanceFilesystem(names.StorageTag) (state.Filesystem, error)
	ReleaseStorageInstance(names.StorageTag, bool, bool, time.Duration) error
	DetachStorage(names.StorageTag, names.UnitTag, bool, time.Duration) error

	Filesystem(names.FilesystemTag) (state.Filesystem, error)
	FilesystemAttachment(names.Tag, names.FilesystemTag) (state.FilesystemAttachment, error)

	Volume(names.VolumeTag) (state.Volume, error)
	VolumeAttachment(names.Tag, names.VolumeTag) (state.VolumeAttachment, error)
	VolumeAttachments(names.VolumeTag) ([]state.VolumeAttachment, error)
	VolumeAttachmentPlan(names.Tag, names.VolumeTag) (state.VolumeAttachmentPlan, error)
	VolumeAttachmentPlans(volume names.VolumeTag) ([]state.VolumeAttachmentPlan, error)

	RemoveFilesystem(names.FilesystemTag) error
	RemoveFilesystemAttachment(names.Tag, names.FilesystemTag, bool) error
	RemoveVolume(names.VolumeTag) error
	RemoveVolumeAttachment(names.Tag, names.VolumeTag, bool) error
	DetachFilesystem(names.Tag, names.FilesystemTag) error
	DestroyFilesystem(names.FilesystemTag, bool) error
	DetachVolume(names.Tag, names.VolumeTag, bool) error
	DestroyVolume(names.VolumeTag, bool) error

	SetFilesystemInfo(names.FilesystemTag, state.FilesystemInfo) error
	SetFilesystemAttachmentInfo(names.Tag, names.FilesystemTag, state.FilesystemAttachmentInfo) error
	SetVolumeInfo(names.VolumeTag, state.VolumeInfo) error
	SetVolumeAttachmentInfo(names.Tag, names.VolumeTag, state.VolumeAttachmentInfo) error

	CreateVolumeAttachmentPlan(names.Tag, names.VolumeTag, state.VolumeAttachmentPlanInfo) error
	RemoveVolumeAttachmentPlan(names.Tag, names.VolumeTag, bool) error
	SetVolumeAttachmentPlanBlockInfo(machineTag names.Tag, volumeTag names.VolumeTag, info state.BlockDeviceInfo) error
}

type StorageProvisionerAPIv4 

type StorageProvisionerAPIv4 struct {
	*common.LifeGetter
	*common.DeadEnsurer
	*common.InstanceIdGetter
	*common.StatusSetter
	// contains filtered or unexported fields
}

StorageProvisionerAPIv4 provides the StorageProvisioner API v4 facade.

func NewFacadeV4 

func NewFacadeV4(ctx facade.Context) (*StorageProvisionerAPIv4, error)

NewFacadeV4 provides the signature required for facade registration.

func NewStorageProvisionerAPIv4 

func NewStorageProvisionerAPIv4(
	st Backend,
	sb StorageBackend,
	resources facade.Resources,
	authorizer facade.Authorizer,
	registry storage.ProviderRegistry,
	poolManager poolmanager.PoolManager,
) (*StorageProvisionerAPIv4, error)

NewStorageProvisionerAPIv4 creates a new server-side StorageProvisioner v3 facade.

func (*StorageProvisionerAPIv4) AttachmentLife 

func (s *StorageProvisionerAPIv4) AttachmentLife(args params.MachineStorageIds) (params.LifeResults, error)

AttachmentLife returns the lifecycle state of each specified machine storage attachment.

func (*StorageProvisionerAPIv4) CreateVolumeAttachmentPlans 

func (s *StorageProvisionerAPIv4) CreateVolumeAttachmentPlans(args params.VolumeAttachmentPlans) (params.ErrorResults, error)

func (*StorageProvisionerAPIv4) FilesystemAttachmentParams 

func (s *StorageProvisionerAPIv4) FilesystemAttachmentParams(
	args params.MachineStorageIds,
) (params.FilesystemAttachmentParamsResults, error)

FilesystemAttachmentParams returns the parameters for creating the filesystem attachments with the specified IDs.

func (*StorageProvisionerAPIv4) FilesystemAttachments 

func (s *StorageProvisionerAPIv4) FilesystemAttachments(args params.MachineStorageIds) (params.FilesystemAttachmentResults, error)

FilesystemAttachments returns details of filesystem attachments with the specified IDs.

func (*StorageProvisionerAPIv4) FilesystemParams 

func (s *StorageProvisionerAPIv4) FilesystemParams(args params.Entities) (params.FilesystemParamsResults, error)

FilesystemParams returns the parameters for creating the filesystems with the specified tags.

func (*StorageProvisionerAPIv4) Filesystems 

func (s *StorageProvisionerAPIv4) Filesystems(args params.Entities) (params.FilesystemResults, error)

Filesystems returns details of filesystems with the specified tags.

func (*StorageProvisionerAPIv4) Remove 

func (s *StorageProvisionerAPIv4) Remove(args params.Entities) (params.ErrorResults, error)

Remove removes volumes and filesystems from state.

func (*StorageProvisionerAPIv4) RemoveAttachment 

func (s *StorageProvisionerAPIv4) RemoveAttachment(args params.MachineStorageIds) (params.ErrorResults, error)

RemoveAttachment removes the specified machine storage attachments from state.

func (*StorageProvisionerAPIv4) RemoveFilesystemParams 

func (s *StorageProvisionerAPIv4) RemoveFilesystemParams(args params.Entities) (params.RemoveFilesystemParamsResults, error)

RemoveFilesystemParams returns the parameters for destroying or releasing the filesystems with the specified tags.

func (*StorageProvisionerAPIv4) RemoveVolumeAttachmentPlan 

func (s *StorageProvisionerAPIv4) RemoveVolumeAttachmentPlan(args params.MachineStorageIds) (params.ErrorResults, error)

func (*StorageProvisionerAPIv4) RemoveVolumeParams 

func (s *StorageProvisionerAPIv4) RemoveVolumeParams(args params.Entities) (params.RemoveVolumeParamsResults, error)

RemoveVolumeParams returns the parameters for destroying or releasing the volumes with the specified tags.

func (*StorageProvisionerAPIv4) SetFilesystemAttachmentInfo 

func (s *StorageProvisionerAPIv4) SetFilesystemAttachmentInfo(
	args params.FilesystemAttachments,
) (params.ErrorResults, error)

SetFilesystemAttachmentInfo records the details of newly provisioned filesystem attachments.

func (*StorageProvisionerAPIv4) SetFilesystemInfo 

func (s *StorageProvisionerAPIv4) SetFilesystemInfo(args params.Filesystems) (params.ErrorResults, error)

SetFilesystemInfo records the details of newly provisioned filesystems.

func (*StorageProvisionerAPIv4) SetVolumeAttachmentInfo 

func (s *StorageProvisionerAPIv4) SetVolumeAttachmentInfo(
	args params.VolumeAttachments,
) (params.ErrorResults, error)

SetVolumeAttachmentInfo records the details of newly provisioned volume attachments.

func (*StorageProvisionerAPIv4) SetVolumeAttachmentPlanBlockInfo 

func (s *StorageProvisionerAPIv4) SetVolumeAttachmentPlanBlockInfo(args params.VolumeAttachmentPlans) (params.ErrorResults, error)

func (*StorageProvisionerAPIv4) SetVolumeInfo 

func (s *StorageProvisionerAPIv4) SetVolumeInfo(args params.Volumes) (params.ErrorResults, error)

SetVolumeInfo records the details of newly provisioned volumes.

func (*StorageProvisionerAPIv4) VolumeAttachmentParams 

func (s *StorageProvisionerAPIv4) VolumeAttachmentParams(
	args params.MachineStorageIds,
) (params.VolumeAttachmentParamsResults, error)

VolumeAttachmentParams returns the parameters for creating the volume attachments with the specified IDs.

func (*StorageProvisionerAPIv4) VolumeAttachmentPlans 

func (s *StorageProvisionerAPIv4) VolumeAttachmentPlans(args params.MachineStorageIds) (params.VolumeAttachmentPlanResults, error)

VolumeAttachmentPlans returns details of volume attachment plans with the specified IDs.

func (*StorageProvisionerAPIv4) VolumeAttachments 

func (s *StorageProvisionerAPIv4) VolumeAttachments(args params.MachineStorageIds) (params.VolumeAttachmentResults, error)

VolumeAttachments returns details of volume attachments with the specified IDs.

func (*StorageProvisionerAPIv4) VolumeBlockDevices 

func (s *StorageProvisionerAPIv4) VolumeBlockDevices(args params.MachineStorageIds) (params.BlockDeviceResults, error)

VolumeBlockDevices returns details of the block devices corresponding to the volume attachments with the specified IDs.

func (*StorageProvisionerAPIv4) VolumeParams 

func (s *StorageProvisionerAPIv4) VolumeParams(args params.Entities) (params.VolumeParamsResults, error)

VolumeParams returns the parameters for creating or destroying the volumes with the specified tags.

func (*StorageProvisionerAPIv4) Volumes 

func (s *StorageProvisionerAPIv4) Volumes(args params.Entities) (params.VolumeResults, error)

Volumes returns details of volumes with the specified tags.

func (*StorageProvisionerAPIv4) WatchApplications 

func (s *StorageProvisionerAPIv4) WatchApplications() (params.StringsWatchResult, error)

WatchApplications starts a StringsWatcher to watch CAAS applications deployed to this model.

func (*StorageProvisionerAPIv4) WatchBlockDevices 

func (s *StorageProvisionerAPIv4) WatchBlockDevices(args params.Entities) (params.NotifyWatchResults, error)

WatchBlockDevices watches for changes to the specified machines' block devices.

func (*StorageProvisionerAPIv4) WatchFilesystemAttachments 

func (s *StorageProvisionerAPIv4) WatchFilesystemAttachments(args params.Entities) (params.MachineStorageIdsWatchResults, error)

WatchFilesystemAttachments watches for changes to filesystem attachments scoped to the entity with the tag passed to NewState.

func (*StorageProvisionerAPIv4) WatchFilesystems 

func (s *StorageProvisionerAPIv4) WatchFilesystems(args params.Entities) (params.StringsWatchResults, error)

WatchFilesystems watches for changes to filesystems scoped to the entity with the tag passed to NewState.

func (*StorageProvisionerAPIv4) WatchMachines 

func (s *StorageProvisionerAPIv4) WatchMachines(args params.Entities) (params.NotifyWatchResults, error)

WatchMachines watches for changes to the specified machines.

func (*StorageProvisionerAPIv4) WatchVolumeAttachmentPlans 

func (s *StorageProvisionerAPIv4) WatchVolumeAttachmentPlans(args params.Entities) (params.MachineStorageIdsWatchResults, error)

WatchVolumeAttachmentPlans watches for changes to volume attachments for a machine for the purpose of allowing that machine to run any initialization needed, for that volume to actually appear as a block device (ie: iSCSI)

func (*StorageProvisionerAPIv4) WatchVolumeAttachments 

func (s *StorageProvisionerAPIv4) WatchVolumeAttachments(args params.Entities) (params.MachineStorageIdsWatchResults, error)

WatchVolumeAttachments watches for changes to volume attachments scoped to the entity with the tag passed to NewState.

func (*StorageProvisionerAPIv4) WatchVolumes 

func (s *StorageProvisionerAPIv4) WatchVolumes(args params.Entities) (params.StringsWatchResults, error)

WatchVolumes watches for changes to volumes scoped to the entity with the tag passed to NewState.

Source Files

View all Source files

Directories

Path Synopsis
internal
filesystemwatcher

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.