dns

type Client ¶

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

Client holds the client for interacting with the k8s DNS system.

func NewClient(logger logr.Logger, kubeClient kubernetes.Interface) *Client

func (c *Client) CheckDNSProvider(ctx context.Context) (Provider, error)

func (c *Client) ConfigureCoreDNS(ctx context.Context, dnsServiceNamespace, dnsServiceName string, dnsServicePort int32) error

func (c *Client) ConfigureKubeDNS(ctx context.Context, dnsServiceNamespace, dnsServiceName string, dnsServicePort int32) error

func (c *Client) RestoreCoreDNS(ctx context.Context) error

func (c *Client) RestoreKubeDNS(ctx context.Context) error

type Control ¶

type Control struct {
	client.Client

	Log logr.Logger

	Namespace string
	Port      int32

	ServiceName string
	ServicePort int32
}

func (c *Control) Configure(ctx context.Context) error

func (c *Control) Start(ctx context.Context)

type Provider ¶

type Provider int

Provider represents a DNS provider.

const (
	UnknownDNS Provider = iota
	CoreDNS
	KubeDNS
)

type Server ¶

type Server struct {
	dns.Server
	// contains filtered or unexported fields
}

Server is a DNS server forwarding A requests to the configured resolver.

func NewServer(port int32, resolver *ShadowServiceResolver, logger logr.Logger) *Server

type ShadowServiceResolver ¶

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

ShadowServiceResolver is a DNS resolver implementation which resolves the shadow service ClusterIP corresponding to a subdomain. The subdomain must be of form: name.namespace.domain where name and namespace match the shadowed service metadata and domain the configured domain.

func NewShadowServiceResolver(domain, namespace string, serviceLister listers.ServiceLister) *ShadowServiceResolver

func (r *ShadowServiceResolver) Domain() string

func (r *ShadowServiceResolver) LookupFQDN(fqdn string) (net.IP, error)