Versions in this module Expand all Collapse all v0 v0.1.9 Mar 6, 2017 Changes in this version + const BuildDir + const ReadKeepaliveTolerance + var IntegrationTestCA = []byte(...) + var IntegrationTestCert = []byte(...) + var IntegrationTestKey = []byte(...) + var LocalhostCert = []byte(...) + var LocalhostKey = []byte(...) + var PollerCommand = fmt.Sprintf(...) + func ChannelOfTimer(timer *time.Timer) <-chan time.Time + func ContainsAllKeys(v map[string]interface{}, keys ...string) bool + func Die(err error, messages ...string) + func GetDNFromCert(namespace pkix.Name, sep string) (string, error) + func HandleInterrupts() chan os.Signal + func IdentifierSafe(r rune) rune + func RunCommand(result *Result) + func ScaleFractionalDuration(duration time.Duration, targetUnits time.Duration) float64 + func StartCommand(result *Result) + func TestTimebox_Quick(t *testing.T) + func TestTimebox_TimesOut(t *testing.T) + func Timebox(t *testing.T, d time.Duration, boxed func(t *testing.T)) bool + func TimeboxNamed(t *testing.T, name string, d time.Duration, boxed func(t *testing.T)) bool + type BannerServer struct + HandleConnection func(conn net.Conn) + func NewBannerServer() *BannerServer + func (s *BannerServer) Serve(listener net.Listener) + func (s *BannerServer) ServeTLS(listener net.Listener) + func (s *BannerServer) Stop() + type BlockingReadBuffer struct + func NewBlockingReadBuffer() *BlockingReadBuffer + func (bb *BlockingReadBuffer) Close() error + func (bb *BlockingReadBuffer) Read(p []byte) (n int, err error) + func (bb *BlockingReadBuffer) ReadReady() bool + func (bb *BlockingReadBuffer) Write(p []byte) (n int, err error) + type BoundAddress struct + IP string + Port int + Zone string + type Commander interface + GetArgs func() []string + GetProcess func() *os.Process + GetProcessState func() *os.ProcessState + Start func() error + Wait func() error + type NowTimestampMillisFunc func() int64 + var NowTimestampMillis NowTimestampMillisFunc = func() int64 { ... } + func InstallAlternateTimestampFunc(newFunc NowTimestampMillisFunc) (priorFunc NowTimestampMillisFunc) + type OutputMessage struct + Address string + BoundAddr *BoundAddress + Level string + Msg string + func BufferToStringSlice(buf *bytes.Buffer) []*OutputMessage + type PollerCmd struct + func (c *PollerCmd) GetArgs() []string + func (c *PollerCmd) GetProcess() *os.Process + func (c *PollerCmd) GetProcessState() *os.ProcessState + type Result struct + Command Commander + Error error + ErrorOnTimeout bool + StdErr *bytes.Buffer + StdOut *bytes.Buffer + Timeout time.Duration + func SetupCommand(commandList []string, errorOnTimeout bool, timeout time.Duration) *Result + type SmartConn struct + HeartbeatSendInterval time.Duration + HeartbeatSender func(sconn *SmartConn) + ReadKeepalive time.Duration + WriteAllowance time.Duration + func NewSmartConn(c net.Conn) *SmartConn + func (c *SmartConn) Close() error + func (c *SmartConn) Read(b []byte) (n int, err error) + func (c *SmartConn) RemoteAddr() net.Addr + func (c *SmartConn) Start() error + func (c *SmartConn) Write(p []byte) (n int, err error) + func (c *SmartConn) WriteJSON(v interface{}) error + type StatusLine struct + func NewStatusLine() *StatusLine + func (sl *StatusLine) Add(key string, value interface{}) + func (sl *StatusLine) AddOption(key string) + func (sl *StatusLine) Clear() + func (sl *StatusLine) String() string + type TimeLatencyTracking struct + PollerRecvTimestamp int64 + PollerSendTimestamp int64 + ServerRecvTimestamp int64 + ServerRespTimestamp int64 + func (tt *TimeLatencyTracking) ComputeSkew() (offset int64, latency int64, _ error)