Versions in this module Expand all Collapse all v0 v0.2.0 Oct 27, 2022 Changes in this version + const ANNOTATION_HEALTH_CHECK_PREFIX + const TargetTypeHost + const TargetTypeIP + var NoSuchHost = errors.New("no such host") + func DefaultInterval(ttl time.Duration) time.Duration + func IsNoSuchHostError(err error) bool + func NewVerifier(resolver resolver) *verifier + type ConditionStatus string + const ConditionFalse + const ConditionTrue + const ConditionUnknown + const DNSRecordFinalizer + type ConfigMapHostResolver struct + Client kubernetes.Interface + Name string + Namespace string + func (r *ConfigMapHostResolver) LookupIPAddr(ctx context.Context, host string) ([]HostAddress, error) + func (r *ConfigMapHostResolver) TxtRecordExists(ctx context.Context, domain string, value string) (bool, error) + type Controller struct + func NewController(config *ControllerConfig) (*Controller, error) + func (c *Controller) ReconcileHealthChecks(ctx context.Context, dnsRecord *v1.DNSRecord) error + type ControllerConfig struct + DNSProvider string + DnsRecordClient kuadrantv1.ClusterInterface + SharedInformerFactory externalversions.SharedInformerFactory + type DefaultHostResolver struct + Client dns.Client + func NewDefaultHostResolver() *DefaultHostResolver + func (hr *DefaultHostResolver) LookupIPAddr(ctx context.Context, host string) ([]HostAddress, error) + type FakeProvider struct + func (FakeProvider) DeleteHealthCheck(ctx context.Context, _ *v1.Endpoint) error + func (FakeProvider) ReconcileHealthCheck(ctx context.Context, _ v1.HealthCheck, _ *v1.Endpoint) error + func (_ *FakeProvider) Delete(record *v1.DNSRecord, zone v1.DNSZone) error + func (_ *FakeProvider) Ensure(record *v1.DNSRecord, zone v1.DNSZone) error + type HealthCheckReconciler interface + DeleteHealthCheck func(ctx context.Context, endpoint *v1.Endpoint) error + ReconcileHealthCheck func(ctx context.Context, hc v1.HealthCheck, endpoint *v1.Endpoint) error + type HostAddress struct + Host string + IP gonet.IP + TTL time.Duration + TXT string + type HostResolver interface + LookupIPAddr func(ctx context.Context, host string) ([]HostAddress, error) + type HostsWatcher struct + OnChange func(interface{}) + Records []RecordWatcher + Resolver HostResolver + WatchInterval func(ttl time.Duration) time.Duration + func NewHostsWatcher(l *logr.Logger, resolver HostResolver, ...) *HostsWatcher + func (w *HostsWatcher) ListHostRecordWatchers(obj interface{}) []RecordWatcher + func (w *HostsWatcher) StartWatching(ctx context.Context, obj interface{}, host string) bool + func (w *HostsWatcher) StopWatching(obj interface{}, host string) + type Provider interface + Delete func(record *v1.DNSRecord, zone v1.DNSZone) error + Ensure func(record *v1.DNSRecord, zone v1.DNSZone) error + func DNSProvider(dnsProviderName string) (Provider, error) + type RecordWatcher struct + Host string + type SafeHostResolver struct + func NewSafeHostResolver(inner HostResolver) *SafeHostResolver + func (r *SafeHostResolver) LookupIPAddr(ctx context.Context, host string) ([]HostAddress, error) + type Target struct + TargetType string + Value []string