azure

Documentation

Index

• func GetResticEnvVars(config map[string]string) (map[string]string, error)
• type ObjectStore
  • func NewObjectStore(logger logrus.FieldLogger) *ObjectStore
  • func (o *ObjectStore) CreateSignedURL(bucket, key string, ttl time.Duration) (string, error)
  • func (o *ObjectStore) DeleteObject(bucket string, key string) error
  • func (o *ObjectStore) GetObject(bucket, key string) (io.ReadCloser, error)
  • func (o *ObjectStore) Init(config map[string]string) error
  • func (o *ObjectStore) ListCommonPrefixes(bucket, prefix, delimiter string) ([]string, error)
  • func (o *ObjectStore) ListObjects(bucket, prefix string) ([]string, error)
  • func (o *ObjectStore) PutObject(bucket, key string, body io.Reader) error
• type VolumeSnapshotter
  • func NewVolumeSnapshotter(logger logrus.FieldLogger) *VolumeSnapshotter
  • func (b *VolumeSnapshotter) CreateSnapshot(volumeID, volumeAZ string, tags map[string]string) (string, error)
  • func (b *VolumeSnapshotter) CreateVolumeFromSnapshot(snapshotID, volumeType, volumeAZ string, iops *int64) (string, error)
  • func (b *VolumeSnapshotter) DeleteSnapshot(snapshotID string) error
  • func (b *VolumeSnapshotter) GetVolumeID(unstructuredPV runtime.Unstructured) (string, error)
  • func (b *VolumeSnapshotter) GetVolumeInfo(volumeID, volumeAZ string) (string, *int64, error)
  • func (b *VolumeSnapshotter) Init(config map[string]string) error
  • func (b *VolumeSnapshotter) SetVolumeID(unstructuredPV runtime.Unstructured, volumeID string) (runtime.Unstructured, error)

Functions

func GetResticEnvVars

func GetResticEnvVars(config map[string]string) (map[string]string, error)

GetResticEnvVars gets the environment variables that restic relies on (AZURE_ACCOUNT_NAME and AZURE_ACCOUNT_KEY) based on info in the provided object storage location config map.

Types

type ObjectStore

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

func NewObjectStore

func NewObjectStore(logger logrus.FieldLogger) *ObjectStore

func (*ObjectStore) CreateSignedURL

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

func (*ObjectStore) DeleteObject

func (o *ObjectStore) DeleteObject(bucket string, key string) error

func (*ObjectStore) GetObject

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

func (*ObjectStore) Init

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

func (*ObjectStore) ListCommonPrefixes

func (o *ObjectStore) ListCommonPrefixes(bucket, prefix, delimiter string) ([]string, error)

func (*ObjectStore) ListObjects

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

func (*ObjectStore) PutObject

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

type VolumeSnapshotter

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

func NewVolumeSnapshotter

func NewVolumeSnapshotter(logger logrus.FieldLogger) *VolumeSnapshotter

func (*VolumeSnapshotter) CreateSnapshot

func (b *VolumeSnapshotter) CreateSnapshot(volumeID, volumeAZ string, tags map[string]string) (string, error)

func (*VolumeSnapshotter) CreateVolumeFromSnapshot

func (b *VolumeSnapshotter) CreateVolumeFromSnapshot(snapshotID, volumeType, volumeAZ string, iops *int64) (string, error)

func (*VolumeSnapshotter) DeleteSnapshot

func (b *VolumeSnapshotter) DeleteSnapshot(snapshotID string) error

func (*VolumeSnapshotter) GetVolumeID

func (b *VolumeSnapshotter) GetVolumeID(unstructuredPV runtime.Unstructured) (string, error)

func (*VolumeSnapshotter) GetVolumeInfo

func (b *VolumeSnapshotter) GetVolumeInfo(volumeID, volumeAZ string) (string, *int64, error)

func (*VolumeSnapshotter) Init

func (b *VolumeSnapshotter) Init(config map[string]string) error

func (*VolumeSnapshotter) SetVolumeID

func (b *VolumeSnapshotter) SetVolumeID(unstructuredPV runtime.Unstructured, volumeID string) (runtime.Unstructured, error)