instance

Documentation

Index

• Constants
• Variables
• func CheckName(name string) error
• func ExtractName(name string) string
• func GetDirPrivileged(name string, subDir string) (string, error)
• func GetDirUnprivileged(name string, subDir string) (string, error)
• func ProcName(name string, username string) string
• func SetLogFile(name string, uid int, subDir string) (*os.File, *os.File, error)
• type File
  • func Add(name string, privileged bool, subDir string) (*File, error)
  • func Get(name string, subDir string) (*File, error)
  • func List(username string, name string, subDir string) ([]*File, error)
  • func (i *File) Delete() error
  • func (i *File) MountNamespaces() error
  • func (i *File) PrivilegedPath() bool
  • func (i *File) Update() error
  • func (i *File) UpdateNamespacesPath(configNs []specs.LinuxNamespace) error
• type LogFormatter
• type Logger
  • func NewLogger(logPath string, formatter LogFormatter) (*Logger, error)
  • func (l *Logger) NewWriter(stream string, dropCRNL bool) *io.PipeWriter
  • func (l *Logger) ReOpenFile()

Constants

const (
	// OciSubDir represents directory where OCI instance files are stored
	OciSubDir = "oci"
	// SingSubDir represents directory where Singularity instance files are stored
	SingSubDir = "sing"
)

const (
	// BasicLogFormat represents basic log format.
	BasicLogFormat = "basic"
	// KubernetesLogFormat represents kubernetes log format.
	KubernetesLogFormat = "kubernetes"
	// JSONLogFormat represents JSON log format.
	JSONLogFormat = "json"
)

Variables

var LogFormats = map[string]LogFormatter{
	BasicLogFormat:      basicLogFormatter,
	KubernetesLogFormat: kubernetesLogFormatter,
	JSONLogFormat:       jsonLogFormatter,
}

LogFormats contains supported log format by default.

Functions

func CheckName

func CheckName(name string) error

CheckName checks if name is a valid instance name

func ExtractName

func ExtractName(name string) string

ExtractName extracts instance name from an instance:// URI

func GetDirPrivileged

func GetDirPrivileged(name string, subDir string) (string, error)

GetDirPrivileged returns directory where instances file will be stored if instance is run with privileges

func GetDirUnprivileged

func GetDirUnprivileged(name string, subDir string) (string, error)

GetDirUnprivileged returns directory where instances file will be stored if instance is run without privileges

func ProcName

func ProcName(name string, username string) string

ProcName returns processus name based on instance name and username

func SetLogFile

func SetLogFile(name string, uid int, subDir string) (*os.File, *os.File, error)

SetLogFile replaces stdout/stderr streams and redirect content to log file

Types

type File

type File struct {
	Path       string `json:"-"`
	Pid        int    `json:"pid"`
	PPid       int    `json:"ppid"`
	Name       string `json:"name"`
	User       string `json:"user"`
	Image      string `json:"image"`
	Privileged bool   `json:"privileged"`
	Config     []byte `json:"config"`
}

File represents an instance file storing instance information

func Add

func Add(name string, privileged bool, subDir string) (*File, error)

Add creates an instance file for a named instance in a privileged or unprivileged path

func Get

func Get(name string, subDir string) (*File, error)

Get returns the instance file corresponding to instance name

func List

func List(username string, name string, subDir string) ([]*File, error)

List returns instance files matching username and/or name pattern

func (*File) Delete

func (i *File) Delete() error

Delete deletes instance file

func (*File) MountNamespaces

func (i *File) MountNamespaces() error

MountNamespaces binds /proc/<pid>/ns directory into instance folder

func (*File) PrivilegedPath

func (i *File) PrivilegedPath() bool

PrivilegedPath returns if instance file is stored in privileged path or not

func (*File) Update

func (i *File) Update() error

Update stores instance information in associated instance file

func (*File) UpdateNamespacesPath

func (i *File) UpdateNamespacesPath(configNs []specs.LinuxNamespace) error

UpdateNamespacesPath updates namespaces path for the provided configuration

type LogFormatter

type LogFormatter func(stream string, data string) string

LogFormatter implements a log formatter.

type Logger

type Logger struct {
	// contains filtered or unexported fields
}

Logger defines a file logger.

func NewLogger

func NewLogger(logPath string, formatter LogFormatter) (*Logger, error)

NewLogger instantiates a new logger with formatter and return it.

func (*Logger) NewWriter

func (l *Logger) NewWriter(stream string, dropCRNL bool) *io.PipeWriter

NewWriter create a new pipe pair for corresponding stream.

func (*Logger) ReOpenFile

func (l *Logger) ReOpenFile()

ReOpenFile closes and re-open log file (eg: log rotation).