commoncluster

Documentation

Index

• type CommonClusterGetter
  • func MakeCommonClusterGetter(secrets SecretStore, store pke.ClusterStore) CommonClusterGetter
  • func (g CommonClusterGetter) GetByID(clusterID uint) (*VspherePkeCluster, error)
• type SecretStore
• type VspherePkeCluster
  • func (a *VspherePkeCluster) AddDefaultsToUpdate(*pkgCluster.UpdateClusterRequest)
  • func (a *VspherePkeCluster) CheckEqualityToUpdate(*pkgCluster.UpdateClusterRequest) error
  • func (a *VspherePkeCluster) CreateCluster() error
  • func (a *VspherePkeCluster) DeleteCluster() error
  • func (a *VspherePkeCluster) DeleteFromDatabase() error
  • func (a *VspherePkeCluster) GetAPIEndpoint() (string, error)
  • func (a *VspherePkeCluster) GetCAHash() (string, error)
  • func (a *VspherePkeCluster) GetCloud() string
  • func (a *VspherePkeCluster) GetConfigSecretId() string
  • func (a *VspherePkeCluster) GetCreatedBy() uint
  • func (a *VspherePkeCluster) GetCurrentWorkflowID() string
  • func (a *VspherePkeCluster) GetDistribution() string
  • func (a *VspherePkeCluster) GetID() uint
  • func (a *VspherePkeCluster) GetK8sConfig() ([]byte, error)
  • func (a *VspherePkeCluster) GetK8sUserConfig() ([]byte, error)
  • func (a *VspherePkeCluster) GetKubernetesUserName() (string, error)
  • func (a *VspherePkeCluster) GetLocation() string
  • func (a *VspherePkeCluster) GetName() string
  • func (a *VspherePkeCluster) GetOrganizationId() uint
  • func (a *VspherePkeCluster) GetPKEOnVsphereCluster() pke.PKEOnVsphereCluster
  • func (a *VspherePkeCluster) GetSecretId() string
  • func (a *VspherePkeCluster) GetSecretWithValidation() (*secret.SecretItemResponse, error)
  • func (a *VspherePkeCluster) GetSshSecretId() string
  • func (a *VspherePkeCluster) GetStatus() (*pkgCluster.GetClusterStatusResponse, error)
  • func (a *VspherePkeCluster) GetUID() string
  • func (a *VspherePkeCluster) HasK8sConfig() (bool, error)
  • func (a *VspherePkeCluster) IsMasterReady() (bool, error)
  • func (a *VspherePkeCluster) IsReady() (bool, error)
  • func (a *VspherePkeCluster) NeedAdminRights() bool
  • func (a *VspherePkeCluster) NodePoolExists(nodePoolName string) bool
  • func (a *VspherePkeCluster) Persist() error
  • func (a *VspherePkeCluster) RbacEnabled() bool
  • func (a *VspherePkeCluster) RequiresSshPublicKey() bool
  • func (a *VspherePkeCluster) SaveConfigSecretId(secretID string) error
  • func (a *VspherePkeCluster) SaveSshSecretId(string) error
  • func (a *VspherePkeCluster) SetStatus(status string, statusMessage string) error
  • func (a *VspherePkeCluster) UpdateCluster(*pkgCluster.UpdateClusterRequest, uint) error
  • func (a *VspherePkeCluster) UpdateNodePools(*pkgCluster.UpdateNodePoolsRequest, uint) error
  • func (a *VspherePkeCluster) ValidateCreationFields(r *pkgCluster.CreateClusterRequest) error

Types

type CommonClusterGetter

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

func MakeCommonClusterGetter

func MakeCommonClusterGetter(secrets SecretStore, store pke.ClusterStore) CommonClusterGetter

func (CommonClusterGetter) GetByID

func (g CommonClusterGetter) GetByID(clusterID uint) (*VspherePkeCluster, error)

type SecretStore

type SecretStore interface {
	Get(organizationID uint, secretID string) (*secret.SecretItemResponse, error)
	GetByName(organizationID uint, secretName string) (*secret.SecretItemResponse, error)
}

type VspherePkeCluster

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

func (*VspherePkeCluster) AddDefaultsToUpdate

func (a *VspherePkeCluster) AddDefaultsToUpdate(*pkgCluster.UpdateClusterRequest)

func (*VspherePkeCluster) CheckEqualityToUpdate

func (a *VspherePkeCluster) CheckEqualityToUpdate(*pkgCluster.UpdateClusterRequest) error

func (*VspherePkeCluster) CreateCluster

func (a *VspherePkeCluster) CreateCluster() error

func (*VspherePkeCluster) DeleteCluster

func (a *VspherePkeCluster) DeleteCluster() error

func (*VspherePkeCluster) DeleteFromDatabase

func (a *VspherePkeCluster) DeleteFromDatabase() error

func (*VspherePkeCluster) GetAPIEndpoint

func (a *VspherePkeCluster) GetAPIEndpoint() (string, error)

func (*VspherePkeCluster) GetCAHash

func (a *VspherePkeCluster) GetCAHash() (string, error)

func (*VspherePkeCluster) GetCloud

func (a *VspherePkeCluster) GetCloud() string

func (*VspherePkeCluster) GetConfigSecretId

func (a *VspherePkeCluster) GetConfigSecretId() string

func (*VspherePkeCluster) GetCreatedBy

func (a *VspherePkeCluster) GetCreatedBy() uint

func (*VspherePkeCluster) GetCurrentWorkflowID

func (a *VspherePkeCluster) GetCurrentWorkflowID() string

func (*VspherePkeCluster) GetDistribution

func (a *VspherePkeCluster) GetDistribution() string

func (*VspherePkeCluster) GetID

func (a *VspherePkeCluster) GetID() uint

func (*VspherePkeCluster) GetK8sConfig

func (a *VspherePkeCluster) GetK8sConfig() ([]byte, error)

func (*VspherePkeCluster) GetK8sUserConfig

func (a *VspherePkeCluster) GetK8sUserConfig() ([]byte, error)

func (*VspherePkeCluster) GetKubernetesUserName

func (a *VspherePkeCluster) GetKubernetesUserName() (string, error)

func (*VspherePkeCluster) GetLocation

func (a *VspherePkeCluster) GetLocation() string

func (*VspherePkeCluster) GetName

func (a *VspherePkeCluster) GetName() string

func (*VspherePkeCluster) GetOrganizationId

func (a *VspherePkeCluster) GetOrganizationId() uint

func (*VspherePkeCluster) GetPKEOnVsphereCluster

func (a *VspherePkeCluster) GetPKEOnVsphereCluster() pke.PKEOnVsphereCluster

func (*VspherePkeCluster) GetSecretId

func (a *VspherePkeCluster) GetSecretId() string

func (*VspherePkeCluster) GetSecretWithValidation

func (a *VspherePkeCluster) GetSecretWithValidation() (*secret.SecretItemResponse, error)

func (*VspherePkeCluster) GetSshSecretId

func (a *VspherePkeCluster) GetSshSecretId() string

func (*VspherePkeCluster) GetStatus

func (a *VspherePkeCluster) GetStatus() (*pkgCluster.GetClusterStatusResponse, error)

func (*VspherePkeCluster) GetUID

func (a *VspherePkeCluster) GetUID() string

func (*VspherePkeCluster) HasK8sConfig

func (a *VspherePkeCluster) HasK8sConfig() (bool, error)

HasK8sConfig returns true if the cluster's k8s config is available

func (*VspherePkeCluster) IsMasterReady

func (a *VspherePkeCluster) IsMasterReady() (bool, error)

func (*VspherePkeCluster) IsReady

func (a *VspherePkeCluster) IsReady() (bool, error)

func (*VspherePkeCluster) NeedAdminRights

func (a *VspherePkeCluster) NeedAdminRights() bool

func (*VspherePkeCluster) NodePoolExists

func (a *VspherePkeCluster) NodePoolExists(nodePoolName string) bool

func (*VspherePkeCluster) Persist

func (a *VspherePkeCluster) Persist() error

func (*VspherePkeCluster) RbacEnabled

func (a *VspherePkeCluster) RbacEnabled() bool

func (*VspherePkeCluster) RequiresSshPublicKey

func (a *VspherePkeCluster) RequiresSshPublicKey() bool

func (*VspherePkeCluster) SaveConfigSecretId

func (a *VspherePkeCluster) SaveConfigSecretId(secretID string) error

func (*VspherePkeCluster) SaveSshSecretId

func (a *VspherePkeCluster) SaveSshSecretId(string) error

func (*VspherePkeCluster) SetStatus

func (a *VspherePkeCluster) SetStatus(status string, statusMessage string) error

func (*VspherePkeCluster) UpdateCluster

func (a *VspherePkeCluster) UpdateCluster(*pkgCluster.UpdateClusterRequest, uint) error

func (*VspherePkeCluster) UpdateNodePools

func (a *VspherePkeCluster) UpdateNodePools(*pkgCluster.UpdateNodePoolsRequest, uint) error

func (*VspherePkeCluster) ValidateCreationFields

func (a *VspherePkeCluster) ValidateCreationFields(r *pkgCluster.CreateClusterRequest) error