provider

Documentation

Overview

Package provider ...

Package provider ...

Package provider ...

Index

• Constants
• func NewProvider(conf *vpcconfig.VPCFileConfig, k8sClient *k8s_utils.KubernetesClient, ...) (local.Provider, error)
• func NewUpdatePVC(volumeRequest provider.Volume) provider.UpdatePVC
• type IksVpcFileProvider
  • func (iksp *IksVpcFileProvider) ContextCredentialsFactory(zone *string) (local.ContextCredentialsFactory, error)
  • func (iksp *IksVpcFileProvider) OpenSession(ctx context.Context, contextCredentials provider.ContextCredentials, ...) (provider.Session, error)
• type IksVpcSession
  • func (vpcIks *IksVpcSession) Close()
  • func (vpcIks *IksVpcSession) GetProviderDisplayName() provider.VolumeProvider
  • func (vpcIks *IksVpcSession) ProviderName() provider.VolumeProvider
  • func (vpcIks *IksVpcSession) Type() provider.VolumeType
  • func (vpcIks *IksVpcSession) UpdateVolume(volumeRequest provider.Volume) (err error)

Constants

const (
	// Provider storage provider
	Provider = provider.VolumeProvider("VPC-SHARE")
	// VolumeType ...
	VolumeType = provider.VolumeType("vpc-share")
)

const (
	//ClusterIDTagName ...
	ClusterIDTagName = "clusterid"
	//VolumeStatus ...
	VolumeStatus = "status"
)

Functions

func NewProvider

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

NewProvider handles both IKS and RIAAS sessions

func NewUpdatePVC

func NewUpdatePVC(volumeRequest provider.Volume) provider.UpdatePVC

Only for v2/storage/updateVolume NewUpdatePVC creates model UpdatePVC from provider volume

Types

type IksVpcFileProvider

type IksVpcFileProvider struct {
	vpcprovider.VPCFileProvider
	// contains filtered or unexported fields
}

IksVpcFileProvider handles both IKS and RIAAS sessions

func (*IksVpcFileProvider) ContextCredentialsFactory

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

ContextCredentialsFactory ...

func (*IksVpcFileProvider) OpenSession

func (iksp *IksVpcFileProvider) 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) Close

func (vpcIks *IksVpcSession) Close()

Close at present does nothing

func (*IksVpcSession) GetProviderDisplayName

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

GetProviderDisplayName returns the name of the VPC provider

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