tether

Jan 11, 2019

Changes in this version

type Tether

+ Wait func(ctx context.Context) error

Jun 28, 2018

Changes in this version

+ type Detail struct

+ CreateTime int64

+ StartTime int64

+ StopTime int64

May 4, 2018

Changes in this version

+ const MaxDeathRecords

+ const SetChildSubreaper — linux/amd64

+ var BindSys = system.NewWithRoot("/.tether")

+ var Sys = shared.Sys

+ func ApplyEndpoint(nl Netlink, t *BaseOperations, endpoint *NetworkEndpoint) error — linux/amd64

+ func Mkdev(majorNumber int, minorNumber int) int — linux/amd64

+ func ReloadConfig() error — linux/amd64

+ type BaseOperations struct — linux/amd64

+ func (t *BaseOperations) AddrAdd(link netlink.Link, addr *netlink.Addr) error

+ func (t *BaseOperations) AddrDel(link netlink.Link, addr *netlink.Addr) error

+ func (t *BaseOperations) AddrList(link netlink.Link, family int) ([]netlink.Addr, error)

+ func (t *BaseOperations) Apply(endpoint *NetworkEndpoint) error

+ func (t *BaseOperations) Cleanup() error

+ func (t *BaseOperations) CopyExistingContent(source string) error

+ func (t *BaseOperations) Fork() error

+ func (t *BaseOperations) HandleUtilityExit(pid, exitCode int) bool

+ func (t *BaseOperations) LaunchUtility(fn UtilityFn) (<-chan int, error)

+ func (t *BaseOperations) LinkByName(name string) (netlink.Link, error)

+ func (t *BaseOperations) LinkBySlot(slot int32) (netlink.Link, error)

+ func (t *BaseOperations) LinkSetAlias(link netlink.Link, alias string) error

+ func (t *BaseOperations) LinkSetDown(link netlink.Link) error

+ func (t *BaseOperations) LinkSetName(link netlink.Link, name string) error

+ func (t *BaseOperations) LinkSetUp(link netlink.Link) error

+ func (t *BaseOperations) MountLabel(ctx context.Context, label, target string) error

+ func (t *BaseOperations) MountTarget(ctx context.Context, source url.URL, target string, mountOptions string) error

+ func (t *BaseOperations) ProcessEnv(session *SessionConfig) []string

+ func (t *BaseOperations) RouteAdd(route *netlink.Route) error

+ func (t *BaseOperations) RouteDel(route *netlink.Route) error

+ func (t *BaseOperations) RuleList(family int) ([]netlink.Rule, error)

+ func (t *BaseOperations) SetHostname(hostname string, aliases ...string) error

+ func (t *BaseOperations) Setup(config Config) error

+ type Config interface

+ Flush func() error

+ UpdateNetworkEndpoint func(e *NetworkEndpoint) error

+ type ContainerSigner struct

+ func NewSigner(id string) *ContainerSigner

+ func (c *ContainerSigner) PublicKey() ssh.PublicKey

+ func (c *ContainerSigner) Sign(rand io.Reader, data []byte) (*ssh.Signature, error)

+ func (c ContainerSigner) Marshal() []byte

+ func (c ContainerSigner) Type() string

+ func (c ContainerSigner) Verify(data []byte, sig *ssh.Signature) error

+ type DHCPInfo struct

+ Assigned net.IPNet

+ Gateway net.IPNet

+ Nameservers []net.IP

+ type ExecutorConfig struct

+ AsymmetricRouting bool

+ DebugLevel int

+ Domainname string

+ Execs map[string]*SessionConfig

+ Hostname string

+ ID string

+ Key []byte

+ Mounts map[string]executor.MountSpec

+ Name string

+ Networks map[string]*NetworkEndpoint

+ Sessions map[string]*SessionConfig

+ type Extension interface

+ Reload func(config *ExecutorConfig) error

+ Start func(System) error

+ Stop func() error

+ type MockHosts struct

+ func (h MockHosts) Copy(conf etcconf.Conf) error

+ func (h MockHosts) HostIP(_ string) []net.IP

+ func (h MockHosts) Load() error

+ func (h MockHosts) Path() string

+ func (h MockHosts) RemoveAll()

+ func (h MockHosts) RemoveHost(_ string)

+ func (h MockHosts) Save() error

+ func (h MockHosts) SetHost(_ string, _ net.IP)

+ type MockResolvConf struct

+ func (h MockResolvConf) AddNameservers(...net.IP)

+ func (h MockResolvConf) Attempts() uint

+ func (h MockResolvConf) Copy(conf etcconf.Conf) error

+ func (h MockResolvConf) Load() error

+ func (h MockResolvConf) Nameservers() []net.IP

+ func (h MockResolvConf) Path() string

+ func (h MockResolvConf) RemoveNameservers(...net.IP)

+ func (h MockResolvConf) Save() error

+ func (h MockResolvConf) SetAttempts(uint)

+ func (h MockResolvConf) SetTimeout(time.Duration)

+ func (h MockResolvConf) Timeout() time.Duration

+ type MockSyscall struct

+ func (m MockSyscall) Mount(source string, target string, fstype string, flags uintptr, data string) error

+ func (m MockSyscall) Sethostname(_ []byte) error

+ func (m MockSyscall) Symlink(_, _ string) error

+ func (m MockSyscall) Unmount(_ string, _ int) error

+ type Netlink interface — linux/amd64

+ AddrAdd func(netlink.Link, *netlink.Addr) error

+ AddrDel func(netlink.Link, *netlink.Addr) error

+ AddrList func(netlink.Link, int) ([]netlink.Addr, error)

+ LinkByName func(string) (netlink.Link, error)

+ LinkBySlot func(slot int32) (netlink.Link, error)

+ LinkSetAlias func(netlink.Link, string) error

+ LinkSetDown func(netlink.Link) error

+ LinkSetName func(netlink.Link, string) error

+ LinkSetUp func(netlink.Link) error

+ RouteAdd func(*netlink.Route) error

+ RouteDel func(*netlink.Route) error

+ RuleList func(family int) ([]netlink.Rule, error)

+ type NetworkEndpoint struct

+ Assigned net.IPNet

+ DHCP *DHCPInfo

+ IP *net.IPNet

+ Internal bool

+ Network executor.ContainerNetwork

+ Ports []string

+ Static bool

+ func (e *NetworkEndpoint) IsDynamic() bool

+ type Operations interface

+ Apply func(endpoint *NetworkEndpoint) error

+ Cleanup func() error

+ CopyExistingContent func(source string) error

+ Fork func() error

+ HandleSessionExit func(config *ExecutorConfig, session *SessionConfig) func()

+ HandleUtilityExit func(pid, exitCode int) bool

+ LaunchUtility func(UtilityFn) (<-chan int, error)

+ Log func() (io.Writer, error)

+ MountLabel func(ctx context.Context, label, target string) error

+ MountTarget func(ctx context.Context, source url.URL, target string, mountOptions string) error

+ ProcessEnv func(session *SessionConfig) []string

+ SessionLog func(session *SessionConfig) (dio.DynamicMultiWriter, dio.DynamicMultiWriter, error)

+ SetHostname func(hostname string, aliases ...string) error

+ Setup func(Config) error

+ SetupFirewall func(ctx context.Context, config *ExecutorConfig) error

+ type SessionConfig struct

+ Active bool

+ Attach bool

+ ClearToLaunch chan struct{}

+ Cmd exec.Cmd

+ Diagnostics executor.Diagnostics

+ Errwriter dio.DynamicMultiWriter

+ ExitStatus int

+ Group string

+ OpenStdin bool

+ Outwriter dio.DynamicMultiWriter

+ Pty *os.File

+ Reader dio.DynamicMultiReader

+ Restart bool

+ RunBlock bool

+ Started string

+ StderrPipe io.ReadCloser

+ StdinPipe io.WriteCloser

+ StdoutPipe io.ReadCloser

+ StopSignal string

+ Tty bool

+ User string

+ func (session *SessionConfig) Unblock() func()

+ type System interface

+ LaunchUtility func(UtilityFn) (<-chan int, error)

+ MountLabel func(ctx context.Context, label, target string) error

+ type Tether interface

+ Register func(name string, ext Extension)

+ Reload func()

+ Start func() error

+ Stop func() error

+ func New(src extraconfig.DataSource, sink extraconfig.DataSink, ops Operations) Tether

+ type TetherKey struct

+ type Toolbox struct — js/wasm, linux/amd64

+ func NewToolbox() *Toolbox

+ func (t *Toolbox) InContainer() *Toolbox

+ func (t *Toolbox) Reload(config *ExecutorConfig) error

+ func (t *Toolbox) Start(system System) error

+ func (t *Toolbox) Stop() error

+ type UtilityFn func() (*os.Process, error)