connectivity

Documentation

Index

• func GetSyntheticResources(kubernetes *kube.Kubernetes, kubeResources *connectivitykube.Resources) (*synthetic.Resources, error)
• func PrintNetworkPolicy(p *networkingv1.NetworkPolicy) string
• func SetupCluster(kubernetes *kube.Kubernetes, kubeResources *connectivitykube.Resources) error
• func SetupClusterTODODelete(kubernetes *kube.Kubernetes, namespaces []string, pods []string, port int, ...) (*connectivitykube.Resources, *synthetic.Resources, error)
• type Interpreter
  • func NewInterpreter(kubernetes *kube.Kubernetes, namespaces []string, pods []string, ports []int, ...) (*Interpreter, error)
  • func (t *Interpreter) ExecuteTestCase(testCase *generator.TestCase) *Result
• type MultipleContextTestCase
• type MultipleContextTestCasePrinter
  • func (t *MultipleContextTestCasePrinter) PrintFinish()
  • func (t *MultipleContextTestCasePrinter) PrintTestCaseResult(result *MultipleContextTestCaseResult)
• type MultipleContextTestCaseResult
• type MultipleContextTester
  • func NewMultipleContextTester() *MultipleContextTester
  • func (t *MultipleContextTester) TestNetworkPolicy(testCase *MultipleContextTestCase) *MultipleContextTestCaseResult
• 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) LastKubeResult() *connectivitykube.Results
• 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 GetSyntheticResources

func GetSyntheticResources(kubernetes *kube.Kubernetes, kubeResources *connectivitykube.Resources) (*synthetic.Resources, error)

func PrintNetworkPolicy

func PrintNetworkPolicy(p *networkingv1.NetworkPolicy) string

func SetupCluster

func SetupCluster(kubernetes *kube.Kubernetes, kubeResources *connectivitykube.Resources) error

func SetupClusterTODODelete

func SetupClusterTODODelete(kubernetes *kube.Kubernetes, namespaces []string, pods []string, port int, protocol v1.Protocol) (*connectivitykube.Resources, *synthetic.Resources, error)

Types

type Interpreter

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

func NewInterpreter

func NewInterpreter(kubernetes *kube.Kubernetes, namespaces []string, pods []string, ports []int, protocols []v1.Protocol, resetClusterBeforeTestCase bool, kubeProbeRetries int) (*Interpreter, error)

func (*Interpreter) ExecuteTestCase

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

type MultipleContextTestCase

type MultipleContextTestCase struct {
	KubePolicies              []*networkingv1.NetworkPolicy
	NetpolCreationWaitSeconds int
	Port                      int
	Protocol                  v1.Protocol
	KubeClients               map[string]*kube.Kubernetes
	KubeResources             map[string]*connectivitykube.Resources
	SyntheticResources        *synthetic.Resources
	NamespacesToClean         []string
	Policy                    *matcher.Policy
}

type MultipleContextTestCasePrinter

type MultipleContextTestCasePrinter struct {
	Noisy            bool
	IgnoreLoopback   bool
	Contexts         []string
	DifferenceCounts [][]int
}

func (*MultipleContextTestCasePrinter) PrintFinish

func (t *MultipleContextTestCasePrinter) PrintFinish()

func (*MultipleContextTestCasePrinter) PrintTestCaseResult

func (t *MultipleContextTestCasePrinter) PrintTestCaseResult(result *MultipleContextTestCaseResult)

type MultipleContextTestCaseResult

type MultipleContextTestCaseResult struct {
	TestCase        *MultipleContextTestCase
	SyntheticResult *synthetic.Result
	KubeResults     map[string]*connectivitykube.Results
	Errors          []error
}

type MultipleContextTester

type MultipleContextTester struct{}

func NewMultipleContextTester

func NewMultipleContextTester() *MultipleContextTester

func (*MultipleContextTester) TestNetworkPolicy

func (t *MultipleContextTester) TestNetworkPolicy(testCase *MultipleContextTestCase) *MultipleContextTestCaseResult

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 {
	SyntheticResult *synthetic.Result
	KubeResults     []*connectivitykube.Results
	Policy          *matcher.Policy
	KubePolicies    []*networkingv1.NetworkPolicy
}

func (*StepResult) LastKubeResult

func (s *StepResult) LastKubeResult() *connectivitykube.Results

type TestCaseState

type TestCaseState struct {
	Kubernetes *kube.Kubernetes
	Resources  *synthetic.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