manager

package
v0.3.3-rc1 Latest Latest
Warning

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

 Go to latest Published: Jan 12, 2019 License: Apache-2.0 Imports: 17 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	WaitForEngineImageCount    = 20
	WaitForEngineImageInterval = 6 * time.Second
)

Functions

This section is empty.

Types

type VolumeManager 

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

func NewVolumeManager 

func NewVolumeManager(currentNodeID string, ds *datastore.DataStore) *VolumeManager

func (*VolumeManager) Attach 

func (m *VolumeManager) Attach(name, nodeID string) (v *longhorn.Volume, err error)

func (*VolumeManager) BackupSnapshot 

func (m *VolumeManager) BackupSnapshot(snapshotName string, labels map[string]string, volumeName string) error

func (*VolumeManager) CheckEngineImageReadiness 

func (m *VolumeManager) CheckEngineImageReadiness(image string) error

func (*VolumeManager) Create 

func (m *VolumeManager) Create(name string, spec *types.VolumeSpec) (v *longhorn.Volume, err error)

func (*VolumeManager) CreateEngineImage 

func (m *VolumeManager) CreateEngineImage(image string) (*longhorn.EngineImage, error)

func (*VolumeManager) CreateOrUpdateSetting 

func (m *VolumeManager) CreateOrUpdateSetting(s *longhorn.Setting) (*longhorn.Setting, error)

func (*VolumeManager) CreateSnapshot 

func (m *VolumeManager) CreateSnapshot(snapshotName string, labels map[string]string, volumeName string) (*engineapi.Snapshot, error)

func (*VolumeManager) Delete 

func (m *VolumeManager) Delete(name string) error

func (*VolumeManager) DeleteBackup 

func (m *VolumeManager) DeleteBackup(backupName, volumeName string) error

func (*VolumeManager) DeleteEngineImageByName 

func (m *VolumeManager) DeleteEngineImageByName(name string) error

func (*VolumeManager) DeleteNode added in v0.3.1 

func (m *VolumeManager) DeleteNode(name string) error

func (*VolumeManager) DeleteReplica 

func (m *VolumeManager) DeleteReplica(replicaName string) error

func (*VolumeManager) DeleteSnapshot 

func (m *VolumeManager) DeleteSnapshot(snapshotName, volumeName string) error

func (*VolumeManager) DeployAndWaitForEngineImage 

func (m *VolumeManager) DeployAndWaitForEngineImage(image string) error

func (*VolumeManager) Detach 

func (m *VolumeManager) Detach(name string) (v *longhorn.Volume, err error)

func (*VolumeManager) DiskUpdate 

func (m *VolumeManager) DiskUpdate(name string, updateDisks []types.DiskSpec) (*longhorn.Node, error)

func (*VolumeManager) EngineUpgrade 

func (m *VolumeManager) EngineUpgrade(volumeName, image string) (v *longhorn.Volume, err error)

func (*VolumeManager) Get 

func (m *VolumeManager) Get(vName string) (*longhorn.Volume, error)

func (*VolumeManager) GetBackup 

func (m *VolumeManager) GetBackup(backupName, volumeName string) (*engineapi.Backup, error)

func (*VolumeManager) GetBackupVolume 

func (m *VolumeManager) GetBackupVolume(volumeName string) (*engineapi.BackupVolume, error)

func (*VolumeManager) GetCurrentNodeID 

func (m *VolumeManager) GetCurrentNodeID() string

func (*VolumeManager) GetEngineClient 

func (m *VolumeManager) GetEngineClient(volumeName string) (client engineapi.EngineClient, err error)

func (*VolumeManager) GetEngineImage 

func (m *VolumeManager) GetEngineImage(image string) (*longhorn.EngineImage, error)

func (*VolumeManager) GetEngineImageByName 

func (m *VolumeManager) GetEngineImageByName(name string) (*longhorn.EngineImage, error)

func (*VolumeManager) GetEngines 

func (m *VolumeManager) GetEngines(vName string) (map[string]*longhorn.Engine, error)

func (*VolumeManager) GetEnginesSorted 

func (m *VolumeManager) GetEnginesSorted(vName string) ([]*longhorn.Engine, error)

func (*VolumeManager) GetManagerNodeIPMap 

func (m *VolumeManager) GetManagerNodeIPMap() (map[string]string, error)

func (*VolumeManager) GetNode 

func (m *VolumeManager) GetNode(name string) (*longhorn.Node, error)

func (*VolumeManager) GetReplicas 

func (m *VolumeManager) GetReplicas(vName string) (map[string]*longhorn.Replica, error)

func (*VolumeManager) GetReplicasSorted 

func (m *VolumeManager) GetReplicasSorted(vName string) ([]*longhorn.Replica, error)

func (*VolumeManager) GetSetting 

func (m *VolumeManager) GetSetting(sName types.SettingName) (*longhorn.Setting, error)

func (*VolumeManager) GetSettingValueExisted 

func (m *VolumeManager) GetSettingValueExisted(sName types.SettingName) (string, error)

func (*VolumeManager) GetSnapshot 

func (m *VolumeManager) GetSnapshot(snapshotName, volumeName string) (*engineapi.Snapshot, error)

func (*VolumeManager) List 

func (m *VolumeManager) List() (map[string]*longhorn.Volume, error)

func (*VolumeManager) ListBackupVolumes 

func (m *VolumeManager) ListBackupVolumes() ([]*engineapi.BackupVolume, error)

func (*VolumeManager) ListBackupsForVolume 

func (m *VolumeManager) ListBackupsForVolume(volumeName string) ([]*engineapi.Backup, error)

func (*VolumeManager) ListEngineImagesByName 

func (m *VolumeManager) ListEngineImagesByName() (map[string]*longhorn.EngineImage, error)

func (*VolumeManager) ListEngineImagesSorted 

func (m *VolumeManager) ListEngineImagesSorted() ([]*longhorn.EngineImage, error)

func (*VolumeManager) ListEvent 

func (m *VolumeManager) ListEvent() ([]*v1.Event, error)

func (*VolumeManager) ListNodes 

func (m *VolumeManager) ListNodes() (map[string]*longhorn.Node, error)

func (*VolumeManager) ListNodesSorted 

func (m *VolumeManager) ListNodesSorted() ([]*longhorn.Node, error)

func (*VolumeManager) ListSettings 

func (m *VolumeManager) ListSettings() (map[types.SettingName]*longhorn.Setting, error)

func (*VolumeManager) ListSettingsSorted 

func (m *VolumeManager) ListSettingsSorted() ([]*longhorn.Setting, error)

func (*VolumeManager) ListSnapshots 

func (m *VolumeManager) ListSnapshots(volumeName string) (map[string]*engineapi.Snapshot, error)

func (*VolumeManager) ListSorted 

func (m *VolumeManager) ListSorted() ([]*longhorn.Volume, error)

func (*VolumeManager) MigrationConfirm 

func (m *VolumeManager) MigrationConfirm(name string) (v *longhorn.Volume, err error)

func (*VolumeManager) MigrationRollback 

func (m *VolumeManager) MigrationRollback(name string) (v *longhorn.Volume, err error)

func (*VolumeManager) MigrationStart 

func (m *VolumeManager) MigrationStart(name, nodeID string) (v *longhorn.Volume, err error)

func (*VolumeManager) Node2APIAddress 

func (m *VolumeManager) Node2APIAddress(nodeID string) (string, error)

func (*VolumeManager) PurgeSnapshot 

func (m *VolumeManager) PurgeSnapshot(volumeName string) error

func (*VolumeManager) RevertSnapshot 

func (m *VolumeManager) RevertSnapshot(snapshotName, volumeName string) error

func (*VolumeManager) Salvage 

func (m *VolumeManager) Salvage(volumeName string, replicaNames []string) (v *longhorn.Volume, err error)

func (*VolumeManager) SettingValidation 

func (m *VolumeManager) SettingValidation(name, value string) (err error)

func (*VolumeManager) UpdateNode 

func (m *VolumeManager) UpdateNode(name string, allowScheduling bool) (*longhorn.Node, error)

func (*VolumeManager) UpdateRecurringJobs 

func (m *VolumeManager) UpdateRecurringJobs(volumeName string, jobs []types.RecurringJob) (v *longhorn.Volume, err error)

func (*VolumeManager) UpdateReplicaCount added in v0.3.3 

func (m *VolumeManager) UpdateReplicaCount(name string, count int) (v *longhorn.Volume, err error)

func (*VolumeManager) WaitForEngineImage 

func (m *VolumeManager) WaitForEngineImage(image string) error

Source Files

View all Source files

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.