driver

package
v0.0.0-...-3883afe Latest Latest
Warning

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

Go to latest
Published: Jul 28, 2022 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

View Source
const S3_FOLDER = "bosh-stemcell"

Variables

This section is empty.

Functions

func LocalfileInS3

func LocalfileInS3(svc *s3.Client, s3Path string, localFile FileInfoT) bool

func PresignOpt

func PresignOpt(s *s3.PresignOptions)

Types

type FileInfoT

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

func GetFileInfo

func GetFileInfo(filePath string) (FileInfoT, error)

type S3Retryer

type S3Retryer struct {
	client.DefaultRetryer
}

S3Retryer handles more error conditions than the default retryer when uploading chunks to S3

func (S3Retryer) MaxRetries

func (r S3Retryer) MaxRetries() int

MaxRetries returns the configured number of NumMaxRetries, defaults to 3

func (S3Retryer) ShouldRetry

func (r S3Retryer) ShouldRetry(req *request.Request) bool

ShouldRetry returns a SerializationError if the response body was interrupted. S3Retryer will check for this error before invoking DefaultRetryer.ShouldRetry

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

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

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

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

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

func (*SDKDeleteVolumeDriver) Delete

func (d *SDKDeleteVolumeDriver) Delete(volume resources.Volume) error

Delete makes a request to delete the 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

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

Create produces a snapshot in EC2 from a previoulsy created EBS volume

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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