utils

package
v0.41.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 13, 2026 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DNSEntryType = (*api.DNSEntry)(nil)
View Source 
var DNSHostedZonePolicyType = (*api.DNSHostedZonePolicy)(nil)
View Source 
var DNSProviderType = (*api.DNSProvider)(nil)

Functions

func DNSProviderKey 

func DNSProviderKey(namespace, name string) resources.ObjectKey

func DNSSetName added in v0.18.0 

func DNSSetName(entry *api.DNSEntry) dns.DNSSetName

func DNSSetNameMatcher added in v0.13.0 

func DNSSetNameMatcher(name dns.DNSSetName) resources.ObjectMatcher

func DetermineErrorCodes added in v0.40.0 

func DetermineErrorCodes(err error) []gardencorev1beta1.ErrorCode

DetermineErrorCodes analyzes an error message and returns appropriate Gardener error codes. This enables Gardener to distinguish between user configuration errors and system-level failures, allowing for proper retry logic and error propagation to Shoot status.

func GetDNSName added in v0.18.0 

func GetDNSName(entry *api.DNSEntry) string

func HasNonRetryableErrorCode added in v0.40.0 

func HasNonRetryableErrorCode(codes []gardencorev1beta1.ErrorCode) bool

HasNonRetryableErrorCode checks if any of the provided error codes indicate a non-retryable error (e.g., authentication failure, configuration problem).

func Match 

func Match(hostname, domain string) bool

func MatchSet 

func MatchSet(hostname string, domains utils.StringSet) int

func ProcessElements 

func ProcessElements(elems Elements, exec Executor, processors int) error

func SetLastOperationAndError added in v0.40.0 

func SetLastOperationAndError(status *api.DNSProviderStatus, lastOperation *gardencorev1beta1.LastOperation, lastError *gardencorev1beta1.LastError) bool

func SetLastOperationAndErrorTime added in v0.40.0 

func SetLastOperationAndErrorTime(status *api.DNSProviderStatus)

func SetLastUpdateTime added in v0.7.21 

func SetLastUpdateTime(lastUpdateTime **metav1.Time)

SetLastUpdateTime sets the time wrapper to the current UTC time.

func TTLToInt32 added in v0.22.2 

func TTLToInt32(ttl int64) int32

TTLToInt32 converts a TTL value to an int32 value.

func TTLToUint32 added in v0.22.2 

func TTLToUint32(ttl int64) uint32

TTLToUint32 converts a TTL value to an uint32 value.

func ToDNSRoutingPolicy added in v0.21.0 

func ToDNSRoutingPolicy(policy *api.RoutingPolicy) *dns.RoutingPolicy

Types

type DNSEntryObject 

type DNSEntryObject struct {
	resources.Object
}

func DNSEntry 

func DNSEntry(o resources.Object) *DNSEntryObject

func (*DNSEntryObject) AcknowledgeCNAMELookupInterval added in v0.19.0 

func (this *DNSEntryObject) AcknowledgeCNAMELookupInterval(interval int64) bool

func (*DNSEntryObject) AcknowledgeDNSName added in v0.25.2 

func (this *DNSEntryObject) AcknowledgeDNSName(name *string) bool

func (*DNSEntryObject) AcknowledgeRoutingPolicy added in v0.13.0 

func (this *DNSEntryObject) AcknowledgeRoutingPolicy(policy *dns.RoutingPolicy) bool

func (*DNSEntryObject) AcknowledgeTargets added in v0.11.0 

func (this *DNSEntryObject) AcknowledgeTargets(targets []string) bool

func (*DNSEntryObject) DNSEntry 

func (this *DNSEntryObject) DNSEntry() *api.DNSEntry

func (*DNSEntryObject) DNSSetName added in v0.13.0 

func (this *DNSEntryObject) DNSSetName() dns.DNSSetName

func (*DNSEntryObject) GetCNameLookupInterval 

func (this *DNSEntryObject) GetCNameLookupInterval() *int64

func (*DNSEntryObject) GetDNSName 

func (this *DNSEntryObject) GetDNSName() string

func (*DNSEntryObject) GetReference added in v0.11.0 

func (this *DNSEntryObject) GetReference() *api.EntryReference

func (*DNSEntryObject) GetRoutingPolicy added in v0.13.0 

func (this *DNSEntryObject) GetRoutingPolicy() *dns.RoutingPolicy

func (*DNSEntryObject) GetSetIdentifier added in v0.13.0 

func (this *DNSEntryObject) GetSetIdentifier() string

func (*DNSEntryObject) GetTTL 

func (this *DNSEntryObject) GetTTL() *int64

func (*DNSEntryObject) GetTargetSpec added in v0.11.0 

func (this *DNSEntryObject) GetTargetSpec(p TargetProvider) TargetSpec

func (*DNSEntryObject) GetTargets 

func (this *DNSEntryObject) GetTargets() []string

func (*DNSEntryObject) GetText added in v0.11.0 

func (this *DNSEntryObject) GetText() []string

func (*DNSEntryObject) ResolveTargetsToAddresses added in v0.19.0 

func (this *DNSEntryObject) ResolveTargetsToAddresses() *bool

func (*DNSEntryObject) Spec 

func (this *DNSEntryObject) Spec() *api.DNSEntrySpec

func (*DNSEntryObject) Status 

func (this *DNSEntryObject) Status() *api.DNSEntryStatus

func (*DNSEntryObject) StatusField added in v0.7.12 

func (this *DNSEntryObject) StatusField() any

type DNSHostedZonePolicyObject added in v0.10.3 

type DNSHostedZonePolicyObject struct {
	resources.Object
}

func DNSHostedZonePolicy added in v0.10.3 

func DNSHostedZonePolicy(o resources.Object) *DNSHostedZonePolicyObject

func (*DNSHostedZonePolicyObject) DNSHostedZonePolicyObject added in v0.10.3 

func (this *DNSHostedZonePolicyObject) DNSHostedZonePolicyObject() *api.DNSHostedZonePolicy

func (*DNSHostedZonePolicyObject) Spec added in v0.10.3 

func (this *DNSHostedZonePolicyObject) Spec() *api.DNSHostedZonePolicySpec

func (*DNSHostedZonePolicyObject) Status added in v0.10.3 

func (this *DNSHostedZonePolicyObject) Status() *api.DNSHostedZonePolicyStatus

type DNSProviderObject 

type DNSProviderObject struct {
	resources.Object
}

func DNSProvider 

func DNSProvider(o resources.Object) *DNSProviderObject

func (*DNSProviderObject) DNSProvider 

func (this *DNSProviderObject) DNSProvider() *api.DNSProvider

func (*DNSProviderObject) SetSelection 

func (this *DNSProviderObject) SetSelection(included, excluded utils.StringSet, target *api.DNSSelectionStatus) bool

func (*DNSProviderObject) SetState 

func (this *DNSProviderObject) SetState(state, message string, errorCodes []gardencorev1beta1.ErrorCode, commonMessagePrefix ...string) bool

func (*DNSProviderObject) SetStateWithError added in v0.7.8 

func (this *DNSProviderObject) SetStateWithError(_ string, err error, errorCodes ...gardencorev1beta1.ErrorCode) bool

func (*DNSProviderObject) Spec 

func (this *DNSProviderObject) Spec() *api.DNSProviderSpec

func (*DNSProviderObject) Status 

func (this *DNSProviderObject) Status() *api.DNSProviderStatus

func (*DNSProviderObject) StatusField added in v0.7.12 

func (this *DNSProviderObject) StatusField() any

func (*DNSProviderObject) TypeCode 

func (this *DNSProviderObject) TypeCode() string

type Elements 

type Elements []resources.Object

type Executor 

type Executor func(resources.Object) error

type LogMessage 

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

func NewLogMessage 

func NewLogMessage(msg string, args ...any) *LogMessage

func (*LogMessage) Debugf 

func (this *LogMessage) Debugf(logger logger.LogContext, add ...any) bool

func (*LogMessage) Errorf 

func (this *LogMessage) Errorf(logger logger.LogContext, add ...any) bool

func (*LogMessage) Get 

func (this *LogMessage) Get() string

func (*LogMessage) Infof 

func (this *LogMessage) Infof(logger logger.LogContext, add ...any) bool

func (*LogMessage) Warnf 

func (this *LogMessage) Warnf(logger logger.LogContext, add ...any) bool

type RateLimiter added in v0.7.9 

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

func NewRateLimiter added in v0.7.9 

func NewRateLimiter(min, max time.Duration) *RateLimiter

func (*RateLimiter) Failed added in v0.7.9 

func (this *RateLimiter) Failed()

func (*RateLimiter) RateLimit added in v0.7.9 

func (this *RateLimiter) RateLimit() time.Duration

func (*RateLimiter) Succeeded added in v0.7.9 

func (this *RateLimiter) Succeeded()

type Target added in v0.11.0 

type Target interface {
	GetHostName() string
	GetRecordType() string
	GetTTL() int64
	AsRecord() *dns.Record
	GetIPStack() string
}

func NewTarget added in v0.11.0 

func NewTarget(ty string, ta string, ttl int64) Target

func NewTargetWithIPStack added in v0.17.0 

func NewTargetWithIPStack(ty string, ta string, ttl int64, ipstack string) Target

func NewText added in v0.11.0 

func NewText(t string, ttl int64) Target

type TargetProvider added in v0.11.0 

type TargetProvider interface {
	Targets() Targets
	TTL() int64
	RoutingPolicy() *dns.RoutingPolicy
}

type TargetSpec added in v0.11.0 

type TargetSpec interface {
	Targets() []Target
	RoutingPolicy() *dns.RoutingPolicy
}

func BaseTargetSpec added in v0.11.0 

func BaseTargetSpec(p TargetProvider) TargetSpec

type Targets added in v0.11.0 

type Targets []Target

func (Targets) DifferFrom added in v0.11.0 

func (this Targets) DifferFrom(targets Targets) bool

func (Targets) Has added in v0.11.0 

func (this Targets) Has(target Target) bool

type TryLock added in v0.10.7 

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

TryLock is a lock supporting both `Lock` and `TryLock` by wrapping a weighted semaphore.

func NewTryLock added in v0.10.7 

func NewTryLock(ctx ...context.Context) *TryLock

NewTryLock creates a lock based on a weighted semaphore.

func (*TryLock) Lock added in v0.10.7 

func (l *TryLock) Lock() error

Lock acquires the lock blocking until resource is available

func (*TryLock) TryLock added in v0.10.7 

func (l *TryLock) TryLock() bool

TryLock tries to acquire the resource and returns true if successful.

func (*TryLock) TryLockSpinning added in v0.10.7 

func (l *TryLock) TryLockSpinning(spinTime time.Duration) bool

TryLockSpinning tries to acquire the resource for some time and returns true if successful.

func (*TryLock) Unlock added in v0.10.7 

func (l *TryLock) Unlock()

Unlock releases the resource

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.