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
- type SecretStore
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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)
}
Source Files
Click to show internal directories.
Click to hide internal directories.