source

type DNSCurrentState struct {
	Names                  map[dns.DNSSetName]*DNSState
	Targets                utils.StringSet
	AnnotatedNames         utils.StringSet
	AnnotatedRoutingPolicy *v1alpha1.RoutingPolicy
}

type DNSFeedback interface {
	Succeeded(logger logger.LogContext)
	Pending(logger logger.LogContext, dnsname string, msg string, dnsState *DNSState)
	Ready(logger logger.LogContext, dnsname string, msg string, dnsState *DNSState)
	Invalid(logger logger.LogContext, dnsname string, err error, dnsState *DNSState)
	Failed(logger logger.LogContext, dnsname string, err error, dnsState *DNSState)
	Deleted(logger logger.LogContext, dnsname string, msg string)
	Created(logger logger.LogContext, dnsname string, name resources.ObjectName)
}

type DNSInfo struct {
	Names                     dns.DNSNameSet
	TTL                       *int64
	Interval                  *int64
	Targets                   utils.StringSet
	Text                      utils.StringSet
	OrigRef                   *v1alpha1.EntryReference
	TargetRef                 *v1alpha1.EntryReference
	RoutingPolicy             *v1alpha1.RoutingPolicy
	IPStack                   string
	ResolveTargetsToAddresses *bool
	Ignore                    string
}

type DNSSource interface {
	Setup() error

	CreateDNSFeedback(obj resources.Object) DNSFeedback
	GetDNSInfo(logger logger.LogContext, obj resources.ObjectData, current *DNSCurrentState) (*DNSInfo, error)

	Delete(logger logger.LogContext, obj resources.Object) reconcile.Status
	Deleted(logger logger.LogContext, key resources.ClusterObjectKey)
}

type DNSSourceCreator func(controller.Interface) (DNSSource, error)

type DNSSourceType interface {
	Name() string
	GroupKind() schema.GroupKind
	Create(controller.Interface) (DNSSource, error)
}

type DNSState struct {
	v1alpha1.DNSEntryStatus
	CreationTimestamp metav1.Time
}

type DNSTargetExtractor func(logger logger.LogContext, obj resources.ObjectData, names dns.DNSNameSet) (*TargetExtraction, error)

type DefaultDNSSource struct {
	*Events
	// contains filtered or unexported fields
}

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

type Events struct {
	Events map[resources.ClusterObjectKey]map[string]TimestampedMessage
	// contains filtered or unexported fields
}

type TargetExtraction struct {
	Targets                   utils.StringSet
	Texts                     utils.StringSet
	IPStack                   string
	ResolveTargetsToAddresses *bool
	Ignore                    string
}

type TimestampedMessage struct {
	Message   string
	Timestamp time.Time
}