k8sctrl

Documentation

Index

• Variables
• type KubeController
  • func NewKubeController(ctx context.Context, c *dnsendpoint.ExtDNSClient, label string) *KubeController
  • func (ctrl *KubeController) HasSynced() bool
  • func (ctrl *KubeController) Run()
• type LocalDNSEndpoint
  • func (lep LocalDNSEndpoint) String() string
• type LookupEndpoint
• type ResourceWithLookup

Variables

var Resources = struct {
	DNSEndpoint *ResourceWithLookup
}{
	DNSEndpoint: &ResourceWithLookup{
		Name: "DNSEndpoint",
	},
}

Types

type KubeController

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

func NewKubeController

func NewKubeController(ctx context.Context, c *dnsendpoint.ExtDNSClient, label string) *KubeController

func (*KubeController) HasSynced

func (ctrl *KubeController) HasSynced() bool

HasSynced returns true if all controllers have been synced

func (*KubeController) Run

func (ctrl *KubeController) Run()

type LocalDNSEndpoint

type LocalDNSEndpoint struct {
	Targets []string
	TTL     endpoint.TTL
	Labels  map[string]string
	DNSName string
}

func (LocalDNSEndpoint) String

func (lep LocalDNSEndpoint) String() string

type LookupEndpoint

type LookupEndpoint func(indexKey string, clientIP net.IP, geoDataFilePath string, geoDataFieldPath ...string) (result LocalDNSEndpoint)

type ResourceWithLookup

type ResourceWithLookup struct {
	Name   string
	Lookup LookupEndpoint
}