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
Constants ¶
View Source
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" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 (*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)
Click to show internal directories.
Click to hide internal directories.