container

Jul 13, 2026

Changes in this version

+ func GetWorkloadPodLogsStream(ctx context.Context, config *types.ServerConfig, name string, tail int, ...) (io.ReadCloser, error)

+ type ClusterStats struct

+ CPU string

+ Memory string

+ Nodes int

+ NodesError string

+ Platform string

+ ReadyNodes int

+ Version string

+ func GetClusterStats(ctx context.Context, config *types.ServerConfig) (*ClusterStats, error)

+ type NamespaceStats struct

+ Failed int

+ Kind string

+ Namespace string

+ Pending int

+ Pods int

+ Ready int

+ Running int

+ Succeeded int

+ func GetNamespaceStats(ctx context.Context, config *types.ServerConfig) ([]NamespaceStats, error)

+ type PodCondition struct

+ Message string

+ Reason string

+ Status string

+ Type string

+ type PodContainerStatus struct

+ Message string

+ Name string

+ Ready bool

+ Reason string

+ Restarts int

+ State string

+ type PodEvent struct

+ Count int

+ LastSeen string

+ Message string

+ Reason string

+ Type string

type WorkloadPod

+ func ListWorkloadPodsSelector(ctx context.Context, config *types.ServerConfig, selector string) ([]WorkloadPod, error)

+ type WorkloadPodStatus struct

+ Conditions []PodCondition

+ Containers []PodContainerStatus

+ Events []PodEvent

+ EventsError string

+ Message string

+ Node string

+ Phase string

+ Reason string

+ func GetWorkloadPodStatus(ctx context.Context, config *types.ServerConfig, name string) (*WorkloadPodStatus, error)

Jul 5, 2026

Changes in this version

+ func GetWorkloadPodLogs(ctx context.Context, config *types.ServerConfig, name string, tail int) (string, error)

+ type AppContainerStopper interface

+ StopAppContainersExcept func(ctx context.Context, appId types.AppId, keep ContainerName) error

+ func AsAppContainerStopper(cm ContainerManager) (AppContainerStopper, bool)

type CommandCM

+ func (c *CommandCM) ContainerExited(ctx context.Context, name ContainerName) (bool, string, error)

+ func (c *CommandCM) StopAppContainersExcept(ctx context.Context, appId types.AppId, keep ContainerName) error

+ type ContainerExitChecker interface

+ ContainerExited func(ctx context.Context, name ContainerName) (exited bool, status string, err error)

+ func AsContainerExitChecker(cm ContainerManager) (ContainerExitChecker, bool)

type DeployTxn

+ func (d *DeployTxn) ContainerNames() []ContainerName

+ func (d *DeployTxn) Len() int

+ type WorkloadMount struct

+ MountPath string

+ Name string

+ ReadOnly bool

+ type WorkloadPod struct

+ AppId string

+ AppPath string

+ AppVersion string

+ CreatedAt string

+ Image string

+ Mounts []WorkloadMount

+ Name string

+ Node string

+ Phase string

+ PodIP string

+ Ready bool

+ Restarts int

+ StartedAt string

+ func GetWorkloadPod(ctx context.Context, config *types.ServerConfig, name string) (*WorkloadPod, error)

+ func ListWorkloadPods(ctx context.Context, config *types.ServerConfig) ([]WorkloadPod, error)

Jun 29, 2026

Changes in this version

+ const INSTANCE_LABEL

+ const KUBERNETES_NAME_MAX

+ const MANAGED_BY_LABEL

+ const MANAGED_BY_VALUE

+ func ClusterRollbackClean(err error) bool

+ func ContextWithDeployTxn(ctx context.Context, d *DeployTxn) context.Context

+ func GetImageReferenceConfig(ctx context.Context, imageRef string, registryConfig *types.RegistryConfig) (name.Reference, []remote.Option, error)

+ func HasPersistentVolume(volumes []*VolumeInfo) bool

type CommandCM

+ func (c *CommandCM) DeployContainer(ctx context.Context, req DeployRequest) (DeployResult, error)

type ContainerManager

+ DeployContainer func(ctx context.Context, req DeployRequest) (DeployResult, error)

+ type DeployRequest struct

+ AppEntry *types.AppEntry

+ ContainerName ContainerName

+ ContainerOptions map[string]string

+ DeployAttempts int

+ EnvMap map[string]string

+ HealthProbe *HealthProbe

+ ImageName ImageName

+ IsImageSpec bool

+ LogLinesToShow int

+ ParamMap map[string]string

+ Port int32

+ ShowLogsForFailure bool

+ SourceDir string

+ Verify bool

+ VersionHash string

+ Volumes []*VolumeInfo

+ type DeployResult struct

+ ContainerName ContainerName

+ HostNamePort string

+ VersionHash string

+ type DeployRollbackError struct

+ Available bool

+ Err error

+ RollbackErr error

+ func (e *DeployRollbackError) Error() string

+ func (e *DeployRollbackError) Unwrap() error

+ type DeployTxn struct

+ func DeployTxnFromContext(ctx context.Context) *DeployTxn

+ func NewDeployTxn() *DeployTxn

+ func (d *DeployTxn) CommitAll(ctx context.Context) error

+ func (d *DeployTxn) Register(appId types.AppId, onRollback, onCommit func(ctx context.Context) error)

+ func (d *DeployTxn) RollbackAll(ctx context.Context) error

type ExistsResult

+ func CheckImageReferenceExists(ctx context.Context, logger *types.Logger, imageRef string, ...) (ExistsResult, error)

+ type HealthProbe struct

+ FailureThreshold int32

+ Path string

+ PeriodSecs int32

+ Port int32

+ Scheme string

+ StartupFailures int32

+ TimeoutSecs int32

type KubernetesCM

+ func (k *KubernetesCM) CurrentVersionHash(ctx context.Context, name ContainerName) (string, error)

+ func (k *KubernetesCM) DeployContainer(ctx context.Context, req DeployRequest) (DeployResult, error)

+ func (k *KubernetesCM) PromoteVersion(ctx context.Context, serviceName ContainerName, versionHash string) (string, map[string]string, error)

+ func (k *KubernetesCM) RemoveVersion(ctx context.Context, serviceName ContainerName, versionHash string) error

+ func (k *KubernetesCM) Restore(ctx context.Context, snapshot any) error

+ func (k *KubernetesCM) Snapshot(ctx context.Context, name ContainerName) (any, error)

+ type VersionReporter interface

+ CurrentVersionHash func(ctx context.Context, name ContainerName) (string, error)

+ func AsVersionReporter(cm ContainerManager) (VersionReporter, bool)

Jun 11, 2026

Changes in this version

+ const DockerLocalhostBindingHostname

+ const OtherLocalhostBindingHostname

+ func LocalhostBindingHostname(containerCommand string) string

+ func LocalhostHostGatewayArgs(containerCommand string) []string

May 28, 2026

Changes in this version

+ func RedactEnvArgs(args []string) []string

May 18, 2026

Changes in this version

+ func DigestPinned(image, digest string) string

type CommandCM

+ func (c *CommandCM) ListOpenRunContainers(ctx context.Context) ([]Container, error)

+ func (c *CommandCM) RefreshImage(ctx context.Context, name ImageName) (string, error)

type ContainerManager

+ RefreshImage func(ctx context.Context, name ImageName) (digest string, err error)

type KubernetesCM

+ func (k *KubernetesCM) RefreshImage(ctx context.Context, name ImageName) (string, error)

Apr 27, 2026

Changes in this version

type ContainerManager

+ func WrapContainerManager(cm ContainerManager, kind string) ContainerManager

Apr 22, 2026

Changes in this version

+ func CommandOptionArgs(options CommandOptions, allowedContainerArgs map[string]string) ([]string, error)

type CommandOptions

+ Cpus string

+ Memory string

+ func ParseCommandOptions(containerCommand string, options map[string]string) (CommandOptions, error)

Jan 4, 2026

Changes in this version

+ const IMAGE_NAME_PREFIX

+ const OPENRUN_FIELD_MANAGER

+ const VERSION_HASH_LABEL

+ var KNOWN_OPTIONS = []string

+ func BytesString(s string) (string, error)

+ func CPUString(s string, targetIsDocker bool) (string, error)

+ func TrimLabelValue(input string) string

+ type CommandCM struct

+ func NewCommandCM(logger *types.Logger, config *types.ServerConfig, appId types.AppId, ...) *CommandCM

+ func (c *CommandCM) BuildImage(ctx context.Context, imgName ImageName, sourceUrl, containerFile string, ...) error

+ func (c *CommandCM) ExecTailN(ctx context.Context, command string, args []string, n int) ([]string, error)

+ func (c *CommandCM) GetContainerLogs(ctx context.Context, name ContainerName, linesToShow int) (string, error)

+ func (c *CommandCM) GetContainerState(ctx context.Context, name ContainerName, expectHash string) (string, bool, error)

+ func (c *CommandCM) ImageExists(ctx context.Context, name ImageName) (bool, error)

+ func (c *CommandCM) RemoveContainer(ctx context.Context, name ContainerName) error

+ func (c *CommandCM) RemoveImage(ctx context.Context, name ImageName) error

+ func (c *CommandCM) RunContainer(ctx context.Context, appEntry *types.AppEntry, sourceDir string, ...) error

+ func (c *CommandCM) StartContainer(ctx context.Context, name ContainerName) error

+ func (c *CommandCM) StopContainer(ctx context.Context, name ContainerName) error

+ func (c CommandCM) VolumeCreate(ctx context.Context, name VolumeName) error

+ func (c CommandCM) VolumeExists(ctx context.Context, name VolumeName) bool

+ func (k *CommandCM) SupportsInPlaceUpdate() bool

+ type CommandOptions struct

+ Other map[string]any

type ContainerManager

+ SupportsInPlaceUpdate func() bool

type KanikoBuild

+ ContainerArgs map[string]string

+ type KubernetesCM struct

+ func NewKubernetesCM(logger *types.Logger, config *types.ServerConfig, appConfig *types.AppConfig, ...) (*KubernetesCM, error)

+ func (k *KubernetesCM) BuildImage(ctx context.Context, imgName ImageName, sourceUrl, containerFile string, ...) error

+ func (k *KubernetesCM) GetContainerLogs(ctx context.Context, name ContainerName, linesToShow int) (string, error)

+ func (k *KubernetesCM) GetContainerState(ctx context.Context, name ContainerName, expectHash string) (string, bool, error)

+ func (k *KubernetesCM) ImageExists(ctx context.Context, name ImageName) (bool, error)

+ func (k *KubernetesCM) RunContainer(ctx context.Context, appEntry *types.AppEntry, sourceDir string, ...) error

+ func (k *KubernetesCM) StartContainer(ctx context.Context, name ContainerName) error

+ func (k *KubernetesCM) StopContainer(ctx context.Context, name ContainerName) error

+ func (k *KubernetesCM) SupportsInPlaceUpdate() bool

+ func (k *KubernetesCM) VolumeCreate(ctx context.Context, name VolumeName) error

+ func (k *KubernetesCM) VolumeExists(ctx context.Context, name VolumeName) bool

+ type KubernetesOptions struct

+ Cpus string

+ MaxReplicas int32

+ Memory string

+ MinReplicas int32

+ Other map[string]any

Dec 1, 2025

Changes in this version

+ const DOCKER_COMMAND

+ const LABEL_PREFIX

+ const PODMAN_COMMAND

+ const UNNAMED_VOLUME

+ func BuildHTTPTransport(r *types.RegistryConfig) (*http.Transport, error)

+ func CreateOrUpdateSecret(ctx context.Context, cs *kubernetes.Clientset, ns, name string, ...) error

+ func DelegateHandler(w http.ResponseWriter, r *http.Request, config *types.ServerConfig, ...)

+ func GenerateDockerConfigJSON(r *types.RegistryConfig) ([]byte, error)

+ func GetDockerConfig(ctx context.Context, imageRef string, registryConfig *types.RegistryConfig) (name.Reference, []remote.Option, error)

+ func ImageExists(ctx context.Context, logger *types.Logger, imageRef string, ...) (bool, error)

+ func KanikoJob(ctx context.Context, logger *types.Logger, cs *kubernetes.Clientset, ...) error

+ func LookupContainerCommand(checkKubernetes bool) string

+ type Container struct

+ ID string

+ Image string

+ Names string

+ Port int

+ PortString string

+ State string

+ Status string

+ type ContainerCommand struct

+ func NewContainerCommand(logger *types.Logger, config *types.ServerConfig, appId types.AppId, ...) *ContainerCommand

+ func (c *ContainerCommand) BuildImage(ctx context.Context, imgName ImageName, sourceUrl, containerFile string, ...) error

+ func (c *ContainerCommand) ExecTailN(ctx context.Context, command string, args []string, n int) ([]string, error)

+ func (c *ContainerCommand) GetContainerLogs(ctx context.Context, name ContainerName) (string, error)

+ func (c *ContainerCommand) GetContainerState(ctx context.Context, name ContainerName) (string, bool, error)

+ func (c *ContainerCommand) ImageExists(ctx context.Context, name ImageName) (bool, error)

+ func (c *ContainerCommand) RemoveContainer(ctx context.Context, name ContainerName) error

+ func (c *ContainerCommand) RemoveImage(ctx context.Context, name ImageName) error

+ func (c *ContainerCommand) RunContainer(ctx context.Context, appEntry *types.AppEntry, sourceDir string, ...) error

+ func (c *ContainerCommand) StartContainer(ctx context.Context, name ContainerName) error

+ func (c *ContainerCommand) StopContainer(ctx context.Context, name ContainerName) error

+ func (c ContainerCommand) VolumeCreate(ctx context.Context, name VolumeName) error

+ func (c ContainerCommand) VolumeExists(ctx context.Context, name VolumeName) bool

+ type ContainerManager interface

+ BuildImage func(ctx context.Context, name ImageName, sourceUrl, containerFile string, ...) error

+ GetContainerLogs func(ctx context.Context, name ContainerName) (string, error)

+ GetContainerState func(ctx context.Context, name ContainerName) (string, bool, error)

+ ImageExists func(ctx context.Context, name ImageName) (bool, error)

+ RunContainer func(ctx context.Context, appEntry *types.AppEntry, sourceDir string, ...) error

+ StartContainer func(ctx context.Context, name ContainerName) error

+ StopContainer func(ctx context.Context, name ContainerName) error

+ VolumeCreate func(ctx context.Context, name VolumeName) error

+ VolumeExists func(ctx context.Context, name VolumeName) bool

+ type ContainerName string

+ func GenContainerName(appId types.AppId, cm ContainerManager, contentHash string) ContainerName

+ type DelegateRequest struct

+ ContainerArgs map[string]string

+ ContainerFile string

+ ImageTag string

+ RegistryConfig *types.RegistryConfig

+ type DevContainerManager interface

+ RemoveContainer func(ctx context.Context, name ContainerName) error

+ RemoveImage func(ctx context.Context, name ImageName) error

+ type ExistsResult struct

+ Digest string

+ Exists bool

+ func CheckImagesExists(ctx context.Context, logger *types.Logger, imageRef string, ...) (ExistsResult, error)

+ type ImageName string

+ func GenImageName(appId types.AppId, contentHash string) ImageName

+ type KanikoBuild struct

+ Destination string

+ Dockerfile string

+ ExtraArgs []string

+ Image string

+ JobName string

+ Namespace string

+ SourceDir string

+ type KubernetesContainerManager struct

+ func NewKubernetesContainerManager(logger *types.Logger, config *types.ServerConfig) (*KubernetesContainerManager, error)

+ func (k *KubernetesContainerManager) BuildImage(ctx context.Context, imgName ImageName, sourceUrl, containerFile string, ...) error

+ func (k *KubernetesContainerManager) GetContainerLogs(ctx context.Context, name ContainerName) (string, error)

+ func (k *KubernetesContainerManager) GetContainerState(ctx context.Context, name ContainerName) (string, bool, error)

+ func (k *KubernetesContainerManager) ImageExists(ctx context.Context, name ImageName) (bool, error)

+ func (k *KubernetesContainerManager) RunContainer(ctx context.Context, appEntry *types.AppEntry, sourceDir string, ...) error

+ func (k *KubernetesContainerManager) StartContainer(ctx context.Context, name ContainerName) error

+ func (k *KubernetesContainerManager) StopContainer(ctx context.Context, name ContainerName) error

+ func (k *KubernetesContainerManager) VolumeCreate(ctx context.Context, name VolumeName) error

+ func (k *KubernetesContainerManager) VolumeExists(ctx context.Context, name VolumeName) bool

+ type VolumeInfo struct

+ IsSecret bool

+ ReadOnly bool

+ SourcePath string

+ TargetPath string

+ VolumeName string

+ type VolumeName string

+ func GenVolumeName(appId types.AppId, dirName string) VolumeName