Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateAWSCredentialsFromSecret ¶
func CreateAWSCredentialsFromSecret(eksCluster *cluster.EKSCluster) (*credentials.Credentials, error)
Types ¶
type ClusterDeleterEvents ¶
type CommonClusterGetter ¶
type EKSClusterDeleter ¶
type EKSClusterDeleter struct {
// contains filtered or unexported fields
}
func NewEKSClusterDeleter ¶
func NewEKSClusterDeleter( events ClusterDeleterEvents, kubeProxyCache KubeProxyCache, logger logrus.FieldLogger, secrets SecretStore, statusChangeDurationMetric metrics.ClusterStatusChangeDurationMetric, workflowClient client.Client, clusterGetter CommonClusterGetter, ) EKSClusterDeleter
func (EKSClusterDeleter) DeleteCluster ¶
func (cd EKSClusterDeleter) DeleteCluster(ctx context.Context, clusterID uint, options intcluster.DeleteClusterOptions) error
DeleteCluster deletes an EKS Cluster
type EksClusterCreator ¶
type EksClusterCreator struct {
// contains filtered or unexported fields
}
func NewEksClusterCreator ¶
func NewEksClusterCreator( logger logrus.FieldLogger, workflowClient client.Client, serviceRegionLister ServiceRegionLister, clusters clusterRepository, secrets secretValidator, statusChangeDurationMetric metrics.ClusterStatusChangeDurationMetric, clusterTotalMetric *prometheus.CounterVec, ) EksClusterCreator
func (*EksClusterCreator) CreateCluster ¶
func (c *EksClusterCreator) CreateCluster(ctx context.Context, commonCluster cluster.CommonCluster, createRequest *pkgCluster.CreateClusterRequest, organizationID uint, userID uint) (cluster.CommonCluster, error)
type EksClusterUpdater ¶
type EksClusterUpdater struct {
// contains filtered or unexported fields
}
func NewEksClusterUpdater ¶
func NewEksClusterUpdater(logger logrus.FieldLogger, workflowClient client.Client) EksClusterUpdater
func (*EksClusterUpdater) UpdateCluster ¶
func (c *EksClusterUpdater) UpdateCluster(ctx context.Context, request *pkgCluster.UpdateClusterRequest, commonCluster cluster.CommonCluster, userID uint, ) error
type KubeProxyCache ¶
type KubeProxyCache interface {
Delete(clusterUID string)
}
type SecretStore ¶
type SecretStore interface {
Get(orgnaizationID uint, secretID string) (*secret.SecretItemResponse, error)
}
type ServiceRegionLister ¶
type ServiceRegionLister interface {
// GetServiceRegions returns the cloud provider regions where the specified service is available.
GetServiceRegions(ctx context.Context, cloudProvider string, service string) ([]string, error)
}
ServiceRegionLister lists regions where a service is available.
Source Files
Click to show internal directories.
Click to hide internal directories.