Documentation ¶
Index ¶
- func GetBucketRegion(bucket string) (string, error)
- func IsValidS3URLScheme(s3URL string) bool
- type ObjectStore
- func (o *ObjectStore) CreateSignedURL(bucket, key string, ttl time.Duration) (string, error)
- func (o *ObjectStore) DeleteObject(bucket, 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 (b *VolumeSnapshotter) CreateSnapshot(volumeID, volumeAZ string, tags map[string]string) (string, error)
- func (b *VolumeSnapshotter) CreateVolumeFromSnapshot(snapshotID, volumeType, volumeAZ string, iops *int64) (volumeID string, err 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetBucketRegion ¶ added in v0.9.0
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
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 (*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)
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 (*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)
Click to show internal directories.
Click to hide internal directories.