Versions in this module Expand all Collapse all v0 v0.14.0 Feb 11, 2026 Changes in this version + const EnvVarLogLevel + const K8sAPITimeout + const K8sNamespaceEnvVar + const ManifestsDir + const RetryDelay + var L zerolog.Logger + func EnvsFromMap(envVars map[string]string) []v1.EnvVar + func K8sEnabled() bool + func NewKubernetesClient() (*kubernetes.Clientset, error) + func Ptr[T any](value T) *T + func Resources(cpu, mem string) map[string]string + func ResourcesLarge() map[string]string + func ResourcesMedium() map[string]string + func ResourcesSmall() map[string]string + func Run(ctx context.Context, cfg *Config) (string, error) + func SizedVolumeClaim(size string) []v1.PersistentVolumeClaim + func SortedKeys(m map[string]string) []string + func WaitReady(ctx context.Context, t time.Duration) error + type API struct + ClientSet *kubernetes.Clientset + RESTConfig *rest.Config + var Client *API + func NewAPI(namespace string) (*API, error) + func (k *API) AllPodsReady(ctx context.Context) (bool, error) + func (k *API) CreateNamespace(ctx context.Context, name string) error + func (k *API) GetPods(ctx context.Context) (*corev1.PodList, error) + func (k *API) RemoveNamespace(name string) error + type App struct + func (n *App) Manifest() string + type Config struct + Namespace string + Pods []*PodConfig + type PodConfig struct + Annotations map[string]string + Command *string + ConfigMap map[string]string + ConfigMapMountPath map[string]string + ContainerSecurityContext *corev1.SecurityContext + Env []corev1.EnvVar + Image *string + Labels map[string]string + Limits map[string]string + Name *string + PodSecurityContext *corev1.PodSecurityContext + Ports []string + ReadinessProbe *corev1.Probe + Replicas *int32 + Requests map[string]string + Secrets map[string]string + SecretsMountPath map[string]string + StatefulSet bool + VolumeClaimTemplates []corev1.PersistentVolumeClaim + type PortForwardConfig struct + ContainerPort int + LocalPort int + Namespace string + ServiceName string + type PortForwardManager struct + func NewForwarder(api *API) *PortForwardManager + func (m *PortForwardManager) Forward(configs []PortForwardConfig) error + func (m *PortForwardManager) List() []string + func (m *PortForwardManager) Stop(serviceName string, localPort int) + func (m *PortForwardManager) StopAll()
Go to main page