Documentation ¶
Index ¶
- Variables
- func DNSProviderKey(namespace, name string) resources.ObjectKey
- func DNSSetName(entry *api.DNSEntry) dns.DNSSetName
- func DNSSetNameMatcher(name dns.DNSSetName) resources.ObjectMatcher
- func GetDNSName(entry *api.DNSEntry) string
- func Match(hostname, domain string) bool
- func MatchSet(hostname string, domains utils.StringSet) int
- func ProcessElements(elems Elements, exec Executor, processors int) error
- func SetLastUpdateTime(lastUptimeTime **metav1.Time)
- func TTLToInt32(ttl int64) int32
- func TTLToUint32(ttl int64) uint32
- func ToDNSRoutingPolicy(policy *api.RoutingPolicy) *dns.RoutingPolicy
- type DNSEntryObject
- func (this *DNSEntryObject) AcknowledgeCNAMELookupInterval(interval int64) bool
- func (this *DNSEntryObject) AcknowledgeRoutingPolicy(policy *dns.RoutingPolicy) bool
- func (this *DNSEntryObject) AcknowledgeTargets(targets []string) bool
- func (this *DNSEntryObject) DNSEntry() *api.DNSEntry
- func (this *DNSEntryObject) DNSSetName() dns.DNSSetName
- func (this *DNSEntryObject) GetCNameLookupInterval() *int64
- func (this *DNSEntryObject) GetDNSName() string
- func (this *DNSEntryObject) GetOwnerId() *string
- func (this *DNSEntryObject) GetReference() *api.EntryReference
- func (this *DNSEntryObject) GetRoutingPolicy() *dns.RoutingPolicy
- func (this *DNSEntryObject) GetSetIdentifier() string
- func (this *DNSEntryObject) GetTTL() *int64
- func (this *DNSEntryObject) GetTargetSpec(p TargetProvider) TargetSpec
- func (this *DNSEntryObject) GetTargets() []string
- func (this *DNSEntryObject) GetText() []string
- func (this *DNSEntryObject) ResolveTargetsToAddresses() *bool
- func (this *DNSEntryObject) Spec() *api.DNSEntrySpec
- func (this *DNSEntryObject) Status() *api.DNSEntryStatus
- func (this *DNSEntryObject) StatusField() interface{}
- type DNSHostedZonePolicyObject
- type DNSOwnerObject
- func (this *DNSOwnerObject) DNSOwner() *api.DNSOwner
- func (this *DNSOwnerObject) GetCount() int
- func (this *DNSOwnerObject) GetCounts() map[string]int
- func (this *DNSOwnerObject) GetOwnerId() string
- func (this *DNSOwnerObject) IsActive() bool
- func (this *DNSOwnerObject) IsEnabled() bool
- func (this *DNSOwnerObject) Spec() *api.DNSOwnerSpec
- func (this *DNSOwnerObject) Status() *api.DNSOwnerStatus
- type DNSProviderObject
- func (this *DNSProviderObject) DNSProvider() *api.DNSProvider
- func (this *DNSProviderObject) SetSelection(included, excluded utils.StringSet, target *api.DNSSelectionStatus) bool
- func (this *DNSProviderObject) SetState(state, message string, commonMessagePrefix ...string) bool
- func (this *DNSProviderObject) SetStateWithError(_ string, err error) bool
- func (this *DNSProviderObject) Spec() *api.DNSProviderSpec
- func (this *DNSProviderObject) Status() *api.DNSProviderStatus
- func (this *DNSProviderObject) StatusField() interface{}
- func (this *DNSProviderObject) TypeCode() string
- type Elements
- type Executor
- type LogMessage
- func (this *LogMessage) Debugf(logger logger.LogContext, add ...interface{}) bool
- func (this *LogMessage) Errorf(logger logger.LogContext, add ...interface{}) bool
- func (this *LogMessage) Get() string
- func (this *LogMessage) Infof(logger logger.LogContext, add ...interface{}) bool
- func (this *LogMessage) Warnf(logger logger.LogContext, add ...interface{}) bool
- type RateLimiter
- type Target
- type TargetProvider
- type TargetSpec
- type Targets
- type TryLock
Constants ¶
This section is empty.
Variables ¶
View Source
var DNSEntryType = (*api.DNSEntry)(nil)
View Source
var DNSHostedZonePolicyType = (*api.DNSHostedZonePolicy)(nil)
View Source
var DNSOwnerType = (*api.DNSOwner)(nil)
View Source
var DNSProviderType = (*api.DNSProvider)(nil)
Functions ¶
func DNSProviderKey ¶
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 GetDNSName ¶ added in v0.18.0
func SetLastUpdateTime ¶ added in v0.7.21
SetLastUpdateTime sets the time wrapper to the current UTC time.
func TTLToInt32 ¶ added in v0.22.2
TTLToInt32 converts a TTL value to an int32 value.
func TTLToUint32 ¶ added in v0.22.2
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 ¶
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) 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) GetOwnerId ¶
func (this *DNSEntryObject) GetOwnerId() *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() interface{}
type DNSHostedZonePolicyObject ¶ added in v0.10.3
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 DNSOwnerObject ¶
func DNSOwner ¶
func DNSOwner(o resources.Object) *DNSOwnerObject
func (*DNSOwnerObject) DNSOwner ¶
func (this *DNSOwnerObject) DNSOwner() *api.DNSOwner
func (*DNSOwnerObject) GetCount ¶ added in v0.7.12
func (this *DNSOwnerObject) GetCount() int
func (*DNSOwnerObject) GetCounts ¶ added in v0.7.12
func (this *DNSOwnerObject) GetCounts() map[string]int
func (*DNSOwnerObject) GetOwnerId ¶
func (this *DNSOwnerObject) GetOwnerId() string
func (*DNSOwnerObject) IsActive ¶
func (this *DNSOwnerObject) IsActive() bool
func (*DNSOwnerObject) IsEnabled ¶ added in v0.10.3
func (this *DNSOwnerObject) IsEnabled() bool
func (*DNSOwnerObject) Spec ¶
func (this *DNSOwnerObject) Spec() *api.DNSOwnerSpec
func (*DNSOwnerObject) Status ¶ added in v0.11.0
func (this *DNSOwnerObject) Status() *api.DNSOwnerStatus
type DNSProviderObject ¶
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, commonMessagePrefix ...string) bool
func (*DNSProviderObject) SetStateWithError ¶ added in v0.7.8
func (this *DNSProviderObject) SetStateWithError(_ string, err error) 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() interface{}
func (*DNSProviderObject) TypeCode ¶
func (this *DNSProviderObject) TypeCode() string
type LogMessage ¶
type LogMessage struct {
// contains filtered or unexported fields
}
func NewLogMessage ¶
func NewLogMessage(msg string, args ...interface{}) *LogMessage
func (*LogMessage) Debugf ¶
func (this *LogMessage) Debugf(logger logger.LogContext, add ...interface{}) bool
func (*LogMessage) Errorf ¶
func (this *LogMessage) Errorf(logger logger.LogContext, add ...interface{}) bool
func (*LogMessage) Get ¶
func (this *LogMessage) Get() string
func (*LogMessage) Infof ¶
func (this *LogMessage) Infof(logger logger.LogContext, add ...interface{}) bool
func (*LogMessage) Warnf ¶
func (this *LogMessage) Warnf(logger logger.LogContext, add ...interface{}) 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 NewTargetWithIPStack ¶ added in v0.17.0
type TargetProvider ¶ added in v0.11.0
type TargetProvider interface { Targets() Targets TTL() int64 OwnerId() string RoutingPolicy() *dns.RoutingPolicy }
type TargetSpec ¶ added in v0.11.0
type TargetSpec interface { Kind() string OwnerId() string Targets() []Target RoutingPolicy() *dns.RoutingPolicy Responsible(set *dns.DNSSet, ownership dns.Ownership) bool }
func BaseTargetSpec ¶ added in v0.11.0
func BaseTargetSpec(entry *DNSEntryObject, p TargetProvider) TargetSpec
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
NewTryLock creates a lock based on a weighted semaphore.
func (*TryLock) TryLock ¶ added in v0.10.7
TryLock tries to acquire the resource and returns true if successful.
func (*TryLock) TryLockSpinning ¶ added in v0.10.7
TryLockSpinning tries to acquire the resource for some time and returns true if successful.
Click to show internal directories.
Click to hide internal directories.