pods

Feb 13, 2026

Changes in this version

+ const ClientReadyTimeout

+ const K8sFunctionCallTimeout

+ func Connect(svc *corev1.Service, waitForConnection bool) error

+ func TCPReadyProbe(port int) *v1.Probe

type App

+ func (n *App) GetConnectionDetails() *corev1.Service

type PortForwardConfig

+ ServicePort int

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()