provider

Documentation

Index

• Constants
• func NewProvider(conf *config.Config, logger *zap.Logger) (local.Provider, error)
• type IksVpcBlockProvider
  • func (iksp *IksVpcBlockProvider) ContextCredentialsFactory(zone *string) (local.ContextCredentialsFactory, error)
  • func (iksp *IksVpcBlockProvider) OpenSession(ctx context.Context, contextCredentials provider.ContextCredentials, ...) (provider.Session, error)
• type IksVpcSession
  • func (vpcIks *IksVpcSession) AttachVolume(volumeAttachmentRequest provider.VolumeAttachmentRequest) (*provider.VolumeAttachmentResponse, error)
  • func (vpcIks *IksVpcSession) Close()
  • func (vpcIks *IksVpcSession) DetachVolume(volumeAttachmentRequest provider.VolumeAttachmentRequest) (*http.Response, error)
  • func (vpcIks *IksVpcSession) GetProviderDisplayName() provider.VolumeProvider
  • func (vpcIks *IksVpcSession) GetVolumeAttachment(volumeAttachmentRequest provider.VolumeAttachmentRequest) (*provider.VolumeAttachmentResponse, error)
  • func (vpcIks *IksVpcSession) ProviderName() provider.VolumeProvider
  • func (vpcIks *IksVpcSession) Type() provider.VolumeType
  • func (vpcIks *IksVpcSession) WaitForAttachVolume(volumeAttachmentRequest provider.VolumeAttachmentRequest) (*provider.VolumeAttachmentResponse, error)
  • func (vpcIks *IksVpcSession) WaitForDetachVolume(volumeAttachmentRequest provider.VolumeAttachmentRequest) error

Constants

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

Functions

func NewProvider

func NewProvider(conf *config.Config, 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) 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