event

Documentation

Index

• type DnsResolver
• type Locator
• type NodeGetter
• type PodLocator
  • func NewApiServerPodLocator(client *kubernetes.Clientset) (*PodLocator, error)
  • func (locator *PodLocator) LocatePod(ip string) (*v1.Pod, error)
  • func (locator *PodLocator) Run(stopCh <-chan struct{})
• type Poster
  • func InitPoster() (*Poster, error)
  • func (poster *Poster) Run(stopCh <-chan struct{}, packetDropCh <-chan drop.PacketDrop)
• type TrafficDirection
  • func (td TrafficDirection) String() string

Types

type DnsResolver

type DnsResolver interface {
	LookupAddr(context context.Context, ip string) (names []string, err error)
}

DnsResolver allows for mocking out the functionality of net.DefaultResolver when testing getPacketDropMessage()

type Locator

type Locator interface {
	Run(stopCh <-chan struct{})
	LocatePod(ip string) (*v1.Pod, error)
}

type NodeGetter

type NodeGetter interface {
	Get(name string, options metav1.GetOptions) (*v1.Node, error)
}

type PodLocator

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

PodLocator handles the process of locating corresponding Pods having iptables packet drops in Kubernetes cluster.

func NewApiServerPodLocator

func NewApiServerPodLocator(client *kubernetes.Clientset) (*PodLocator, error)

* Returns a locator that pulls pod data from the apiserver

func (*PodLocator) LocatePod

func (locator *PodLocator) LocatePod(ip string) (*v1.Pod, error)

func (*PodLocator) Run

func (locator *PodLocator) Run(stopCh <-chan struct{})

type Poster

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

Poster handles submitting Kubernetes Events to Pods running in the cluster.

func InitPoster

func InitPoster() (*Poster, error)

Init Poster and return its pointer

func (*Poster) Run

func (poster *Poster) Run(stopCh <-chan struct{}, packetDropCh <-chan drop.PacketDrop)

Run the poster by handling PacketDrop from given channel. Apply exponential backoff if server is down.

type TrafficDirection

type TrafficDirection int

func (TrafficDirection) String

func (td TrafficDirection) String() string