test

Feb 15, 2018

Changes in this version

type TestBackup

+ func (b *TestBackup) WithDeletionTimestamp(time time.Time) *TestBackup

+ func (b *TestBackup) WithFinalizers(finalizers ...string) *TestBackup

+ func (b *TestBackup) WithResourceVersion(version string) *TestBackup

Nov 30, 2017

Changes in this version

type BackupService

+ func (_m *BackupService) UploadRestoreResults(bucket string, backup string, restore string, results io.Reader) error

type FakeSnapshotService

+ VolumeID string

+ VolumeIDSet string

+ func (s *FakeSnapshotService) GetVolumeID(pv runtime.Unstructured) (string, error)

+ func (s *FakeSnapshotService) SetVolumeID(pv runtime.Unstructured, volumeID string) (runtime.Unstructured, error)

+ type ObjectStore struct

+ func (_m *ObjectStore) CreateSignedURL(bucket string, key string, ttl time.Duration) (string, error)

+ func (_m *ObjectStore) DeleteObject(bucket string, key string) error

+ func (_m *ObjectStore) GetObject(bucket string, key string) (io.ReadCloser, error)

+ func (_m *ObjectStore) Init(config map[string]string) error

+ func (_m *ObjectStore) ListCommonPrefixes(bucket string, delimiter string) ([]string, error)

+ func (_m *ObjectStore) ListObjects(bucket string, prefix string) ([]string, error)

+ func (_m *ObjectStore) PutObject(bucket string, key string, body io.Reader) error

Oct 26, 2017

Changes in this version

+ func NewLogger() *logrus.Entry

type FakeDiscoveryHelper

+ AutoReturnResource bool

+ func NewFakeDiscoveryHelper(autoReturnResource bool, ...) *FakeDiscoveryHelper

+ func (dh *FakeDiscoveryHelper) ResourceFor(input schema.GroupVersionResource) (schema.GroupVersionResource, metav1.APIResource, error)

type FakeDynamicClient

+ func (c *FakeDynamicClient) Get(name string, opts metav1.GetOptions) (*unstructured.Unstructured, error)

Sep 14, 2017

Changes in this version

+ type BackupService struct

+ func (_m *BackupService) CreateSignedURL(target v1.DownloadTarget, bucket string, ttl time.Duration) (string, error)

+ func (_m *BackupService) DeleteBackupDir(bucket string, backupName string) error

+ func (_m *BackupService) DownloadBackup(bucket string, name string) (io.ReadCloser, error)

+ func (_m *BackupService) GetAllBackups(bucket string) ([]*v1.Backup, error)

+ func (_m *BackupService) GetBackup(bucket string, name string) (*v1.Backup, error)

+ func (_m *BackupService) UploadBackup(bucket string, name string, metadata io.ReadSeeker, backup io.ReadSeeker, ...) error

+ func (_m *BackupService) UploadRestoreLog(bucket string, backup string, restore string, log io.ReadSeeker) error

type FakeBackupService

+ func (f *FakeBackupService) GetBackup(bucket, name string) (*v1.Backup, error)

+ type FakeDiscoveryHelper struct

+ RESTMapper meta.RESTMapper

+ ResourceList []*metav1.APIResourceList

+ func (dh *FakeDiscoveryHelper) Mapper() meta.RESTMapper

+ func (dh *FakeDiscoveryHelper) Refresh() error

+ func (dh *FakeDiscoveryHelper) ResolveGroupResource(resource string) (schema.GroupResource, error)

+ func (dh *FakeDiscoveryHelper) Resources() []*metav1.APIResourceList

+ type ObjectStorageAdapter struct

+ func (_m *ObjectStorageAdapter) CreateSignedURL(bucket string, key string, ttl time.Duration) (string, error)

+ func (_m *ObjectStorageAdapter) DeleteObject(bucket string, key string) error

+ func (_m *ObjectStorageAdapter) GetObject(bucket string, key string) (io.ReadCloser, error)

+ func (_m *ObjectStorageAdapter) ListCommonPrefixes(bucket string, delimiter string) ([]string, error)

+ func (_m *ObjectStorageAdapter) ListObjects(bucket string, prefix string) ([]string, error)

+ func (_m *ObjectStorageAdapter) PutObject(bucket string, key string, body io.ReadSeeker) error

type TestBackup

+ func (b *TestBackup) WithSnapshotVolumes(value bool) *TestBackup

+ func (b *TestBackup) WithSnapshotVolumesPointer(value *bool) *TestBackup

type TestRestore

+ func NewDefaultTestRestore() *TestRestore

+ func (r *TestRestore) WithExcludedNamespace(name string) *TestRestore

+ func (r *TestRestore) WithExcludedResource(resource string) *TestRestore

+ func (r *TestRestore) WithIncludedNamespace(name string) *TestRestore

+ func (r *TestRestore) WithIncludedResource(resource string) *TestRestore

+ func (r *TestRestore) WithMappedNamespace(from string, to string) *TestRestore

+ func (r *TestRestore) WithRestorePVs(value bool) *TestRestore

Aug 2, 2017

Changes in this version

+ type FakeBackupService struct

+ func (f *FakeBackupService) DeleteBackup(bucket, backupName string) error

+ func (f *FakeBackupService) DownloadBackup(bucket, name string) (io.ReadCloser, error)

+ func (f *FakeBackupService) GetAllBackups(bucket string) ([]*v1.Backup, error)

+ func (f *FakeBackupService) UploadBackup(bucket, name string, metadata, backup io.ReadSeeker) error

+ type FakeDynamicClient struct

+ func (c *FakeDynamicClient) Create(obj *unstructured.Unstructured) (*unstructured.Unstructured, error)

+ func (c *FakeDynamicClient) List(options metav1.ListOptions) (runtime.Object, error)

+ func (c *FakeDynamicClient) Watch(options metav1.ListOptions) (watch.Interface, error)

+ type FakeDynamicFactory struct

+ func (df *FakeDynamicFactory) ClientForGroupVersionKind(gvk schema.GroupVersionKind, resource metav1.APIResource, namespace string) (client.Dynamic, error)

+ func (df *FakeDynamicFactory) ClientForGroupVersionResource(gvr schema.GroupVersionResource, resource metav1.APIResource, namespace string) (client.Dynamic, error)

+ type FakeMapper struct

+ AutoReturnResource bool

+ Resources map[schema.GroupVersionResource]schema.GroupVersionResource

+ func (m *FakeMapper) ResourceFor(input schema.GroupVersionResource) (schema.GroupVersionResource, error)

+ type FakeSnapshotService struct

+ RestorableVolumes map[api.VolumeBackupInfo]string

+ SnapshotsTaken sets.String

+ SnapshottableVolumes map[string]api.VolumeBackupInfo

+ func (s *FakeSnapshotService) CreateSnapshot(volumeID string) (string, error)

+ func (s *FakeSnapshotService) CreateVolumeFromSnapshot(snapshotID, volumeType string, iops *int) (string, error)

+ func (s *FakeSnapshotService) DeleteSnapshot(snapshotID string) error

+ func (s *FakeSnapshotService) GetAllSnapshots() ([]string, error)

+ func (s *FakeSnapshotService) GetVolumeInfo(volumeID string) (string, *int, error)

+ type TestBackup struct

+ func NewTestBackup() *TestBackup

+ func (b *TestBackup) WithExcludedNamespaces(ns ...string) *TestBackup

+ func (b *TestBackup) WithExcludedResources(r ...string) *TestBackup

+ func (b *TestBackup) WithExpiration(expiration time.Time) *TestBackup

+ func (b *TestBackup) WithIncludedNamespaces(ns ...string) *TestBackup

+ func (b *TestBackup) WithIncludedResources(r ...string) *TestBackup

+ func (b *TestBackup) WithLabel(key, value string) *TestBackup

+ func (b *TestBackup) WithName(name string) *TestBackup

+ func (b *TestBackup) WithNamespace(namespace string) *TestBackup

+ func (b *TestBackup) WithPhase(phase v1.BackupPhase) *TestBackup

+ func (b *TestBackup) WithSnapshot(pv string, snapshot string) *TestBackup

+ func (b *TestBackup) WithTTL(ttl time.Duration) *TestBackup

+ func (b *TestBackup) WithVersion(version int) *TestBackup

+ type TestRestore struct

+ func NewTestRestore(ns, name string, phase api.RestorePhase) *TestRestore

+ func (r *TestRestore) WithBackup(name string) *TestRestore

+ func (r *TestRestore) WithErrors(e api.RestoreResult) *TestRestore

+ func (r *TestRestore) WithRestorableNamespace(name string) *TestRestore

+ func (r *TestRestore) WithValidationError(err string) *TestRestore

+ type TestSchedule struct

+ func NewTestSchedule(namespace, name string) *TestSchedule

+ func (s *TestSchedule) WithCronSchedule(cronExpression string) *TestSchedule

+ func (s *TestSchedule) WithLastBackupTime(timeString string) *TestSchedule

+ func (s *TestSchedule) WithPhase(phase api.SchedulePhase) *TestSchedule

+ func (s *TestSchedule) WithValidationError(msg string) *TestSchedule