e2e

package

Go to main page

Versions in this module

v0

v0.5.0

Oct 14, 2026

Changes in this version

+ func ScrapeEgressEnvoyMetrics(ctx context.Context) (string, error)

+ func ServiceDNSTrustBundle(t *testing.T, ctx context.Context, clients *Clients) string

+ func WaitForServerEndpoint(t *testing.T, ctx context.Context, spec ServerPod)

type AtenetDataplane

+ EgressConnectStats func(before, after string) EgressConnectStats

+ ScrapeMetrics func(context.Context) (string, error)

+ type EgressConnectStats struct

+ Connections int

+ Requests int

type ProbeOption

+ func WithSystemRoots() ProbeOption

type RouterClient

+ func (c *RouterClient) ConnectWithHeaders(ctx context.Context, actorRef resources.ActorRef, port int, header http.Header) (net.Conn, error)

type Server

+ Name string

+ TLSPort int

+ func CreateServerService(t *testing.T, ctx context.Context, spec ServerPod) Server

+ func (s Server) SvcName() string

+ func (s Server) TLSAddress() string

type ServerPod

+ TLSPort int

+ func ServiceDNSTLS(spec ServerPod) ServerPod

v0.4.0

Oct 7, 2026

Changes in this version

+ func AddEgressCA(t *testing.T, ctx context.Context, clients *Clients, id string) string

+ func ConfigureCredentialProvider(t *testing.T)

+ func EgressAllowPassthrough(patterns ...string) *ateapipb.EgressRule

+ func EgressAllowPassthroughOnPorts(ports []int32, patterns ...string) *ateapipb.EgressRule

+ func SameCertificates(a, b string) bool

v0.3.0

Sep 30, 2026

Changes in this version

+ const CredentialInjectionToken

+ const CredentialInjectionURI

+ const CredentialSecretsNamespace

+ func DeployCredentialProvider(t *testing.T)

+ func EgressAllowHTTP(patterns ...string) *ateapipb.EgressRule

+ func EgressAllowHTTPS(patterns ...string) *ateapipb.EgressRule

+ func EgressInjectHeader(header, prefix, credentialURI string, patterns ...string) *ateapipb.EgressRule

+ func EgressInjectHeaderHTTP(header, prefix, credentialURI string, patterns ...string) *ateapipb.EgressRule

v0.2.0

Sep 25, 2026

Changes in this version

+ const AtenetDataplaneEnv

+ const LifecycleEventMetric

+ const ResourcePrefixEnv

+ const SystemNamespaceEnv

+ func EgressAllowAll() *ateapipb.EgressRule

+ func EgressAllowCIDRs(cidrs ...string) *ateapipb.EgressRule

+ func EgressAllowHostnames(patterns ...string) *ateapipb.EgressRule

+ func EnsureEgressPolicy(t *testing.T, ctx context.Context, clients *Clients, actor *ateapipb.ObjectRef, ...)

+ func LifecycleEventCounts(scrape string) map[string]float64

+ func ResourceName(name string) string

+ func ScrapeAgentGatewayRouterMetrics(ctx context.Context) (string, error)

+ func StatesNotAdvanced(before, after map[string]float64, states []string) []string

+ func SystemNamespace() string

+ type AtenetDataplane interface

+ IsEgressPolicyDenied func(status int, body string) bool

+ IsRetryableParkingBudgetExhaustion func(status int, body string) bool

+ NewParkingObserver func(context.Context) (ParkingObserver, error)

+ ParkingBudgetStatus func() int

+ PlatformMetricPrefixes func([]string) []string

+ RouteDurationSeen func(context.Context, string) (bool, error)

+ SupportsIngressProtocolDowngrade func() bool

+ SupportsTLSPassthroughEgressPolicy func() bool

+ func CurrentAtenetDataplane() AtenetDataplane

+ type ParkingObserver interface

+ Close func()

+ WaitForCount func(context.Context, func(int) bool) (int, error)

type StatuszClient

+ func (c *StatuszClient) WaitForCount(ctx context.Context, cond func(int) bool) (int, error)

type SubstrateTemplateOptions

+ SnapshotConfig *ateapipb.SnapshotConfig

v0.1.0

Sep 9, 2026

Changes in this version

+ const EgressTrustBundleObjectName

+ const NamespaceLabel

+ const ProbeName

+ const SandboxClassMicroVM

+ var PlatformMetricPrefixes = []string

+ var StorageClass string

+ func CollectorHasService(scrape string, services ...string) bool

+ func CreateSubstrateCounterTemplate(ctx context.Context, t *testing.T, clients *Clients, namespace string, ...) *ateapipb.ActorTemplate

+ func CreateSubstrateTemplateFrom(ctx context.Context, t *testing.T, clients *Clients, namespace string, ...) *ateapipb.ActorTemplate

+ func DeployProbe(t *testing.T, bucket, name string, opts ...ProbeOption) (string, *ateapipb.ActorTemplate)

+ func DeploySubstrateFixture(t *testing.T, ctx context.Context, clients *Clients, ...) (string, []*ateapipb.ActorTemplate)

+ func DescribePodState(pod *corev1.Pod) string

+ func EnsureEgressTrustBundle(t *testing.T, ctx context.Context, clients *Clients)

+ func FixtureName(base string) string

+ func IsMicroVM() bool

+ func MissingPlatformMetrics(scrape string, prefixes []string) []string

+ func RegisterSuiteCleanup(fn func())

+ func RenderFixtureManifest(t *testing.T, relPath, bucket, name string) string

+ func ReplaceEgressTrustPool(t *testing.T, ctx context.Context, clients *Clients, cn string) string

+ func ResumeActorAwaitCapacity(t *testing.T, ctx context.Context, clients *Clients, ...) (*ateapipb.ResumeActorResponse, error)

+ func RetainNamespaces()

+ func RunCmdOutput(t *testing.T, env []string, name string, args ...string) []byte

+ func SandboxClass() string

+ func ScrapeCollectorMetrics(ctx context.Context) (string, error)

+ func TargetInfoLabel(scrape, service, label string) string

+ func TemplateReadyTimeout(t *testing.T) time.Duration

+ func TemplateRef(at *ateapipb.ActorTemplate) *ateapipb.ObjectRef

+ func WaitForPodReady(t *testing.T, ctx context.Context, namespace, name string, ...)

+ func WaitForSubstrateTemplateReady(ctx context.Context, t *testing.T, clients *Clients, atespace, name string)

+ type Fixture struct

+ DeployWith string

+ Name string

+ Namespace string

+ func EgressFixture() Fixture

+ type ParkingStatusz struct

+ Active int

+ Enabled bool

+ MaxParked int

+ MaxWait string

+ type ProbeOption func(*probeConfig)

+ func WithTrustBundle() ProbeOption

+ type RouterClient struct

+ func NewRouterClient(ctx context.Context) (*RouterClient, error)

+ func (c *RouterClient) BaseURL() string

+ func (c *RouterClient) Close()

+ func (c *RouterClient) Connect(ctx context.Context, actorRef resources.ActorRef, port int) (net.Conn, error)

+ func (c *RouterClient) Get(ctx context.Context, actorRef resources.ActorRef, path string) (*http.Response, error)

+ func (c *RouterClient) PostJSON(ctx context.Context, actorRef resources.ActorRef, path string, body []byte) (*http.Response, error)

+ type Server struct

+ ClusterIP string

+ Namespace string

+ Port int

+ func DeployServerPod(t *testing.T, ctx context.Context, spec ServerPod) Server

+ func (s Server) Address() string

+ type ServerPod struct

+ Args []string

+ GRPCProbe bool

+ HealthPath string

+ ImportPath string

+ Name string

+ Namespace string

+ Port int

+ TargetPort int

+ VolumeMounts []corev1.VolumeMount

+ Volumes []corev1.Volume

+ type StatuszClient struct

+ func NewStatuszClient(ctx context.Context) (*StatuszClient, error)

+ func (c *StatuszClient) Close()

+ func (c *StatuszClient) Parking(ctx context.Context) (*ParkingStatusz, error)

+ type SubstrateFixture struct

+ Atespace string

+ DeployWith string

+ Name string

+ PoolName string

+ PoolNamespace string

+ func SubstrateCounterFixture() SubstrateFixture

+ type SubstrateFixtureManifests struct

+ Pool string

+ Template string

+ type SubstrateTemplateOptions struct

+ Atespace string

+ Labels map[string]string

+ Modify func(*ateapipb.ActorTemplate)

+ Name string

+ PoolName string

+ PoolReplicas int32

+ SnapshotsConfig *ateapipb.SnapshotsConfig

v0.0.0

May 19, 2026

Changes in this version

+ var KubeConfig string

+ var KubeContext string

+ var NoColor bool

+ var RunE2E bool

+ func CheckEnv(keys ...string) (map[string]string, error)

+ func CleanupNamespaces()

+ func Colorf(format string, a ...any) string

+ func FColorf(f io.Writer, format string, a ...any) error

+ func FColorfln(f io.Writer, format string, a ...any) error

+ func FindRepoRoot() (string, error)

+ func PreflightChecks() error

+ func RunCmd(t *testing.T, name string, args ...string)

+ func RunCmdWithEnv(t *testing.T, env []string, name string, args ...string)

+ func RunTestMain(m *testing.M) int

+ type Clients struct

+ CRD *apiextensionsclientset.Clientset

+ K8s *kubernetes.Clientset

+ SubstrateAPI *client.Client

+ SubstrateK8s *versioned.Clientset

+ func GetClients() *Clients

+ func NewClients(ctx context.Context) (*Clients, error)

+ func (c *Clients) Close()

+ type ColorWriter struct

+ ANSI string

+ W io.Writer

+ func (cw *ColorWriter) Write(p []byte) (n int, err error)

+ type IndentWriter struct

+ Val string

+ W io.Writer

+ func NewIndentWriter(w io.Writer, indent string) *IndentWriter

+ func (iw *IndentWriter) Write(p []byte) (n int, err error)

+ type Namespace struct

+ Name string

+ func CreateNamespace(t *testing.T) *Namespace

+ func (ns *Namespace) Delete(t *testing.T)

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