connectivity

package

Go to main page

Versions in this module

v0

v0.5.6

Jul 11, 2024

v0.5.5

Oct 10, 2023

v0.5.4

Sep 6, 2023

v0.5.3

Apr 7, 2023

v0.5.2

Mar 9, 2023

Changes in this version

type InterpreterConfig

+ FailFast bool

type StepResult

+ func (s *StepResult) Passed(ignoreLoopback bool) bool

v0.5.1

Nov 22, 2022

Changes in this version

+ func PassedPercentage(p *passFailRow) float64

v0.5.0

Jul 12, 2022

v0.4.7

May 22, 2021

v0.4.6

May 2, 2021

Changes in this version

+ func PrintJUnitResults(filename string, results []*Result, ignoreLoopback bool) error

+ func ResultsToJUnit(results []*JUnitTestResult) junit.JUnitTestSuite

+ type JUnitTestResult struct

+ Name string

+ Passed bool

type Result

+ func (r *Result) Passed(ignoreLoopback bool) bool

+ type SummaryTable struct

+ Failed int

+ FeatureCounts map[string]map[string]map[bool]int

+ FeaturePrimaryCounts map[string]map[bool]int

+ Passed int

+ ProtocolCounts map[v1.Protocol]map[Comparison]int

+ TagCounts map[string]map[string]map[bool]int

+ TagPrimaryCounts map[string]map[bool]int

+ Tests [][]string

+ func NewSummaryTableFromResults(ignoreLoopback bool, results []*Result) *SummaryTable

v0.4.5

Apr 27, 2021

Changes in this version

type Printer

+ JunitResultsFile string

v0.4.4

Apr 25, 2021

Changes in this version

type Interpreter

+ Config *InterpreterConfig

type InterpreterConfig

+ JobTimeoutSeconds int

+ func (i *InterpreterConfig) PerturbationWaitDuration() time.Duration

v0.4.3

Apr 14, 2021

v0.4.2

Apr 10, 2021

Changes in this version

+ func RunTestCaseStateTests()

+ type LabelsDiff struct

+ Different []string

+ Extra []string

+ Missing []string

+ Same []string

+ func NewLabelsDiff(actual map[string]string, expected map[string]string) *LabelsDiff

+ func (ld *LabelsDiff) AreAllExpectedLabelsPresent() bool

+ func (ld *LabelsDiff) AreLabelsEqual() bool

v0.4.1

Apr 8, 2021

v0.4.0

Mar 23, 2021

v0.3.1

Mar 4, 2021

Changes in this version

+ type InterpreterConfig struct

+ BatchJobs bool

+ IgnoreLoopback bool

+ KubeProbeRetries int

+ PerturbationWaitSeconds int

+ ResetClusterBeforeTestCase bool

+ VerifyClusterStateBeforeTestCase bool

v0.3.0

Mar 3, 2021

Changes in this version

+ type CombinedResults struct

+ Results []*Result

+ func (c *CombinedResults) Summary(ignoreLoopback bool) *Summary

+ type Summary struct

+ Failed int

+ FeatureCounts map[string]map[string]map[bool]int

+ FeaturePrimaryCounts map[string]map[bool]int

+ Passed int

+ ProtocolCounts map[v1.Protocol]map[Comparison]int

+ TagCounts map[string]map[string]map[bool]int

+ TagPrimaryCounts map[string]map[bool]int

+ Tests [][]string

type TestCaseState

+ func (t *TestCaseState) ResetClusterState() error

+ func (t *TestCaseState) VerifyClusterState() error

v0.2.5

Mar 1, 2021

v0.2.4

Feb 27, 2021

Changes in this version

type ComparisonTable

+ func (c *ComparisonTable) RenderSuccessTable() string

+ func (c *ComparisonTable) ResultsByProtocol() map[bool]map[v1.Protocol]int

+ func (c *ComparisonTable) ValueCountsByProtocol(ignoreLoopback bool) map[v1.Protocol]map[Comparison]int

+ type Item struct

+ Kube *probe.Item

+ Simulated *probe.Item

+ func (i *Item) IsSuccess() bool

+ func (i *Item) ResultsByProtocol() map[bool]map[v1.Protocol]int

type Result

+ InitialResources *probe.Resources

+ func (r *Result) Features() ([]string, []string, []string, []string)

+ func (r *Result) ResultsByProtocol() map[bool]map[v1.Protocol]int

type StepResult

+ func NewStepResult(simulated *probe.Table, policy *matcher.Policy, ...) *StepResult

+ func (s *StepResult) AddKubeProbe(kubeProbe *probe.Table)

+ func (s *StepResult) Comparison(i int) *ComparisonTable

+ func (s *StepResult) LastComparison() *ComparisonTable

type TestCaseState

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

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

+ func (t *TestCaseState) DeleteNamespace(ns string) error

+ func (t *TestCaseState) DeletePod(ns string, pod string) error

v0.2.3

Feb 12, 2021

v0.2.2

Feb 12, 2021

v0.2.1

Feb 12, 2021

v0.2.0

Feb 8, 2021

Changes in this version

+ type Comparison string

+ const DifferentComparison

+ const IgnoredComparison

+ const SameComparison

+ func (c Comparison) ShortString() string

+ type ComparisonTable struct

+ Wrapped *utils.TruthTable

+ func NewComparisonTable(items []string) *ComparisonTable

+ func NewComparisonTableFrom(kubeProbe *types.Table, simulatedProbe *types.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 StepResult

+ KubeProbes []*types.Table

+ SimulatedProbe *types.Probe

+ func (s *StepResult) LastKubeProbe() *types.Table

v0.1.4

Feb 2, 2021

v0.1.3

Feb 2, 2021

v0.1.2

Feb 1, 2021

v0.1.1

Jan 31, 2021

v0.1.0

Jan 30, 2021

Changes in this version

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

+ func PrintNetworkPolicy(p *networkingv1.NetworkPolicy) string

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

+ type Interpreter struct

+ func NewInterpreter(kubernetes *kube.Kubernetes, namespaces []string, pods []string, ports []int, ...) (*Interpreter, error)

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

+ type MultipleContextTestCase struct

+ KubeClients map[string]*kube.Kubernetes

+ KubePolicies []*networkingv1.NetworkPolicy

+ KubeResources map[string]*connectivitykube.Resources

+ NamespacesToClean []string

+ NetpolCreationWaitSeconds int

+ Policy *matcher.Policy

+ Port int

+ Protocol v1.Protocol

+ SyntheticResources *synthetic.Resources

+ type MultipleContextTestCasePrinter struct

+ Contexts []string

+ DifferenceCounts [][]int

+ IgnoreLoopback bool

+ Noisy bool

+ func (t *MultipleContextTestCasePrinter) PrintFinish()

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

+ type MultipleContextTestCaseResult struct

+ Errors []error

+ KubeResults map[string]*connectivitykube.Results

+ SyntheticResult *synthetic.Result

+ TestCase *MultipleContextTestCase

+ type MultipleContextTester struct

+ func NewMultipleContextTester() *MultipleContextTester

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

+ type Printer struct

+ IgnoreLoopback bool

+ Noisy bool

+ Results []*Result

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

+ func (t *Printer) PrintSummary()

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

+ type Result struct

+ Err error

+ Steps []*StepResult

+ TestCase *generator.TestCase

+ type StepResult struct

+ KubePolicies []*networkingv1.NetworkPolicy

+ KubeResults []*connectivitykube.Results

+ Policy *matcher.Policy

+ SyntheticResult *synthetic.Result

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

+ type TestCaseState struct

+ Kubernetes *kube.Kubernetes

+ Policies []*networkingv1.NetworkPolicy

+ Resources *synthetic.Resources

+ 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

v0.0.10

Jan 25, 2021

Changes in this version

type TestCase

+ KubePolicies []*networkingv1.NetworkPolicy

v0.0.9

Jan 24, 2021

v0.0.8

Jan 24, 2021

Changes in this version

+ func SetupCluster(kubernetes *kube.Kubernetes, namespaces []string, pods []string, port int, ...) (*connectivitykube.Resources, *synthetic.Resources, error)

+ type TestCase struct

+ KubePolicy *networkingv1.NetworkPolicy

+ KubeResources *connectivitykube.Resources

+ NamespacesToClean []string

+ NetpolCreationWaitSeconds int

+ Port int

+ Protocol v1.Protocol

+ SyntheticResources *synthetic.Resources

+ type TestCasePrinter struct

+ IgnoreLoopback bool

+ Noisy bool

+ func (t *TestCasePrinter) PrintTestCaseResult(result *TestCaseResult)

+ type TestCaseResult struct

+ Err error

+ KubeResult *connectivitykube.Results

+ Policy *matcher.Policy

+ SyntheticResult *synthetic.Result

+ TestCase *TestCase

+ type Tester struct

+ func NewTester(kubernetes *kube.Kubernetes) *Tester

+ func (t *Tester) TestNetworkPolicy(testCase *TestCase) *TestCaseResult

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL