utils

Documentation

Overview

Package utils implements common, reusable helpers

Index

• func Dig(fqdn string, edgeDNSServers ...DNSServer) (ips []string, err error)
• func Exchange(m *dns.Msg, edgeDNSServers []DNSServer) (msg *dns.Msg, err error)
• func GetType(v interface{}) string
• func MergeAnnotations(target map[string]string, source map[string]string) map[string]string
• func SplitAfter(s string, re *regexp.Regexp) (r []string)
• func YamlToGslb(yaml []byte) (*k8gbv1beta1.Gslb, error)
• type DNSList
  • func (l DNSList) String() string
• type DNSMock
  • func NewFakeDNS(settings FakeDNSSettings) *DNSMock
  • func (m *DNSMock) AddAAAARecord(ip net.IP) *DNSMock
  • func (m *DNSMock) AddARecord(fqdn string, ip net.IP) *DNSMock
  • func (m *DNSMock) AddNSRecord(fqdn, nsName string) *DNSMock
  • func (m *DNSMock) AddTXTRecord(fqdn string, strings ...string) *DNSMock
  • func (m *DNSMock) RunTestFunc(f func()) *Result
  • func (m *DNSMock) Start() *DNSMock
• type DNSServer
  • func (s DNSServer) String() string
• type FakeDNSSettings
• type ReconcileResultHandler
  • func NewReconcileResultHandler(reconcileAfter int) *ReconcileResultHandler
  • func (r *ReconcileResultHandler) Requeue() (ctrl.Result, error)
  • func (r *ReconcileResultHandler) RequeueError(err error) (ctrl.Result, error)
  • func (r *ReconcileResultHandler) RequeueNow() (ctrl.Result, error)
  • func (r *ReconcileResultHandler) Stop() (ctrl.Result, error)
• type Result
  • func (r *Result) RequireNoError(t *testing.T)

Functions

func Dig

func Dig(fqdn string, edgeDNSServers ...DNSServer) (ips []string, err error)

Dig returns a list of IP addresses for a given FQDN by using the dns servers from edgeDNSServers dns servers are tried one by one from the edgeDNSServers and if there is a non-error response it is returned and the rest is not tried

func Exchange

func Exchange(m *dns.Msg, edgeDNSServers []DNSServer) (msg *dns.Msg, err error)

func GetType

func GetType(v interface{}) string

func MergeAnnotations

func MergeAnnotations(target map[string]string, source map[string]string) map[string]string

MergeAnnotations adds or updates annotations from source to target and returns merge

func SplitAfter

func SplitAfter(s string, re *regexp.Regexp) (r []string)

SplitAfter works as the same way as strings.SplitAfter() but the separator is regexp

func YamlToGslb

func YamlToGslb(yaml []byte) (*k8gbv1beta1.Gslb, error)

YamlToGslb takes yaml and returns Gslb object

Types

type DNSList

type DNSList []DNSServer

func (DNSList) String

func (l DNSList) String() string

type DNSMock

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

DNSMock acts as DNS server but returns mock values

func NewFakeDNS

func NewFakeDNS(settings FakeDNSSettings) *DNSMock

func (*DNSMock) AddAAAARecord

func (m *DNSMock) AddAAAARecord(ip net.IP) *DNSMock

func (*DNSMock) AddARecord

func (m *DNSMock) AddARecord(fqdn string, ip net.IP) *DNSMock

func (*DNSMock) AddNSRecord

func (m *DNSMock) AddNSRecord(fqdn, nsName string) *DNSMock

func (*DNSMock) AddTXTRecord

func (m *DNSMock) AddTXTRecord(fqdn string, strings ...string) *DNSMock

func (*DNSMock) RunTestFunc

func (m *DNSMock) RunTestFunc(f func()) *Result

func (*DNSMock) Start

func (m *DNSMock) Start() *DNSMock

type DNSServer

type DNSServer struct {
	Host string
	Port int
}

func (DNSServer) String

func (s DNSServer) String() string

type FakeDNSSettings

type FakeDNSSettings struct {
	FakeDNSPort     int
	EdgeDNSZoneFQDN string
	DNSZoneFQDN     string
}

type ReconcileResultHandler

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

func NewReconcileResultHandler

func NewReconcileResultHandler(reconcileAfter int) *ReconcileResultHandler

func (*ReconcileResultHandler) Requeue

func (r *ReconcileResultHandler) Requeue() (ctrl.Result, error)

Requeue requeue loop after config.ReconcileRequeueSeconds this apply in case you didn't modify request resources. If so, reconciliation starts immediately see: https://github.com/operator-framework/operator-sdk/issues/1164

func (*ReconcileResultHandler) RequeueError

func (r *ReconcileResultHandler) RequeueError(err error) (ctrl.Result, error)

RequeueError requeue loop immediately see default controller limiter: https://danielmangum.com/posts/controller-runtime-client-go-rate-limiting/

func (*ReconcileResultHandler) RequeueNow

func (r *ReconcileResultHandler) RequeueNow() (ctrl.Result, error)

func (*ReconcileResultHandler) Stop

func (r *ReconcileResultHandler) Stop() (ctrl.Result, error)

Stop stops reconciliation loop

type Result

type Result struct {
	Error error
}

func (*Result) RequireNoError

func (r *Result) RequireNoError(t *testing.T)