runtimeutil

Nov 9, 2020

Changes in this version

+ const ContainerLabelHostNetwork

+ const ContainerLabelPodContainer

+ const ContainerLabelPodContainerRole

+ const ContainerLabelPodName

+ const ContainerLabelPodNamespace

+ const ContainerLabelPodUID

+ const ContainerNameAbbot

+ const ContainerNamePause

+ const ContainerRoleInfra

+ const ContainerRoleWork

+ const DefaultDockerImageDomain

+ const DefaultDockerImageNamespace

+ const LabelRole

+ const LabelRoleValueAbbot

+ const StorageArgEnvMountpoint

+ const StorageArgEnvRemotePath

+ var ErrMountpointInProcess = errors.New("already in process")

+ var ErrMountpointInUse = errors.New("already in use")

+ func AbbotMatchLabels() map[string]string

+ func CleanupPodData(podDir, remoteVolumeDir, tmpfsVolumeDir string, ...) error

+ func CollectErrors(errCh <-chan error) error

+ func ContainerLabels(options *runtimepb.PodEnsureCmd, container string) map[string]string

+ func GenerateImageName(defaultDomain, defaultNamespace, name string) string

+ func GenerateUnmountCmd(binPath string, mountPoint string) []string

+ func GetContainerName(namespace, name, container string) string

+ func GetEnv(env []string) map[string]string

+ func IsAbbotPod(labels map[string]string) bool

+ func IsHostNetwork(labels map[string]string) bool

+ func IsLikelyNotMountPoint(file string) (bool, error)

+ func IsPauseContainer(labels map[string]string) bool

+ func LookupUnmountUtil(extraLookupPaths []string, fuse bool) (string, error)

+ func PortForward(ctx context.Context, address, protocol string, port int32, upstream io.Reader, ...) error

+ func ReadLogs(ctx context.Context, path string, options *aranyagopb.LogsCmd, ...) error

+ func RemoveAllOneFilesystem(path string) error

+ func ResolveHostPathMountSource(path, podUID, volName string, remote bool, ...) (string, error)

+ func ResolveStorageCommand(bin string, args []string, remotePath, localPath string) ([]string, error)

+ func SharedNamespaces(pauseCtrID string, options *runtimepb.PodEnsureCmd) map[string]string

+ type AbbotExecFunc func(ctx context.Context, env map[string]string, stdin io.Reader, ...) error

+ type BaseRuntime struct

+ func NewBaseRuntime(ctx context.Context, dataDir string, ...) *BaseRuntime

+ func (r *BaseRuntime) ActionContext(ctx context.Context) (context.Context, context.CancelFunc)

+ func (r *BaseRuntime) Arch() string

+ func (r *BaseRuntime) ImageActionContext(ctx context.Context) (context.Context, context.CancelFunc)

+ func (r *BaseRuntime) KernelVersion() string

+ func (r *BaseRuntime) Name() string

+ func (r *BaseRuntime) OS() string

+ func (r *BaseRuntime) OSImage() string

+ func (r *BaseRuntime) PodActionContext(ctx context.Context) (context.Context, context.CancelFunc)

+ func (r *BaseRuntime) PodBindVolumeDir(podUID, volumeName string) string

+ func (r *BaseRuntime) PodDir(podUID string) string

+ func (r *BaseRuntime) PodRemoteVolumeDir(podUID, volumeName string) string

+ func (r *BaseRuntime) PodResolvConfFile(podUID string) string

+ func (r *BaseRuntime) PodTmpfsVolumeDir(podUID, volumeName string) string

+ func (r *BaseRuntime) Version() string

+ type JSONLog struct — darwin/amd64, linux/amd64, windows/amd64

+ Attrs map[string]string

+ Created time.Time

+ Log string

+ Stream string

+ func (jl *JSONLog) Reset()

+ type LogOptions struct — darwin/amd64, linux/amd64, windows/amd64

+ type NetworkClient struct

+ func NewNetworkClient(exec AbbotExecFunc) *NetworkClient

+ func (c *NetworkClient) CreateResolvConf(nameservers, searches, options []string) ([]byte, error)

+ func (c *NetworkClient) Delete(ctx context.Context, pid int64, containerID string) error

+ func (c *NetworkClient) Do(ctx context.Context, abbotReqData []byte, pid int64, containerID string) (abbotRespData []byte, err error)

+ func (c *NetworkClient) Query(ctx context.Context, pid int64, containerID string) ([]byte, error)

+ func (c *NetworkClient) Restore(ctx context.Context, pid int64, containerID string) error

+ type StorageClient struct

+ func NewStorageClient(ctx context.Context, impl StorageDriver, successTimeWait time.Duration, ...) (_ *StorageClient, err error)

+ func (c *StorageClient) Close()

+ func (c *StorageClient) Mount(ctx context.Context, remotePath, mountPoint string, ...) error

+ func (c *StorageClient) Unmount(ctx context.Context, mountPoint string) error

+ type StorageDriver interface

+ GetMountCmd func(remotePath, mountPoint string) []string

+ GetUnmountCmd func(mountPoint string) []string

+ type StorageExitHandleFunc func(remotePath, mountPoint string, err error)