check

Jul 31, 2024

Changes in this version

+ func AssertFRRBGPNeighborTimers(t *Test, neighbors map[string]FRRBGPNeighborInfo, checkNeighbors []netip.Addr, ...)

type FRRBGPNeighborInfo

+ BgpTimerHoldTimeMsecs int

+ BgpTimerKeepAliveIntervalMsecs int

+ BgpTimerUpEstablishedEpoch int

+ BgpTimerUpMsec int

+ type JUnitCollector struct

+ func NewJUnitCollector(junitProperties map[string]string, junitFile string) *JUnitCollector

+ func (j *JUnitCollector) Collect(ct *ConnectivityTest)

+ func (j *JUnitCollector) Write() error

type Parameters

+ TestNamespaceIndex int

Jul 10, 2024

Changes in this version

+ func ApplyFRRConfig(ctx context.Context, t *Test, frrPod *Pod, config string)

+ func AssertFRRBGPCommunity(t *Test, frrPrefixes FRRBGPPrefixMap, checkPrefixes []netip.Prefix, ...)

+ func ClearFRRConfig(ctx context.Context, t *Test, frrPod *Pod)

+ func DeleteK8sResourceWithWait[T any](ctx context.Context, t *Test, k8sClient k8s.ResourceClient[T], ...)

+ func DumpFRRBGPState(ctx context.Context, t *Test, frrPod *Pod)

+ func NewFRRConfigMap() *corev1.ConfigMap

+ func NewFRRDaemonSet(params Parameters) *appsv1.DaemonSet

+ func RenderFRRBGPPeeringConfig(t *Test, params FRRBGPPeeringParams) string

+ func RunFRRCommand(ctx context.Context, t *Test, frrPod *Pod, cmd string) []byte

+ func WaitForFRRBGPNeighborsState(ctx context.Context, t *Test, frrPod *Pod, expPeers []netip.Addr, ...)

type ConnectivityTest

+ func (ct *ConnectivityTest) EchoServicePrefixes(ipFamily features.IPFamily) []netip.Prefix

+ func (ct *ConnectivityTest) FRRPods() []Pod

+ func (ct *ConnectivityTest) InternalNodeIPAddresses(ipFamily features.IPFamily) []netip.Addr

+ func (ct *ConnectivityTest) PodCIDRPrefixes(ipFamily features.IPFamily) []netip.Prefix

+ type FRRBGPAddressFamilyInfo struct

+ LocalAS int

+ RouterID string

+ Routes FRRBGPPrefixMap

+ VrfID int

+ VrfName string

+ type FRRBGPNeighborInfo struct

+ BGPState string

+ Hostname string

+ LocalAS int

+ LocalRouterID string

+ RemoteAS int

+ RemoteRouterID string

+ type FRRBGPNextHopInfo struct

+ Accessible bool

+ Afi string

+ Hostname string

+ IP string

+ Metric int

+ Scope string

+ Used bool

+ type FRRBGPPeeringParams struct

+ LocalASN int

+ Peers []netip.Addr

+ type FRRBGPPrefixMap map[string][]FRRBGPRouteInfo

+ func WaitForFRRBGPPrefixes(ctx context.Context, t *Test, frrPod *Pod, expPrefixes []netip.Prefix, ...) FRRBGPPrefixMap

+ type FRRBGPRouteInfo struct

+ ASPath struct{ ... }

+ BestPath struct{ ... }

+ Community struct{ ... }

+ NextHops []FRRBGPNextHopInfo

+ Origin string

+ Valid bool

+ Version int

type Parameters

+ FRRImage string

type Test

+ func (t *Test) Failed() bool

Jun 7, 2024

Changes in this version

+ var ResultCurlTimeout = Result

type Action

+ func (a *Action) Scenario() Scenario

+ type CiliumLocalRedirectPolicyParams struct

+ FrontendIP string

+ Name string

+ Policy string

+ SkipRedirectFromBackend bool

type ConnectivityTest

+ func (ct *ConnectivityTest) EchoExternalServices() map[string]Service

+ func (ct *ConnectivityTest) LrpBackendPods() map[string]Pod

+ func (ct *ConnectivityTest) LrpClientPods() map[string]Pod

+ type EchoIPService struct

+ func (s EchoIPService) Path() string

+ type LRPFrontend struct

+ func NewLRPFrontend(frontend ciliumv2.RedirectFrontend) *LRPFrontend

+ func (l LRPFrontend) Address(features.IPFamily) string

+ func (l LRPFrontend) FlowFilters() []*flow.FlowFilter

+ func (l LRPFrontend) HasLabel(string, string) bool

+ func (l LRPFrontend) Labels() map[string]string

+ func (l LRPFrontend) Name() string

+ func (l LRPFrontend) Path() string

+ func (l LRPFrontend) Port() uint32

+ func (l LRPFrontend) Scheme() string

type Service

+ func (s Service) ToEchoIPService() EchoIPService

type Test

+ func (t *Test) CiliumLocalRedirectPolicies() map[string]*ciliumv2.CiliumLocalRedirectPolicy

+ func (t *Test) WithCiliumLocalRedirectPolicy(params CiliumLocalRedirectPolicyParams) *Test

May 29, 2024

Changes in this version

+ type ConcurrentLogger struct

+ func NewConcurrentLogger(writer io.Writer, concurrency int) *ConcurrentLogger

+ func (c *ConcurrentLogger) FinishTest(test *Test)

+ func (c *ConcurrentLogger) Printf(test *Test, format string, args ...interface{})

+ func (c *ConcurrentLogger) Start(ctx context.Context)

+ func (c *ConcurrentLogger) Stop()

type ConnectivityTest

+ func (ct *ConnectivityTest) Cleanup()

+ func (ct *ConnectivityTest) PrintReport(ctx context.Context) error

+ func (ct *ConnectivityTest) PrintTestInfo()

type Parameters

+ EchoServerHostPort int

+ ExternalDeploymentPort int

+ TestConcurrency int

Apr 26, 2024

Changes in this version

+ const EchoOtherNodeDeploymentHeadlessServiceName

type ConnectivityTest

+ func (ct *ConnectivityTest) DigCommandService(peer TestPeer, ipFam features.IPFamily) []string

+ func (ct *ConnectivityTest) EchoServicesAll() map[string]Service

type Parameters

+ TestConnDisruptImage string

Mar 28, 2024

Changes in this version

type Service

+ func WaitForServiceRetrieval(ctx context.Context, log Logger, client *k8s.Client, namespace string, ...) (Service, error)

Mar 5, 2024

Changes in this version

+ func CreateOrUpdatePolicy[T policy](ctx context.Context, client client[T], obj T, mutator func(obj T) bool) (bool, error)

+ func ParsePolicyYAML[T runtime.Object](input string, scheme *runtime.Scheme) (output []T, err error)

+ func RegisterPolicy[T policy](current map[string]T, policies ...T) (map[string]T, error)

type ConnectivityTest

+ func (ct *ConnectivityTest) AddTest(t *Test) *Test

type Test

+ func NewTest(name string, verbose bool, debug bool) *Test

+ func (t *Test) CiliumClusterwideNetworkPolicies() map[string]*ciliumv2.CiliumClusterwideNetworkPolicy

+ func (t *Test) WithCiliumClusterwidePolicy(policy string) *Test

+ func (t *Test) WithCondition(fn func() bool) *Test

Feb 15, 2024

Changes in this version

type Parameters

+ CiliumPodSelector string

Jan 31, 2024

Changes in this version

type Action

+ func (a *Action) DebugEnabled() bool

type ConnectivityTest

+ func (ct *ConnectivityTest) CiliumNodes() map[NodeIdentity]*ciliumv2.CiliumNode

+ type NodeIdentity struct

+ Cluster string

+ Name string

+ type SetupHooks interface

+ DetectFeatures func(ctx context.Context, ct *ConnectivityTest) error

+ SetupAndValidate func(ctx context.Context, ct *ConnectivityTest) error

+ type SysdumpPolicy int

+ const SysdumpPolicyEach

+ const SysdumpPolicyNever

+ const SysdumpPolicyOnce

type Test

+ func (t *Test) NewGenericAction(s Scenario, name string) *Action

+ func (t *Test) WithSysdumpPolicy(policy SysdumpPolicy) *Test

Jan 10, 2024

Changes in this version

+ func WaitForDaemonSet(ctx context.Context, log Logger, client *k8s.Client, namespace string, ...) error

type CiliumEgressGatewayPolicyParams

+ ExcludedCIDRsConf ExcludedCIDRsKind

+ Name string

+ PodSelectorKind string

+ type ExcludedCIDRsKind int

Dec 18, 2023

Changes in this version

+ const PerfHostName

+ const PerfOtherNode

type Parameters

+ ExpectedXFRMErrors []string

+ PerfPodNet bool

+ PerfReportDir string

Dec 13, 2023

Changes in this version

type Parameters

+ ExpectedDropReasons []string

Dec 5, 2023

Changes in this version

type Parameters

+ Timeout time.Duration

Nov 28, 2023

Changes in this version

type Parameters

+ PerfLatency bool

type PerfResult

+ Latency map[string][]float64

Nov 16, 2023

Changes in this version

type Action

+ func (a *Action) IPFamily() features.IPFamily

type ConnectivityTest

+ func (ct *ConnectivityTest) ControlPlaneClientPods() map[string]Pod

+ func (ct *ConnectivityTest) ControlPlaneNodes() map[string]*corev1.Node

+ func (ct *ConnectivityTest) K8sService() Service

+ func (ct *ConnectivityTest) MustGetTest(name string) *Test

type Parameters

+ ControlPlaneCIDRs []string

+ K8sCIDR string

+ K8sLocalHostTest bool

type Service

+ URLPath string

Nov 2, 2023

Changes in this version

type ConnectivityTest

+ func (ct *ConnectivityTest) CurlCommandParallelWithOutput(peer TestPeer, ipFam features.IPFamily, parallel int, opts ...string) []string

+ func (ct *ConnectivityTest) CurlCommandWithOutput(peer TestPeer, ipFam features.IPFamily, opts ...string) []string

+ type EchoIPPod struct

+ func (p EchoIPPod) Path() string

type Pod

+ func (p Pod) ToEchoIPPod() EchoIPPod

Oct 4, 2023

Changes in this version

+ const AnySourceLabelPrefix

+ const KubernetesSourcedLabelPrefix

type Parameters

+ NodeCIDRs []string

type Test

+ func (t *Test) CiliumLogs(ctx context.Context)

Sep 12, 2023

Changes in this version

type ConnectivityTest

+ func (ct *ConnectivityTest) DeleteConnDisruptTestDeployment(ctx context.Context, client *k8s.Client) error

type Parameters

+ ConnDisruptDispatchInterval time.Duration

Aug 31, 2023

Changes in this version

type ConnectivityTest

+ func (ct *ConnectivityTest) SecondaryNetworkNodeIPv4() map[string]string

+ func (ct *ConnectivityTest) SecondaryNetworkNodeIPv6() map[string]string

type Parameters

+ SecondaryNetworkIface string

Jul 20, 2023

Changes in this version

type Parameters

+ ConnDisruptTestRestartsPath string

+ ConnDisruptTestSetup bool

+ ConnDisruptTestXfrmErrorsPath string

+ ExternalTargetCAName string

+ ExternalTargetCANamespace string

+ IncludeConnDisruptTest bool

Jul 12, 2023

Changes in this version

type Service

+ func (s Service) NameWithoutNamespace() string

Jul 11, 2023

Changes in this version

type FeatureSet

+ func (fs FeatureSet) IPFamilies() []IPFamily

Jun 27, 2023

Changes in this version

+ const LongTimeout

+ const PollInterval

+ const ShortTimeout

+ func WaitForCiliumEndpoint(ctx context.Context, log Logger, client *k8s.Client, namespace, name string) error

+ func WaitForCoreDNS(ctx context.Context, log Logger, client Pod) error

+ func WaitForDeployment(ctx context.Context, log Logger, client *k8s.Client, namespace string, ...) error

+ func WaitForIPCache(ctx context.Context, log Logger, agent Pod, pods []Pod) error

+ func WaitForNodePorts(ctx context.Context, log Logger, client Pod, nodeIP string, service Service) error

+ func WaitForPodDNS(ctx context.Context, log Logger, src, dst Pod) error

+ func WaitForService(ctx context.Context, log Logger, client Pod, service Service) error

+ func WaitForServiceEndpoints(ctx context.Context, log Logger, agent Pod, service Service, backends uint) error

type ConnectivityTest

+ Features FeatureSet

+ type Logger interface

+ Debug func(a ...interface{})

+ Debugf func(format string, a ...interface{})

+ Info func(a ...interface{})

+ Infof func(format string, a ...interface{})

+ Log func(a ...interface{})

+ Logf func(format string, a ...interface{})

Jun 23, 2023

Changes in this version

+ const KindTestConnDisrupt

type Parameters

+ FlushCT bool

+ IncludeUpgradeTest bool

+ UpgradeTestResultPath string

+ UpgradeTestSetup bool

Jun 14, 2023

Changes in this version

type Feature

+ const FeatureAuthSpiffe

type Parameters

+ DeploymentAnnotations annotationsMap

+ NamespaceAnnotations annotations

Jun 1, 2023

Changes in this version

+ const ExternalNodeExcludedCIDRs

+ const NoExcludedCIDRs

+ type CiliumEgressGatewayPolicyParams struct

+ ExcludedCIDRs int

type ConnectivityTest

+ func (ct *ConnectivityTest) DigCommand(peer TestPeer, ipFam IPFamily) []string

+ type NodeportService struct

+ Node *v1.Node

+ Service Service

+ func (s NodeportService) Address(family IPFamily) string

+ func (s NodeportService) FlowFilters() []*flow.FlowFilter

+ func (s NodeportService) HasLabel(name, value string) bool

+ func (s NodeportService) Labels() map[string]string

+ func (s NodeportService) Name() string

+ func (s NodeportService) Path() string

+ func (s NodeportService) Port() uint32

+ func (s NodeportService) Scheme() string

type Service

+ func (s Service) ToNodeportService(node *v1.Node) NodeportService

May 25, 2023

Changes in this version

type Action

+ func (a *Action) GetEgressMetricsRequirements() []MetricsResult

+ func (a *Action) GetIngressMetricsRequirements() []MetricsResult

+ func (a *Action) ValidateMetrics(ctx context.Context, pod Pod, results []MetricsResult)

type ConnectivityTest

+ func (ct *ConnectivityTest) CiliumAgentMetrics() MetricsSource

+ func (ct *ConnectivityTest) Clients() []*k8s.Client

+ func (ct *ConnectivityTest) GetTest(name string) (*Test, error)

type ExternalWorkload

+ func (e ExternalWorkload) FlowFilters() []*flow.FlowFilter

+ type MetricsResult struct

+ Assert assertMetricsFunc

+ Source MetricsSource

+ func (m MetricsResult) IsEmpty() bool

+ type MetricsSource struct

+ Name string

+ Pods []Pod

+ Port string

+ func (m MetricsSource) IsEmpty() bool

type Parameters

+ CurlInsecure bool

+ IncludeUnsafeTests bool

+ JunitProperties map[string]string

+ NodesWithoutCiliumIPs []nodesWithoutCiliumIP

+ PodCIDRs []podCIDRs

type Pod

+ Outside bool

+ func (p Pod) FlowFilters() []*flow.FlowFilter

+ func (p Pod) NameWithoutNamespace() string

+ func (p Pod) Namespace() string

+ func (p Pod) NodeName() string

type Result

+ Metrics []MetricsResult

+ func (r Result) ExpectMetricsIncrease(source MetricsSource, metrics ...string) Result

type Service

+ func (s Service) FlowFilters() []*flow.FlowFilter

+ type SetupFunc func(ctx context.Context, t *Test, testCtx *ConnectivityTest) error

type Test

+ func (t *Test) CiliumNetworkPolicies() map[string]*ciliumv2.CiliumNetworkPolicy

+ func (t *Test) KubernetesNetworkPolicies() map[string]*networkingv1.NetworkPolicy

+ func (t *Test) WithCiliumVersion(vsn string) *Test

+ func (t *Test) WithFinalizer(f func() error) *Test

+ func (t *Test) WithIPRoutesFromOutsideToPodCIDRs() *Test

+ func (t *Test) WithSetupFunc(f SetupFunc) *Test

type TestPeer

+ FlowFilters func() []*flow.FlowFilter

May 17, 2023

Changes in this version

type Parameters

+ JunitFile string

May 8, 2023

Changes in this version

type ConnectivityTest

+ func (ct *ConnectivityTest) CurlClientIPCommand(peer TestPeer, ipFam IPFamily, opts ...string) []string

+ func (ct *ConnectivityTest) ExternalEchoPods() map[string]Pod

type Feature

+ const FeatureEgressGateway

type FeatureRequirement

+ func RequireFeatureDisabled(feature Feature) FeatureRequirement

type Test

+ func (t *Test) EgressGatewayNode() string

+ func (t *Test) WithCiliumEgressGatewayPolicy(policy string) *Test

May 3, 2023

Changes in this version

+ const IngressServiceName

type ConnectivityTest

+ func (ct *ConnectivityTest) IngressService() map[string]Service

type Feature

+ const FeatureIngressController

type Parameters

+ Retry uint

+ RetryDelay time.Duration

Apr 24, 2023

Changes in this version

+ var ResultCurlHTTPError = Result

+ var ResultDropAuthRequired = Result

type ConnectivityTest

+ CiliumVersion semver.Version

type Feature

+ const FeatureAuthMTLSSpiffe

+ const FeatureCNP

+ const FeatureKNP

type Parameters

+ ExternalFromCIDRMasks []int

+ ExternalFromCIDRs []string

type Test

+ func (t *Test) WithCiliumPolicy(policy string) *Test

+ func (t *Test) WithK8SPolicy(policy string) *Test

Mar 21, 2023

Changes in this version

type Action

+ func (a *Action) WriteDataToPod(ctx context.Context, filePath string, data []byte)

type Feature

+ const FeatureSecretBackendK8s

type Parameters

+ NodeSelector map[string]string

type Test

+ func (t *Test) CertificateCAs() map[string][]byte

+ func (t *Test) WithCABundleSecret() *Test

+ func (t *Test) WithCertificate(name, hostname string) *Test

+ func (t *Test) WithSecret(secret *corev1.Secret) *Test

Mar 2, 2023 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

type IPFamily

+ const IPFamilyAny

Feb 24, 2023 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

type ConnectivityTest

+ func (ct *ConnectivityTest) Nodes() map[string]*corev1.Node

type Feature

+ const FeatureEndpointRoutes

+ const FeatureFlavor

+ const FeatureIPv4

+ const FeatureIPv6

+ type IPFamily int

+ const IPFamilyNone

+ const IPFamilyV4

+ const IPFamilyV6

+ func GetIPFamily(addr string) IPFamily

+ func (f IPFamily) String() string

type Test

+ func (t *Test) ForEachIPFamily(do func(IPFamily))

Feb 15, 2023 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

type Parameters

+ ExternalCIDR string

+ ExternalIP string

+ ExternalOtherIP string

Jan 11, 2023 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

type ConnectivityTest

+ func (ct *ConnectivityTest) CurlCommand(peer TestPeer, opts ...string) []string

+ func (ct *ConnectivityTest) Feature(f Feature) (FeatureStatus, bool)

+ func (ct *ConnectivityTest) PingCommand(peer TestPeer) []string

type Feature

+ const FeatureEncryptionNode

+ const FeatureEncryptionPod

+ const FeatureTunnel

type Parameters

+ ConnectTimeout time.Duration

+ ExternalTarget string

+ RequestTimeout time.Duration

Dec 1, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Nov 29, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

type ConnectivityTest

+ func (ct *ConnectivityTest) Timestamp()

+ func (ct *ConnectivityTest) UninstallResources(ctx context.Context, wait bool)

Nov 23, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

type Parameters

+ CollectSysdumpOnFailure bool

+ SysdumpOptions sysdump.Options

Nov 21, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

type ConnectivityTest

+ func (ct *ConnectivityTest) ForceDisableFeature(feature Feature)

+ func (ct *ConnectivityTest) UpdateFeaturesFromNodes(ctx context.Context) error

type Parameters

+ DeleteCiliumOnNodes []string

+ HelmChartDirectory string

+ HelmValuesSecretName string

+ K8sVersion string

Nov 14, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Nov 3, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Oct 18, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

+ var ResultAnyReasonEgressDrop = Result

+ var ResultDefaultDenyEgressDrop = Result

+ var ResultDefaultDenyIngressDrop = Result

+ var ResultIngressAnyReasonDrop = Result

+ var ResultPolicyDenyEgressDrop = Result

+ var ResultPolicyDenyIngressDrop = Result

type Parameters

+ AgentPodSelector string

type Result

+ DropReasonFunc func(flow *flowpb.Flow) bool

+ EgressDrop bool

+ IngressDrop bool

Sep 21, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

type ExternalWorkload

+ func (e ExternalWorkload) Labels() map[string]string

type Feature

+ const FeatureHealthChecking

type Pod

+ func (p Pod) Labels() map[string]string

type Service

+ func (s Service) Labels() map[string]string

type TestPeer

+ Labels func() map[string]string

Sep 1, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Aug 26, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

+ const EchoServerHostPort

+ type ConditionalScenario interface

+ Requirements func() []FeatureRequirement

type ConnectivityTest

+ func (ct *ConnectivityTest) HostNetNSPodsByNode() map[string]Pod

+ func (ct *ConnectivityTest) NodesWithoutCilium() []string

type Feature

+ const FeatureHostPort

+ const FeatureICMPPolicy

+ const FeatureKPRExternalIPs

+ const FeatureKPRGracefulTermination

+ const FeatureKPRHostPort

+ const FeatureKPRMode

+ const FeatureKPRNodePort

+ const FeatureKPRSessionAffinity

+ const FeatureKPRSocketLB

+ const FeatureNodeWithoutCilium

type FlowParameters

+ AltDstIP string

+ AltDstPort uint32

type Parameters

+ Datapath bool

type Test

+ func (t *Test) NodesWithoutCilium() []string

Aug 4, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

type ConnectivityTest

+ func (ct *ConnectivityTest) DetectMinimumCiliumVersion(ctx context.Context) (*semver.Version, error)

+ type Feature string

+ const FeatureCNIChaining

+ const FeatureHostFirewall

+ const FeatureL7Proxy

+ const FeatureMonitorAggregation

+ type FeatureRequirement struct

+ func RequireFeatureEnabled(feature Feature) FeatureRequirement

+ func RequireFeatureMode(feature Feature, mode string) FeatureRequirement

+ type FeatureSet map[Feature]FeatureStatus

+ func (fs FeatureSet) MatchRequirements(reqs ...FeatureRequirement) bool

+ type FeatureStatus struct

+ Enabled bool

+ Mode string

+ func (s FeatureStatus) String() string

type Parameters

+ AssumeCiliumVersion string

+ Timestamp bool

type Test

+ func (t *Test) WithFeatureRequirements(reqs ...FeatureRequirement) *Test

Jul 19, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

type Parameters

+ AgentDaemonSetName string

+ DNSTestServerImage string

type TestPeer

+ func HTTPEndpointWithLabels(name, rawurl string, labels map[string]string) TestPeer

Jul 6, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

+ const DNSTestServerContainerName

+ const DNSTestServerImage

Jun 22, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Jun 16, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Jun 14, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

type ConnectivityTest

+ func (ct *ConnectivityTest) K8sClient() *k8s.Client

type Parameters

+ CurlImage string

+ JSONMockImage string

+ PerformanceImage string

May 17, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

May 12, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

+ const PerfHostNetNamingSuffix

type Parameters

+ PerfHostNet bool

type PerfResult

+ Scenario string

May 4, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Apr 29, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Apr 27, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Apr 25, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Apr 14, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Apr 13, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

May 31, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

May 24, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

May 20, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

+ const PerfClientAcrossDeploymentName

+ const PerfClientDeploymentName

+ const PerfClientName

+ const PerfServerDeploymentName

+ const PerfServerName

type Action

+ CollectFlows bool

+ func (a *Action) CmdOutput() string

type ConnectivityTest

+ PerfResults map[PerfTests]PerfResult

+ func (ct *ConnectivityTest) Params() Parameters

+ func (ct *ConnectivityTest) PerfClientPods() map[string]Pod

+ func (ct *ConnectivityTest) PerfServerPod() map[string]Pod

type Parameters

+ Perf bool

+ PerfCRR bool

+ PerfDuration time.Duration

+ PerfSamples int

+ type PerfResult struct

+ Avg float64

+ Duration time.Duration

+ Metric string

+ Samples int

+ Values []float64

+ type PerfTests struct

+ Pod string

+ Test string

Feb 24, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

type ConnectivityTest

+ func (ct *ConnectivityTest) CiliumBaseVersion() string

+ func (ct *ConnectivityTest) FetchCiliumPodImageTag() string

+ func (ct *ConnectivityTest) SetupAndValidate(ctx context.Context) error

type Parameters

+ CiliumBaseVersion string

Feb 16, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Jan 28, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Jan 21, 2022 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Dec 9, 2021 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Nov 9, 2021 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Oct 25, 2021 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Sep 24, 2021 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Sep 7, 2021 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

+ var ResultDNSOKDropCurlHTTPError = Result

+ var ResultDNSOKDropCurlTimeout = Result

+ var ResultDropCurlHTTPError = Result

+ var ResultDropCurlTimeout = Result

+ type ExitCode int16

+ const ExitAnyError

+ const ExitCurlHTTPError

+ const ExitCurlTimeout

+ const ExitInvalidCode

+ func (e ExitCode) Check(code uint8) bool

+ func (e ExitCode) String() string

type ExternalWorkload

+ func (e ExternalWorkload) Path() string

type Parameters

+ SkipIPCacheCheck bool

type Pod

+ func (p Pod) Path() string

type Result

+ ExitCode ExitCode

type Service

+ func (s Service) Path() string

type TestPeer

+ Path func() string

Aug 9, 2021 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Jul 14, 2021 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Jul 5, 2021 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Jun 29, 2021 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Jun 24, 2021 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Jun 21, 2021 GO-2023-1653

  GO-2023-1653: `cilium-cli` disables etcd authorization for clustermesh clusters in github.com/cilium/cilium-cli

Changes in this version

+ const Client2DeploymentName

+ const ClientDeploymentName

+ const FlowValidationModeDisabled

+ const FlowValidationModeStrict

+ const FlowValidationModeWarning

+ var ResultDNSOK = Result

+ var ResultDNSOKRequestDrop = Result

+ var ResultDrop = Result

+ var ResultNone = Result

+ var ResultOK = Result

+ type Action struct

+ func (a *Action) Debug(s ...interface{})

+ func (a *Action) Debugf(format string, s ...interface{})

+ func (a *Action) Destination() TestPeer

+ func (a *Action) ExecInPod(ctx context.Context, cmd []string)

+ func (a *Action) Fail(s ...interface{})

+ func (a *Action) Failf(format string, s ...interface{})

+ func (a *Action) Fatal(s ...interface{})

+ func (a *Action) Fatalf(format string, s ...interface{})

+ func (a *Action) GetEgressRequirements(p FlowParameters) (reqs []filters.FlowSetRequirement)

+ func (a *Action) GetIngressRequirements(p FlowParameters) []filters.FlowSetRequirement

+ func (a *Action) Info(s ...interface{})

+ func (a *Action) Infof(format string, s ...interface{})

+ func (a *Action) Log(s ...interface{})

+ func (a *Action) Logf(format string, s ...interface{})

+ func (a *Action) Peers() string

+ func (a *Action) Run(f func(*Action))

+ func (a *Action) Source() TestPeer

+ func (a *Action) String() string

+ func (a *Action) ValidateFlows(ctx context.Context, pod, podIP string, reqs []filters.FlowSetRequirement)

+ func (a *Action) Warn(s ...interface{})

+ func (a *Action) Warnf(format string, s ...interface{})

+ type ConnectivityTest struct

+ func NewConnectivityTest(client *k8s.Client, p Parameters) (*ConnectivityTest, error)

+ func (ct *ConnectivityTest) AllFlows() bool

+ func (ct *ConnectivityTest) CiliumPods() map[string]Pod

+ func (ct *ConnectivityTest) ClientPods() map[string]Pod

+ func (ct *ConnectivityTest) Debug(a ...interface{})

+ func (ct *ConnectivityTest) Debugf(format string, a ...interface{})

+ func (ct *ConnectivityTest) EchoPods() map[string]Pod

+ func (ct *ConnectivityTest) EchoServices() map[string]Service

+ func (ct *ConnectivityTest) ExternalWorkloads() map[string]ExternalWorkload

+ func (ct *ConnectivityTest) Fail(a ...interface{})

+ func (ct *ConnectivityTest) Failf(format string, a ...interface{})

+ func (ct *ConnectivityTest) Fatal(a ...interface{})

+ func (ct *ConnectivityTest) Fatalf(format string, a ...interface{})

+ func (ct *ConnectivityTest) FlowAggregation() bool

+ func (ct *ConnectivityTest) Header(a ...interface{})

+ func (ct *ConnectivityTest) Headerf(format string, a ...interface{})

+ func (ct *ConnectivityTest) HubbleClient() observer.ObserverClient

+ func (ct *ConnectivityTest) Info(a ...interface{})

+ func (ct *ConnectivityTest) Infof(format string, a ...interface{})

+ func (ct *ConnectivityTest) LoadLastTimestamp(pod string) time.Time

+ func (ct *ConnectivityTest) Log(a ...interface{})

+ func (ct *ConnectivityTest) Logf(format string, a ...interface{})

+ func (ct *ConnectivityTest) NewTest(name string) *Test

+ func (ct *ConnectivityTest) PostTestSleepDuration() time.Duration

+ func (ct *ConnectivityTest) PrintFlows() bool

+ func (ct *ConnectivityTest) RandomClientPod() *Pod

+ func (ct *ConnectivityTest) Run(ctx context.Context) error

+ func (ct *ConnectivityTest) StoreLastTimestamp(pod string, t time.Time)

+ func (ct *ConnectivityTest) Warn(a ...interface{})

+ func (ct *ConnectivityTest) Warnf(format string, a ...interface{})

+ type ExpectationsFunc func(a *Action) (egress, ingress Result)

+ type ExternalWorkload struct

+ func (e ExternalWorkload) Address() string

+ func (e ExternalWorkload) HasLabel(name, value string) bool

+ func (e ExternalWorkload) Name() string

+ func (e ExternalWorkload) Port() uint32

+ func (e ExternalWorkload) Scheme() string

+ type FlowParameters struct

+ DNSRequired bool

+ NodePort uint32

+ Protocol L4Protocol

+ RSTAllowed bool

+ type FlowRequirementResults struct

+ Failures int

+ FirstMatch int

+ LastMatch int

+ LastMatchTimestamp time.Time

+ Matched MatchMap

+ NeedMoreFlows bool

+ func (r *FlowRequirementResults) Merge(from *FlowRequirementResults)

+ type HTTP struct

+ Method string

+ Status string

+ URL string

+ type L4Protocol int

+ const ICMP

+ const TCP

+ const UDP

+ type MatchMap map[int]bool

+ type Parameters struct

+ AllFlows bool

+ CiliumNamespace string

+ Debug bool

+ FlowValidation string

+ ForceDeploy bool

+ Hubble bool

+ HubbleServer string

+ MultiCluster string

+ PauseOnFail bool

+ PostTestSleepDuration time.Duration

+ PrintFlows bool

+ RunTests []*regexp.Regexp

+ SingleNode bool

+ SkipTests []*regexp.Regexp

+ TestNamespace string

+ Verbose bool

+ Writer io.ReadWriter

+ type Pod struct

+ K8sClient *k8s.Client

+ Pod *corev1.Pod

+ func (p Pod) Address() string

+ func (p Pod) HasLabel(name, value string) bool

+ func (p Pod) Name() string

+ func (p Pod) Port() uint32

+ func (p Pod) Scheme() string

+ func (p Pod) String() string

+ type Result struct

+ DNSProxy bool

+ Drop bool

+ HTTP HTTP

+ L7Proxy bool

+ None bool

+ func (r Result) String() string

+ type Scenario interface

+ Name func() string

+ Run func(ctx context.Context, t *Test)

+ type Service struct

+ Service *corev1.Service

+ func (s Service) Address() string

+ func (s Service) HasLabel(name, value string) bool

+ func (s Service) Name() string

+ func (s Service) Port() uint32

+ func (s Service) Scheme() string

+ type Test struct

+ func (t *Test) Context() *ConnectivityTest

+ func (t *Test) Debug(a ...interface{})

+ func (t *Test) Debugf(format string, a ...interface{})

+ func (t *Test) Fail(a ...interface{})

+ func (t *Test) Failf(format string, a ...interface{})

+ func (t *Test) Fatal(a ...interface{})

+ func (t *Test) Fatalf(format string, a ...interface{})

+ func (t *Test) Headerf(format string, a ...interface{})

+ func (t *Test) Info(a ...interface{})

+ func (t *Test) Infof(format string, a ...interface{})

+ func (t *Test) Log(a ...interface{})

+ func (t *Test) Logf(format string, a ...interface{})

+ func (t *Test) Name() string

+ func (t *Test) NewAction(s Scenario, name string, src *Pod, dst TestPeer) *Action

+ func (t *Test) Run(ctx context.Context) error

+ func (t *Test) String() string

+ func (t *Test) Warn(a ...interface{})

+ func (t *Test) Warnf(format string, a ...interface{})

+ func (t *Test) WithExpectations(f ExpectationsFunc) *Test

+ func (t *Test) WithPolicy(policy string) *Test

+ func (t *Test) WithScenarios(sl ...Scenario) *Test

+ type TestPeer interface

+ Address func() string

+ HasLabel func(name, value string) bool

+ Name func() string

+ Port func() uint32

+ Scheme func() string

+ func HTTPEndpoint(name, rawurl string) TestPeer

+ func ICMPEndpoint(name, host string) TestPeer