Versions in this module Expand all Collapse all v1 v1.0.0 Feb 29, 2020 Changes in this version + var Components = make(map[string]ComponentInfo) + var InitialRetryInterval = 32 * time.Millisecond + var KeepAliveInterval = 30 * time.Second + var MaxRetryInterval = 5 * time.Minute + var QueueAddr = ParseAddr("127.0.0.1:9000") + func LocalAddr() (net.Addr, error) + func ParseAddr(description string) (net.Addr, error) + type Component interface + Run func() + Setup func(fs *flag.FlagSet, args []string) error + Shutdown func() + type ComponentInfo struct + Description string + Name string + New func() Component + type Conn struct + func Dial(addr net.Addr) (*Conn, error) + func DialRetry(addr net.Addr) *Conn + func WrapConn(conn net.Conn) *Conn + func (c *Conn) Close() error + func (c *Conn) Receive() <-chan Message + func (c *Conn) Send(msg Message) error + type Listener struct + Addr net.Addr + func Listen(addr net.Addr) (*Listener, error) + func (l *Listener) Accept() (*Conn, error) + func (l *Listener) Close() error + type Message struct + Capacity int + Id string + Input string + Message MsgType + Output string + Status Status + Task *Task + func (msg Message) String() string + type MsgType string + const AbortMsg + const DoneMsg + const KeepAliveMsg + const LaunchMsg + const RegisterPoolMsg + type Status string + const Abort + const Crash + const Error + const Fatal + const Overflow + const Success + const Timeout + type Task struct + Environment string + Limits struct{ ... } + TaskFS string + func (task Task) String() string
Go to main page