aws

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: May 20, 2019 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetBucketRegion added in v0.9.0

func GetBucketRegion(bucket string) (string, error)

GetBucketRegion returns the AWS region that a bucket is in, or an error if the region cannot be determined.

func IsValidS3URLScheme added in v0.10.0

func IsValidS3URLScheme(s3URL string) bool

IsValidS3URLScheme returns true if the scheme is http:// or https:// and the url parses correctly, otherwise, return false

Types

type ObjectStore added in v1.0.0

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

func NewObjectStore added in v0.6.0

func NewObjectStore(logger logrus.FieldLogger) *ObjectStore

func (*ObjectStore) CreateSignedURL added in v1.0.0

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

func (*ObjectStore) DeleteObject added in v1.0.0

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

func (*ObjectStore) GetObject added in v1.0.0

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

func (*ObjectStore) Init added in v1.0.0

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

func (*ObjectStore) ListCommonPrefixes added in v1.0.0

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

func (*ObjectStore) ListObjects added in v1.0.0

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

func (*ObjectStore) ObjectExists added in v1.0.0

func (o *ObjectStore) ObjectExists(bucket, key string) (bool, error)

ObjectExists checks if there is an object with the given key in the object storage bucket.

func (*ObjectStore) PutObject added in v1.0.0

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

type VolumeSnapshotter added in v1.0.0

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

func NewVolumeSnapshotter added in v1.0.0

func NewVolumeSnapshotter(logger logrus.FieldLogger) *VolumeSnapshotter

func (*VolumeSnapshotter) CreateSnapshot added in v1.0.0

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

func (*VolumeSnapshotter) CreateVolumeFromSnapshot added in v1.0.0

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

func (*VolumeSnapshotter) DeleteSnapshot added in v1.0.0

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

func (*VolumeSnapshotter) GetVolumeID added in v1.0.0

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

func (*VolumeSnapshotter) GetVolumeInfo added in v1.0.0

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

func (*VolumeSnapshotter) Init added in v1.0.0

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

func (*VolumeSnapshotter) SetVolumeID added in v1.0.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL