k8s

Documentation

Index

• Constants
• type K8sIPResolver
  • func NewK8sIPResolver(clientset kubernetes.Interface, resolveDns bool) (*K8sIPResolver, error)
  • func (resolver *K8sIPResolver) ResolveIP(ip string) Workload
  • func (resolver *K8sIPResolver) StartWatching() error
  • func (resolver *K8sIPResolver) StopWatching()
• type Workload

Constants

const MAX_RESOLVED_DNS = 10000 // arbitrary limit

Types

type K8sIPResolver

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

func NewK8sIPResolver

func NewK8sIPResolver(clientset kubernetes.Interface, resolveDns bool) (*K8sIPResolver, error)

func (*K8sIPResolver) ResolveIP

func (resolver *K8sIPResolver) ResolveIP(ip string) Workload

resolve the given IP from the resolver's cache if not available, return the IP itself.

func (*K8sIPResolver) StartWatching

func (resolver *K8sIPResolver) StartWatching() error

func (*K8sIPResolver) StopWatching

func (resolver *K8sIPResolver) StopWatching()

type Workload

type Workload struct {
	Name      string
	Namespace string
	Kind      string
}