utils

Documentation

Index

• func GetClientSet() (*kubernetes.Clientset, error)
• func IsIPv4(ipFamily string) bool
• func IsIPv6(ipFamily string) bool
• func ParseNFQLB(output string) int
• func PodExec(pod *corev1.Pod, container string, command []string) (string, error)
• func PodHasNetworkInterface(pod *corev1.Pod, container string, interfaceSubName string) (bool, error)
• func VIPPort(vip string, port int) string
• type CTraffic
  • func (ct *CTraffic) AnalyzeTraffic(output []byte) (map[string]int, int)
  • func (ct *CTraffic) GetCommand(ipPort string, protocol string) string
• type MConnect
  • func (mc *MConnect) AnalyzeTraffic(output []byte) (map[string]int, int)
  • func (mc *MConnect) GetCommand(ipPort string, protocol string) string
• type StreamStatus
  • func ParseTargetWatch(output string) []*StreamStatus
• type TrafficGenerator
• type TrafficGeneratorHost
  • func (tgh *TrafficGeneratorHost) SendTraffic(tg TrafficGenerator, trench string, namespace string, ipPort string, ...) (map[string]int, int)

Functions

func GetClientSet

func GetClientSet() (*kubernetes.Clientset, error)

func IsIPv4

func IsIPv4(ipFamily string) bool

func IsIPv6

func IsIPv6(ipFamily string) bool

func ParseNFQLB

func ParseNFQLB(output string) int

func PodExec

func PodExec(pod *corev1.Pod, container string, command []string) (string, error)

func PodHasNetworkInterface

func PodHasNetworkInterface(pod *corev1.Pod, container string, interfaceSubName string) (bool, error)

func VIPPort

func VIPPort(vip string, port int) string

Types

type CTraffic

type CTraffic struct {
	NConn int
	Rate  int
}

func (*CTraffic) AnalyzeTraffic

func (ct *CTraffic) AnalyzeTraffic(output []byte) (map[string]int, int)

func (*CTraffic) GetCommand

func (ct *CTraffic) GetCommand(ipPort string, protocol string) string

type MConnect

type MConnect struct {
	NConn int
}

func (*MConnect) AnalyzeTraffic

func (mc *MConnect) AnalyzeTraffic(output []byte) (map[string]int, int)

func (*MConnect) GetCommand

func (mc *MConnect) GetCommand(ipPort string, protocol string) string

type StreamStatus

type StreamStatus struct {
	Trench  string
	Conduit string
	Stream  string
	Status  string
}

func ParseTargetWatch

func ParseTargetWatch(output string) []*StreamStatus

type TrafficGenerator

type TrafficGenerator interface {
	GetCommand(ipPort string, protocol string) string
	AnalyzeTraffic([]byte) (map[string]int, int)
}

type TrafficGeneratorHost

type TrafficGeneratorHost struct {
	TrafficGeneratorCommand string
}

func (*TrafficGeneratorHost) SendTraffic

func (tgh *TrafficGeneratorHost) SendTraffic(tg TrafficGenerator, trench string, namespace string, ipPort string, protocol string) (map[string]int, int)