search_domain_operator

Documentation

Index

• func AddToList(sd *discoveryv1alpha1.SearchDomain, refs []v1.ObjectReference)
• func AnswerToTxt(answers []dns.RR) ([]string, error)
• func ForeignClustersToObjectReferences(fcs []*discoveryv1alpha1.ForeignCluster) []v1.ObjectReference
• func GetDnsMsg(name string, qType uint16) *dns.Msg
• func ResolveWan(c *dns.Client, dnsAddr string, ptr *dns.PTR, test bool) (*discovery.TxtData, error)
• func StartOperator(mgr *manager.Manager, requeueAfter time.Duration, ...)
• func Wan(dnsAddr string, name string, test bool) ([]*discovery.TxtData, error)
• type SearchDomainReconciler
  • func GetSDReconciler(scheme *runtime.Scheme, crdClient *crdClient.CRDClient, ...) *SearchDomainReconciler
  • func (r *SearchDomainReconciler) CheckForDeletion(sd *discoveryv1alpha1.SearchDomain, txts []*discovery.TxtData) ([]string, error)
  • func (r *SearchDomainReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *SearchDomainReconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func AddToList

func AddToList(sd *discoveryv1alpha1.SearchDomain, refs []v1.ObjectReference)

func AnswerToTxt

func AnswerToTxt(answers []dns.RR) ([]string, error)

func ForeignClustersToObjectReferences

func ForeignClustersToObjectReferences(fcs []*discoveryv1alpha1.ForeignCluster) []v1.ObjectReference

func GetDnsMsg

func GetDnsMsg(name string, qType uint16) *dns.Msg

func ResolveWan

func ResolveWan(c *dns.Client, dnsAddr string, ptr *dns.PTR, test bool) (*discovery.TxtData, error)

func StartOperator

func StartOperator(mgr *manager.Manager, requeueAfter time.Duration, discoveryCtrl *discovery.DiscoveryCtrl, kubeconfigPath string)

func Wan

func Wan(dnsAddr string, name string, test bool) ([]*discovery.TxtData, error)

Types

type SearchDomainReconciler

type SearchDomainReconciler struct {
	Scheme *runtime.Scheme

	DiscoveryCtrl *discovery.DiscoveryCtrl
	// contains filtered or unexported fields
}

func GetSDReconciler

func GetSDReconciler(scheme *runtime.Scheme, crdClient *crdClient.CRDClient, discoveryCtrl *discovery.DiscoveryCtrl, requeueAfter time.Duration) *SearchDomainReconciler

func (*SearchDomainReconciler) CheckForDeletion

func (r *SearchDomainReconciler) CheckForDeletion(sd *discoveryv1alpha1.SearchDomain, txts []*discovery.TxtData) ([]string, error)

func (*SearchDomainReconciler) Reconcile

func (r *SearchDomainReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*SearchDomainReconciler) SetupWithManager

func (r *SearchDomainReconciler) SetupWithManager(mgr ctrl.Manager) error