Versions in this module Expand all Collapse all v0 v0.0.2 Nov 10, 2022 v0.0.1 Feb 21, 2020 Changes in this version + const BackendSecretSource + const KeyExistsErr + const KeyNotFoundErr + const NotSupported + const UnavailableClusterErr + var ErrKeyNotFound = errors.New("etcdserver: key not found") + func IsStatusError(err error) bool + func IsStatusNotFoundError(err error) bool + func MatchKeyNotFoundErr(err error) bool + func MatchUnavailableClusterErr(err error) bool + type CRDClient interface + AddStorageClassPersistent func(b *storageclass.Persistent) error + HasBackends func() (bool, error) + HasStorageClasses func() (bool, error) + HasVolumeTransactions func() (bool, error) + HasVolumes func() (bool, error) + type CRDClientV1 struct + func NewCRDClientV1(apiServerIP, kubeConfigPath string) (*CRDClientV1, error) + func NewCRDClientV1InCluster() (*CRDClientV1, error) + func (k *CRDClientV1) AddBackend(backend *storage.Backend) error + func (k *CRDClientV1) AddBackendPersistent(backendPersistent *storage.BackendPersistent) error + func (k *CRDClientV1) AddOrUpdateNode(node *utils.Node) error + func (k *CRDClientV1) AddSnapshot(snapshot *storage.Snapshot) error + func (k *CRDClientV1) AddStorageClass(sc *storageclass.StorageClass) error + func (k *CRDClientV1) AddStorageClassPersistent(scp *storageclass.Persistent) error + func (k *CRDClientV1) AddVolume(volume *storage.Volume) error + func (k *CRDClientV1) AddVolumePersistent(volume *storage.VolumeExternal) error + func (k *CRDClientV1) AddVolumeTransaction(txn *storage.VolumeTransaction) error + func (k *CRDClientV1) DeleteBackend(b *storage.Backend) error + func (k *CRDClientV1) DeleteBackends() error + func (k *CRDClientV1) DeleteNode(n *utils.Node) error + func (k *CRDClientV1) DeleteSnapshot(snapshot *storage.Snapshot) error + func (k *CRDClientV1) DeleteSnapshotIgnoreNotFound(snapshot *storage.Snapshot) error + func (k *CRDClientV1) DeleteSnapshots() error + func (k *CRDClientV1) DeleteStorageClass(sc *storageclass.StorageClass) error + func (k *CRDClientV1) DeleteVolume(volume *storage.Volume) error + func (k *CRDClientV1) DeleteVolumeIgnoreNotFound(volume *storage.Volume) error + func (k *CRDClientV1) DeleteVolumeTransaction(volTxn *storage.VolumeTransaction) error + func (k *CRDClientV1) DeleteVolumes() error + func (k *CRDClientV1) GetBackend(backendName string) (*storage.BackendPersistent, error) + func (k *CRDClientV1) GetBackends() ([]*storage.BackendPersistent, error) + func (k *CRDClientV1) GetConfig() *ClientConfig + func (k *CRDClientV1) GetExistingVolumeTransaction(volTxn *storage.VolumeTransaction) (*storage.VolumeTransaction, error) + func (k *CRDClientV1) GetNode(nName string) (*utils.Node, error) + func (k *CRDClientV1) GetNodes() ([]*utils.Node, error) + func (k *CRDClientV1) GetSnapshot(volumeName, snapshotName string) (*storage.SnapshotPersistent, error) + func (k *CRDClientV1) GetSnapshots() ([]*storage.SnapshotPersistent, error) + func (k *CRDClientV1) GetStorageClass(scName string) (*storageclass.Persistent, error) + func (k *CRDClientV1) GetStorageClasses() ([]*storageclass.Persistent, error) + func (k *CRDClientV1) GetType() StoreType + func (k *CRDClientV1) GetVersion() (*config.PersistentStateVersion, error) + func (k *CRDClientV1) GetVolume(volName string) (*storage.VolumeExternal, error) + func (k *CRDClientV1) GetVolumeTransactions() ([]*storage.VolumeTransaction, error) + func (k *CRDClientV1) GetVolumes() ([]*storage.VolumeExternal, error) + func (k *CRDClientV1) HasBackends() (bool, error) + func (k *CRDClientV1) HasStorageClasses() (bool, error) + func (k *CRDClientV1) HasVolumeTransactions() (bool, error) + func (k *CRDClientV1) HasVolumes() (bool, error) + func (k *CRDClientV1) ReplaceBackendAndUpdateVolumes(origBackend, newBackend *storage.Backend) error + func (k *CRDClientV1) SetVersion(version *config.PersistentStateVersion) error + func (k *CRDClientV1) Stop() error + func (k *CRDClientV1) UpdateBackend(update *storage.Backend) error + func (k *CRDClientV1) UpdateBackendPersistent(update *storage.BackendPersistent) error + func (k *CRDClientV1) UpdateVolume(update *storage.Volume) error + func (k *CRDClientV1) UpdateVolumePersistent(update *storage.VolumeExternal) error + type CRDDataMigrator struct + func NewCRDDataMigrator(etcdClient EtcdClient, crdClient CRDClient, dryRun bool, ...) *CRDDataMigrator + func (m *CRDDataMigrator) Run() error + func (m *CRDDataMigrator) RunPrechecks() error + type Client interface + AddBackend func(b *storage.Backend) error + AddBackendPersistent func(b *storage.BackendPersistent) error + AddOrUpdateNode func(n *utils.Node) error + AddSnapshot func(snapshot *storage.Snapshot) error + AddStorageClass func(sc *storageclass.StorageClass) error + AddVolume func(vol *storage.Volume) error + AddVolumePersistent func(vol *storage.VolumeExternal) error + AddVolumeTransaction func(volTxn *storage.VolumeTransaction) error + DeleteBackend func(backend *storage.Backend) error + DeleteBackends func() error + DeleteNode func(n *utils.Node) error + DeleteSnapshot func(snapshot *storage.Snapshot) error + DeleteSnapshotIgnoreNotFound func(snapshot *storage.Snapshot) error + DeleteSnapshots func() error + DeleteStorageClass func(sc *storageclass.StorageClass) error + DeleteVolume func(vol *storage.Volume) error + DeleteVolumeIgnoreNotFound func(vol *storage.Volume) error + DeleteVolumeTransaction func(volTxn *storage.VolumeTransaction) error + DeleteVolumes func() error + GetBackend func(backendName string) (*storage.BackendPersistent, error) + GetBackends func() ([]*storage.BackendPersistent, error) + GetConfig func() *ClientConfig + GetExistingVolumeTransaction func(volTxn *storage.VolumeTransaction) (*storage.VolumeTransaction, error) + GetNode func(nName string) (*utils.Node, error) + GetNodes func() ([]*utils.Node, error) + GetSnapshot func(volumeName, snapshotName string) (*storage.SnapshotPersistent, error) + GetSnapshots func() ([]*storage.SnapshotPersistent, error) + GetStorageClass func(scName string) (*storageclass.Persistent, error) + GetStorageClasses func() ([]*storageclass.Persistent, error) + GetType func() StoreType + GetVersion func() (*config.PersistentStateVersion, error) + GetVolume func(volName string) (*storage.VolumeExternal, error) + GetVolumeTransactions func() ([]*storage.VolumeTransaction, error) + GetVolumes func() ([]*storage.VolumeExternal, error) + ReplaceBackendAndUpdateVolumes func(origBackend, newBackend *storage.Backend) error + SetVersion func(version *config.PersistentStateVersion) error + Stop func() error + UpdateBackend func(b *storage.Backend) error + UpdateBackendPersistent func(b *storage.BackendPersistent) error + UpdateVolume func(vol *storage.Volume) error + UpdateVolumePersistent func(vol *storage.VolumeExternal) error + type ClientConfig struct + TLSConfig *tls.Config + type DataMigrator struct + DestClient Client + SourceClient Client + func NewDataMigrator(SourceClient, DestClient Client, dryRun bool) *DataMigrator + func (m *DataMigrator) Run() error + type Error struct + Key string + Message string + func NewPersistentStoreError(message, key string) *Error + func (e *Error) Error() string + type EtcdClient interface + Create func(key, value string) error + Delete func(key string) error + DeleteKeys func(keyPrefix string) error + Read func(key string) (string, error) + ReadKeys func(keyPrefix string) ([]string, error) + Set func(key, value string) error + Update func(key, value string) error + type EtcdClientV2 struct + func NewEtcdClientV2(endpoints string) (*EtcdClientV2, error) + func NewEtcdClientV2FromConfig(etcdConfig *ClientConfig) (*EtcdClientV2, error) + func (p *EtcdClientV2) AddBackend(b *storage.Backend) error + func (p *EtcdClientV2) AddBackendPersistent(backend *storage.BackendPersistent) error + func (p *EtcdClientV2) AddOrUpdateNode(n *utils.Node) error + func (p *EtcdClientV2) AddSnapshot(snapshot *storage.Snapshot) error + func (p *EtcdClientV2) AddStorageClass(sc *storageclass.StorageClass) error + func (p *EtcdClientV2) AddVolume(vol *storage.Volume) error + func (p *EtcdClientV2) AddVolumePersistent(volume *storage.VolumeExternal) error + func (p *EtcdClientV2) AddVolumeTransaction(volTxn *storage.VolumeTransaction) error + func (p *EtcdClientV2) Create(key, value string) error + func (p *EtcdClientV2) Delete(key string) error + func (p *EtcdClientV2) DeleteBackend(backend *storage.Backend) error + func (p *EtcdClientV2) DeleteBackends() error + func (p *EtcdClientV2) DeleteKeys(keyPrefix string) error + func (p *EtcdClientV2) DeleteNode(n *utils.Node) error + func (p *EtcdClientV2) DeleteSnapshot(snapshot *storage.Snapshot) error + func (p *EtcdClientV2) DeleteSnapshotIgnoreNotFound(snapshot *storage.Snapshot) error + func (p *EtcdClientV2) DeleteSnapshots() error + func (p *EtcdClientV2) DeleteStorageClass(sc *storageclass.StorageClass) error + func (p *EtcdClientV2) DeleteVolume(vol *storage.Volume) error + func (p *EtcdClientV2) DeleteVolumeIgnoreNotFound(vol *storage.Volume) error + func (p *EtcdClientV2) DeleteVolumeTransaction(volTxn *storage.VolumeTransaction) error + func (p *EtcdClientV2) DeleteVolumes() error + func (p *EtcdClientV2) GetBackend(backendName string) (*storage.BackendPersistent, error) + func (p *EtcdClientV2) GetBackends() ([]*storage.BackendPersistent, error) + func (p *EtcdClientV2) GetConfig() *ClientConfig + func (p *EtcdClientV2) GetExistingVolumeTransaction(volTxn *storage.VolumeTransaction) (*storage.VolumeTransaction, error) + func (p *EtcdClientV2) GetNode(nName string) (*utils.Node, error) + func (p *EtcdClientV2) GetNodes() ([]*utils.Node, error) + func (p *EtcdClientV2) GetSnapshot(volumeName, snapshotName string) (*storage.SnapshotPersistent, error) + func (p *EtcdClientV2) GetSnapshots() ([]*storage.SnapshotPersistent, error) + func (p *EtcdClientV2) GetStorageClass(scName string) (*storageclass.Persistent, error) + func (p *EtcdClientV2) GetStorageClasses() ([]*storageclass.Persistent, error) + func (p *EtcdClientV2) GetType() StoreType + func (p *EtcdClientV2) GetVersion() (*config.PersistentStateVersion, error) + func (p *EtcdClientV2) GetVolume(volName string) (*storage.VolumeExternal, error) + func (p *EtcdClientV2) GetVolumeTransactions() ([]*storage.VolumeTransaction, error) + func (p *EtcdClientV2) GetVolumes() ([]*storage.VolumeExternal, error) + func (p *EtcdClientV2) Read(key string) (string, error) + func (p *EtcdClientV2) ReadKeys(keyPrefix string) ([]string, error) + func (p *EtcdClientV2) ReplaceBackendAndUpdateVolumes(origBackend, newBackend *storage.Backend) error + func (p *EtcdClientV2) Set(key, value string) error + func (p *EtcdClientV2) SetVersion(version *config.PersistentStateVersion) error + func (p *EtcdClientV2) Stop() error + func (p *EtcdClientV2) Update(key, value string) error + func (p *EtcdClientV2) UpdateBackend(b *storage.Backend) error + func (p *EtcdClientV2) UpdateBackendPersistent(update *storage.BackendPersistent) error + func (p *EtcdClientV2) UpdateVolume(vol *storage.Volume) error + func (p *EtcdClientV2) UpdateVolumePersistent(volume *storage.VolumeExternal) error + type EtcdClientV3 struct + func NewEtcdClientV3(endpoints string) (*EtcdClientV3, error) + func NewEtcdClientV3FromConfig(etcdConfig *ClientConfig) (*EtcdClientV3, error) + func NewEtcdClientV3WithTLS(endpoints, etcdV3Cert, etcdV3CACert, etcdV3Key string) (*EtcdClientV3, error) + func (p *EtcdClientV3) AddBackend(b *storage.Backend) error + func (p *EtcdClientV3) AddBackendPersistent(backend *storage.BackendPersistent) error + func (p *EtcdClientV3) AddBackendSTM(s conc.STM, b *storage.Backend) error + func (p *EtcdClientV3) AddOrUpdateNode(n *utils.Node) error + func (p *EtcdClientV3) AddSnapshot(snapshot *storage.Snapshot) error + func (p *EtcdClientV3) AddStorageClass(sc *storageclass.StorageClass) error + func (p *EtcdClientV3) AddVolume(vol *storage.Volume) error + func (p *EtcdClientV3) AddVolumePersistent(volExternal *storage.VolumeExternal) error + func (p *EtcdClientV3) AddVolumeTransaction(volTxn *storage.VolumeTransaction) error + func (p *EtcdClientV3) Create(key, value string) error + func (p *EtcdClientV3) CreateSTM(s conc.STM, key, value string) error + func (p *EtcdClientV3) Delete(key string) error + func (p *EtcdClientV3) DeleteBackend(backend *storage.Backend) error + func (p *EtcdClientV3) DeleteBackendSTM(s conc.STM, backend *storage.Backend) error + func (p *EtcdClientV3) DeleteBackends() error + func (p *EtcdClientV3) DeleteKeys(keyPrefix string) error + func (p *EtcdClientV3) DeleteNode(n *utils.Node) error + func (p *EtcdClientV3) DeleteSTM(s conc.STM, key string) error + func (p *EtcdClientV3) DeleteSnapshot(snapshot *storage.Snapshot) error + func (p *EtcdClientV3) DeleteSnapshotIgnoreNotFound(snapshot *storage.Snapshot) error + func (p *EtcdClientV3) DeleteSnapshots() error + func (p *EtcdClientV3) DeleteStorageClass(sc *storageclass.StorageClass) error + func (p *EtcdClientV3) DeleteVolume(vol *storage.Volume) error + func (p *EtcdClientV3) DeleteVolumeIgnoreNotFound(vol *storage.Volume) error + func (p *EtcdClientV3) DeleteVolumeTransaction(volTxn *storage.VolumeTransaction) error + func (p *EtcdClientV3) DeleteVolumes() error + func (p *EtcdClientV3) GetBackend(backendName string) (*storage.BackendPersistent, error) + func (p *EtcdClientV3) GetBackends() ([]*storage.BackendPersistent, error) + func (p *EtcdClientV3) GetConfig() *ClientConfig + func (p *EtcdClientV3) GetExistingVolumeTransaction(volTxn *storage.VolumeTransaction) (*storage.VolumeTransaction, error) + func (p *EtcdClientV3) GetNode(nName string) (*utils.Node, error) + func (p *EtcdClientV3) GetNodes() ([]*utils.Node, error) + func (p *EtcdClientV3) GetSnapshot(volumeName, snapshotName string) (*storage.SnapshotPersistent, error) + func (p *EtcdClientV3) GetSnapshots() ([]*storage.SnapshotPersistent, error) + func (p *EtcdClientV3) GetStorageClass(scName string) (*storageclass.Persistent, error) + func (p *EtcdClientV3) GetStorageClasses() ([]*storageclass.Persistent, error) + func (p *EtcdClientV3) GetType() StoreType + func (p *EtcdClientV3) GetVersion() (*config.PersistentStateVersion, error) + func (p *EtcdClientV3) GetVolume(volName string) (*storage.VolumeExternal, error) + func (p *EtcdClientV3) GetVolumeSTM(s conc.STM, volName string) (*storage.VolumeExternal, error) + func (p *EtcdClientV3) GetVolumeTransactions() ([]*storage.VolumeTransaction, error) + func (p *EtcdClientV3) GetVolumes() ([]*storage.VolumeExternal, error) + func (p *EtcdClientV3) GetVolumesSTM(s conc.STM) ([]*storage.VolumeExternal, error) + func (p *EtcdClientV3) Read(key string) (string, error) + func (p *EtcdClientV3) ReadKeys(keyPrefix string) ([]string, error) + func (p *EtcdClientV3) ReadSTM(s conc.STM, key string) (string, error) + func (p *EtcdClientV3) ReplaceBackendAndUpdateVolumes(origBackend, newBackend *storage.Backend) error + func (p *EtcdClientV3) Set(key, value string) error + func (p *EtcdClientV3) SetSTM(s conc.STM, key, value string) error + func (p *EtcdClientV3) SetVersion(version *config.PersistentStateVersion) error + func (p *EtcdClientV3) Stop() error + func (p *EtcdClientV3) Update(key, value string) error + func (p *EtcdClientV3) UpdateBackend(b *storage.Backend) error + func (p *EtcdClientV3) UpdateBackendPersistent(backend *storage.BackendPersistent) error + func (p *EtcdClientV3) UpdateSTM(s conc.STM, key, value string) error + func (p *EtcdClientV3) UpdateVolume(vol *storage.Volume) error + func (p *EtcdClientV3) UpdateVolumePersistent(volExternal *storage.VolumeExternal) error + func (p *EtcdClientV3) UpdateVolumeSTM(s conc.STM, vol *storage.Volume) error + type EtcdDataMigrator struct + DestClient EtcdClient + SourceClient EtcdClient + func NewEtcdDataMigrator(SourceClient, DestClient EtcdClient) *EtcdDataMigrator + func (m *EtcdDataMigrator) Start(keyPrefix string, deleteSrc bool) error + func (m *EtcdDataMigrator) Stop() error + type EtcdDataTransformer struct + func NewEtcdDataTransformer(etcdClient Client, dryRun, shouldPersist bool) *EtcdDataTransformer + func (m *EtcdDataTransformer) Run() (*EtcdDataTransformerResult, error) + func (m *EtcdDataTransformer) RunPrechecks() error + type EtcdDataTransformerResult struct + Backends []*storage.BackendPersistent + Volumes []*storage.VolumeExternal + type InMemoryClient struct + func NewInMemoryClient() *InMemoryClient + func (c *InMemoryClient) AddBackend(b *storage.Backend) error + func (c *InMemoryClient) AddBackendPersistent(backend *storage.BackendPersistent) error + func (c *InMemoryClient) AddOrUpdateNode(n *utils.Node) error + func (c *InMemoryClient) AddSnapshot(snapshot *storage.Snapshot) error + func (c *InMemoryClient) AddStorageClass(s *sc.StorageClass) error + func (c *InMemoryClient) AddVolume(vol *storage.Volume) error + func (c *InMemoryClient) AddVolumePersistent(volume *storage.VolumeExternal) error + func (c *InMemoryClient) AddVolumeTransaction(volTxn *storage.VolumeTransaction) error + func (c *InMemoryClient) DeleteBackend(b *storage.Backend) error + func (c *InMemoryClient) DeleteBackends() error + func (c *InMemoryClient) DeleteNode(n *utils.Node) error + func (c *InMemoryClient) DeleteSnapshot(snapshot *storage.Snapshot) error + func (c *InMemoryClient) DeleteSnapshotIgnoreNotFound(snapshot *storage.Snapshot) error + func (c *InMemoryClient) DeleteSnapshots() error + func (c *InMemoryClient) DeleteStorageClass(s *sc.StorageClass) error + func (c *InMemoryClient) DeleteVolume(vol *storage.Volume) error + func (c *InMemoryClient) DeleteVolumeIgnoreNotFound(vol *storage.Volume) error + func (c *InMemoryClient) DeleteVolumeTransaction(volTxn *storage.VolumeTransaction) error + func (c *InMemoryClient) DeleteVolumes() error + func (c *InMemoryClient) GetBackend(backendName string) (*storage.BackendPersistent, error) + func (c *InMemoryClient) GetBackends() ([]*storage.BackendPersistent, error) + func (c *InMemoryClient) GetConfig() *ClientConfig + func (c *InMemoryClient) GetExistingVolumeTransaction(volTxn *storage.VolumeTransaction) (*storage.VolumeTransaction, error) + func (c *InMemoryClient) GetNode(nName string) (*utils.Node, error) + func (c *InMemoryClient) GetNodes() ([]*utils.Node, error) + func (c *InMemoryClient) GetSnapshot(volumeName, snapshotName string) (*storage.SnapshotPersistent, error) + func (c *InMemoryClient) GetSnapshots() ([]*storage.SnapshotPersistent, error) + func (c *InMemoryClient) GetStorageClass(scName string) (*sc.Persistent, error) + func (c *InMemoryClient) GetStorageClasses() ([]*sc.Persistent, error) + func (c *InMemoryClient) GetType() StoreType + func (c *InMemoryClient) GetVersion() (*config.PersistentStateVersion, error) + func (c *InMemoryClient) GetVolume(volumeName string) (*storage.VolumeExternal, error) + func (c *InMemoryClient) GetVolumeTransactions() ([]*storage.VolumeTransaction, error) + func (c *InMemoryClient) GetVolumes() ([]*storage.VolumeExternal, error) + func (c *InMemoryClient) ReplaceBackendAndUpdateVolumes(origBackend, newBackend *storage.Backend) error + func (c *InMemoryClient) SetVersion(version *config.PersistentStateVersion) error + func (c *InMemoryClient) Stop() error + func (c *InMemoryClient) UpdateBackend(b *storage.Backend) error + func (c *InMemoryClient) UpdateBackendPersistent(update *storage.BackendPersistent) error + func (c *InMemoryClient) UpdateVolume(vol *storage.Volume) error + func (c *InMemoryClient) UpdateVolumePersistent(volume *storage.VolumeExternal) error + type PassthroughClient struct + func NewPassthroughClient(configPath string) (*PassthroughClient, error) + func (c *PassthroughClient) AddBackend(backend *storage.Backend) error + func (c *PassthroughClient) AddBackendPersistent(backend *storage.BackendPersistent) error + func (c *PassthroughClient) AddOrUpdateNode(n *utils.Node) error + func (c *PassthroughClient) AddSnapshot(snapshot *storage.Snapshot) error + func (c *PassthroughClient) AddStorageClass(sc *sc.StorageClass) error + func (c *PassthroughClient) AddVolume(vol *storage.Volume) error + func (c *PassthroughClient) AddVolumePersistent(volume *storage.VolumeExternal) error + func (c *PassthroughClient) AddVolumeTransaction(volTxn *storage.VolumeTransaction) error + func (c *PassthroughClient) DeleteBackend(backend *storage.Backend) error + func (c *PassthroughClient) DeleteBackends() error + func (c *PassthroughClient) DeleteNode(n *utils.Node) error + func (c *PassthroughClient) DeleteSnapshot(snapshot *storage.Snapshot) error + func (c *PassthroughClient) DeleteSnapshotIgnoreNotFound(snapshot *storage.Snapshot) error + func (c *PassthroughClient) DeleteSnapshots() error + func (c *PassthroughClient) DeleteStorageClass(sc *sc.StorageClass) error + func (c *PassthroughClient) DeleteVolume(vol *storage.Volume) error + func (c *PassthroughClient) DeleteVolumeIgnoreNotFound(vol *storage.Volume) error + func (c *PassthroughClient) DeleteVolumeTransaction(volTxn *storage.VolumeTransaction) error + func (c *PassthroughClient) DeleteVolumes() error + func (c *PassthroughClient) GetBackend(backendName string) (*storage.BackendPersistent, error) + func (c *PassthroughClient) GetBackends() ([]*storage.BackendPersistent, error) + func (c *PassthroughClient) GetConfig() *ClientConfig + func (c *PassthroughClient) GetExistingVolumeTransaction(volTxn *storage.VolumeTransaction) (*storage.VolumeTransaction, error) + func (c *PassthroughClient) GetNode(nName string) (*utils.Node, error) + func (c *PassthroughClient) GetNodes() ([]*utils.Node, error) + func (c *PassthroughClient) GetSnapshot(volumeName, snapshotName string) (*storage.SnapshotPersistent, error) + func (c *PassthroughClient) GetSnapshots() ([]*storage.SnapshotPersistent, error) + func (c *PassthroughClient) GetStorageClass(scName string) (*sc.Persistent, error) + func (c *PassthroughClient) GetStorageClasses() ([]*sc.Persistent, error) + func (c *PassthroughClient) GetType() StoreType + func (c *PassthroughClient) GetVersion() (*config.PersistentStateVersion, error) + func (c *PassthroughClient) GetVolume(volName string) (*storage.VolumeExternal, error) + func (c *PassthroughClient) GetVolumeTransactions() ([]*storage.VolumeTransaction, error) + func (c *PassthroughClient) GetVolumes() ([]*storage.VolumeExternal, error) + func (c *PassthroughClient) ReplaceBackendAndUpdateVolumes(origBackend, newBackend *storage.Backend) error + func (c *PassthroughClient) SetVersion(version *config.PersistentStateVersion) error + func (c *PassthroughClient) Stop() error + func (c *PassthroughClient) UpdateBackend(backend *storage.Backend) error + func (c *PassthroughClient) UpdateBackendPersistent(update *storage.BackendPersistent) error + func (c *PassthroughClient) UpdateVolume(vol *storage.Volume) error + func (c *PassthroughClient) UpdateVolumePersistent(volume *storage.VolumeExternal) error + type StoreType string + const CRDV1Store + const EtcdV2Store + const EtcdV3Store + const EtcdV3bStore + const MemoryStore + const PassthroughStore
Go to main page