Versions in this module Expand all Collapse all v0 v0.8.3 Apr 27, 2018 Changes in this version + var LogDirName = "logs" + var SharedAllocContainerPath = filepath.Join("/", SharedAllocName) — darwin/amd64, linux/amd64 + var SharedAllocContainerPath = filepath.Join("c:\\", SharedAllocName) — windows/amd64 + var SharedAllocDirs = []string + var SharedAllocName = "alloc" + var SharedDataDir = "data" + var SnapshotErrorTime = time.Date(2000, 0, 0, 0, 0, 0, 0, time.UTC) + var TaskDirs = map[string]os.FileMode + var TaskLocal = "local" + var TaskLocalContainerPath = filepath.Join("/", TaskLocal) — darwin/amd64, linux/amd64 + var TaskLocalContainerPath = filepath.Join("c:\\", TaskLocal) — windows/amd64 + var TaskSecrets = "secrets" + var TaskSecretsContainerPath = filepath.Join("/", TaskSecrets) — darwin/amd64, linux/amd64 + var TaskSecretsContainerPath = filepath.Join("c:\\", TaskSecrets) — windows/amd64 + var TmpDirName = "tmp" + func MountSpecialDirs(taskDir string) error — windows/amd64 + func SnapshotErrorFilename(allocID string) string + type AllocDir struct + AllocDir string + SharedDir string + TaskDirs map[string]*TaskDir + func NewAllocDir(logger *log.Logger, allocDir string) *AllocDir + func (d *AllocDir) BlockUntilExists(ctx context.Context, path string) (chan error, error) + func (d *AllocDir) Build() error + func (d *AllocDir) ChangeEvents(ctx context.Context, path string, curOffset int64) (*watch.FileChanges, error) + func (d *AllocDir) Copy() *AllocDir + func (d *AllocDir) Destroy() error + func (d *AllocDir) List(path string) ([]*cstructs.AllocFileInfo, error) + func (d *AllocDir) Move(other *AllocDir, tasks []*structs.Task) error + func (d *AllocDir) NewTaskDir(name string) *TaskDir + func (d *AllocDir) ReadAt(path string, offset int64) (io.ReadCloser, error) + func (d *AllocDir) Snapshot(w io.Writer) error + func (d *AllocDir) Stat(path string) (*cstructs.AllocFileInfo, error) + func (d *AllocDir) UnmountAll() error + type AllocDirFS interface + BlockUntilExists func(ctx context.Context, path string) (chan error, error) + ChangeEvents func(ctx context.Context, path string, curOffset int64) (*watch.FileChanges, error) + List func(path string) ([]*cstructs.AllocFileInfo, error) + ReadAt func(path string, offset int64) (io.ReadCloser, error) + Snapshot func(w io.Writer) error + Stat func(path string) (*cstructs.AllocFileInfo, error) + type TaskDir struct + Dir string + LocalDir string + LogDir string + SecretsDir string + SharedAllocDir string + SharedTaskDir string + func (t *TaskDir) Build(chrootCreated bool, chroot map[string]string, fsi cstructs.FSIsolation) error + func (t *TaskDir) Copy() *TaskDir
Go to main page