provider

package
v1.1.7 Latest Latest
Warning

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

Go to latest
Published: Jan 24, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package provider ...

Package provider ...

Package provider ...

Index

Constants

View Source
const (
	// Provider storage provider
	Provider = provider.VolumeProvider("IKS-VPC-Block")
	// VolumeType ...
	VolumeType = provider.VolumeType("VPC-Block")
)

Variables

This section is empty.

Functions

func NewProvider

func NewProvider(conf *vpcconfig.VPCBlockConfig, k8sClient *k8s_utils.KubernetesClient, logger *zap.Logger) (local.Provider, error)

NewProvider handles both IKS and RIAAS sessions

Types

type IksVpcBlockProvider

type IksVpcBlockProvider struct {
	vpcprovider.VPCBlockProvider
	// contains filtered or unexported fields
}

IksVpcBlockProvider handles both IKS and RIAAS sessions

func (*IksVpcBlockProvider) ContextCredentialsFactory

func (iksp *IksVpcBlockProvider) ContextCredentialsFactory(zone *string) (local.ContextCredentialsFactory, error)

ContextCredentialsFactory ...

func (*IksVpcBlockProvider) OpenSession

func (iksp *IksVpcBlockProvider) OpenSession(ctx context.Context, contextCredentials provider.ContextCredentials, ctxLogger *zap.Logger) (provider.Session, error)

OpenSession opens a session on the provider

type IksVpcSession

type IksVpcSession struct {
	vpcprovider.VPCSession                         // Holds VPC/Riaas session by default
	IksSession             *vpcprovider.VPCSession // Holds IKS session
}

IksVpcSession implements lib.Session for VPC IKS dual session

func (*IksVpcSession) AttachVolume

func (vpcIks *IksVpcSession) AttachVolume(volumeAttachmentRequest provider.VolumeAttachmentRequest) (*provider.VolumeAttachmentResponse, error)

AttachVolume attach volume based on given volume attachment request

func (*IksVpcSession) Close

func (vpcIks *IksVpcSession) Close()

Close at present does nothing

func (*IksVpcSession) DetachVolume

func (vpcIks *IksVpcSession) DetachVolume(volumeAttachmentRequest provider.VolumeAttachmentRequest) (*http.Response, error)

DetachVolume attach volume based on given volume attachment request

func (*IksVpcSession) GetProviderDisplayName

func (vpcIks *IksVpcSession) GetProviderDisplayName() provider.VolumeProvider

GetProviderDisplayName returns the name of the VPC provider

func (*IksVpcSession) GetVolumeAttachment

func (vpcIks *IksVpcSession) GetVolumeAttachment(volumeAttachmentRequest provider.VolumeAttachmentRequest) (*provider.VolumeAttachmentResponse, error)

GetVolumeAttachment attach volume based on given volume attachment request

func (*IksVpcSession) ProviderName

func (vpcIks *IksVpcSession) ProviderName() provider.VolumeProvider

ProviderName ...

func (*IksVpcSession) Type

func (vpcIks *IksVpcSession) Type() provider.VolumeType

Type ...

func (*IksVpcSession) UpdateVolume

func (vpcIks *IksVpcSession) UpdateVolume(volumeRequest provider.Volume) (err error)

UpdateVolume updates the volume with given information

func (*IksVpcSession) WaitForAttachVolume

func (vpcIks *IksVpcSession) WaitForAttachVolume(volumeAttachmentRequest provider.VolumeAttachmentRequest) (*provider.VolumeAttachmentResponse, error)

WaitForAttachVolume attach volume based on given volume attachment request

func (*IksVpcSession) WaitForDetachVolume

func (vpcIks *IksVpcSession) WaitForDetachVolume(volumeAttachmentRequest provider.VolumeAttachmentRequest) error

WaitForDetachVolume attach volume based on given volume attachment request

Jump to

Keyboard shortcuts

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