Versions in this module Expand all Collapse all v0 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)
Go to main page