Documentation
¶
Index ¶
- Constants
- Variables
- func AddRecord(targetsets dns.RecordSets, ty string, host string, ttl int64)
- func AlwaysRateLimiter() flowcontrol.RateLimiter
- func AssureTimestamp(target **metav1.Time, ts time.Time) bool
- func Create(c controller.Interface, factory DNSHandlerFactory) (reconcile.Interface, error)
- func CreateFactoryOptionSource(factory DNSHandlerFactory, prefix string) config.OptionSource
- func DNSController(name string, factory DNSHandlerFactory) controller.Configuration
- func DNSReconcilerType(factory DNSHandlerFactory) controller.ReconcilerType
- func EqualAttrs(a, b map[string]string) bool
- func FactoryOptionSourceCreator(factory DNSHandlerFactory) extension.OptionSourceCreator
- func HandlerStringMapper(name string) func(s string) string
- func Match(zone DNSHostedZone, dnsname string) int
- func NewDNSState(ctx Context, ownerresc resources.Interface, classes *controller.Classes, ...) *state
- func Provider(p DNSProvider) string
- func StatusMessage(s string) *string
- func StatusMessagef(msgfmt string, args ...interface{}) *string
- func ToDedicatedRecordset(rawrs DedicatedRecordSet) (string, *dns.RecordSet)
- type AccountCache
- func (this *AccountCache) Get(logger logger.LogContext, provider *dnsutils.DNSProviderObject, ...) (*DNSAccount, error)
- func (this *AccountCache) Hash(props utils.Properties, ptype string, extension *runtime.RawExtension) string
- func (this *AccountCache) Release(logger logger.LogContext, a *DNSAccount, name resources.ObjectName)
- type AdvancedConfig
- type AdvancedOptions
- func (this *AdvancedOptions) AddOptionsToSet(set config.OptionSet)
- func (c *AdvancedOptions) GetAdvancedConfig() AdvancedConfig
- func (c *AdvancedOptions) GetBlockedZones() utils.StringSet
- func (c AdvancedOptions) SetBatchSize(batchSize int) AdvancedOptions
- func (c AdvancedOptions) SetMaxRetries(maxRetries int) AdvancedOptions
- type ChangeGroup
- type ChangeModel
- func (this *ChangeModel) Apply(name, updateGroup string, createdAt time.Time, done DoneHandler, ...) ChangeResult
- func (this *ChangeModel) ApplySpec(set *dns.DNSSet, base *dns.DNSSet, provider DNSProvider, spec TargetSpec) *dns.DNSSet
- func (this *ChangeModel) Cleanup(logger logger.LogContext) bool
- func (this *ChangeModel) Delete(name, updateGroup string, createdAt time.Time, done DoneHandler, ...) ChangeResult
- func (this *ChangeModel) Domain() string
- func (this *ChangeModel) Exec(apply bool, delete bool, name, updateGroup string, createdAt time.Time, ...) ChangeResult
- func (this *ChangeModel) IsFailed(dnsName string) bool
- func (this *ChangeModel) IsForeign(set *dns.DNSSet) bool
- func (this *ChangeModel) IsStale(dns ZonedDNSName) *Entry
- func (this *ChangeModel) Owns(set *dns.DNSSet) bool
- func (this *ChangeModel) Setup() error
- func (this *ChangeModel) Update(logger logger.LogContext) error
- func (this *ChangeModel) ZoneId() string
- type ChangeRequest
- type ChangeRequests
- type ChangeResult
- type CompoundFactory
- func (this *CompoundFactory) Add(f DNSHandlerFactory, finalizer ...string) error
- func (this *CompoundFactory) Create(typecode string, cfg *DNSHandlerConfig) (DNSHandler, error)
- func (this *CompoundFactory) CreateOptionSource() (config.OptionSource, *GenericFactoryOptions)
- func (this *CompoundFactory) Finalizers() utils.StringSet
- func (this *CompoundFactory) IsResponsibleFor(object *dnsutils.DNSProviderObject) bool
- func (this *CompoundFactory) Name() string
- func (this *CompoundFactory) SupportZoneStateCache(typecode string) (bool, error)
- func (this *CompoundFactory) TypeCodes() utils.StringSet
- type Config
- type Context
- type DNSAccount
- func (this *DNSAccount) AddGenericRequests(requestType string, n int)
- func (this *DNSAccount) AddZoneRequests(zoneID, requestType string, n int)
- func (this *DNSAccount) ExecuteRequests(logger logger.LogContext, zone DNSHostedZone, state DNSZoneState, ...) error
- func (this *DNSAccount) GetZoneState(zone DNSHostedZone) (DNSZoneState, error)
- func (this *DNSAccount) GetZones() (DNSHostedZones, error)
- func (this *DNSAccount) Hash() string
- func (this *DNSAccount) MapTarget(t Target) Target
- func (this *DNSAccount) ProviderType() string
- func (this *DNSAccount) Release()
- func (this *DNSAccount) ReportZoneStateConflict(zone DNSHostedZone, err error) bool
- type DNSHandler
- type DNSHandlerConfig
- func (c *DNSHandlerConfig) Complete() error
- func (c *DNSHandlerConfig) FillDefaultedBoolProperty(target **bool, def bool, prop string, alt ...string) error
- func (c *DNSHandlerConfig) FillDefaultedIntProperty(target **int, def int, prop string, alt ...string) error
- func (c *DNSHandlerConfig) FillDefaultedProperty(target **string, def string, prop string, alt ...string) error
- func (c *DNSHandlerConfig) FillRequiredIntProperty(target **int, prop string, alt ...string) error
- func (c *DNSHandlerConfig) FillRequiredProperty(target **string, prop string, alt ...string) error
- func (c *DNSHandlerConfig) GetDefaultedBoolProperty(key string, def bool, altKeys ...string) (bool, error)
- func (c *DNSHandlerConfig) GetDefaultedIntProperty(key string, def int, altKeys ...string) (int, error)
- func (c *DNSHandlerConfig) GetDefaultedProperty(key string, def string, altKeys ...string) string
- func (c *DNSHandlerConfig) GetProperty(key string, altKeys ...string) string
- func (c *DNSHandlerConfig) GetRequiredBoolProperty(key string, altKeys ...string) (bool, error)
- func (c *DNSHandlerConfig) GetRequiredIntProperty(key string, altKeys ...string) (int, error)
- func (c *DNSHandlerConfig) GetRequiredProperty(key string, altKeys ...string) (string, error)
- type DNSHandlerCreatorFunction
- type DNSHandlerFactory
- type DNSHandlerOptionSource
- type DNSHostedZone
- type DNSHostedZones
- type DNSNames
- type DNSProvider
- type DNSProviders
- type DNSZoneState
- type DedicatedDNSAccess
- type DedicatedRecord
- type DedicatedRecordSet
- type DefaultContext
- func (this *DefaultContext) Enqueue(obj resources.Object) error
- func (this *DefaultContext) EnqueueCommand(cmd string) error
- func (this *DefaultContext) EnqueueKey(key resources.ClusterObjectKey) error
- func (this *DefaultContext) GetByExample(obj runtime.Object) (resources.Interface, error)
- func (this *DefaultContext) GetCluster(name string) resources.Cluster
- func (this *DefaultContext) GetContext() context.Context
- func (this *DefaultContext) GetIntOption(name string) (int, error)
- func (this *DefaultContext) GetPool(name string) controller.Pool
- func (this *DefaultContext) GetPoolPeriod(name string) *time.Duration
- func (this *DefaultContext) GetSecretPropertiesByRef(src resources.ResourcesSource, ref *corev1.SecretReference) (utils.Properties, *resources.SecretObject, error)
- func (this *DefaultContext) GetStringOption(name string) (string, error)
- func (this *DefaultContext) HasFinalizer(obj resources.Object) bool
- func (this *DefaultContext) IsReady() bool
- func (this *DefaultContext) RemoveFinalizer(obj resources.Object) error
- func (this *DefaultContext) SetFinalizer(obj resources.Object) error
- func (this *DefaultContext) Synchronize(log logger.LogContext, name string, obj resources.Object) (bool, error)
- type DefaultDNSHandler
- type DefaultDNSHostedZone
- func (this *DefaultDNSHostedZone) Domain() string
- func (this *DefaultDNSHostedZone) ForwardedDomains() []string
- func (this *DefaultDNSHostedZone) Id() string
- func (this *DefaultDNSHostedZone) IsPrivate() bool
- func (this *DefaultDNSHostedZone) Key() string
- func (this *DefaultDNSHostedZone) Match(dnsname string) int
- func (this *DefaultDNSHostedZone) ProviderType() string
- type DefaultDNSZoneState
- type DoneHandler
- type DumpDNSHostedZone
- type Entries
- type Entry
- func (this *Entry) Before(e *Entry) bool
- func (this *Entry) CreatedAt() time.Time
- func (this *Entry) IsActive() bool
- func (this *Entry) IsModified() bool
- func (this *Entry) RemoveFinalizer() error
- func (this *Entry) Trigger(logger logger.LogContext)
- func (this *Entry) Update(logger logger.LogContext, new *EntryVersion) *Entry
- type EntryList
- type EntryPremise
- type EntryVersion
- func (this *EntryVersion) ClusterKey() resources.ClusterObjectKey
- func (this *EntryVersion) DNSName() string
- func (this *EntryVersion) Description() string
- func (this *EntryVersion) Interval() int64
- func (this *EntryVersion) IsDeleting() bool
- func (this *EntryVersion) IsResponsible() bool
- func (this *EntryVersion) IsValid() bool
- func (this *EntryVersion) KeepRecords() bool
- func (this *EntryVersion) Kind() string
- func (this *EntryVersion) Message() string
- func (this *EntryVersion) Object() dnsutils.DNSSpecification
- func (this *EntryVersion) ObjectName() resources.ObjectName
- func (this *EntryVersion) OwnerId() string
- func (this *EntryVersion) ProviderName() resources.ObjectName
- func (this *EntryVersion) ProviderType() string
- func (this *EntryVersion) RequiresUpdateFor(e *EntryVersion) (reasons []string, refresh bool)
- func (this *EntryVersion) Setup(logger logger.LogContext, state *state, p *EntryPremise, op string, err error, ...) reconcile.Status
- func (this *EntryVersion) State() string
- func (this *EntryVersion) TTL() int64
- func (this *EntryVersion) Targets() Targets
- func (this *EntryVersion) UpdateStatus(logger logger.LogContext, state string, msg string) (bool, error)
- func (this *EntryVersion) ZoneId() string
- func (this *EntryVersion) ZonedDNSName() ZonedDNSName
- type Factory
- func (this *Factory) Create(typecode string, config *DNSHandlerConfig) (DNSHandler, error)
- func (this *Factory) CreateOptionSource() (config.OptionSource, *GenericFactoryOptions)
- func (this *Factory) IsResponsibleFor(object *dnsutils.DNSProviderObject) bool
- func (this *Factory) Name() string
- func (this *Factory) SetGenericFactoryOptionDefaults(defaults ...GenericFactoryOptions) *Factory
- func (this *Factory) SetOptionSourceByExample(proto config.OptionSource, defaults ...GenericFactoryOptions) *Factory
- func (this *Factory) SetOptionSourceCreator(creator extension.OptionSourceCreator, defaults ...GenericFactoryOptions) *Factory
- func (this *Factory) SupportZoneStateCache(typecode string) (bool, error)
- func (this *Factory) TypeCodes() utils.StringSet
- type FactoryOptions
- type FinalizerHandler
- type Finalizers
- type ForwardedDomainsHandlerData
- func (hd *ForwardedDomainsHandlerData) DeleteZone(zoneID string)
- func (hd *ForwardedDomainsHandlerData) GetForwardedDomains(zoneid string) []string
- func (hd *ForwardedDomainsHandlerData) Marshal(zoneID string) (*PersistentHandlerData, error)
- func (hd *ForwardedDomainsHandlerData) SetForwardedDomains(zoneid string, value []string)
- func (hd *ForwardedDomainsHandlerData) Unmarshal(zoneID string, data *PersistentHandlerData) error
- type FullDump
- type GenericFactoryOptions
- type HandlerData
- type InMemory
- func (m *InMemory) AddZone(zone DNSHostedZone) bool
- func (m *InMemory) Apply(zoneID string, request *ChangeRequest, metrics Metrics) error
- func (m *InMemory) BuildFullDump() *FullDump
- func (m *InMemory) CloneZoneState(zone DNSHostedZone) (DNSZoneState, error)
- func (m *InMemory) DeleteZone(zone DNSHostedZone)
- func (m *InMemory) FindHostedZone(zoneid string) DNSHostedZone
- func (m *InMemory) GetZones() DNSHostedZones
- func (m *InMemory) SetZone(zone DNSHostedZone, zoneState DNSZoneState)
- type Metrics
- type NullMetrics
- type OwnerCache
- func (this *OwnerCache) DeleteOwner(key resources.ObjectKey) (changeset utils.StringSet, activeset utils.StringSet)
- func (this *OwnerCache) GetDNSActivations() OwnerDNSActivations
- func (this *OwnerCache) GetIds() utils.StringSet
- func (this *OwnerCache) IsResponsibleFor(id string) bool
- func (this *OwnerCache) IsResponsiblePendingFor(id string) bool
- func (this *OwnerCache) SetPending(id string)
- func (this *OwnerCache) TriggerDNSActivation(logger logger.LogContext, cntr controller.Interface)
- func (this *OwnerCache) UpdateCountsWith(statistic statistic.OwnerStatistic, types utils.StringSet) OwnerCounts
- func (this *OwnerCache) UpdateOwner(owner *dnsutils.DNSOwnerObject) (changeset utils.StringSet, activeset utils.StringSet)
- type OwnerCounts
- type OwnerDNSActivation
- type OwnerDNSActivations
- type OwnerIDInfo
- type OwnerIDInfos
- type OwnerName
- type OwnerObjectInfo
- type OwnerObjectInfos
- type PersistentHandlerData
- type PersistentZone
- type PersistentZoneState
- type ProviderCacheContext
- type ProviderTypeCounts
- type RateLimiterConfig
- type RateLimiterOptions
- func (this *RateLimiterOptions) AddOptionsToSet(set config.OptionSet)
- func (c *RateLimiterOptions) GetRateLimiterConfig() *RateLimiterConfig
- func (c RateLimiterOptions) SetBurst(burst int) RateLimiterOptions
- func (c RateLimiterOptions) SetEnabled(enabled bool) RateLimiterOptions
- func (c RateLimiterOptions) SetQPS(qps int) RateLimiterOptions
- type References
- type StateTTLGetter
- type StatusUpdate
- type Target
- type TargetSpec
- type Targets
- type Ticker
- type ZoneCache
- type ZoneCacheConfig
- type ZoneCacheStateUpdater
- type ZoneCacheZoneUpdater
- type ZoneDump
- type ZonedDNSName
Constants ¶
View Source
const ( R_CREATE = "create" R_UPDATE = "update" R_DELETE = "delete" )
View Source
const ( OPT_IDENTIFIER = "identifier" OPT_CLASS = source.OPT_CLASS OPT_DRYRUN = "dry-run" OPT_TTL = "ttl" OPT_CACHE_TTL = "cache-ttl" OPT_CACHE_DIR = "cache-dir" OPT_SETUP = dns.OPT_SETUP OPT_DNSDELAY = "dns-delay" OPT_RESCHEDULEDELAY = "reschedule-delay" OPT_LOCKSTATUSCHECKPERIOD = "lock-status-check-period" OPT_DISABLE_ZONE_STATE_CACHING = "disable-zone-state-caching" OPT_PROVIDERTYPES = "provider-types" OPT_RATELIMITER_ENABLED = "ratelimiter.enabled" OPT_RATELIMITER_QPS = "ratelimiter.qps" OPT_RATELIMITER_BURST = "ratelimiter.burst" OPT_ADVANCED_BATCH_SIZE = "advanced.batch-size" OPT_ADVANCED_MAX_RETRIES = "advanced.max-retries" OPT_ADVANCED_BLOCKED_ZONE = "blocked-zone" CMD_HOSTEDZONE_PREFIX = "hostedzone:" CMD_STATISTIC = "statistic" CMD_DNSLOOKUP = "dnslookup" )
View Source
const ( M_LISTZONES = "list_zones" M_PLISTZONES = "list_zones_pages" M_LISTRECORDS = "list_records" M_PLISTRECORDS = "list_records_pages" M_UPDATERECORDS = "update_records" M_PUPDATEREORDS = "update_records_pages" M_CREATERECORDS = "create_records" M_DELETERECORDS = "delete_records" M_CACHED_GETZONES = "cached_getzones" M_CACHED_GETZONESTATE = "cached_getzonestate" )
View Source
const CONTROLLER_GROUP_DNS_CONTROLLERS = dns.CONTROLLER_GROUP_DNS_CONTROLLERS
View Source
const DNS_POOL = "dns"
View Source
const FACTORY_OPTIONS = "factory"
View Source
const KEY_STATE = "dns-state"
View Source
const MSG_PRESERVED = "errorneous entry preserved in provider"
View Source
const PROVIDER_CLUSTER = "provider"
View Source
const SYNC_ENTRIES = "entries"
View Source
const TARGET_CLUSTER = source.TARGET_CLUSTER
View Source
const TempSuffix = ".~.tmp"
View Source
const ZoneCachePrefix = "zc-"
Variables ¶
View Source
var AdvancedOptionsDefaults = AdvancedOptions{ BatchSize: 50, MaxRetries: 7, BlockedZones: []string{}, }
View Source
var GenericFactoryOptionDefaults = GenericFactoryOptions{ RateLimiterOptions: RateLimiterOptionDefaults, AdvancedOptions: AdvancedOptionsDefaults, }
View Source
var RateLimiterOptionDefaults = RateLimiterOptions{ Enabled: true, QPS: 10, Burst: 20, }
Functions ¶
func AlwaysRateLimiter ¶ added in v0.7.12
func AlwaysRateLimiter() flowcontrol.RateLimiter
func AssureTimestamp ¶ added in v0.11.0
func Create ¶
func Create(c controller.Interface, factory DNSHandlerFactory) (reconcile.Interface, error)
func CreateFactoryOptionSource ¶ added in v0.7.12
func CreateFactoryOptionSource(factory DNSHandlerFactory, prefix string) config.OptionSource
func DNSController ¶
func DNSController(name string, factory DNSHandlerFactory) controller.Configuration
func DNSReconcilerType ¶
func DNSReconcilerType(factory DNSHandlerFactory) controller.ReconcilerType
func EqualAttrs ¶ added in v0.11.0
func FactoryOptionSourceCreator ¶ added in v0.7.12
func FactoryOptionSourceCreator(factory DNSHandlerFactory) extension.OptionSourceCreator
func HandlerStringMapper ¶ added in v0.7.12
func Match ¶ added in v0.8.1
func Match(zone DNSHostedZone, dnsname string) int
func NewDNSState ¶
func Provider ¶
func Provider(p DNSProvider) string
func StatusMessage ¶
func StatusMessagef ¶
func ToDedicatedRecordset ¶ added in v0.11.0
func ToDedicatedRecordset(rawrs DedicatedRecordSet) (string, *dns.RecordSet)
Types ¶
type AccountCache ¶
type AccountCache struct {
// contains filtered or unexported fields
}
func NewAccountCache ¶
func NewAccountCache(ttl time.Duration, dir string, opts *FactoryOptions) *AccountCache
func (*AccountCache) Get ¶
func (this *AccountCache) Get(logger logger.LogContext, provider *dnsutils.DNSProviderObject, props utils.Properties, state *state) (*DNSAccount, error)
func (*AccountCache) Hash ¶
func (this *AccountCache) Hash(props utils.Properties, ptype string, extension *runtime.RawExtension) string
func (*AccountCache) Release ¶
func (this *AccountCache) Release(logger logger.LogContext, a *DNSAccount, name resources.ObjectName)
type AdvancedConfig ¶ added in v0.10.0
func (AdvancedConfig) String ¶ added in v0.10.0
func (c AdvancedConfig) String() string
type AdvancedOptions ¶ added in v0.10.0
func (*AdvancedOptions) AddOptionsToSet ¶ added in v0.10.0
func (this *AdvancedOptions) AddOptionsToSet(set config.OptionSet)
func (*AdvancedOptions) GetAdvancedConfig ¶ added in v0.10.0
func (c *AdvancedOptions) GetAdvancedConfig() AdvancedConfig
func (*AdvancedOptions) GetBlockedZones ¶ added in v0.10.7
func (c *AdvancedOptions) GetBlockedZones() utils.StringSet
func (AdvancedOptions) SetBatchSize ¶ added in v0.10.0
func (c AdvancedOptions) SetBatchSize(batchSize int) AdvancedOptions
func (AdvancedOptions) SetMaxRetries ¶ added in v0.10.0
func (c AdvancedOptions) SetMaxRetries(maxRetries int) AdvancedOptions
type ChangeGroup ¶
type ChangeGroup struct {
// contains filtered or unexported fields
}
type ChangeModel ¶
type ChangeModel struct { logger.LogContext // contains filtered or unexported fields }
func NewChangeModel ¶
func NewChangeModel(logger logger.LogContext, ownership dns.Ownership, req *zoneReconciliation, config Config) *ChangeModel
func (*ChangeModel) Apply ¶
func (this *ChangeModel) Apply(name, updateGroup string, createdAt time.Time, done DoneHandler, spec TargetSpec) ChangeResult
func (*ChangeModel) ApplySpec ¶ added in v0.11.0
func (this *ChangeModel) ApplySpec(set *dns.DNSSet, base *dns.DNSSet, provider DNSProvider, spec TargetSpec) *dns.DNSSet
func (*ChangeModel) Cleanup ¶
func (this *ChangeModel) Cleanup(logger logger.LogContext) bool
func (*ChangeModel) Delete ¶
func (this *ChangeModel) Delete(name, updateGroup string, createdAt time.Time, done DoneHandler, spec TargetSpec) ChangeResult
func (*ChangeModel) Domain ¶
func (this *ChangeModel) Domain() string
func (*ChangeModel) Exec ¶
func (this *ChangeModel) Exec(apply bool, delete bool, name, updateGroup string, createdAt time.Time, done DoneHandler, spec TargetSpec) ChangeResult
func (*ChangeModel) IsFailed ¶ added in v0.8.2
func (this *ChangeModel) IsFailed(dnsName string) bool
func (*ChangeModel) IsStale ¶
func (this *ChangeModel) IsStale(dns ZonedDNSName) *Entry
func (*ChangeModel) Setup ¶
func (this *ChangeModel) Setup() error
func (*ChangeModel) Update ¶
func (this *ChangeModel) Update(logger logger.LogContext) error
func (*ChangeModel) ZoneId ¶
func (this *ChangeModel) ZoneId() string
type ChangeRequest ¶
type ChangeRequest struct { Action string Type string Addition *dns.DNSSet Deletion *dns.DNSSet Done DoneHandler }
func NewChangeRequest ¶
func NewChangeRequest(action string, rtype string, del, add *dns.DNSSet, done DoneHandler) *ChangeRequest
type ChangeRequests ¶
type ChangeRequests []*ChangeRequest
type ChangeResult ¶
type CompoundFactory ¶
type CompoundFactory struct {
// contains filtered or unexported fields
}
func NewDNSHandlerCompoundFactory ¶
func NewDNSHandlerCompoundFactory(name string) *CompoundFactory
func (*CompoundFactory) Add ¶
func (this *CompoundFactory) Add(f DNSHandlerFactory, finalizer ...string) error
func (*CompoundFactory) Create ¶
func (this *CompoundFactory) Create(typecode string, cfg *DNSHandlerConfig) (DNSHandler, error)
func (*CompoundFactory) CreateOptionSource ¶ added in v0.7.12
func (this *CompoundFactory) CreateOptionSource() (config.OptionSource, *GenericFactoryOptions)
func (*CompoundFactory) Finalizers ¶ added in v0.7.12
func (this *CompoundFactory) Finalizers() utils.StringSet
func (*CompoundFactory) IsResponsibleFor ¶
func (this *CompoundFactory) IsResponsibleFor(object *dnsutils.DNSProviderObject) bool
func (*CompoundFactory) Name ¶
func (this *CompoundFactory) Name() string
func (*CompoundFactory) SupportZoneStateCache ¶
func (this *CompoundFactory) SupportZoneStateCache(typecode string) (bool, error)
func (*CompoundFactory) TypeCodes ¶
func (this *CompoundFactory) TypeCodes() utils.StringSet
type Config ¶
type Config struct { TTL int64 CacheTTL time.Duration CacheDir string RescheduleDelay time.Duration StatusCheckPeriod time.Duration Ident string Dryrun bool ZoneStateCaching bool Delay time.Duration Enabled utils.StringSet Options *FactoryOptions Factory DNSHandlerFactory }
func NewConfigForController ¶
func NewConfigForController(c controller.Interface, factory DNSHandlerFactory) (*Config, error)
type Context ¶
type Context interface { logger.LogContext GetContext() context.Context IsReady() bool GetByExample(runtime.Object) (resources.Interface, error) GetStringOption(name string) (string, error) GetIntOption(name string) (int, error) Synchronize(log logger.LogContext, name string, initiator resources.Object) (bool, error) Enqueue(obj resources.Object) error EnqueueCommand(cmd string) error EnqueueKey(key resources.ClusterObjectKey) error SetFinalizer(resources.Object) error RemoveFinalizer(resources.Object) error HasFinalizer(resources.Object) bool GetSecretPropertiesByRef(src resources.ResourcesSource, ref *corev1.SecretReference) (utils.Properties, *resources.SecretObject, error) GetPoolPeriod(name string) *time.Duration GetCluster(name string) resources.Cluster GetPool(name string) controller.Pool }
func NewDefaultContext ¶
func NewDefaultContext(controller controller.Interface) Context
type DNSAccount ¶
type DNSAccount struct { *dnsutils.RateLimiter // contains filtered or unexported fields }
func NewDNSAccount ¶ added in v0.7.9
func NewDNSAccount(config utils.Properties, handler DNSHandler, hash string) *DNSAccount
func (*DNSAccount) AddGenericRequests ¶ added in v0.8.4
func (this *DNSAccount) AddGenericRequests(requestType string, n int)
func (*DNSAccount) AddZoneRequests ¶ added in v0.8.4
func (this *DNSAccount) AddZoneRequests(zoneID, requestType string, n int)
func (*DNSAccount) ExecuteRequests ¶
func (this *DNSAccount) ExecuteRequests(logger logger.LogContext, zone DNSHostedZone, state DNSZoneState, reqs []*ChangeRequest) error
func (*DNSAccount) GetZoneState ¶
func (this *DNSAccount) GetZoneState(zone DNSHostedZone) (DNSZoneState, error)
func (*DNSAccount) GetZones ¶
func (this *DNSAccount) GetZones() (DNSHostedZones, error)
func (*DNSAccount) Hash ¶
func (this *DNSAccount) Hash() string
func (*DNSAccount) MapTarget ¶
func (this *DNSAccount) MapTarget(t Target) Target
func (*DNSAccount) ProviderType ¶
func (this *DNSAccount) ProviderType() string
func (*DNSAccount) Release ¶
func (this *DNSAccount) Release()
func (*DNSAccount) ReportZoneStateConflict ¶
func (this *DNSAccount) ReportZoneStateConflict(zone DNSHostedZone, err error) bool
type DNSHandler ¶
type DNSHandler interface { ProviderType() string GetZones() (DNSHostedZones, error) GetZoneState(DNSHostedZone) (DNSZoneState, error) ReportZoneStateConflict(zone DNSHostedZone, err error) bool ExecuteRequests(logger logger.LogContext, zone DNSHostedZone, state DNSZoneState, reqs []*ChangeRequest) error MapTarget(t Target) Target Release() }
type DNSHandlerConfig ¶
type DNSHandlerConfig struct { Logger logger.LogContext Properties utils.Properties Config *runtime.RawExtension DryRun bool Context context.Context CacheConfig ZoneCacheConfig Options *FactoryOptions Metrics Metrics RateLimiter flowcontrol.RateLimiter }
func (*DNSHandlerConfig) Complete ¶ added in v0.10.0
func (c *DNSHandlerConfig) Complete() error
func (*DNSHandlerConfig) FillDefaultedBoolProperty ¶ added in v0.7.21
func (*DNSHandlerConfig) FillDefaultedIntProperty ¶ added in v0.7.7
func (*DNSHandlerConfig) FillDefaultedProperty ¶ added in v0.7.14
func (*DNSHandlerConfig) FillRequiredIntProperty ¶ added in v0.7.7
func (c *DNSHandlerConfig) FillRequiredIntProperty(target **int, prop string, alt ...string) error
func (*DNSHandlerConfig) FillRequiredProperty ¶ added in v0.7.7
func (c *DNSHandlerConfig) FillRequiredProperty(target **string, prop string, alt ...string) error
func (*DNSHandlerConfig) GetDefaultedBoolProperty ¶ added in v0.7.21
func (*DNSHandlerConfig) GetDefaultedIntProperty ¶ added in v0.7.7
func (*DNSHandlerConfig) GetDefaultedProperty ¶ added in v0.7.7
func (c *DNSHandlerConfig) GetDefaultedProperty(key string, def string, altKeys ...string) string
func (*DNSHandlerConfig) GetProperty ¶
func (c *DNSHandlerConfig) GetProperty(key string, altKeys ...string) string
func (*DNSHandlerConfig) GetRequiredBoolProperty ¶ added in v0.7.21
func (c *DNSHandlerConfig) GetRequiredBoolProperty(key string, altKeys ...string) (bool, error)
func (*DNSHandlerConfig) GetRequiredIntProperty ¶ added in v0.7.7
func (c *DNSHandlerConfig) GetRequiredIntProperty(key string, altKeys ...string) (int, error)
func (*DNSHandlerConfig) GetRequiredProperty ¶
func (c *DNSHandlerConfig) GetRequiredProperty(key string, altKeys ...string) (string, error)
type DNSHandlerCreatorFunction ¶
type DNSHandlerCreatorFunction func(config *DNSHandlerConfig) (DNSHandler, error)
type DNSHandlerFactory ¶
type DNSHandlerFactory interface { Name() string TypeCodes() utils.StringSet Create(typecode string, config *DNSHandlerConfig) (DNSHandler, error) IsResponsibleFor(object *dnsutils.DNSProviderObject) bool SupportZoneStateCache(typecode string) (bool, error) }
type DNSHandlerOptionSource ¶ added in v0.7.12
type DNSHandlerOptionSource interface {
CreateOptionSource() (local config.OptionSource, defaults *GenericFactoryOptions)
}
type DNSHostedZone ¶
type DNSHostedZone interface { ProviderType() string Key() string Id() string Domain() string ForwardedDomains() []string Match(dnsname string) int IsPrivate() bool }
func CopyDNSHostedZone ¶
func CopyDNSHostedZone(zone DNSHostedZone, forwardedDomains []string) DNSHostedZone
func NewDNSHostedZone ¶
func NewDNSHostedZone(ptype string, id, domain, key string, forwarded []string, isPrivate bool) DNSHostedZone
type DNSHostedZones ¶
type DNSHostedZones []DNSHostedZone
type DNSNames ¶
type DNSNames map[ZonedDNSName]*Entry
type DNSProvider ¶
type DNSProvider interface { ObjectName() resources.ObjectName Object() resources.Object TypeCode() string DefaultTTL() int64 GetZones() DNSHostedZones IncludesZone(zoneID string) bool GetZoneState(zone DNSHostedZone) (DNSZoneState, error) ExecuteRequests(logger logger.LogContext, zone DNSHostedZone, state DNSZoneState, requests []*ChangeRequest) error GetDedicatedDNSAccess() DedicatedDNSAccess Match(dns string) int MatchZone(dns string) int IsValid() bool AccountHash() string MapTarget(t Target) Target // ReportZoneStateConflict is used to report a conflict because of stale data. // It returns true if zone data will be updated and a retry may resolve the conflict ReportZoneStateConflict(zone DNSHostedZone, err error) bool }
type DNSProviders ¶
type DNSProviders map[resources.ObjectName]DNSProvider
func (DNSProviders) LookupFor ¶
func (this DNSProviders) LookupFor(dns string) DNSProvider
type DNSZoneState ¶
func NewDNSZoneState ¶
func NewDNSZoneState(sets dns.DNSSets) DNSZoneState
type DedicatedDNSAccess ¶ added in v0.11.0
type DedicatedDNSAccess interface { GetRecordSet(zone DNSHostedZone, dnsName, recordType string) (DedicatedRecordSet, error) CreateOrUpdateRecordSet(logger logger.LogContext, zone DNSHostedZone, old, new DedicatedRecordSet) error DeleteRecordSet(logger logger.LogContext, zone DNSHostedZone, rs DedicatedRecordSet) error }
type DedicatedRecord ¶ added in v0.11.0
type DedicatedRecordSet ¶ added in v0.11.0
type DedicatedRecordSet []DedicatedRecord
func FromDedicatedRecordSet ¶ added in v0.11.0
func FromDedicatedRecordSet(dnsName string, rs *dns.RecordSet) DedicatedRecordSet
func (DedicatedRecordSet) GetAttr ¶ added in v0.11.0
func (rs DedicatedRecordSet) GetAttr(name string) string
type DefaultContext ¶
type DefaultContext struct { logger.LogContext // contains filtered or unexported fields }
func (*DefaultContext) EnqueueCommand ¶
func (this *DefaultContext) EnqueueCommand(cmd string) error
func (*DefaultContext) EnqueueKey ¶
func (this *DefaultContext) EnqueueKey(key resources.ClusterObjectKey) error
func (*DefaultContext) GetByExample ¶
func (*DefaultContext) GetCluster ¶ added in v0.10.3
func (this *DefaultContext) GetCluster(name string) resources.Cluster
func (*DefaultContext) GetContext ¶
func (this *DefaultContext) GetContext() context.Context
func (*DefaultContext) GetIntOption ¶
func (this *DefaultContext) GetIntOption(name string) (int, error)
func (*DefaultContext) GetPool ¶ added in v0.10.7
func (this *DefaultContext) GetPool(name string) controller.Pool
func (*DefaultContext) GetPoolPeriod ¶
func (this *DefaultContext) GetPoolPeriod(name string) *time.Duration
func (*DefaultContext) GetSecretPropertiesByRef ¶
func (this *DefaultContext) GetSecretPropertiesByRef(src resources.ResourcesSource, ref *corev1.SecretReference) (utils.Properties, *resources.SecretObject, error)
func (*DefaultContext) GetStringOption ¶ added in v0.7.12
func (this *DefaultContext) GetStringOption(name string) (string, error)
func (*DefaultContext) HasFinalizer ¶
func (this *DefaultContext) HasFinalizer(obj resources.Object) bool
func (*DefaultContext) IsReady ¶
func (this *DefaultContext) IsReady() bool
func (*DefaultContext) RemoveFinalizer ¶
func (this *DefaultContext) RemoveFinalizer(obj resources.Object) error
func (*DefaultContext) SetFinalizer ¶
func (this *DefaultContext) SetFinalizer(obj resources.Object) error
func (*DefaultContext) Synchronize ¶ added in v0.7.12
func (this *DefaultContext) Synchronize(log logger.LogContext, name string, obj resources.Object) (bool, error)
type DefaultDNSHandler ¶
type DefaultDNSHandler struct {
// contains filtered or unexported fields
}
func NewDefaultDNSHandler ¶
func NewDefaultDNSHandler(providerType string) DefaultDNSHandler
func (*DefaultDNSHandler) MapTarget ¶
func (this *DefaultDNSHandler) MapTarget(t Target) Target
func (*DefaultDNSHandler) ProviderType ¶
func (this *DefaultDNSHandler) ProviderType() string
type DefaultDNSHostedZone ¶
type DefaultDNSHostedZone struct {
// contains filtered or unexported fields
}
func (*DefaultDNSHostedZone) Domain ¶
func (this *DefaultDNSHostedZone) Domain() string
func (*DefaultDNSHostedZone) ForwardedDomains ¶
func (this *DefaultDNSHostedZone) ForwardedDomains() []string
func (*DefaultDNSHostedZone) Id ¶
func (this *DefaultDNSHostedZone) Id() string
func (*DefaultDNSHostedZone) IsPrivate ¶
func (this *DefaultDNSHostedZone) IsPrivate() bool
func (*DefaultDNSHostedZone) Key ¶
func (this *DefaultDNSHostedZone) Key() string
func (*DefaultDNSHostedZone) Match ¶ added in v0.8.1
func (this *DefaultDNSHostedZone) Match(dnsname string) int
func (*DefaultDNSHostedZone) ProviderType ¶
func (this *DefaultDNSHostedZone) ProviderType() string
type DefaultDNSZoneState ¶
type DefaultDNSZoneState struct {
// contains filtered or unexported fields
}
func (*DefaultDNSZoneState) Clone ¶ added in v0.7.14
func (this *DefaultDNSZoneState) Clone() DNSZoneState
func (*DefaultDNSZoneState) GetDNSSets ¶
func (this *DefaultDNSZoneState) GetDNSSets() dns.DNSSets
type DoneHandler ¶
func NewStatusUpdate ¶
func NewStatusUpdate(logger logger.LogContext, e *Entry, f FinalizerHandler) DoneHandler
type DumpDNSHostedZone ¶
type Entries ¶
type Entries map[resources.ObjectName]*Entry
func (Entries) AddActiveZoneTo ¶ added in v0.7.18
func (Entries) AddResponsibleTo ¶ added in v0.7.12
type Entry ¶
type Entry struct { *EntryVersion // contains filtered or unexported fields }
func NewEntry ¶
func NewEntry(v *EntryVersion, state *state) *Entry
func (*Entry) IsModified ¶
func (*Entry) RemoveFinalizer ¶ added in v0.7.12
func (*Entry) Trigger ¶
func (this *Entry) Trigger(logger logger.LogContext)
func (*Entry) Update ¶
func (this *Entry) Update(logger logger.LogContext, new *EntryVersion) *Entry
type EntryList ¶
type EntryList []*Entry
func (EntryList) UpdateStatistic ¶ added in v0.7.12
func (this EntryList) UpdateStatistic(statistic *statistic.EntryStatistic)
type EntryPremise ¶
type EntryPremise struct {
// contains filtered or unexported fields
}
func (*EntryPremise) Match ¶ added in v0.7.12
func (this *EntryPremise) Match(p *EntryPremise) bool
func (*EntryPremise) NotifyChange ¶
func (this *EntryPremise) NotifyChange(p *EntryPremise) string
type EntryVersion ¶
type EntryVersion struct {
// contains filtered or unexported fields
}
func NewEntryVersion ¶
func NewEntryVersion(object dnsutils.DNSSpecification, old *Entry) *EntryVersion
func (*EntryVersion) ClusterKey ¶
func (this *EntryVersion) ClusterKey() resources.ClusterObjectKey
func (*EntryVersion) DNSName ¶
func (this *EntryVersion) DNSName() string
func (*EntryVersion) Description ¶
func (this *EntryVersion) Description() string
func (*EntryVersion) Interval ¶
func (this *EntryVersion) Interval() int64
func (*EntryVersion) IsDeleting ¶
func (this *EntryVersion) IsDeleting() bool
func (*EntryVersion) IsResponsible ¶ added in v0.7.7
func (this *EntryVersion) IsResponsible() bool
func (*EntryVersion) IsValid ¶
func (this *EntryVersion) IsValid() bool
func (*EntryVersion) KeepRecords ¶ added in v0.8.3
func (this *EntryVersion) KeepRecords() bool
func (*EntryVersion) Kind ¶ added in v0.11.0
func (this *EntryVersion) Kind() string
func (*EntryVersion) Message ¶
func (this *EntryVersion) Message() string
func (*EntryVersion) Object ¶
func (this *EntryVersion) Object() dnsutils.DNSSpecification
func (*EntryVersion) ObjectName ¶
func (this *EntryVersion) ObjectName() resources.ObjectName
func (*EntryVersion) OwnerId ¶
func (this *EntryVersion) OwnerId() string
func (*EntryVersion) ProviderName ¶ added in v0.7.12
func (this *EntryVersion) ProviderName() resources.ObjectName
func (*EntryVersion) ProviderType ¶ added in v0.7.7
func (this *EntryVersion) ProviderType() string
func (*EntryVersion) RequiresUpdateFor ¶
func (this *EntryVersion) RequiresUpdateFor(e *EntryVersion) (reasons []string, refresh bool)
func (*EntryVersion) Setup ¶
func (this *EntryVersion) Setup(logger logger.LogContext, state *state, p *EntryPremise, op string, err error, config Config, old *Entry) reconcile.Status
func (*EntryVersion) State ¶
func (this *EntryVersion) State() string
func (*EntryVersion) TTL ¶
func (this *EntryVersion) TTL() int64
func (*EntryVersion) Targets ¶
func (this *EntryVersion) Targets() Targets
func (*EntryVersion) UpdateStatus ¶
func (this *EntryVersion) UpdateStatus(logger logger.LogContext, state string, msg string) (bool, error)
func (*EntryVersion) ZoneId ¶
func (this *EntryVersion) ZoneId() string
func (*EntryVersion) ZonedDNSName ¶ added in v0.10.7
func (this *EntryVersion) ZonedDNSName() ZonedDNSName
type Factory ¶
type Factory struct {
// contains filtered or unexported fields
}
func NewDNSHandlerFactory ¶
func NewDNSHandlerFactory(typecode string, create DNSHandlerCreatorFunction, disableZoneStateCache ...bool) *Factory
func (*Factory) Create ¶
func (this *Factory) Create(typecode string, config *DNSHandlerConfig) (DNSHandler, error)
func (*Factory) CreateOptionSource ¶ added in v0.7.12
func (this *Factory) CreateOptionSource() (config.OptionSource, *GenericFactoryOptions)
func (*Factory) IsResponsibleFor ¶
func (this *Factory) IsResponsibleFor(object *dnsutils.DNSProviderObject) bool
func (*Factory) SetGenericFactoryOptionDefaults ¶ added in v0.7.12
func (this *Factory) SetGenericFactoryOptionDefaults(defaults ...GenericFactoryOptions) *Factory
func (*Factory) SetOptionSourceByExample ¶ added in v0.7.12
func (this *Factory) SetOptionSourceByExample(proto config.OptionSource, defaults ...GenericFactoryOptions) *Factory
func (*Factory) SetOptionSourceCreator ¶ added in v0.7.12
func (this *Factory) SetOptionSourceCreator(creator extension.OptionSourceCreator, defaults ...GenericFactoryOptions) *Factory
func (*Factory) SupportZoneStateCache ¶
type FactoryOptions ¶ added in v0.7.12
type FactoryOptions struct { // type specific options Options config.OptionSource // generic options for all factory types GenericFactoryOptions }
FactoryOptions is a set of generic options and type specific options related to factories that are provided for all provider types but in a provider specific manner. The provide specif options are defined by an option source optionally offered by the provider factory. It is handled by the compound factory, also, to provide dedicated option sets for hosted sub factories.
func GetFactoryOptions ¶ added in v0.7.12
func GetFactoryOptions(src config.OptionSource) *FactoryOptions
func (*FactoryOptions) AddOptionsToSet ¶ added in v0.7.12
func (this *FactoryOptions) AddOptionsToSet(set config.OptionSet)
func (*FactoryOptions) Evaluate ¶ added in v0.7.12
func (this *FactoryOptions) Evaluate() error
type FinalizerHandler ¶
type Finalizers ¶ added in v0.7.12
type ForwardedDomainsHandlerData ¶
type ForwardedDomainsHandlerData struct {
// contains filtered or unexported fields
}
func NewForwardedDomainsHandlerData ¶
func NewForwardedDomainsHandlerData() *ForwardedDomainsHandlerData
func (*ForwardedDomainsHandlerData) DeleteZone ¶
func (hd *ForwardedDomainsHandlerData) DeleteZone(zoneID string)
func (*ForwardedDomainsHandlerData) GetForwardedDomains ¶
func (hd *ForwardedDomainsHandlerData) GetForwardedDomains(zoneid string) []string
func (*ForwardedDomainsHandlerData) Marshal ¶
func (hd *ForwardedDomainsHandlerData) Marshal(zoneID string) (*PersistentHandlerData, error)
func (*ForwardedDomainsHandlerData) SetForwardedDomains ¶
func (hd *ForwardedDomainsHandlerData) SetForwardedDomains(zoneid string, value []string)
func (*ForwardedDomainsHandlerData) Unmarshal ¶
func (hd *ForwardedDomainsHandlerData) Unmarshal(zoneID string, data *PersistentHandlerData) error
type GenericFactoryOptions ¶ added in v0.7.12
type GenericFactoryOptions struct { RateLimiterOptions AdvancedOptions }
func (*GenericFactoryOptions) AddOptionsToSet ¶ added in v0.7.12
func (this *GenericFactoryOptions) AddOptionsToSet(set config.OptionSet)
func (GenericFactoryOptions) SetAdvancedOptions ¶ added in v0.10.0
func (this GenericFactoryOptions) SetAdvancedOptions(o AdvancedOptions) GenericFactoryOptions
func (GenericFactoryOptions) SetRateLimiterOptions ¶ added in v0.7.12
func (this GenericFactoryOptions) SetRateLimiterOptions(o RateLimiterOptions) GenericFactoryOptions
type HandlerData ¶
type HandlerData interface { Marshal(zoneID string) (*PersistentHandlerData, error) Unmarshal(zoneID string, data *PersistentHandlerData) error DeleteZone(zoneID string) }
type InMemory ¶
type InMemory struct {
// contains filtered or unexported fields
}
func NewInMemory ¶
func NewInMemory() *InMemory
func (*InMemory) AddZone ¶
func (m *InMemory) AddZone(zone DNSHostedZone) bool
func (*InMemory) Apply ¶
func (m *InMemory) Apply(zoneID string, request *ChangeRequest, metrics Metrics) error
func (*InMemory) BuildFullDump ¶
func (*InMemory) CloneZoneState ¶
func (m *InMemory) CloneZoneState(zone DNSHostedZone) (DNSZoneState, error)
func (*InMemory) DeleteZone ¶
func (m *InMemory) DeleteZone(zone DNSHostedZone)
func (*InMemory) FindHostedZone ¶
func (m *InMemory) FindHostedZone(zoneid string) DNSHostedZone
func (*InMemory) GetZones ¶
func (m *InMemory) GetZones() DNSHostedZones
func (*InMemory) SetZone ¶
func (m *InMemory) SetZone(zone DNSHostedZone, zoneState DNSZoneState)
type NullMetrics ¶
type NullMetrics struct{}
func (*NullMetrics) AddGenericRequests ¶ added in v0.8.4
func (m *NullMetrics) AddGenericRequests(request_type string, n int)
func (*NullMetrics) AddZoneRequests ¶ added in v0.8.4
func (m *NullMetrics) AddZoneRequests(zon, request_type string, n int)
type OwnerCache ¶
type OwnerCache struct {
// contains filtered or unexported fields
}
func NewOwnerCache ¶
func NewOwnerCache(ctx ProviderCacheContext, config *Config) *OwnerCache
func (*OwnerCache) DeleteOwner ¶
func (*OwnerCache) GetDNSActivations ¶ added in v0.11.0
func (this *OwnerCache) GetDNSActivations() OwnerDNSActivations
func (*OwnerCache) GetIds ¶
func (this *OwnerCache) GetIds() utils.StringSet
func (*OwnerCache) IsResponsibleFor ¶
func (this *OwnerCache) IsResponsibleFor(id string) bool
func (*OwnerCache) IsResponsiblePendingFor ¶ added in v0.7.21
func (this *OwnerCache) IsResponsiblePendingFor(id string) bool
func (*OwnerCache) SetPending ¶ added in v0.7.21
func (this *OwnerCache) SetPending(id string)
func (*OwnerCache) TriggerDNSActivation ¶ added in v0.11.0
func (this *OwnerCache) TriggerDNSActivation(logger logger.LogContext, cntr controller.Interface)
func (*OwnerCache) UpdateCountsWith ¶ added in v0.7.12
func (this *OwnerCache) UpdateCountsWith(statistic statistic.OwnerStatistic, types utils.StringSet) OwnerCounts
func (*OwnerCache) UpdateOwner ¶
func (this *OwnerCache) UpdateOwner(owner *dnsutils.DNSOwnerObject) (changeset utils.StringSet, activeset utils.StringSet)
type OwnerCounts ¶ added in v0.7.12
type OwnerCounts map[OwnerName]ProviderTypeCounts
type OwnerDNSActivation ¶ added in v0.11.0
type OwnerDNSActivation struct { Key resources.ClusterObjectKey Current bool api.DNSActivation }
func (*OwnerDNSActivation) IsActive ¶ added in v0.11.0
func (this *OwnerDNSActivation) IsActive() bool
type OwnerDNSActivations ¶ added in v0.11.0
type OwnerDNSActivations map[resources.ClusterObjectKey]*OwnerDNSActivation
type OwnerIDInfo ¶ added in v0.7.12
type OwnerIDInfo struct {
// contains filtered or unexported fields
}
type OwnerIDInfos ¶ added in v0.7.12
type OwnerIDInfos map[string]OwnerIDInfo
func (OwnerIDInfos) Contains ¶ added in v0.7.12
func (this OwnerIDInfos) Contains(id string) bool
func (OwnerIDInfos) KeySet ¶ added in v0.7.12
func (this OwnerIDInfos) KeySet() utils.StringSet
type OwnerObjectInfo ¶ added in v0.7.12
type OwnerObjectInfo struct {
// contains filtered or unexported fields
}
type OwnerObjectInfos ¶ added in v0.7.12
type OwnerObjectInfos map[OwnerName]OwnerObjectInfo
type PersistentHandlerData ¶
type PersistentHandlerData struct { Name string `json:"name"` Version string `json:"version"` Value *runtime.RawExtension }
type PersistentZone ¶
type PersistentZone struct { ProviderType string `json:"providerType"` Key string `json:"key"` Id string `json:"id"` Domain string `json:"domain"` ForwardedDomains []string `json:"forwardedDomains"` IsPrivate bool `json:"isPrivate"` }
func NewPersistentZone ¶
func NewPersistentZone(zone DNSHostedZone) *PersistentZone
func (*PersistentZone) ToDNSHostedZone ¶
func (z *PersistentZone) ToDNSHostedZone() DNSHostedZone
type PersistentZoneState ¶
type PersistentZoneState struct { Version string `json:"version"` Valid time.Time `json:"valid"` Zone PersistentZone `json:"zone"` DNSSets dns.DNSSets `json:"dnssets,omitempty"` HandlerData *PersistentHandlerData `json:"handlerData,omitempty"` }
type ProviderCacheContext ¶ added in v0.10.3
type ProviderTypeCounts ¶ added in v0.7.12
type RateLimiterConfig ¶ added in v0.7.12
func (*RateLimiterConfig) NewRateLimiter ¶ added in v0.7.12
func (c *RateLimiterConfig) NewRateLimiter() (flowcontrol.RateLimiter, error)
func (*RateLimiterConfig) String ¶ added in v0.7.12
func (c *RateLimiterConfig) String() string
type RateLimiterOptions ¶ added in v0.7.12
func (*RateLimiterOptions) AddOptionsToSet ¶ added in v0.7.12
func (this *RateLimiterOptions) AddOptionsToSet(set config.OptionSet)
func (*RateLimiterOptions) GetRateLimiterConfig ¶ added in v0.7.12
func (c *RateLimiterOptions) GetRateLimiterConfig() *RateLimiterConfig
func (RateLimiterOptions) SetBurst ¶ added in v0.7.12
func (c RateLimiterOptions) SetBurst(burst int) RateLimiterOptions
func (RateLimiterOptions) SetEnabled ¶ added in v0.7.12
func (c RateLimiterOptions) SetEnabled(enabled bool) RateLimiterOptions
func (RateLimiterOptions) SetQPS ¶ added in v0.7.12
func (c RateLimiterOptions) SetQPS(qps int) RateLimiterOptions
type References ¶ added in v0.7.12
type References struct {
// contains filtered or unexported fields
}
func NewReferenceCache ¶ added in v0.7.12
func NewReferenceCache() *References
func (*References) AddRef ¶ added in v0.7.12
func (this *References) AddRef(holder resources.ClusterObjectKey, ref resources.ClusterObjectKey)
func (*References) DelRef ¶ added in v0.7.12
func (this *References) DelRef(holder resources.ClusterObjectKey)
func (*References) NotifyHolder ¶ added in v0.7.12
func (this *References) NotifyHolder(ctx Context, ref resources.ClusterObjectKey)
type StateTTLGetter ¶ added in v0.10.3
type StatusUpdate ¶
type StatusUpdate struct { *Entry // contains filtered or unexported fields }
func (*StatusUpdate) Failed ¶
func (this *StatusUpdate) Failed(err error)
func (*StatusUpdate) SetInvalid ¶
func (this *StatusUpdate) SetInvalid(err error)
func (*StatusUpdate) Succeeded ¶
func (this *StatusUpdate) Succeeded()
type Target ¶
func NewHostTargetFromEntryVersion ¶ added in v0.11.0
func NewHostTargetFromEntryVersion(name string, entry *EntryVersion) (Target, error)
type TargetSpec ¶ added in v0.11.0
type TargetSpec = dnsutils.TargetSpec
type Ticker ¶ added in v0.10.7
type Ticker struct {
// contains filtered or unexported fields
}
func (*Ticker) TickWhile ¶ added in v0.10.7
func (t *Ticker) TickWhile(log logger.LogContext, f func())
type ZoneCache ¶
type ZoneCache interface { GetZones() (DNSHostedZones, error) GetZoneState(zone DNSHostedZone) (DNSZoneState, error) ApplyRequests(logctx logger.LogContext, err error, zone DNSHostedZone, reqs []*ChangeRequest) GetHandlerData() HandlerData Release() ReportZoneStateConflict(zone DNSHostedZone, err error) bool }
func NewZoneCache ¶
func NewZoneCache(config ZoneCacheConfig, metrics Metrics, handlerData HandlerData, zonesUpdater ZoneCacheZoneUpdater, stateUpdater ZoneCacheStateUpdater) (ZoneCache, error)
type ZoneCacheConfig ¶
type ZoneCacheConfig struct {
// contains filtered or unexported fields
}
func NewTestZoneCacheConfig ¶ added in v0.10.3
func NewTestZoneCacheConfig(stateTTL time.Duration) *ZoneCacheConfig
func (*ZoneCacheConfig) CopyWithDisabledZoneStateCache ¶
func (c *ZoneCacheConfig) CopyWithDisabledZoneStateCache() *ZoneCacheConfig
type ZoneCacheStateUpdater ¶
type ZoneCacheStateUpdater func(zone DNSHostedZone, cache ZoneCache) (DNSZoneState, error)
type ZoneCacheZoneUpdater ¶
type ZoneCacheZoneUpdater func(cache ZoneCache) (DNSHostedZones, error)
type ZoneDump ¶
type ZoneDump struct { HostedZone DumpDNSHostedZone DNSSets dns.DNSSets }
type ZonedDNSName ¶ added in v0.10.7
func (ZonedDNSName) String ¶ added in v0.10.7
func (z ZonedDNSName) String() string
Source Files
¶
- advancedopts.go
- changemodel.go
- config.go
- const.go
- context.go
- controller.go
- dedicatedrecord.go
- default.go
- entry.go
- factory.go
- foreign.go
- inmemory.go
- interface.go
- ownercache.go
- provider.go
- ratelimiter.go
- references.go
- state.go
- state_entry.go
- state_owner.go
- state_provider.go
- state_secret.go
- state_statistic.go
- state_zone.go
- state_zonepolicy.go
- statusupdate.go
- target.go
- ticker.go
- utils.go
- zone.go
- zonecache.go
Click to show internal directories.
Click to hide internal directories.