aws

Documentation

Overview

Copyright 2020 The OpenSDS Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Constants
• type AwsAdapter
  • func (ad *AwsAdapter) Close() error
  • func (ad *AwsAdapter) CreateVolume(ctx context.Context, volume *block.CreateVolumeRequest) (*block.CreateVolumeResponse, error)
  • func (ad *AwsAdapter) DeleteVolume(ctx context.Context, volume *block.DeleteVolumeRequest) (*block.DeleteVolumeResponse, error)
  • func (ad *AwsAdapter) DescribeVolume(input *awsec2.DescribeVolumesInput) (*awsec2.DescribeVolumesOutput, error)
  • func (ad *AwsAdapter) GetVolume(ctx context.Context, volume *block.GetVolumeRequest) (*block.GetVolumeResponse, error)
  • func (ad *AwsAdapter) ListVolume(ctx context.Context, volume *block.ListVolumeRequest) (*block.ListVolumeResponse, error)
  • func (ad *AwsAdapter) ParseUpdatedVolume(volumeAWS *awsec2.VolumeModification) (*block.Volume, error)
  • func (ad *AwsAdapter) ParseVolume(volumeAWS *awsec2.Volume) (*block.Volume, error)
  • func (ad *AwsAdapter) UpdateVolume(ctx context.Context, in *block.UpdateVolumeRequest) (*block.UpdateVolumeResponse, error)
  • func (ad *AwsAdapter) UpdateVolumeTags(ctx context.Context, in *block.UpdateVolumeRequest, svc *awsec2.EC2) error
• type AwsBlockDriverFactory
  • func (factory *AwsBlockDriverFactory) CreateBlockStorageDriver(backend *backendpb.BackendDetail) (driver.BlockDriver, error)

Constants

const (
	GB_FACTOR = 1024 * 1024 * 1024

	// Information about the volume attachments in AWS.
	Attachments = "Attachments"

	// The time that the volume was created in AWS.
	CreationTimeAtBackend = "CreationTimeAtBackend"

	// Indicates whether the volume was created using fast snapshot restore in AWS.
	FastRestored = "FastRestored"

	// Information about the volume iops.
	Iops = "Iops"

	// The ID of an AWS Key Management Service (AWS KMS) customer master key (CMK)
	// that was used to protect the encrypted volume.
	KmsKeyId = "KmsKeyId"

	// The Amazon Resource Name (ARN) of the Outpost.
	OutpostArn = "OutpostArn"

	// The ID of the volume in AWS.
	VolumeId = "VolumeId"

	// The type of the volume in AWS.
	VolumeType = "VolumeType"

	// The type of the volume in AWS.
	Progress = "Progress"

	// The modification completion or failure time at AWS.
	StartTimeAtBackend = "StartTimeAtBackend"

	// The modification completion or failure time at AWS.
	EndTimeAtBackend = "EndTimeAtBackend"

	// A status message about the modification progress or failure in AWS.
	StatusMessage = "StatusMessage"
)

Types

type AwsAdapter

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

func (*AwsAdapter) Close

func (ad *AwsAdapter) Close() error

func (*AwsAdapter) CreateVolume

func (ad *AwsAdapter) CreateVolume(ctx context.Context, volume *block.CreateVolumeRequest) (*block.CreateVolumeResponse, error)

Create EBS volume

func (*AwsAdapter) DeleteVolume

func (ad *AwsAdapter) DeleteVolume(ctx context.Context, volume *block.DeleteVolumeRequest) (*block.DeleteVolumeResponse, error)

func (*AwsAdapter) DescribeVolume

func (ad *AwsAdapter) DescribeVolume(input *awsec2.DescribeVolumesInput) (*awsec2.DescribeVolumesOutput, error)

func (*AwsAdapter) GetVolume

func (ad *AwsAdapter) GetVolume(ctx context.Context, volume *block.GetVolumeRequest) (*block.GetVolumeResponse, error)

func (*AwsAdapter) ListVolume

func (ad *AwsAdapter) ListVolume(ctx context.Context, volume *block.ListVolumeRequest) (*block.ListVolumeResponse, error)

func (*AwsAdapter) ParseUpdatedVolume

func (ad *AwsAdapter) ParseUpdatedVolume(volumeAWS *awsec2.VolumeModification) (*block.Volume, error)

func (*AwsAdapter) ParseVolume

func (ad *AwsAdapter) ParseVolume(volumeAWS *awsec2.Volume) (*block.Volume, error)

func (*AwsAdapter) UpdateVolume

func (ad *AwsAdapter) UpdateVolume(ctx context.Context, in *block.UpdateVolumeRequest) (*block.UpdateVolumeResponse, error)

func (*AwsAdapter) UpdateVolumeTags

func (ad *AwsAdapter) UpdateVolumeTags(ctx context.Context, in *block.UpdateVolumeRequest, svc *awsec2.EC2) error

type AwsBlockDriverFactory

type AwsBlockDriverFactory struct {
}

func (*AwsBlockDriverFactory) CreateBlockStorageDriver

func (factory *AwsBlockDriverFactory) CreateBlockStorageDriver(backend *backendpb.BackendDetail) (driver.BlockDriver, error)