shootOperations

Documentation

Index

• Constants
• func CheckReadinessAndUpdateShootClusterObj(gardenCs gardenClientSet.Interface, shootCluster *v1alpha1.ShootCluster) (err error)
• func CreateShootCluster(sdkops common.SdkOperations, gardenCs gardenClientSet.Interface, ...) (*v1beta1.Shoot, error)
• func DefaultAwsConfig() *gApiV1beta.Shoot
• func NewK8sCleaner(cs kubernetes.Interface, log *logrus.Entry) *clusterCleaner
• type CollectionDeleter
• type Operator
• type ShootOperator
  • func NewShootOperator(sdkops common.SdkOperations, cache k8sClientCache.ClientCacher, ...) *ShootOperator
  • func (so *ShootOperator) Delete(shootCluster *v1alpha1.ShootCluster) error
  • func (so *ShootOperator) Sync(shootCluster *v1alpha1.ShootCluster) error
• type ShootOperatorFactory
  • func NewShootOperatorFactory(opSdk common.SdkOperations, cache k8sClientCache.ClientCacher, ...) ShootOperatorFactory
• type SubnetGenerator
  • func NewSubnetGenerator(baseCIDR string) *SubnetGenerator
  • func (sng *SubnetGenerator) GenerateNext24Subnet() (string, error)
  • func (sng *SubnetGenerator) GenerateNext25Subnet() (string, error)
  • func (sng *SubnetGenerator) GenerateSubnet(size int) (string, error)
  • func (sng *SubnetGenerator) Init(blockedCIDRs []*net.IPNet)

Constants

const (
	ENVDnsDomainSuffix               = "AWS_DNS_DOMAIN_SUFFIX"
	ENVAwsMaintenanceAutoupdate      = "AWS_MAINTENANCE_AUTOUPDATE"
	ENVAwsMaintenanceAutoUpdateBegin = "AWS_MAINTENANCE_AUTOUPDATE_TWBEGIN"
	ENVAwsMaintenanceAutoUpdateEnd   = "AWS_MAINTENANCE_AUTOUPDATE_TWBEND"
	ENVSecretBindingRef              = "SECRET_BINDING_REF"
)

Functions

func CheckReadinessAndUpdateShootClusterObj

func CheckReadinessAndUpdateShootClusterObj(gardenCs gardenClientSet.Interface, shootCluster *v1alpha1.ShootCluster) (err error)

func CreateShootCluster

func CreateShootCluster(sdkops common.SdkOperations, gardenCs gardenClientSet.Interface, shootCluster *v1alpha1.ShootCluster, log *logrus.Entry) (*v1beta1.Shoot, error)

func DefaultAwsConfig

func DefaultAwsConfig() *gApiV1beta.Shoot

func NewK8sCleaner

func NewK8sCleaner(cs kubernetes.Interface, log *logrus.Entry) *clusterCleaner

Types

type CollectionDeleter

type CollectionDeleter interface {
	DeleteCollection(options *v1.DeleteOptions, listOptions v1.ListOptions) error
}

type Operator

type Operator interface {
	Sync(shootCluster *v1alpha1.ShootCluster) error
	Delete(shootCluster *v1alpha1.ShootCluster) error
}

type ShootOperator

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

func NewShootOperator

func NewShootOperator(sdkops common.SdkOperations, cache k8sClientCache.ClientCacher, csFactory utils.K8sClientSetCreator, log *logrus.Entry) *ShootOperator

func (*ShootOperator) Delete

func (so *ShootOperator) Delete(shootCluster *v1alpha1.ShootCluster) error

func (*ShootOperator) Sync

func (so *ShootOperator) Sync(shootCluster *v1alpha1.ShootCluster) error

type ShootOperatorFactory

type ShootOperatorFactory interface {
	Get(log *logrus.Entry) *ShootOperator
}

func NewShootOperatorFactory

func NewShootOperatorFactory(opSdk common.SdkOperations, cache k8sClientCache.ClientCacher, csCreator utils.K8sClientSetCreator) ShootOperatorFactory

type SubnetGenerator

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

func NewSubnetGenerator

func NewSubnetGenerator(baseCIDR string) *SubnetGenerator

* Generates a new subnet generator. Requires a base subnet (baseCIDR) where all generated subnets will lie in

sng := NewsubnetGenerator("10.250.0.0/16") blockedCIDRs := map[string]struct{} {"10.250.0.0/24" : struct{}{}, "10.250.1.0/24" : struct{}{}} nextSn, _ := sng.GenerateSubnet(254)

func (*SubnetGenerator) GenerateNext24Subnet

func (sng *SubnetGenerator) GenerateNext24Subnet() (string, error)

func (*SubnetGenerator) GenerateNext25Subnet

func (sng *SubnetGenerator) GenerateNext25Subnet() (string, error)

func (*SubnetGenerator) GenerateSubnet

func (sng *SubnetGenerator) GenerateSubnet(size int) (string, error)

func (*SubnetGenerator) Init

func (sng *SubnetGenerator) Init(blockedCIDRs []*net.IPNet)

initializes the generator with the given map of CIDRs. After the call, no generated subnet will overlap with the ones given in blockedCIDRs