util

Documentation

Index

• Constants
• func CreateConfigFile(vddkConfig map[string]string, logger logrus.FieldLogger) (string, error)
• func DeleteConfigFile(path string, logger logrus.FieldLogger) error
• func GetStringFromParamsMap(params map[string]interface{}, key string, logger logrus.FieldLogger) (value string, ok bool)
• func IsConnectionResetError(err error) bool
• func RetrievePlatformInfoFromConfig(config *rest.Config, params map[string]interface{}) error
• type ClusterFlavor
  • func GetClusterFlavor(config *rest.Config) (ClusterFlavor, error)
• type SeqWriterAt
  • func NewSeqWriterAt(w io.Writer) SeqWriterAt
  • func (this SeqWriterAt) WriteAt(p []byte, offset int64) (n int, err error)

Constants

const (
	VCSecretNs             = "kube-system"
	VCSecretNsSupervisor   = "vmware-system-csi"
	VCSecret               = "vsphere-config-secret"
	VCSecretTKG            = "csi-vsphere-config"
	VCSecretData           = "csi-vsphere.conf"
	VCSecretDataSupervisor = "vsphere-cloud-provider.conf"
)

const (
	Unknown    ClusterFlavor = "Unknown"
	Supervisor               = "Supervisor Cluster"
	TkgGuest                 = "TKG Guest Cluster"
	VSphere                  = "vSphere Kubernetes Cluster"
)

const (
	TkgSupervisorService = "supervisor"
)

const VddkConfigPath = "/tmp/config"

TODO: Merge constants from plugin and here

Functions

func CreateConfigFile

func CreateConfigFile(vddkConfig map[string]string, logger logrus.FieldLogger) (string, error)

func DeleteConfigFile

func DeleteConfigFile(path string, logger logrus.FieldLogger) error

func GetStringFromParamsMap

func GetStringFromParamsMap(params map[string]interface{}, key string, logger logrus.FieldLogger) (value string, ok bool)

func IsConnectionResetError

func IsConnectionResetError(err error) bool

func RetrievePlatformInfoFromConfig

func RetrievePlatformInfoFromConfig(config *rest.Config, params map[string]interface{}) error

Types

type ClusterFlavor

type ClusterFlavor string

Indicates the type of cluster where Plugin is installed

func GetClusterFlavor

func GetClusterFlavor(config *rest.Config) (ClusterFlavor, error)

Check the cluster flavor that the plugin is deployed in

type SeqWriterAt

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

func NewSeqWriterAt

func NewSeqWriterAt(w io.Writer) SeqWriterAt

func (SeqWriterAt) WriteAt

func (this SeqWriterAt) WriteAt(p []byte, offset int64) (n int, err error)