assistant

Documentation

Index

• type Assistant
• type Gslb
  • func NewGslbAssistant(client client.Client, k8gbNamespace string, edgeDNSServers []utils.DNSServer) *Gslb
  • func (r *Gslb) CoreDNSExposedIPs() ([]string, error)
  • func (r *Gslb) GetExternalTargets(host string, extClusterNsNames map[string]string) (targets Targets)
  • func (r *Gslb) GslbIngressExposedIPs(gslb *k8gbv1beta1.Gslb) ([]string, error)
  • func (r *Gslb) InspectTXTThreshold(fqdn string, splitBrainThreshold time.Duration) error
  • func (r *Gslb) RemoveEndpoint(endpointName string) error
  • func (r *Gslb) SaveDNSEndpoint(namespace string, i *externaldns.DNSEndpoint) error
• type Target
• type Targets
  • func NewTargets() Targets
  • func (t Targets) Append(tag string, ips []string)
  • func (t Targets) AppendTargets(targets Targets)
  • func (t Targets) GetIPs() (ips []string)
  • func (t Targets) Sort()

Types

type Assistant

type Assistant interface {
	// CoreDNSExposedIPs retrieves list of exposed IP by CoreDNS
	CoreDNSExposedIPs() ([]string, error)
	// GslbIngressExposedIPs retrieves list of IP's exposed by all GSLB ingresses
	GslbIngressExposedIPs(gslb *k8gbv1beta1.Gslb) ([]string, error)
	// GetExternalTargets retrieves slice of targets from external clusters
	GetExternalTargets(host string, extClusterNsNames map[string]string) (targets Targets)
	// SaveDNSEndpoint update DNS endpoint or create new one if doesnt exist
	SaveDNSEndpoint(namespace string, i *externaldns.DNSEndpoint) error
	// RemoveEndpoint removes endpoint
	RemoveEndpoint(endpointName string) error
	// InspectTXTThreshold inspects fqdn TXT record from edgeDNSServer. If record doesn't exists or timestamp is greater than
	// splitBrainThreshold the error is returned. In case fakeDNSEnabled is true, 127.0.0.1:7753 is used as edgeDNSServer
	InspectTXTThreshold(fqdn string, splitBrainThreshold time.Duration) error
}

type Gslb

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

Gslb is common wrapper operating on GSLB instance. It uses apimachinery client to call kubernetes API

func NewGslbAssistant

func NewGslbAssistant(client client.Client, k8gbNamespace string, edgeDNSServers []utils.DNSServer) *Gslb

func (*Gslb) CoreDNSExposedIPs

func (r *Gslb) CoreDNSExposedIPs() ([]string, error)

CoreDNSExposedIPs retrieves list of IP's exposed by CoreDNS

func (*Gslb) GetExternalTargets

func (r *Gslb) GetExternalTargets(host string, extClusterNsNames map[string]string) (targets Targets)

func (*Gslb) GslbIngressExposedIPs

func (r *Gslb) GslbIngressExposedIPs(gslb *k8gbv1beta1.Gslb) ([]string, error)

GslbIngressExposedIPs retrieves list of IP's exposed by all GSLB ingresses

func (*Gslb) InspectTXTThreshold

func (r *Gslb) InspectTXTThreshold(fqdn string, splitBrainThreshold time.Duration) error

InspectTXTThreshold inspects fqdn TXT record from edgeDNSServer. If record doesn't exists or timestamp is greater than splitBrainThreshold the error is returned.

func (*Gslb) RemoveEndpoint

func (r *Gslb) RemoveEndpoint(endpointName string) error

RemoveEndpoint removes endpoint

func (*Gslb) SaveDNSEndpoint

func (r *Gslb) SaveDNSEndpoint(namespace string, i *externaldns.DNSEndpoint) error

SaveDNSEndpoint update DNS endpoint or create new one if doesnt exist

type Target

type Target struct {
	IPs []string
}

type Targets

type Targets map[string]*Target

func NewTargets

func NewTargets() Targets

func (Targets) Append

func (t Targets) Append(tag string, ips []string)

func (Targets) AppendTargets

func (t Targets) AppendTargets(targets Targets)

func (Targets) GetIPs

func (t Targets) GetIPs() (ips []string)

func (Targets) Sort

func (t Targets) Sort()