driver

Documentation

Index

• func CreateAWSCredentialsFromSecret(eksCluster *cluster.EKSCluster) (*credentials.Credentials, error)
• type ClusterDeleterEvents
• type CommonClusterGetter
• type EKSClusterDeleter
  • func NewEKSClusterDeleter(events ClusterDeleterEvents, kubeProxyCache KubeProxyCache, ...) EKSClusterDeleter
  • func (cd EKSClusterDeleter) DeleteCluster(ctx context.Context, clusterID uint, options intcluster.DeleteClusterOptions) error
• type EksClusterCreator
  • func NewEksClusterCreator(logger logrus.FieldLogger, workflowClient client.Client, ...) EksClusterCreator
  • func (c *EksClusterCreator) CreateCluster(ctx context.Context, commonCluster cluster.CommonCluster, ...) (cluster.CommonCluster, error)
• type EksClusterUpdater
  • func NewEksClusterUpdater(logger logrus.FieldLogger, workflowClient client.Client) EksClusterUpdater
  • func (c *EksClusterUpdater) UpdateCluster(ctx context.Context, request *pkgCluster.UpdateClusterRequest, ...) error
• type KubeProxyCache
• type SecretStore
• type ServiceRegionLister

Functions

func CreateAWSCredentialsFromSecret

func CreateAWSCredentialsFromSecret(eksCluster *cluster.EKSCluster) (*credentials.Credentials, error)

Types

type ClusterDeleterEvents

type ClusterDeleterEvents interface {
	ClusterDeleted(organizationID uint, clusterName string)
}

type CommonClusterGetter

type CommonClusterGetter interface {
	GetClusterByIDOnly(ctx context.Context, clusterID uint) (cluster.CommonCluster, error)
}

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.