server

package

Go to main page

Versions in this module

v1

v1.2.1

Apr 29, 2021

v1.2.0

Apr 20, 2021

Changes in this version

+ const UpdateTypeNoChanges

+ const UpdateTypePodCreate

+ const UpdateTypePodRestart

+ const UpdateTypeUnitsChange

+ const UseOverlayfsAnnotationKey

+ func KillChildren()

type PodController

+ func (pc *PodController) CreatePod(spec *api.PodSpec) error

+ func (pc *PodController) GetLogBuffer(options runtime.LogOptions) (*logbuf.LogBuffer, error)

+ func (pc *PodController) GetPid(unitName string) (int, bool)

+ func (pc *PodController) ReadSystemMetrics(ifname string) api.ResourceMetrics

+ func (pc *PodController) ReadUnitMetrics(ifname string) api.ResourceMetrics

+ func (pc *PodController) RestartPod(spec, status *api.PodSpec) error

+ func (pc *PodController) RestartUnits(spec, status *api.PodSpec) ([]api.Unit, error)

+ func (pc *PodController) UnitRunning(unit string) bool

type Server

+ func NewTestServer(store EnvStore, rootdir string, podCtl *PodController) Server

v1.1.5

Sep 30, 2020

Changes in this version

+ var LOG_PIPE_FINISH_READ_SLEEP = time.Second * 3

v1.1.4

Sep 2, 2020

v1.1.3

Aug 5, 2020

v1.1.2

Jun 10, 2020

Changes in this version

+ var ContainerLogDir = "/var/log/containers"

v1.1.1

Jun 4, 2020

v1.1.0

May 20, 2020

Changes in this version

+ const BACKOFF_RESET_TIME

+ const CERTS_DIR

+ const CHILD_OOM_SCORE

+ const DEFAULT_ROOTDIR

+ const FILE_BYTES_LIMIT

+ const ITZO_DIR

+ const ITZO_VERSION

+ const MAX_BACKOFF_TIME

+ const MAX_HOSTNAME_LEN

+ const MULTIPART_PACKAGE

+ const MaxContainerTerminationMessageLength

+ const PIPE_UNIT_STDERR

+ const PIPE_UNIT_STDOUT

+ var KubeRouterMinimumVersion = "v0.3.1"

+ var KubeRouterProg = "kube-router"

+ var KubeRouterURL = "https://milpa-builds.s3.amazonaws.com/kube-router"

+ var MaxBufferSize int64 = 1024 * 1024 * 10

+ var NVIDIA_CONTAINER_CLI_PRG = "nvidia-container-cli"

+ var NVIDIA_SMI_PRG = "nvidia-smi"

+ var UNIT_PIPES = []string

+ func DeployPackage(filename, rootdir, pkgname string) (err error)

+ func DiffUnits(spec []api.Unit, status []api.Unit, allModifiedVolumes sets.String) ([]api.Unit, []api.Unit)

+ func DiffVolumes(spec []api.Volume, status []api.Volume) (map[string]api.Volume, map[string]api.Volume, sets.String)

+ func IsUnitExist(rootdir, name string) bool

+ func MergeSecretsIntoSpec(secrets map[string]map[string][]byte, units []api.Unit)

+ func StartUnit(rootdir, podname, hostname, unitname, workingdir, netns string, ...) error

+ type Config struct

+ ArgsEscaped bool

+ AttachStderr bool

+ AttachStdin bool

+ AttachStdout bool

+ Cmd []string

+ Domainname string

+ Entrypoint []string

+ Env []string

+ ExposedPorts map[string]struct{}

+ Healthcheck *HealthConfig

+ Hostname string

+ Image string

+ Labels map[string]string

+ MacAddress string

+ NetworkDisabled bool

+ OnBuild []string

+ OpenStdin bool

+ Shell []string

+ StdinOnce bool

+ StopSignal string

+ StopTimeout *int

+ Tty bool

+ User string

+ Volumes map[string]struct{}

+ WorkingDir string

+ type EnvStore struct

+ func (e *EnvStore) Add(unit, key, value string)

+ func (e *EnvStore) Delete(unit, key string)

+ func (e *EnvStore) Get(unit, key string) (value string, exists bool)

+ func (e *EnvStore) Items(unit string) [][2]string

+ type HealthConfig struct

+ Interval time.Duration

+ Retries int

+ StartPeriod time.Duration

+ Test []string

+ Timeout time.Duration

+ type ImagePuller struct

+ func (ip *ImagePuller) PullImage(rootdir, name, image, server, username, password string) error

+ type Link struct

+ type LogPipe struct

+ Pipes map[string]*os.File

+ Unitdir string

+ func NewLogPipe(dir string) (*LogPipe, error)

+ func (l *LogPipe) Chown(uid, gid int) error

+ func (l *LogPipe) OpenWriter(name string) (fp *os.File, err error)

+ func (l *LogPipe) Remove()

+ func (l *LogPipe) StartAllReaders(cb func(string))

+ func (l *LogPipe) StartReader(name string, cb func(string))

+ type MiniUnit struct

+ Args []string

+ Command []string

+ Env []api.EnvVar

+ Image string

+ Name string

+ VolumeMounts []api.VolumeMount

+ type Mounter interface

+ AttachMount func(unitname, src, dst string) error

+ CreateMount func(*api.Volume) error

+ DeleteMount func(*api.Volume) error

+ DetachMount func(unitname, dst string) error

+ type ParameterError struct

+ func (pe *ParameterError) Error() string

+ type PodController struct

+ func NewPodController(rootdir string, mounter Mounter, unitMgr UnitRunner) *PodController

+ func (pc *PodController) GetStatus() ([]api.UnitStatus, []api.UnitStatus, error)

+ func (pc *PodController) GetUnitName(unitName string) (string, error)

+ func (pc *PodController) SetPodNetwork(netNS, podIP string)

+ func (pc *PodController) Start()

+ func (pc *PodController) SyncPodUnits(spec *api.PodSpec, status *api.PodSpec, ...)

+ func (pc *PodController) UpdatePod(params *api.PodParameters) error

+ type Puller interface

+ PullImage func(rootdir, name, image, server, username, password string) error

+ type Server struct

+ func New(rootdir string) *Server

+ func (s *Server) ListenAndServe(addr string, disableTLS bool)

+ func (s *Server) RunLogTailer(w http.ResponseWriter, r *http.Request, unitName string, withMetadata bool, ...)

+ func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Unit struct

+ Directory string

+ Image string

+ Name string

+ func OpenUnit(rootdir, name string) (*Unit, error)

+ func (u *Unit) CreateCommand(command []string, args []string) []string

+ func (u *Unit) Destroy() error

+ func (u *Unit) GetEnv() []string

+ func (u *Unit) GetRootfs() string

+ func (u *Unit) GetStatus() (*api.UnitStatus, error)

+ func (u *Unit) GetUser(lookup util.UserLookup) (uid, gid uint32, groups []uint32, homedir string, err error)

+ func (u *Unit) GetWorkingDir() string

+ func (u *Unit) OpenStdinWriter() (io.WriteCloser, error)

+ func (u *Unit) PullAndExtractImage(image, server, username, password string) error

+ func (u *Unit) Run(podname, hostname string, command []string, workingdir string, ...) error

+ func (u *Unit) SaveUnitConfig(unitConfig UnitConfig) error

+ func (u *Unit) SetImage(image string) error

+ func (u *Unit) SetState(state api.UnitState, restarts *int) error

+ func (u *Unit) SetStatus(status *api.UnitStatus) error

+ func (u *Unit) UpdateStatusAttr(ready, started *bool) error

+ type UnitConfig struct

+ LivenessProbe *api.Probe

+ PodIP string

+ ReadinessProbe *api.Probe

+ StartupProbe *api.Probe

+ TerminationMessagePath string

+ TerminationMessagePolicy api.TerminationMessagePolicy

+ type UnitManager struct

+ func NewUnitManager(rootDir string) *UnitManager

+ func (um *UnitManager) CaptureLogs(name string, unit *Unit)

+ func (um *UnitManager) GetLogBuffer(unit string) (*logbuf.LogBuffer, error)

+ func (um *UnitManager) GetPid(unitName string) (int, bool)

+ func (um *UnitManager) ReadLogBuffer(unit string, n int) ([]logbuf.LogEntry, error)

+ func (um *UnitManager) RemoveUnit(name string) error

+ func (um *UnitManager) StartUnit(podname, hostname, unitname, workingdir, netns string, ...) error

+ func (um *UnitManager) StopUnit(name string) error

+ func (um *UnitManager) UnitRunning(unit string) bool

+ type UnitRunner interface

+ RemoveUnit func(string) error

+ StartUnit func(string, string, string, string, string, []string, []string, []string, ...) error

+ StopUnit func(string) error

v1.1.0-beta.1

Mar 18, 2020

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