common

Documentation

Index

• Constants
• func CopyMap(m map[string]string) map[string]string
• func FindExtension(ctx context.Context, reader client.Reader, namespace string) (*extapi.Extension, error)
• func IsMigrating(ex *extensionsv1alpha1.Extension) bool
• func IsRestoring(ex *extensionsv1alpha1.Extension) bool
• func ShortenID(id string, maxlen int) string
• type Env
  • func NewEnv(name string, config config.DNSServiceConfig) *Env
  • func (e *Env) APIReader() client.Reader
  • func (e *Env) Client() client.Client
  • func (e *Env) Config() *config.DNSServiceConfig
  • func (e *Env) CreateObject(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
  • func (e *Env) GetObject(ctx context.Context, key client.ObjectKey, obj client.Object) error
  • func (e *Env) InjectAPIReader(reader client.Reader) error
  • func (e *Env) InjectClient(client client.Client) error
  • func (e *Env) InjectConfig(config *rest.Config) error
  • func (e *Env) InjectFunc(f inject.Func) error
  • func (e *Env) InjectLogger(l logr.Logger) error
  • func (e *Env) RestConfig() *rest.Config
  • func (e *Env) UpdateObject(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
• type ShootDNSEntriesHelper
  • func NewShootDNSEntriesHelper(ctx context.Context, client client.Client, ext *v1alpha1.Extension) *ShootDNSEntriesHelper
  • func (h *ShootDNSEntriesHelper) Context() context.Context
  • func (h *ShootDNSEntriesHelper) DeleteAll() error
  • func (h *ShootDNSEntriesHelper) Extension() *v1alpha1.Extension
  • func (h *ShootDNSEntriesHelper) GetCluster() (*controller.Cluster, error)
  • func (h *ShootDNSEntriesHelper) List() ([]dnsapi.DNSEntry, error)
  • func (h *ShootDNSEntriesHelper) ShootDNSEntryMatchingLabel() (client.MatchingLabels, error)
  • func (h *ShootDNSEntriesHelper) ShootID() (string, string, error)
• type StateHandler
  • func NewStateHandler(ctx context.Context, env *Env, ext *v1alpha1.Extension, refresh bool) (*StateHandler, error)
  • func (s *StateHandler) Delete(name string) error
  • func (s *StateHandler) EnsureEntries(entries []dnsapi.DNSEntry) bool
  • func (s *StateHandler) EnsureEntryDeleted(name string) bool
  • func (s *StateHandler) EnsureEntryFor(entry *dnsapi.DNSEntry) bool
  • func (s *StateHandler) Infof(msg string, args ...interface{})
  • func (s *StateHandler) Refresh() (bool, error)
  • func (s *StateHandler) ShootDNSEntriesHelper() *ShootDNSEntriesHelper
  • func (s *StateHandler) StateItems() []*apis.DNSEntry
  • func (s *StateHandler) Update(reason string) error

Constants

const (
	ANNOTATION_OPERATION         = constants.GardenerOperation
	ANNOTATION_OPERATION_MIGRATE = constants.GardenerOperationMigrate
	ANNOTATION_OPERATION_RESTORE = constants.GardenerOperationRestore
)

const ShootDNSEntryLabelKey = "gardener.cloud/shoot-id"

ShootDNSEntryLabelKey is the label key for DNS entries managed for shoots

Functions

func CopyMap

func CopyMap(m map[string]string) map[string]string

func FindExtension

func FindExtension(ctx context.Context, reader client.Reader, namespace string) (*extapi.Extension, error)

func IsMigrating

func IsMigrating(ex *extensionsv1alpha1.Extension) bool

func IsRestoring

func IsRestoring(ex *extensionsv1alpha1.Extension) bool

func ShortenID

func ShortenID(id string, maxlen int) string

ShortenID shortens an identifier longer than maxlen characters by cutting the string and adding a hash suffix so that total length is maxlen. Identifiers are preserved if length < maxlen.

Types

type Env

type Env struct {
	logr.Logger
	// contains filtered or unexported fields
}

func NewEnv

func NewEnv(name string, config config.DNSServiceConfig) *Env

func (*Env) APIReader

func (e *Env) APIReader() client.Reader

func (*Env) Client

func (e *Env) Client() client.Client

func (*Env) Config

func (e *Env) Config() *config.DNSServiceConfig

func (*Env) CreateObject

func (e *Env) CreateObject(ctx context.Context, obj client.Object, opts ...client.CreateOption) error

func (*Env) GetObject

func (e *Env) GetObject(ctx context.Context, key client.ObjectKey, obj client.Object) error

func (*Env) InjectAPIReader

func (e *Env) InjectAPIReader(reader client.Reader) error

InjectAPIReader injects the APIReader into the reconciler.

func (*Env) InjectClient

func (e *Env) InjectClient(client client.Client) error

InjectConfig injects the caching client into the reconciler.

func (*Env) InjectConfig

func (e *Env) InjectConfig(config *rest.Config) error

InjectConfig injects the rest configuration into the reconciler.

func (*Env) InjectFunc

func (e *Env) InjectFunc(f inject.Func) error

InjectFunc enables dependency injection into the actuator.

func (*Env) InjectLogger

func (e *Env) InjectLogger(l logr.Logger) error

InjectLogger injects the controller runtime client into the reconciler.

func (*Env) RestConfig

func (e *Env) RestConfig() *rest.Config

func (*Env) UpdateObject

func (e *Env) UpdateObject(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

type ShootDNSEntriesHelper

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

func NewShootDNSEntriesHelper

func NewShootDNSEntriesHelper(ctx context.Context, client client.Client, ext *v1alpha1.Extension) *ShootDNSEntriesHelper

func (*ShootDNSEntriesHelper) Context

func (h *ShootDNSEntriesHelper) Context() context.Context

func (*ShootDNSEntriesHelper) DeleteAll

func (h *ShootDNSEntriesHelper) DeleteAll() error

func (*ShootDNSEntriesHelper) Extension

func (h *ShootDNSEntriesHelper) Extension() *v1alpha1.Extension

func (*ShootDNSEntriesHelper) GetCluster

func (h *ShootDNSEntriesHelper) GetCluster() (*controller.Cluster, error)

func (*ShootDNSEntriesHelper) List

func (h *ShootDNSEntriesHelper) List() ([]dnsapi.DNSEntry, error)

func (*ShootDNSEntriesHelper) ShootDNSEntryMatchingLabel

func (h *ShootDNSEntriesHelper) ShootDNSEntryMatchingLabel() (client.MatchingLabels, error)

func (*ShootDNSEntriesHelper) ShootID

func (h *ShootDNSEntriesHelper) ShootID() (string, string, error)

type StateHandler

type StateHandler struct {
	*Env
	// contains filtered or unexported fields
}

func NewStateHandler

func NewStateHandler(ctx context.Context, env *Env, ext *v1alpha1.Extension, refresh bool) (*StateHandler, error)

func (*StateHandler) Delete

func (s *StateHandler) Delete(name string) error

func (*StateHandler) EnsureEntries

func (s *StateHandler) EnsureEntries(entries []dnsapi.DNSEntry) bool

func (*StateHandler) EnsureEntryDeleted

func (s *StateHandler) EnsureEntryDeleted(name string) bool

func (*StateHandler) EnsureEntryFor

func (s *StateHandler) EnsureEntryFor(entry *dnsapi.DNSEntry) bool

func (*StateHandler) Infof

func (s *StateHandler) Infof(msg string, args ...interface{})

func (*StateHandler) Refresh

func (s *StateHandler) Refresh() (bool, error)

func (*StateHandler) ShootDNSEntriesHelper

func (s *StateHandler) ShootDNSEntriesHelper() *ShootDNSEntriesHelper

func (*StateHandler) StateItems

func (s *StateHandler) StateItems() []*apis.DNSEntry

func (*StateHandler) Update

func (s *StateHandler) Update(reason string) error