connectivity

Documentation

Index

• func PrintNetworkPolicy(p *networkingv1.NetworkPolicy) string
• type Comparison
  • func (c Comparison) ShortString() string
• type ComparisonTable
  • func NewComparisonTable(items []string) *ComparisonTable
  • func NewComparisonTableFrom(kubeProbe *probe.Table, simulatedProbe *probe.Table) *ComparisonTable
  • func (c *ComparisonTable) Get(from string, to string) bool
  • func (c *ComparisonTable) RenderTable() string
  • func (c *ComparisonTable) Set(from string, to string, value bool)
  • func (c *ComparisonTable) ValueCounts(ignoreLoopback bool) map[Comparison]int
• type Interpreter
  • func NewInterpreter(kubernetes *kube.Kubernetes, resources *probe.Resources, ...) (*Interpreter, error)
  • func (t *Interpreter) ExecuteTestCase(testCase *generator.TestCase) *Result
• type Printer
  • func (t *Printer) PrintStep(i int, step *generator.TestStep, stepResult *StepResult)
  • func (t *Printer) PrintSummary()
  • func (t *Printer) PrintTestCaseResult(result *Result)
• type Result
• type StepResult
  • func (s *StepResult) LastKubeProbe() *probe.Table
• type TestCaseState
  • func (t *TestCaseState) CreatePolicy(policy *networkingv1.NetworkPolicy) error
  • func (t *TestCaseState) DeletePolicy(ns string, name string) error
  • func (t *TestCaseState) ReadPolicies(namespaces []string) error
  • func (t *TestCaseState) SetNamespaceLabels(ns string, labels map[string]string) error
  • func (t *TestCaseState) SetPodLabels(ns string, pod string, labels map[string]string) error
  • func (t *TestCaseState) UpdatePolicy(policy *networkingv1.NetworkPolicy) error

Functions

func PrintNetworkPolicy

func PrintNetworkPolicy(p *networkingv1.NetworkPolicy) string

Types

type Comparison

type Comparison string

const (
	SameComparison      Comparison = "same"
	DifferentComparison Comparison = "different"
	IgnoredComparison   Comparison = "ignored"
)

func (Comparison) ShortString

func (c Comparison) ShortString() string

type ComparisonTable

type ComparisonTable struct {
	Wrapped *probe.TruthTable
}

func NewComparisonTable

func NewComparisonTable(items []string) *ComparisonTable

func NewComparisonTableFrom

func NewComparisonTableFrom(kubeProbe *probe.Table, simulatedProbe *probe.Table) *ComparisonTable

func (*ComparisonTable) Get

func (c *ComparisonTable) Get(from string, to string) bool

func (*ComparisonTable) RenderTable

func (c *ComparisonTable) RenderTable() string

func (*ComparisonTable) Set

func (c *ComparisonTable) Set(from string, to string, value bool)

func (*ComparisonTable) ValueCounts

func (c *ComparisonTable) ValueCounts(ignoreLoopback bool) map[Comparison]int

type Interpreter

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

func NewInterpreter

func NewInterpreter(kubernetes *kube.Kubernetes, resources *probe.Resources, resetClusterBeforeTestCase bool, kubeProbeRetries int, perturbationWaitSeconds int, verifyClusterStateBeforeTestCase bool) (*Interpreter, error)

func (*Interpreter) ExecuteTestCase

func (t *Interpreter) ExecuteTestCase(testCase *generator.TestCase) *Result

type Printer

type Printer struct {
	Noisy          bool
	IgnoreLoopback bool
	Results        []*Result
}

func (*Printer) PrintStep

func (t *Printer) PrintStep(i int, step *generator.TestStep, stepResult *StepResult)

func (*Printer) PrintSummary

func (t *Printer) PrintSummary()

func (*Printer) PrintTestCaseResult

func (t *Printer) PrintTestCaseResult(result *Result)

type Result

type Result struct {
	TestCase *generator.TestCase
	Steps    []*StepResult
	Err      error
}

type StepResult

type StepResult struct {
	SimulatedProbe *probe.Probe
	KubeProbes     []*probe.Table
	Policy         *matcher.Policy
	KubePolicies   []*networkingv1.NetworkPolicy
}

func (*StepResult) LastKubeProbe

func (s *StepResult) LastKubeProbe() *probe.Table

type TestCaseState

type TestCaseState struct {
	Kubernetes *kube.Kubernetes
	Resources  *probe.Resources
	Policies   []*networkingv1.NetworkPolicy
}

func (*TestCaseState) CreatePolicy

func (t *TestCaseState) CreatePolicy(policy *networkingv1.NetworkPolicy) error

func (*TestCaseState) DeletePolicy

func (t *TestCaseState) DeletePolicy(ns string, name string) error

func (*TestCaseState) ReadPolicies

func (t *TestCaseState) ReadPolicies(namespaces []string) error

func (*TestCaseState) SetNamespaceLabels

func (t *TestCaseState) SetNamespaceLabels(ns string, labels map[string]string) error

func (*TestCaseState) SetPodLabels

func (t *TestCaseState) SetPodLabels(ns string, pod string, labels map[string]string) error

func (*TestCaseState) UpdatePolicy

func (t *TestCaseState) UpdatePolicy(policy *networkingv1.NetworkPolicy) error