Documentation ¶
Index ¶
- Constants
- func LocalfileInS3(svc *s3.Client, s3Path string, localFile FileInfoT) bool
- func PresignOpt(s *s3.PresignOptions)
- type FileInfoT
- type S3Retryer
- type S3Uploader
- type SDKCopyAmiDriver
- type SDKCreateAmiDriver
- type SDKCreateMachineImageDriver
- type SDKCreateMachineImageManifestDriver
- type SDKCreateMachineImageManifestDriverGen2
- type SDKCreateVolumeDriver
- type SDKDeleteMachineImageDriver
- type SDKDeleteVolumeDriver
- type SDKSnapshotFromImageDriver
- type SDKSnapshotFromVolumeDriver
Constants ¶
const S3_FOLDER = "bosh-stemcell"
Variables ¶
This section is empty.
Functions ¶
func PresignOpt ¶
func PresignOpt(s *s3.PresignOptions)
Types ¶
type FileInfoT ¶
type FileInfoT struct {
// contains filtered or unexported fields
}
func GetFileInfo ¶
type S3Retryer ¶
type S3Retryer struct {
client.DefaultRetryer
}
S3Retryer handles more error conditions than the default retryer when uploading chunks to S3
func (S3Retryer) MaxRetries ¶
MaxRetries returns the configured number of NumMaxRetries, defaults to 3
type S3Uploader ¶
type S3Uploader struct {
// contains filtered or unexported fields
}
func (S3Uploader) Upload ¶
func (s S3Uploader) Upload(s3Path string, fchan FileInfoT) (*manager.UploadOutput, error)
type SDKCopyAmiDriver ¶
type SDKCopyAmiDriver struct {
// contains filtered or unexported fields
}
SDKCopyAmiDriver uses the AWS SDK to register an AMI from an existing snapshot in EC2
func NewCopyAmiDriver ¶
func NewCopyAmiDriver(logDest io.Writer, creds config.Credentials) *SDKCopyAmiDriver
NewCopyAmiDriver creates a SDKCopyAmiDriver for copying AMIs in EC2
func (*SDKCopyAmiDriver) Create ¶
func (d *SDKCopyAmiDriver) Create(driverConfig resources.AmiDriverConfig) (resources.Ami, error)
Create creates an AMI, copied from a source AMI, and optionally makes the AMI publically available
type SDKCreateAmiDriver ¶
type SDKCreateAmiDriver struct {
// contains filtered or unexported fields
}
SDKCreateAmiDriver uses the AWS SDK to register an AMI from an existing snapshot in EC2
func NewCreateAmiDriver ¶
func NewCreateAmiDriver(logDest io.Writer, creds config.Credentials) *SDKCreateAmiDriver
NewCreateAmiDriver creates a SDKCreateAmiDriver for an AMI from a snapshot in EC2
func (*SDKCreateAmiDriver) Create ¶
func (d *SDKCreateAmiDriver) Create(driverConfig resources.AmiDriverConfig) (resources.Ami, error)
Create registers an AMI from an existing snapshot and optionally makes the AMI publically available
type SDKCreateMachineImageDriver ¶
type SDKCreateMachineImageDriver struct {
// contains filtered or unexported fields
}
The SDKCreateMachineImageDriver uploads a machine image to S3 and creates a presigned URL for GET operations
func NewCreateMachineImageDriver ¶
func NewCreateMachineImageDriver(logDest io.Writer, creds config.Credentials) *SDKCreateMachineImageDriver
NewCreateMachineImageDriver creates a MachineImageDriver for S3 uploads
func (*SDKCreateMachineImageDriver) Create ¶
func (d *SDKCreateMachineImageDriver) Create(driverConfig resources.MachineImageDriverConfig) (resources.MachineImage, error)
Create uploads a machine image to S3 and returns a presigned URL
type SDKCreateMachineImageManifestDriver ¶
type SDKCreateMachineImageManifestDriver struct {
// contains filtered or unexported fields
}
The SDKCreateMachineImageManifestDriver uploads a machine image to S3 and creates an import volume manifest
func NewCreateMachineImageManifestDriver ¶
func NewCreateMachineImageManifestDriver(logDest io.Writer, creds config.Credentials) *SDKCreateMachineImageManifestDriver
NewCreateMachineImageManifestDriver creates a MachineImageDriver machine image manifest generation
func (*SDKCreateMachineImageManifestDriver) Create ¶
func (d *SDKCreateMachineImageManifestDriver) Create(driverConfig resources.MachineImageDriverConfig) (resources.MachineImage, error)
Create uploads a machine image to S3 and returns a presigned URL to an import volume manifest
type SDKCreateMachineImageManifestDriverGen2 ¶
type SDKCreateMachineImageManifestDriverGen2 struct {
// contains filtered or unexported fields
}
The SDKCreateMachineImageManifestDriver uploads a machine image to S3 and creates an import volume manifest
func NewCreateMachineImageManifestDriverGen2 ¶
func NewCreateMachineImageManifestDriverGen2(logDest io.Writer, creds config.Credentials) *SDKCreateMachineImageManifestDriverGen2
NewCreateMachineImageManifestDriver creates a MachineImageDriver machine image manifest generation
func (*SDKCreateMachineImageManifestDriverGen2) Create ¶
func (d *SDKCreateMachineImageManifestDriverGen2) Create(driverConfig resources.MachineImageDriverConfig) (resources.MachineImage, error)
Create uploads a machine image to S3 and returns a presigned URL to an import volume manifest
type SDKCreateVolumeDriver ¶
type SDKCreateVolumeDriver struct {
// contains filtered or unexported fields
}
SDKCreateVolumeDriver is an implementation of the resources VolumeDriver that handles creation of a volume from a machine image on AWS
func NewCreateVolumeDriver ¶
func NewCreateVolumeDriver(logDest io.Writer, creds config.Credentials) *SDKCreateVolumeDriver
NewCreateVolumeDriver creates a SDKCreateVolumeDriver for importing a volume from a machine image url
func (*SDKCreateVolumeDriver) Create ¶
func (d *SDKCreateVolumeDriver) Create(driverConfig resources.VolumeDriverConfig) (resources.Volume, error)
Create makes an EBS volume from a machine image URL in the first availability zone returned from DescribeAvailabilityZones
type SDKDeleteMachineImageDriver ¶
type SDKDeleteMachineImageDriver struct {
// contains filtered or unexported fields
}
The SDKDeleteMachineImageDriver deletes a previously uploaded machine image and manifest from S3
func NewDeleteMachineImageDriver ¶
func NewDeleteMachineImageDriver(logDest io.Writer, creds config.Credentials) *SDKDeleteMachineImageDriver
NewDeleteMachineImageDriver deletes a previously uploaded machine image and manifest from S3
func (*SDKDeleteMachineImageDriver) Delete ¶
func (d *SDKDeleteMachineImageDriver) Delete(machineImage resources.MachineImage) error
Delete will perform DELETE requests to all DeleteURLs on the machineImage
type SDKDeleteVolumeDriver ¶
type SDKDeleteVolumeDriver struct {
// contains filtered or unexported fields
}
SDKDeleteVolumeDriver handles deletion of a volume from a machine image on AWS
func NewDeleteVolumeDriver ¶
func NewDeleteVolumeDriver(logDest io.Writer, creds config.Credentials) *SDKDeleteVolumeDriver
NewDeleteVolumeDriver deletes a previously created Volume
type SDKSnapshotFromImageDriver ¶
type SDKSnapshotFromImageDriver struct {
// contains filtered or unexported fields
}
SDKSnapshotFromImageDriver creates an AMI directly from a machine image
func NewSnapshotFromImageDriver ¶
func NewSnapshotFromImageDriver(logDest io.Writer, creds config.Credentials) *SDKSnapshotFromImageDriver
NewSnapshotFromImageDriver creates a SDKSnapshotFromImageDriver for creating snapshots in EC2
func (*SDKSnapshotFromImageDriver) Create ¶
func (d *SDKSnapshotFromImageDriver) Create(driverConfig resources.SnapshotDriverConfig) (resources.Snapshot, error)
Create produces a snapshot in EC2 from a machine image previously uploaded to S3
type SDKSnapshotFromVolumeDriver ¶
type SDKSnapshotFromVolumeDriver struct {
// contains filtered or unexported fields
}
SDKSnapshotFromVolumeDriver creates an AMI from a previously created EBS volume
func NewSnapshotFromVolumeDriver ¶
func NewSnapshotFromVolumeDriver(logDest io.Writer, creds config.Credentials) *SDKSnapshotFromVolumeDriver
NewSnapshotFromVolumeDriver creates a NewSnapshotFromVolumeDriver for creating snapshots in EC2
func (*SDKSnapshotFromVolumeDriver) Create ¶
func (d *SDKSnapshotFromVolumeDriver) Create(driverConfig resources.SnapshotDriverConfig) (resources.Snapshot, error)
Create produces a snapshot in EC2 from a previoulsy created EBS volume
Source Files ¶
- copy_ami_driver.go
- create_ami_driver.go
- create_machine_image_driver.go
- create_machine_image_manifest_driver.go
- create_machine_image_manifest_driver_gen2.go
- create_volume_driver.go
- creds.go
- delete_machine_image_driver.go
- delete_volume_driver.go
- driver_logger.go
- retryer.go
- snapshot_from_image_driver.go
- snapshot_from_volume_driver.go
- uploader.go