Versions in this module Expand all Collapse all v0 v0.4.0 Nov 26, 2025 Changes in this version + const MaxConfigSize + func AreSharedDependenciesInstalled() bool + func GetFrameworkRegistry() *sync.Map + func InstallSharedDependencies() + func UninstallSharedDependencies() + type DeploymentInfo struct + Containers []string + InitContainers []string + type Framework struct + TestDataPath string + func FromContext(ctx context.Context) *Framework + func FromReportEntries(entries []types.ReportEntry) *Framework + func GetRegisteredFramework(namespace string) (*Framework, bool) + func NewFramework(namespace string) *Framework + func NewUniqueFramework(baseName string) *Framework + func Shared(namespace string) *Framework + func (f *Framework) ApplyTestData(path string) + func (f *Framework) ApplyTestDataWithVars(path string, vars map[string]string) + func (f *Framework) ApplyTestDataWithoutNamespaceReplacement(path string) + func (f *Framework) ApplyYAML(yamlContent string) + func (f *Framework) AssertNoLogsContaining(podName, substring string, checkDuration time.Duration) error + func (f *Framework) ClusterPipeline(name string) *assertions.PipelineResource + func (f *Framework) CountPipelines() (int, error) + func (f *Framework) CountServicesContaining(substring string) (int, error) + func (f *Framework) CountServicesWithLabel(labelSelector string) int + func (f *Framework) CountValidPipelines() (int, error) + func (f *Framework) CreateMultiplePipelinesFromTemplate(templatePath, placeholder string, count int) time.Duration + func (f *Framework) DeleteClusterResource(kind, name string) + func (f *Framework) DeleteResource(kind, name string) + func (f *Framework) DeleteTestData(path string) + func (f *Framework) ExpectServiceExists(name string) + func (f *Framework) ExportTestPlan() + func (f *Framework) GetAgentPods(vectorName string) ([]string, error) + func (f *Framework) GetAggregatorPods(aggregatorName string) ([]string, error) + func (f *Framework) GetClusterPipelineAnnotation(name, annotationKey string) string + func (f *Framework) GetClusterPipelineStatus(name, field string) string + func (f *Framework) GetDeployment(name string) (*DeploymentInfo, error) + func (f *Framework) GetPipelineAnnotation(name string, annotationKey string) string + func (f *Framework) GetPipelineAnnotationInNamespace(name, namespace, annotationKey string) string + func (f *Framework) GetPipelineStatus(name string, field string) string + func (f *Framework) GetPodLogs(podName string) (string, error) + func (f *Framework) GetPodLogsTail(podName string, lines int) (string, error) + func (f *Framework) GetPodLogsWithOptions(podName string, opts LogOptions) (string, error) + func (f *Framework) GetPodsByLabel(labelSelector string) ([]string, error) + func (f *Framework) GetSecret(name string) (map[string][]byte, error) + func (f *Framework) GetServicePort(name string) string + func (f *Framework) Kubectl() *kubectl.Client + func (f *Framework) Namespace() string + func (f *Framework) Pipeline(name string) *assertions.PipelineResource + func (f *Framework) PrintMetrics() + func (f *Framework) RecordStep(step recorder.TestStep) + func (f *Framework) Service(name string) *assertions.ServiceResource + func (f *Framework) SetTestName(name string) + func (f *Framework) Setup() + func (f *Framework) Teardown() + func (f *Framework) ToContext(ctx context.Context) context.Context + func (f *Framework) TryGetServicePort(name string) (string, error) + func (f *Framework) VerifyAgentHasClusterPipeline(vectorName, pipelineName string) error + func (f *Framework) VerifyAgentHasPipeline(vectorName, pipelineName string) error + func (f *Framework) VerifyAgentHasPipelineInNamespace(vectorName, pipelineName, namespace string) error + func (f *Framework) VerifyAggregatorHasClusterPipeline(aggregatorName, pipelineName string) error + func (f *Framework) VerifyAggregatorHasPipeline(aggregatorName, pipelineName string) error + func (f *Framework) WaitForClusterPipelineInvalid(name string) + func (f *Framework) WaitForClusterPipelineValid(name string) + func (f *Framework) WaitForDeploymentReady(name string) + func (f *Framework) WaitForLogsContaining(podName, substring string, timeout time.Duration) error + func (f *Framework) WaitForLogsMatching(podName, pattern string, timeout time.Duration) error + func (f *Framework) WaitForPipelineInvalid(name string) + func (f *Framework) WaitForPipelineValid(name string) + func (f *Framework) WaitForPipelineValidInNamespace(name, namespace string) + func (f *Framework) WaitForPodReady(podName string) + func (f *Framework) WaitForPodReadyInNamespace(podName, namespace string) + func (f *Framework) WaitForServiceCount(labelSelector string, expectedCount int, timeout time.Duration) + type FrameworkContextKey struct + type LogOptions struct + Container string + SinceSeconds int + TailLines int + type SharedDependencies struct + type TestMetrics struct + CleanupTime time.Duration + DeploymentWaitTime time.Duration + PipelineValidationTime time.Duration + SetupTime time.Duration
Go to main page