dnsendpoint

Documentation

Index

• Constants
• func DedupeAndMergeEndpoints(endpoints []*feddnsv1a1.Endpoint) (result []*feddnsv1a1.Endpoint)
• func ExtractLoadBalancerTargets(lbStatus corev1.LoadBalancerStatus) feddnsv1a1.Targets
• func StartIngressDNSEndpointController(config *restclient.Config, targetNamespace string, stopChan <-chan struct{}, ...) error
• func StartServiceDNSEndpointController(config *restclient.Config, targetNamespace string, stopChan <-chan struct{}, ...) error
• type GetEndpointsFunc
• type NetWrapper
• type NetWrapperDefaultImplementation
  • func (r *NetWrapperDefaultImplementation) LookupHost(host string) (addrs []string, err error)

Constants

const (

	// RecordTypeA is a RecordType enum value
	RecordTypeA = "A"
	// RecordTypeCNAME is a RecordType enum value
	RecordTypeCNAME = "CNAME"
)

Functions

func DedupeAndMergeEndpoints

func DedupeAndMergeEndpoints(endpoints []*feddnsv1a1.Endpoint) (result []*feddnsv1a1.Endpoint)

Merge and remove duplicate endpoints

func ExtractLoadBalancerTargets

func ExtractLoadBalancerTargets(lbStatus corev1.LoadBalancerStatus) feddnsv1a1.Targets

func StartIngressDNSEndpointController

func StartIngressDNSEndpointController(config *restclient.Config, targetNamespace string, stopChan <-chan struct{}, minimizeLatency bool) error

func StartServiceDNSEndpointController

func StartServiceDNSEndpointController(config *restclient.Config, targetNamespace string, stopChan <-chan struct{}, minimizeLatency bool) error

Types

type GetEndpointsFunc

type GetEndpointsFunc func(interface{}) ([]*feddnsv1a1.Endpoint, error)

type NetWrapper

type NetWrapper interface {
	LookupHost(host string) (addrs []string, err error)
}

Abstracting away the internet for testing purposes

type NetWrapperDefaultImplementation

type NetWrapperDefaultImplementation struct{}

func (*NetWrapperDefaultImplementation) LookupHost

func (r *NetWrapperDefaultImplementation) LookupHost(host string) (addrs []string, err error)