allocdir

Nov 19, 2020

Changes in this version

+ var AllocGRPCSocket = filepath.Join(SharedAllocName, TmpDirName, "consul_grpc.sock")

type AllocDir

+ func TestAllocDir(t testing.T, l hclog.Logger, prefix string) (*AllocDir, func())

Jun 12, 2019

Changes in this version

+ var SnapshotErrorTime = time.Date(2000, 0, 0, 0, 0, 0, 0, time.UTC)

+ func SnapshotErrorFilename(allocID string) string

type TaskDir

+ AllocDir string

Nov 1, 2017

Changes in this version

+ var TmpDirName = "tmp"

type AllocDir

+ func (d *AllocDir) Copy() *AllocDir

type TaskDir

+ func (t *TaskDir) Copy() *TaskDir

Mar 14, 2017

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 SharedDataDir = "data"

+ var TaskDirs = []string

+ 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

+ func MountSpecialDirs(taskDir string) error — windows/amd64

type AllocDir

+ func (d *AllocDir) BlockUntilExists(path string, t *tomb.Tomb) (chan error, error)

+ func (d *AllocDir) ChangeEvents(path string, curOffset int64, t *tomb.Tomb) (*watch.FileChanges, error)

+ func (d *AllocDir) List(path string) ([]*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) (*AllocFileInfo, error)

+ func (d *AllocDir) UnmountAll() error

+ type AllocDirFS interface

+ BlockUntilExists func(path string, t *tomb.Tomb) (chan error, error)

+ ChangeEvents func(path string, curOffset int64, t *tomb.Tomb) (*watch.FileChanges, error)

+ List func(path string) ([]*AllocFileInfo, error)

+ ReadAt func(path string, offset int64) (io.ReadCloser, error)

+ Snapshot func(w io.Writer) error

+ Stat func(path string) (*AllocFileInfo, error)

+ type AllocFileInfo struct

+ FileMode string

+ IsDir bool

+ ModTime time.Time

+ Name string

+ Size int64

+ 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

Dec 11, 2015

Changes in this version

+ var SharedAllocDirs = []string

+ var SharedAllocName = "alloc"

+ var TaskLocal = "local"

+ type AllocDir struct

+ AllocDir string

+ SharedDir string

+ TaskDirs map[string]string

+ func NewAllocDir(allocDir string) *AllocDir

+ func (d *AllocDir) Build(tasks []*structs.Task) error

+ func (d *AllocDir) Destroy() error

+ func (d *AllocDir) Embed(task string, entries map[string]string) error

+ func (d *AllocDir) MountSharedDir(task string) error