commoncluster

Documentation

Index

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

Types

type AzurePkeCluster

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

func (*AzurePkeCluster) AddDefaultsToUpdate

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

func (*AzurePkeCluster) CheckEqualityToUpdate

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

func (*AzurePkeCluster) CreateCluster

func (a *AzurePkeCluster) CreateCluster() error

func (*AzurePkeCluster) DeleteCluster

func (a *AzurePkeCluster) DeleteCluster() error

func (*AzurePkeCluster) DeleteFromDatabase

func (a *AzurePkeCluster) DeleteFromDatabase() error

func (*AzurePkeCluster) GetAPIEndpoint

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

func (*AzurePkeCluster) GetCAHash

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

func (*AzurePkeCluster) GetCloud

func (a *AzurePkeCluster) GetCloud() string

func (*AzurePkeCluster) GetConfigSecretId

func (a *AzurePkeCluster) GetConfigSecretId() string

func (*AzurePkeCluster) GetCurrentWorkflowID

func (a *AzurePkeCluster) GetCurrentWorkflowID() string

func (*AzurePkeCluster) GetDistribution

func (a *AzurePkeCluster) GetDistribution() string

func (*AzurePkeCluster) GetID

func (a *AzurePkeCluster) GetID() uint

func (*AzurePkeCluster) GetK8sConfig

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

func (*AzurePkeCluster) GetK8sUserConfig

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

func (*AzurePkeCluster) GetKubernetesVersion

func (a *AzurePkeCluster) GetKubernetesVersion() (string, error)

func (*AzurePkeCluster) GetLocation

func (a *AzurePkeCluster) GetLocation() string

func (*AzurePkeCluster) GetName

func (a *AzurePkeCluster) GetName() string

func (*AzurePkeCluster) GetOrganizationId

func (a *AzurePkeCluster) GetOrganizationId() uint

func (*AzurePkeCluster) GetPKEOnAzureCluster

func (a *AzurePkeCluster) GetPKEOnAzureCluster() pke.Cluster

func (*AzurePkeCluster) GetResourceGroupName

func (a *AzurePkeCluster) GetResourceGroupName() string

func (*AzurePkeCluster) GetSecretId

func (a *AzurePkeCluster) GetSecretId() string

func (*AzurePkeCluster) GetSecretWithValidation

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

func (*AzurePkeCluster) GetSshSecretId

func (a *AzurePkeCluster) GetSshSecretId() string

func (*AzurePkeCluster) GetStatus

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

func (*AzurePkeCluster) GetUID

func (a *AzurePkeCluster) GetUID() string

func (*AzurePkeCluster) HasK8sConfig

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

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

func (*AzurePkeCluster) IsMasterReady

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

func (*AzurePkeCluster) IsReady

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

func (*AzurePkeCluster) ListNodePools

func (a *AzurePkeCluster) ListNodePools() ([]string, error)

ListNodePools returns node pool names.

func (*AzurePkeCluster) NodePoolExists

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

func (*AzurePkeCluster) Persist

func (a *AzurePkeCluster) Persist() error

func (*AzurePkeCluster) RbacEnabled

func (a *AzurePkeCluster) RbacEnabled() bool

func (*AzurePkeCluster) RequiresSshPublicKey

func (a *AzurePkeCluster) RequiresSshPublicKey() bool

func (*AzurePkeCluster) SaveConfigSecretId

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

func (*AzurePkeCluster) SaveSshSecretId

func (a *AzurePkeCluster) SaveSshSecretId(string) error

func (*AzurePkeCluster) SetStatus

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

func (*AzurePkeCluster) UpdateCluster

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

func (*AzurePkeCluster) UpdateNodePools

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

func (*AzurePkeCluster) ValidateCreationFields

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

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) (*AzurePkeCluster, error)

type SecretStore

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