Documentation
¶
Overview ¶
That this code needs to exist is kind of dumb, but I'm not sure how else to do it.
Index ¶
- Constants
- Variables
- func AddSlash(path string) string
- func AllocatePort() (int, error)
- func AtoiEmptyDefault(s string, def int) (int, error)
- func BlockFsDetect(dev string) (string, error)
- func CachePath(path ...string) string
- func CertFingerprint(cert *x509.Certificate) string
- func CertFingerprintStr(c string) (string, error)
- func DebugJson(r *bytes.Buffer)
- func DeepCopy(src, dest interface{}) error
- func ExecReaderToChannel(r io.Reader, bufferSize int, exited <-chan bool, fd int) <-chan []byte
- func ExtractSnapshotName(name string) string
- func FileCopy(source string, dest string) error
- func FileMove(oldPath string, newPath string) error
- func FindOrGenCert(certf string, keyf string, certtype bool) error
- func GenCert(certf string, keyf string, certtype bool) error
- func GenerateMemCert(client bool) ([]byte, []byte, error)
- func GetAllXattr(path string) (xattrs map[string]string, err error)
- func GetByteSizeString(input int64, precision uint) string
- func GetErrno(err error) (errno error, iserrno bool)
- func GetFileStat(p string) (uid int, gid int, major int, minor int, inode uint64, nlink int, err error)
- func GetOwnerMode(fInfo os.FileInfo) (os.FileMode, int, int)
- func GetPollRevents(fd int, timeout int, flags int) (int, int, error)
- func GetRemoteCertificate(address string) (*x509.Certificate, error)
- func GetTLSConfig(tlsClientCertFile string, tlsClientKeyFile string, tlsClientCAFile string, ...) (*tls.Config, error)
- func GetTLSConfigMem(tlsClientCert string, tlsClientKey string, tlsClientCA string, ...) (*tls.Config, error)
- func GroupId(name string) (int, error)
- func HostPath(path string) string
- func Int64InSlice(key int64, list []int64) bool
- func IntInSlice(key int, list []int) bool
- func IsBlockdev(fm os.FileMode) bool
- func IsBlockdevPath(pathName string) bool
- func IsDir(name string) bool
- func IsLoopback(iface *net.Interface) bool
- func IsMountPoint(name string) bool
- func IsSnapshot(name string) bool
- func IsTrue(value string) bool
- func IsUnixSocket(path string) bool
- func LogPath(path ...string) string
- func Major(dev uint64) int
- func Minor(dev uint64) int
- func MkdirAllOwner(path string, perm os.FileMode, uid int, gid int) error
- func OpenPty(uid, gid int64) (master *os.File, slave *os.File, err error)
- func ParseBitSizeString(input string) (int64, error)
- func ParseByteSizeString(input string) (int64, error)
- func ParseLXDFileHeaders(headers http.Header) (uid int64, gid int64, mode int, type_ string, write string)
- func ParseMetadata(metadata interface{}) (map[string]interface{}, error)
- func PathExists(name string) bool
- func PathIsEmpty(path string) (bool, error)
- func Pipe() (master *os.File, slave *os.File, err error)
- func ProxyFromConfig(httpsProxy string, httpProxy string, noProxy string) func(req *http.Request) (*url.URL, error)
- func ProxyFromEnvironment(req *http.Request) (*url.URL, error)
- func RFC3493Dialer(network, address string) (net.Conn, error)
- func RandomCryptoString() (string, error)
- func ReadCert(fpath string) (*x509.Certificate, error)
- func ReadDir(p string) ([]string, error)
- func ReadLastNLines(f *os.File, lines int) (string, error)
- func ReadStdin() ([]byte, error)
- func ReadToJSON(r io.Reader, req interface{}) error
- func ReaderToChannel(r io.Reader, bufferSize int) <-chan []byte
- func RunCommand(name string, arg ...string) (string, error)
- func RunningInUserNS() bool
- func SetSize(fd int, width int, height int) (err error)
- func SplitExt(fpath string) (string, string)
- func StringInSlice(key string, list []string) bool
- func TextEditor(inPath string, inContent []byte) ([]byte, error)
- func TimeIsSet(ts time.Time) bool
- func TryRunCommand(name string, arg ...string) (string, error)
- func URLEncode(path string, query map[string]string) (string, error)
- func UserId(name string) (int, error)
- func ValidHostname(name string) bool
- func VarPath(path ...string) string
- func WebsocketExecMirror(conn *websocket.Conn, w io.WriteCloser, r io.ReadCloser, exited chan bool, ...) (chan bool, chan bool)
- func WebsocketMirror(conn *websocket.Conn, w io.WriteCloser, r io.ReadCloser, ...) (chan bool, chan bool)
- func WebsocketProxy(source *websocket.Conn, target *websocket.Conn) chan bool
- func WebsocketRecvStream(w io.Writer, conn *websocket.Conn) chan bool
- func WebsocketSendStream(conn *websocket.Conn, r io.Reader, bufferSize int) chan bool
- func WriteAll(w io.Writer, buf []byte) error
- func WriteAllBuf(w io.Writer, buf *bytes.Buffer) error
- func WriteTempFile(dir string, prefix string, content string) (string, error)
- type BytesReadCloser
- type ContainerAction
- type Jmap
- type RunError
- type StringSet
- type Utsname
- type WebSocketMirrorReader
- type WebSocketMirrorWriter
Constants ¶
const ABSTRACT_UNIX_SOCK_LEN int = C.ABSTRACT_UNIX_SOCK_LEN
const DefaultPort = "8443"
const POLLERR int = C.POLLERR
const POLLHUP int = C.POLLHUP
const POLLIN int = C.POLLIN
const POLLNVAL int = C.POLLNVAL
const POLLPRI int = C.POLLPRI
const POLLRDHUP int = C.POLLRDHUP
const SnapshotDelimiter = "/"
Variables ¶
Functions ¶
func AddSlash ¶
AddSlash adds a slash to the end of paths if they don't already have one. This can be useful for rsyncing things, since rsync has behavior present on the presence or absence of a trailing slash.
func AllocatePort ¶
AllocatePort asks the kernel for a free open port that is ready to use
func BlockFsDetect ¶
func CachePath ¶
CachePath returns the directory that LXD should its cache under. If LXD_DIR is set, this path is $LXD_DIR/cache, otherwise it is /var/cache/lxd.
func CertFingerprint ¶
func CertFingerprint(cert *x509.Certificate) string
func CertFingerprintStr ¶
func DeepCopy ¶
func DeepCopy(src, dest interface{}) error
DeepCopy copies src to dest by using encoding/gob so its not that fast.
func ExecReaderToChannel ¶
Extensively commented directly in the code. Please leave the comments! Looking at this in a couple of months noone will know why and how this works anymore.
func ExtractSnapshotName ¶
func FileMove ¶
FileMove tries to move a file by using os.Rename, if that fails it tries to copy the file and remove the source.
func GenerateMemCert ¶
GenerateMemCert creates client or server certificate and key pair, returning them as byte arrays in memory.
func GetAllXattr ¶
GetAllXattr retrieves all extended attributes associated with a file, directory or symbolic link.
func GetByteSizeString ¶
func GetFileStat ¶
func GetRemoteCertificate ¶
func GetRemoteCertificate(address string) (*x509.Certificate, error)
func GetTLSConfig ¶
func GetTLSConfigMem ¶
func GroupId ¶
GroupId is an adaption from https://codereview.appspot.com/4589049.
func HostPath ¶
HostPath returns the host path for the provided path On a normal system, this does nothing When inside of a snap environment, returns the real path
func Int64InSlice ¶
func IntInSlice ¶
func IsBlockdev ¶
func IsBlockdevPath ¶
func IsLoopback ¶
func IsMountPoint ¶
func IsSnapshot ¶
func IsUnixSocket ¶
IsUnixSocket returns true if the given path is either a Unix socket or a symbolic link pointing at a Unix socket.
func LogPath ¶
LogPath returns the directory that LXD should put logs under. If LXD_DIR is set, this path is $LXD_DIR/logs, otherwise it is /var/log/lxd.
func ParseBitSizeString ¶
Parse a size string in bits (e.g. 200kbit or 5Gbit) into the number of bits it represents. Supports suffixes up to Ebit. "" == 0.
func ParseByteSizeString ¶
Parse a size string in bytes (e.g. 200kB or 5GB) into the number of bytes it represents. Supports suffixes up to EB. "" == 0.
func ParseLXDFileHeaders ¶
func ParseMetadata ¶
func PathExists ¶
func PathIsEmpty ¶
PathIsEmpty checks if the given path is empty.
func ProxyFromConfig ¶
func ProxyFromEnvironment ¶
This is basically the same as golang's ProxyFromEnvironment, except it doesn't fall back to http_proxy when https_proxy isn't around, which is incorrect behavior. It still respects HTTP_PROXY, HTTPS_PROXY, and NO_PROXY.
func RandomCryptoString ¶
Returns a random base64 encoded string from crypto/rand.
func ReadToJSON ¶
func RunningInUserNS ¶
func RunningInUserNS() bool
func StringInSlice ¶
func TextEditor ¶
Spawn the editor with a temporary YAML file for editing configs
func UserId ¶
UserId is an adaption from https://codereview.appspot.com/4589049.
func ValidHostname ¶
func VarPath ¶
VarPath returns the provided path elements joined by a slash and appended to the end of $LXD_DIR, which defaults to /var/lib/lxd.
func WebsocketExecMirror ¶
func WebsocketExecMirror(conn *websocket.Conn, w io.WriteCloser, r io.ReadCloser, exited chan bool, fd int) (chan bool, chan bool)
func WebsocketMirror ¶
func WebsocketMirror(conn *websocket.Conn, w io.WriteCloser, r io.ReadCloser, Reader WebSocketMirrorReader, Writer WebSocketMirrorWriter) (chan bool, chan bool)
func WebsocketSendStream ¶
Types ¶
type BytesReadCloser ¶
func (BytesReadCloser) Close ¶
func (r BytesReadCloser) Close() error
type ContainerAction ¶
type ContainerAction string
const ( Stop ContainerAction = "stop" Start ContainerAction = "start" Restart ContainerAction = "restart" Freeze ContainerAction = "freeze" Unfreeze ContainerAction = "unfreeze" )
type StringSet ¶
func NewStringSet ¶
type Utsname ¶
type Utsname struct {
Sysname string
Nodename string
Release string
Version string
Machine string
Domainname string
}
Utsname returns the same info as syscall.Utsname, as strings
type WebSocketMirrorReader ¶
type WebSocketMirrorReader func(conn *websocket.Conn, r io.ReadCloser, readDone chan<- bool)
WebsocketMirror allows mirroring a reader to a websocket and taking the result and writing it to a writer. This function allows for multiple mirrorings and correctly negotiates stream endings. However, it means any websocket.Conns passed to it are live when it returns, and must be closed explicitly.
type WebSocketMirrorWriter ¶
type WebSocketMirrorWriter func(conn *websocket.Conn, w io.WriteCloser, writeDone chan<- bool)
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
Package api contains Go structs for all LXD API objects Overview This package has Go structs for every API object, all the various structs are named after the object they represent and some variations of those structs exist for initial object creation, object update and object retrieval.
|
Package api contains Go structs for all LXD API objects Overview This package has Go structs for every API object, all the various structs are named after the object they represent and some variations of those structs exist for initial object creation, object update and object retrieval. |
|
Package gnuflag implements command-line flag parsing in the GNU style.
|
Package gnuflag implements command-line flag parsing in the GNU style. |
|
Package subtest provides a backwards-compatible way to run subtests.
|
Package subtest provides a backwards-compatible way to run subtests. |